BmnDataReceiver.h

Go to the documentation of this file.

/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
 
/*
 * File:   BmnDataReceiver.h
 * Author: ilnur
 *
 * Created on October 18, 2016, 5:22 PM
 */
 
#ifndef BMNDATARECEIVER_H
#define BMNDATARECEIVER_H 1
#include <BmnMath.h>
#include <TNamed.h>
#include <deque>
#include <stdlib.h>
 
#define PNP_DISCOVER_PORT 33304
#define PNP_DISCOVER_IP_ADDR "239.192.1.2"
#define INPUT_IFACE "eno1"
#define MAX_BUF_LEN 128 * 1024 * 1024
#define MAX_ADDR_LEN 255
#define MAX_PORT_LEN 7
#define MSG_TIMEOUT 400000
#define CONN_TIMEOUT 3000000
 
using namespace std;
 
class BmnDataReceiver : public TNamed
{
  public:
    BmnDataReceiver();
    virtual ~BmnDataReceiver();
 
    Int_t ConnectRaw();
    Int_t Connect();
    Int_t SendHello();
    Int_t InitRecvStream();
    void FreeRecvStream();
    Int_t IterRecvStream();
    Int_t RecvData();
 
    void SetDataQueue(deque<UInt_t> v) { this->data_queue = v; }
 
    deque<UInt_t>* GetDataQueue() { return &data_queue; }
 
    //    void *GetQueMutex(){ return _deque_mutex;}
    //    void SetQueMutex(void *v){_deque_mutex = v;}
 
  private:
    // zmq::context_t _ctx;
    // zmq::socket_t _socket_mcast;
    struct serverIface
    {
        Bool_t enabled;
        Bool_t isFree;
        Int_t id;
        UShort_t port;
        Char_t type[MAX_ADDR_LEN];
    };
    struct serverInfo
    {
        Char_t hostName[MAX_ADDR_LEN];
        Char_t index[MAX_ADDR_LEN];
        Char_t name[MAX_ADDR_LEN];
        Char_t type[MAX_ADDR_LEN];
        vector<serverIface> interfaces;
    };
 
    deque<UInt_t> data_queue;
    void* _ctx;
    void* _socket_mcast;
    void* _socket_data;
    Int_t _sfd;
    struct serverInfo _dataServer;
    struct addrinfo* dataAddrInfo;
    Bool_t isListening;
    Bool_t isAddr = kFALSE;
    //    void *_deque_mutex; // actually std::mutex
    // static void HandleSignal(int signal);
    void InitSocks();
    void DeinitSocks();
    static Int_t ParsePNPMsg(char* msgStr, serverInfo* sInfo);
 
    ClassDef(BmnDataReceiver, 1)
};
 
#endif /* BMNDATARECEIVER_H */