daqsocket/NDS2Socket.hh

/* -*- mode: c++; c-basic-offset: 4; -*- */
#ifndef NDS2SOCKET_HH
#define NDS2SOCKET_HH
//
//    This is a C++ NDS2 client interface.
//
#include "DAQC_api.hh"


class NDS2Socket :public DAQC_api {
public:
    using DAQC_api::GetData;

    NDS2Socket(void);
   
    explicit NDS2Socket(const std::string& ipaddr, int ipport = NDS2_PORT,
                        long RcvBufferLen = 16384);
   
    ~NDS2Socket(void);
    
    int  open (const std::string& ipaddr, int ipport = NDS2_PORT, 
               long bufsize = 16384);

    void close();
   
    void flush();

    int  Available (chantype typ, long gps, std::vector<DAQDChannel>& list, 
                    wait_time timeout=-1);
   
    int GetData(wait_time timeout = -1);
   
    int  RequestOnlineData (double stride=1.0, wait_time timeout=-1);
   
    int  RequestData (unsigned long start, unsigned long duration, 
                      wait_time timeout=-1);

    int  StopWriter(void);
   
    int  Times (chantype typ, unsigned long& start, unsigned long& duration, 
                wait_time timeout = -1);
   
    int WaitforData (bool poll);
      
private:   
    int authenticate(const char* server);

    int gets(char* buf, int buflen);

    int puts(const char* buf, int buflen);


    int RecvData(wait_time timeout = -1);

    int RecvRec(char *buf, long len, bool readall=false, 
                wait_time maxwait=-1);
    
    int RecvReconfig(unsigned long len, wait_time maxwait=-1);
   
    int SendRec(const char *buffer, long length, wait_time maxwait=-1);

    int SendRequest(const std::string& text, char *reply=0, long length=0, 
                    long *Size=0, wait_time maxwait=-1);

private:
    int   mSocket;
   
    int   mOffline;

    void* mAuthContxt;

private:
    static bool sasl_init;
};

#endif  //  NDS2SOCKET_HH

---