ReceiverSocket.h

#ifndef _ots_ReceiverSocket_h_
#define _ots_ReceiverSocket_h_
 
#include "otsdaq/NetworkUtilities/Socket.h"
 
#include <mutex>  //for std::mutex
#include <string>
#include <vector>
 
namespace ots
{
class ReceiverSocket : public virtual Socket
{
    friend class TransceiverSocket;
 
  public:
    ReceiverSocket(std::string IPAddress, unsigned int port = 0);
    virtual ~ReceiverSocket(void);
 
    int flush()
    {
        int n = 0;
        while(recvfrom(socketNumber_,
                       flushBuffer_,
                       sizeof(flushBuffer_),
                       MSG_DONTWAIT,
                       nullptr,
                       nullptr) >= 0)
        {
            ++n;
        }
        return n;
    };  
 
    int receive(std::string& buffer,
                unsigned int timeoutSeconds  = 1,
                unsigned int timeoutUSeconds = 0,
                bool         verbose         = false);
    int receive(std::vector<uint32_t>& buffer,
                unsigned int           timeoutSeconds  = 1,
                unsigned int           timeoutUSeconds = 0,
                bool                   verbose         = false);
    int receive(std::string&    buffer,
                unsigned long&  fromIPAddress,
                unsigned short& fromPort,
                unsigned int    timeoutSeconds  = 1,
                unsigned int    timeoutUSeconds = 0,
                bool            verbose         = false);
    int receive(std::vector<uint32_t>& buffer,
                unsigned long&         fromIPAddress,
                unsigned short&        fromPort,
                unsigned int           timeoutSeconds  = 1,
                unsigned int           timeoutUSeconds = 0,
                bool                   verbose         = false);
 
    std::string    getLastIncomingIPAddress(void);
    unsigned short getLastIncomingPort(void);
 
  protected:
    ReceiverSocket(void);
 
  private:
    fd_set             fileDescriptor_;
    struct timeval     timeout_;
    struct sockaddr_in fromAddress_;
    socklen_t          addressLength_;
    int                numberOfBytes_;
 
    unsigned long  lastIncomingIPAddress_ = 0;
    unsigned short lastIncomingPort_      = 0;
    unsigned int   readCounter_;
 
    std::mutex receiveMutex_;  
        //  i.e. multiple threads can share a socket and call receive()
 
    char flushBuffer_
        [1500]{};  
};
 
}  // namespace ots
 
#endif