---

dataclient.h

Go to the documentation of this file.

//**************************************************************************
#ifndef _DATACLIENT_H_
#define _DATACLIENT_H_
//**************************************************************************
#include "remotesocket.h"
#include "keyinfo.h"
#include "misc.h"
#include <string>
#include "errcode.h"
//**************************************************************************
class DataClient : private RemoteSocket
{
private:
        KeyTable *keytable;
        int portnum;
        char servername[100];
        bool connected;
        int SendClientName();
        bool SendKeyForDataSend(int handle);
        bool SendKeyForDataSend(char *keyword);
        bool SendKeyword(char *keyword);
        int QueryKeyword(char *keyword)
                { SendLine(keyword); return RecvVar<int>(); }
        int RecvDummyBytes(int size);
        int Release() { return SendKeyword("_q_private"); }
        bool isWritable(int handle);
        bool VerifyElementSize(int handle, int elem_size);
        bool isVariable(int handle);
        bool isStaticArray(int handle)
                { return keytable->isStaticArray(handle); }
        bool isStaticArray(char *keyword)
                { return keytable->isStaticArray(keyword); }
        bool isDynamicArray(int handle, int dim);

public:
        DataClient();

        DataClient(char *host, int port = 4096);

        ~DataClient();

        int Connect(char *host, int port = 4096);

        int Disconnect();

        char *ServerName() { return (char *) servername; }

        int Port() { return portnum; }

        bool isBigEndian();

        bool isValidKeyword(char *keyword, int *handle = NULL);

        int SetPrintFlag(int flag) { return RemoteSocket::SetPrintFlag(flag); }

        KeyTable *GetTable();

        bool isWritable(char *keyword);

        int RecvKeyTable(KeyTable *K = NULL);

        VariableType VarType(char *keyword);

        char *RecvValue(char *keyword);

        int SendValue(char *keyword, char *value);

        void ListKeywords();

        void ListValues();

        template <class Etype>
                int SendVariable(char *keyword, Etype a);

        template <class Etype>
                int RecvVariable(char *keyword, Etype *a);

        template <class Etype>
                Etype RecvVariable(char *keyword);

        int SendArray(char *keyword, void *a);

        int RecvArray(char *keyword, void *a);

        int getArrayDim(char *keyword, int dim);

        template <class Etype>
                int SendArray1D(char *keyword, Etype *a);

        template <class Etype>
                int RecvArray1D(char *keyword, Etype *a);

        template <class Etype>
                int RecvArray1D(char *keyword, Etype **ptr);

        template <class Etype>
                int SendArray2D(char *keyword, Etype **a);

        template <class Etype>
                int RecvArray2D(char *keyword, Etype **a);

        template <class Etype>
                int RecvArray2D(char *keyword, Etype ***ptr);

        template <class Etype>
                int SendArray3D(char *keyword, Etype ***a);

        template <class Etype>
                int RecvArray3D(char *keyword, Etype ***a);

        template <class Etype>
                int RecvArray3D(char *keyword, Etype ****ptr);

        template <class Etype>
                int SendArray4D(char *keyword, Etype ****a);

        template <class Etype>
                int RecvArray4D(char *keyword, Etype ****a);

        template <class Etype>
                int RecvArray4D(char *keyword, Etype *****ptr);

        template <class myStruct>
                int SendStruct(char *keyword, myStruct *S, Semaphore *sem=NULL);

        template <class myStruct>
                double RecvStruct(char *keyword, myStruct *S, Semaphore *sem = NULL);

        int SendFile(char *filename, char *destfile = NULL);

        int RecvFile(char *filename, char *destfile = NULL);

        double BytesSent() { return TCPSocket::BytesSent(); }

        double BytesRecd() { return TCPSocket::BytesRecd(); }

        int SendTime() { return TCPSocket::SendTime(); }

        int RecvTime() { return TCPSocket::RecvTime(); }

        double SendRate() { return 8.0*BytesSent()/(1000.0*SendTime()); }

        double RecvRate() { return 8.0*BytesRecd()/(1000.0*RecvTime()); }

};
//**************************************************************************
#include "dataclientsend.h"
#include "dataclientrecv.h"
//**************************************************************************
#endif  // _DATACLIENT_H_
//**************************************************************************

---