ZMQRawConnection.h

/**************************************************************************
 * BASF2 (Belle Analysis Framework 2)                                     *
 * Copyright(C) 2019 - Belle II Collaboration                             *
 *                                                                        *
 * Author: The Belle II Collaboration                                     *
 * Contributors: Nils Braun                                               *
 *                                                                        *
 * This software is provided "as is" without any warranty.                *
 **************************************************************************/
#pragma once
 
#include <framework/pcore/zmq/connections/ZMQConnection.h>
#include <framework/pcore/zmq/utils/ZMQParent.h>
 
#include <zmq.hpp>
 
#include <string>
#include <memory>
 
namespace Belle2 {
  class ZMQRawInput : public ZMQConnectionOverSocket {
  public:
    ZMQRawInput(const std::string& inputAddress, unsigned int maximalBufferSize, bool receiveEventMessages,
                const std::shared_ptr<ZMQParent>& parent);
 
    std::vector<zmq::message_t> handleIncomingData();
 
    void clear();
 
  private:
    unsigned int m_maximalBufferSize;
    std::vector<char> m_buffer;
    size_t m_writeAddress = 0;
    unsigned int m_currentSize = 0;
    bool m_receiveEventMessages;
    std::string m_inputIdentity = "";
  };
 
  class ZMQRawOutput : public ZMQConnectionOverSocket {
  public:
    ZMQRawOutput(const std::string& outputAddress, bool addEventSize, const std::shared_ptr<ZMQParent>& parent);
 
    virtual void handleEvent(zmq::message_t message);
    void handleIncomingData();
    bool isReady() const final;
 
  private:
    std::string m_dataIdentity = "";
    bool m_addEventSize = false;
  };
}