141 lines
5.0 KiB
C++
Executable File
141 lines
5.0 KiB
C++
Executable File
#if !defined (_CDEV_CLIENT_SERVICE_H_)
|
|
#define _CDEV_CLIENT_SERVICE_H_
|
|
|
|
#include <cdevService.h>
|
|
#include <cdevRequestObject.h>
|
|
#include <cdevTranObj.h>
|
|
#include <ServerInterface.h>
|
|
#include <AddressIndex.h>
|
|
#include <cdevContextMap.h>
|
|
#include <ClientInfo.h>
|
|
#include <cdevGenericServerTags.h>
|
|
#include <StringHash.h>
|
|
|
|
// *****************************************************************************
|
|
// * class NSCallbackArg :
|
|
// * This class is provided as a technique for allowing the name server
|
|
// * to differentiate when making monitorOn requests between two servers that
|
|
// * use the same service.
|
|
// *****************************************************************************
|
|
class GENERIC_SERVER_API NSCallbackArg
|
|
{
|
|
friend class cdevClientService;
|
|
|
|
private:
|
|
char * server;
|
|
cdevClientService * service;
|
|
|
|
NSCallbackArg ( char * Server, cdevClientService * Service )
|
|
: server(strdup(Server)), service(Service)
|
|
{
|
|
}
|
|
|
|
~NSCallbackArg ( void )
|
|
{
|
|
if(server) delete server;
|
|
}
|
|
};
|
|
|
|
|
|
// *****************************************************************************
|
|
// * cdevClientService:
|
|
// * This is class provides the mechanisms that the cdev system will use
|
|
// * to communicate with the model service.
|
|
// *****************************************************************************
|
|
class GENERIC_SERVER_API cdevClientService : public cdevService,
|
|
public ServerInterface,
|
|
public cdevTagTableCallback
|
|
{
|
|
friend class cdevClientRequestObject;
|
|
friend class cdevClientTransaction;
|
|
|
|
public:
|
|
enum { ServiceTagBase=511 };
|
|
|
|
static int ServerTag;
|
|
static int HostTag;
|
|
static int PortTag;
|
|
|
|
cdevClientService ( char * domain, char * name, cdevSystem & system = cdevSystem::defaultSystem());
|
|
static void defaultCallback (int, void *, cdevRequestObject &, cdevData &);
|
|
static void nameServerCallback(int, void *, cdevRequestObject &, cdevData &);
|
|
virtual int outputError (int severity, char *name, char *formatString, ...);
|
|
ServerHandler * connect ( char * server, char * host=NULL, unsigned short port = 0);
|
|
ServerHandler * disconnect ( char * server );
|
|
|
|
int flush ( void );
|
|
int pend ( double seconds, int fd = -1 );
|
|
int getFd ( int * &fd, int & numFd );
|
|
|
|
int poll ( void );
|
|
int pend ( int fd = -1 );
|
|
int getNameServer ( cdevDevice * &ns );
|
|
int getRequestObject ( char * device, char * message, cdevRequestObject * &req);
|
|
|
|
int enqueue ( char * server, cdevData * in, cdevTranObj & xobj );
|
|
int enqueue ( ServerHandler * handler, cdevData * in, cdevTranObj & xobj );
|
|
int enqueue ( ServerHandler * handler, class cdevClientTransaction &, unsigned);
|
|
int cancel ( cdevTranObj & xobj );
|
|
int enqueue ( int status, ServerHandler * handler, char * binary, size_t binaryLen );
|
|
int isPacketValid ( char * binary, size_t binaryLen );
|
|
void callback ( int newTag, char * newName );
|
|
char * getDomain ( void ) const { return domain; }
|
|
|
|
protected:
|
|
virtual ~cdevClientService ( void );
|
|
virtual void fireCallback ( int status, cdevTranObj &xobj, cdevData *resultData, int partialTransaction = 0 );
|
|
virtual int processLocal ( cdevData * in, cdevTranObj & xobj );
|
|
|
|
char * domain;
|
|
AddressIndex transactions;
|
|
cdevCallback syncCallback;
|
|
cdevContextMap contexts;
|
|
int quitFlag;
|
|
StringHash nsCallbackArgs;
|
|
static ClientInfo clientInfo;
|
|
static cdevGenericServerTagDef tags;
|
|
|
|
NSCallbackArg * getCallbackArg ( char * server );
|
|
};
|
|
|
|
class GENERIC_SERVER_API cdevClientTransaction
|
|
{
|
|
private:
|
|
// *********************************************************************
|
|
// * Free list data elements and private array constructor.
|
|
// *********************************************************************
|
|
enum {ALLOCATION_COUNT = 16 };
|
|
static cdevClientTransaction * freeList_;
|
|
cdevClientTransaction * freeListNext_;
|
|
cdevClientTransaction ( void );
|
|
|
|
public:
|
|
// *********************************************************************
|
|
// * Public free list interface.
|
|
// *********************************************************************
|
|
void * operator new ( size_t size );
|
|
void operator delete ( void * ptr );
|
|
|
|
char server[256];
|
|
cdevTranObj * xobj;
|
|
int permanent;
|
|
int statusCode;
|
|
|
|
// *********************************************************************
|
|
// * Data elements used for restartable transactions.
|
|
// *********************************************************************
|
|
int restartable;
|
|
int contextID;
|
|
cdevData * userData;
|
|
|
|
cdevClientTransaction ( cdevTranObj & XObj, ServerHandler &handler,
|
|
int Restartable=0, cdevData *data=NULL,
|
|
unsigned ContextID=0 );
|
|
virtual ~cdevClientTransaction ( void );
|
|
void reconnect (char * host=NULL, unsigned short port=0, unsigned key=0);
|
|
|
|
};
|
|
|
|
|
|
#endif /* _CDEV_CLIENT_SERVICE_H_ */
|