121 lines
4.3 KiB
C++
Executable File
121 lines
4.3 KiB
C++
Executable File
#if !defined (_CDEV_SERVER_H_)
|
|
#define _CDEV_SERVER_H_
|
|
|
|
#include "SignalManager.h"
|
|
#include "cdevServerTools.h"
|
|
#include "cdevMessage.h"
|
|
#include "cdevContextMap.h"
|
|
#include "cdevTagMap.h"
|
|
#include "ClientInfo.h"
|
|
#include "ServerInfo.h"
|
|
#include "cdevGenericServerTags.h"
|
|
|
|
// *****************************************************************************
|
|
// * class CLIPClientSession :
|
|
// *
|
|
// * This class also allows the server to associate certain data with a
|
|
// * specific client...
|
|
// *
|
|
// * context: This is a pointer to the most recently used context from the
|
|
// * cdevContextMap.
|
|
// *****************************************************************************
|
|
class GENERIC_SERVER_API CLIPClientSession : public ClientSession
|
|
{
|
|
private:
|
|
cdevData *context;
|
|
|
|
public:
|
|
CLIPClientSession ( int SocketID, int ClientID, int LocalID )
|
|
: ClientSession(SocketID, ClientID, LocalID),
|
|
context(NULL)
|
|
{
|
|
}
|
|
virtual ~CLIPClientSession ( void ) { }
|
|
cdevData * getContext ( void ) { return context; }
|
|
void setContext ( cdevData * cxt ) { context = cxt; }
|
|
};
|
|
|
|
|
|
// *****************************************************************************
|
|
// * class CLIPSocketSession :
|
|
// *
|
|
// * This class allows the developer to associate additional information with
|
|
// * a particular socket...
|
|
// *
|
|
// * contextMap : a table of cdevData contexts that can be retrieved by index
|
|
// *
|
|
// * tagMap : the table for mapping cdevData tags from the remote system
|
|
// * to the tag table associated with this system.
|
|
// *****************************************************************************
|
|
class GENERIC_SERVER_API CLIPSocketSession : public SocketSession, public ClientInfoStruct
|
|
{
|
|
private:
|
|
cdevContextMap contextMap;
|
|
cdevTagMap tagMap;
|
|
|
|
public:
|
|
CLIPSocketSession ( int SocketID )
|
|
: SocketSession ( SocketID )
|
|
{
|
|
}
|
|
virtual ~CLIPSocketSession ( void ) { }
|
|
cdevContextMap & ContextMap ( void ) { return contextMap; }
|
|
cdevTagMap & TagMap ( void ) { return tagMap; }
|
|
};
|
|
|
|
|
|
// *****************************************************************************
|
|
// * cdevServer :
|
|
// * This is the cdevServer class. It is responsible for establishing a
|
|
// * listening socket, and then responding to all incoming and outgoing
|
|
// * messages.
|
|
// *****************************************************************************
|
|
class GENERIC_SERVER_API cdevServer : public cdevSessionManager
|
|
{
|
|
public:
|
|
typedef enum { SUCCESS = 0,
|
|
UNINITIALIZED,
|
|
CANT_OPEN_SOCKET,
|
|
CANT_REGISTER_LISTENER,
|
|
CANT_REGISTER_SERVER,
|
|
CANT_REGISTER_TIMER
|
|
} ServerInitStatus;
|
|
|
|
protected:
|
|
char * serverName;
|
|
class ClientAcceptor * acceptor;
|
|
cdevNameServerManager * timer;
|
|
ServerInitStatus status;
|
|
ServerInfo * serverInfo;
|
|
|
|
public:
|
|
static cdevGenericServerTagDef tags;
|
|
static SignalManager SigManager;
|
|
static sig_atomic_t Finished;
|
|
|
|
static void runServer (void);
|
|
|
|
cdevServer (char * DomainName, char * ServerName, unsigned short Port, double Rate);
|
|
cdevServer (void);
|
|
virtual ~cdevServer (void);
|
|
int startServer (char * DomainName, char * ServerName, unsigned short Port, double Rate, int searchForPort=0);
|
|
|
|
virtual void registerClient ( short localID );
|
|
virtual void unregisterClient ( short localID );
|
|
|
|
virtual ClientSession * newClientSession ( int SocketID, int ClientID, int LocalID );
|
|
virtual SocketSession * newSocketSession ( int SocketID );
|
|
virtual void deleteSocketSession ( SocketSession *socket );
|
|
|
|
virtual int dequeue (cdevMessage * &message);
|
|
void processLocal (cdevMessage * &message);
|
|
virtual cdevPacket * decodePacket (cdevPacketBinary * input);
|
|
virtual cdevPacket * decodePacket (cdevMessage * message);
|
|
virtual cdevPacketBinary * encodePacket (cdevPacket * input);
|
|
virtual cdevPacketBinary * encodePacket (cdevMessage * message);
|
|
virtual int operational (void) { return (status==0)?1:0; }
|
|
virtual ServerInitStatus getInitStatus(void) { return status; }
|
|
};
|
|
|
|
#endif /* _CDEV_SERVER_H_ */
|