daqsocket/NDS1Socket.hh

/* -*- mode: c++; c-basic-offset: 4; -*- */
#ifndef NDS1SOCKET_HH
#define NDS1SOCKET_HH
//
//    This is a C++ interface for frame data.
//
#include "DAQC_api.hh"


class NDS1Socket : public DAQC_api {
public:
    using DAQC_api::Available;
    using DAQC_api::AddChannel;
    using DAQC_api::GetData;

    NDS1Socket(void);
   
    explicit NDS1Socket(const std::string& ipaddr, int ipport = DAQD_PORT,
                        long RcvBufferLen = 16384);
   
    ~NDS1Socket(void);
   
    int  open (const std::string& ipaddr, int ipport = DAQD_PORT, 
               long RecvBufferLen = 16384);

    void close();
   
    void flush();

    int AddChannel(const std::string& chan, chantype ty, double rate);
 
    int Available(std::vector<DAQDChannel>& list, wait_time timeout = -1);
  
    int Available(chantype chant, long gps, std::vector<DAQDChannel>& list, 
                  wait_time timeout = -1);
   
    int GetData(wait_time timeout = -1);
   
    long GetFrame(char *buf, long len);
   
    long GetName(char *buf, long len);
   
    int  RequestData (unsigned long start, unsigned long duration, 
                      wait_time timeout = -1);
   
    int  RequestFrames();
   
    int  RequestNames(wait_time timeout = -1);
   
    int  RequestOnlineData (double stride=1.0, wait_time timeout = -1);
   
    int  RequestTrend (unsigned long start, unsigned long duration,
                       bool mintrend = false, wait_time timeout = -1);

    void RmChannel(const std::string& chan);

    int  StopWriter(void);
      
    int Times(chantype chtyp, unsigned long& start, unsigned long& duration, 
              wait_time timeout = -1);

    int  TimesTrend (unsigned long& start, unsigned long& duration, 
                     bool mintrend = false, wait_time timeout = -1);

    int WaitforData (bool poll);

private:
    int SendRequest(const std::string& text, char *reply=0, long length=0, 
                    long *Size=0, wait_time maxwait=-1);
   
    int RecvRec(char *buf, long len, bool readall=false, 
                wait_time maxwait=-1);

    int RecvReconfig(count_type block_len, wait_time maxwait);

    int RecvData(wait_time timeout=-1);
   
    int SendRec(const char *buffer, long length, wait_time maxwait=-1);
  
private:
    int   mSocket;
   
    bool  mGetAll;
   
    char  mWriter[8];
   
    int   mOffline;
};

#endif  //  DAQSOCKET_HH

---