TransceiverSocket.h

#ifndef _ots_TransceiverSocket_h_
#define _ots_TransceiverSocket_h_
 
#include "otsdaq/NetworkUtilities/ReceiverSocket.h"
#include "otsdaq/NetworkUtilities/TransmitterSocket.h"
 
#include <string>
#include <vector>
 
namespace ots
{
class TransceiverSocket : public TransmitterSocket, public ReceiverSocket
{
  public:
    TransceiverSocket(std::string IPAddress, unsigned int port = 0);
    virtual ~TransceiverSocket(void);
 
    int acknowledge(const std::string& buffer,
                    bool               verbose                = false,
                    size_t             maxChunkSize           = 1500,
                    unsigned int       interPacketGapUSeconds = 0,
                    bool               enableRetransmission   = false);
 
    int sendAll(const std::string& buffer,
                bool               verbose                = false,
                size_t             maxChunkSize           = 65500,
                unsigned int       interPacketGapUSeconds = 0);
 
    int receiveAll(std::string& buffer,
                   unsigned int timeoutSeconds       = 5,
                   unsigned int retransmitMaxRetries = 10,
                   bool         verbose              = false);
 
    std::string sendAndReceive(Socket&            toSocket,
                               const std::string& sendBuffer,
                               unsigned int       timeoutSeconds             = 1,
                               unsigned int       timeoutUSeconds            = 0,
                               bool               verbose                    = false,
                               unsigned int       interPacketTimeoutUSeconds = 10000);
 
    std::string sendAndReceiveAll(Socket&            toSocket,
                                  const std::string& sendBuffer,
                                  unsigned int       timeoutSeconds       = 5,
                                  unsigned int       retransmitMaxRetries = 10,
                                  bool               verbose              = false);
 
    static constexpr uint16_t RETRANSMIT_MAGIC       = 0xD2C4;
    static constexpr size_t   RETRANSMIT_HEADER_SIZE = 8;
 
  protected:
    TransceiverSocket(void);
 
  private:
    std::mutex sendAndReceiveMutex_;
};
 
}  // namespace ots
 
#endif