---

sendrecvstruct.h

Go to the documentation of this file.

//**************************************************************************
#include "remotesocket.h"
//**************************************************************************
#ifndef _SENDRECVSTRUCT_H
#define _SENDRECVSTRUCT_H
#define PRINT_RECV_STATUS ANIDEBUG
#ifndef PRINT_RECV_STATUS
#define PRINT_RECV_STATUS
#endif
//**************************************************************************
template <class myStruct>
inline int RemoteSocket::SendStruct(myStruct *S, Semaphore *sem)
{
unsigned char *data;
int totsize = 0;

if (!S)
        {
         cout << "SendStruct: Error! Custom structure empty!!" << endl << flush;
         SendVar<int>(-1);
         return -1;
        }
if (sem) sem->Wait();
int ptr = packStruct(S, &data, totsize);
if (sem) sem->Post();
#ifdef ANIDEBUG
cout << "RemoteSocket::SendStruct: Sending " << totsize << " bytes." << endl << flush;
#endif

if (ptr != totsize)
        {
         cout << "packStruct(): Error!! [ptr -> " << ptr << " != totsize -> " << totsize << "]" << endl << flush;
         exit(-1);
        }

SendVar<int>(totsize);
SendBytes(totsize, data);

FREE1D(&data, totsize);
return totsize;
}
//**************************************************************************
template <class myStruct>
inline double RemoteSocket::RecvStruct(myStruct *S, Semaphore *sem)
{
int time1 = myTimer();
double trans_rate;
unsigned char *data;
int size = RecvVar<int>();
if (size == 0 || size == -1)
        {
         cout << "RemoteSocket::RecvStruct: Received empty structure!!" << endl << flush;
         return 0.0;
        }

ALLOC1D(&data, size);
int t1 = myTimer();
RecvBytes(size, data);

int tot_time = myTimer()-t1+1;
trans_rate = 8.0*size/tot_time/1000.0;

if (print_flag)
        {
         cout.precision(3);
         cout << endl << "RemoteSocket::RecvStruct: " << size << " bytes in " << tot_time << " ms [" << trans_rate << " Mb/sec] (Tot: " << flush;
        }

if (sem) sem->Wait();
int ptr = unpackStruct(S, data, size);
if (sem) sem->Post();

if (ptr != size)
        {
         cout << "unpackStruct(): Error!! [ptr -> " << ptr << " != totsize -> " << size << "]" << endl << flush;
         exit(-1);
        }

if (print_flag)
        {
         cout <<  myTimer()-time1 << " ms)" << endl << endl << flush; 
        }

FREE1D(&data, size);

return trans_rate;
}
//**************************************************************************
#endif // _SENDRECVSTRUCT_H
//**************************************************************************

---