diff options
Diffstat (limited to '')
| -rw-r--r-- | src/stable/server.h | 138 |
1 files changed, 69 insertions, 69 deletions
diff --git a/src/stable/server.h b/src/stable/server.h index 5a414d9..05ec018 100644 --- a/src/stable/server.h +++ b/src/stable/server.h | |||
| @@ -11,7 +11,7 @@ | |||
| 11 | #include <stdint.h> | 11 | #include <stdint.h> |
| 12 | 12 | ||
| 13 | #ifndef WIN32 | 13 | #ifndef WIN32 |
| 14 | #include <sys/select.h> | 14 | #include <sys/select.h> |
| 15 | #endif | 15 | #endif |
| 16 | 16 | ||
| 17 | #include "bu/string.h" | 17 | #include "bu/string.h" |
| @@ -25,90 +25,90 @@ | |||
| 25 | 25 | ||
| 26 | namespace Bu | 26 | namespace Bu |
| 27 | { | 27 | { |
| 28 | class TcpServerSocket; | 28 | class TcpServerSocket; |
| 29 | class TcpSocket; | 29 | class TcpSocket; |
| 30 | class Client; | 30 | class Client; |
| 31 | 31 | ||
| 32 | /** | 32 | /** |
| 33 | * Core of a network server. This class is distinct from a ServerSocket in | 33 | * Core of a network server. This class is distinct from a ServerSocket in |
| 34 | * that a ServerSocket is one listening socket, nothing more. Socket will | 34 | * that a ServerSocket is one listening socket, nothing more. Socket will |
| 35 | * manage a pool of both ServerSockets and connected Sockets along with | 35 | * manage a pool of both ServerSockets and connected Sockets along with |
| 36 | * their protocols and buffers. | 36 | * their protocols and buffers. |
| 37 | * | 37 | * |
| 38 | * To start serving on a new port, use the addPort functions. Each call to | 38 | * To start serving on a new port, use the addPort functions. Each call to |
| 39 | * addPort creates a new ServerSocket, starts it listening, and adds it to | 39 | * addPort creates a new ServerSocket, starts it listening, and adds it to |
| 40 | * the server pool. | 40 | * the server pool. |
| 41 | * | 41 | * |
| 42 | * All of the real work is done by scan, which will wait for up | 42 | * All of the real work is done by scan, which will wait for up |
| 43 | * to the timeout set by setTimeout before returning if there is no data | 43 | * to the timeout set by setTimeout before returning if there is no data |
| 44 | * pending. scan should probably be called in some sort of tight | 44 | * pending. scan should probably be called in some sort of tight |
| 45 | * loop, possibly in it's own thread, or in the main control loop. | 45 | * loop, possibly in it's own thread, or in the main control loop. |
| 46 | * | 46 | * |
| 47 | * In order to use a Server you must subclass it and implement the pure | 47 | * In order to use a Server you must subclass it and implement the pure |
| 48 | * virtual functions. These allow you to receive notification of events | 48 | * virtual functions. These allow you to receive notification of events |
| 49 | * happening within the server itself, and actually makes it useful. | 49 | * happening within the server itself, and actually makes it useful. |
| 50 | *@ingroup Serving | 50 | *@ingroup Serving |
| 51 | */ | 51 | */ |
| 52 | class Server | 52 | class Server |
| 53 | { | 53 | { |
| 54 | public: | 54 | public: |
| 55 | Server(); | 55 | Server(); |
| 56 | virtual ~Server(); | 56 | virtual ~Server(); |
| 57 | 57 | ||
| 58 | #ifdef WIN32 | 58 | #ifdef WIN32 |
| 59 | typedef unsigned int socket_t; | 59 | typedef unsigned int socket_t; |
| 60 | #else | 60 | #else |
| 61 | typedef int socket_t; | 61 | typedef int socket_t; |
| 62 | #endif | 62 | #endif |
| 63 | 63 | ||
| 64 | void addPort( int nPort, int nPoolSize=40 ); | 64 | void addPort( int nPort, int nPoolSize=40 ); |
| 65 | void addPort( const String &sAddr, int nPort, int nPoolSize=40 ); | 65 | void addPort( const String &sAddr, int nPort, int nPoolSize=40 ); |
| 66 | 66 | ||
| 67 | virtual void scan(); | 67 | virtual void scan(); |
| 68 | void setTimeout( int nTimeoutSec, int nTimeoutUSec=0 ); | 68 | void setTimeout( int nTimeoutSec, int nTimeoutUSec=0 ); |
| 69 | 69 | ||
| 70 | void addClient( socket_t nSocket, int nPort ); | 70 | void addClient( socket_t nSocket, int nPort ); |
| 71 | 71 | ||
| 72 | void setAutoTick( bool bEnable=true ); | 72 | void setAutoTick( bool bEnable=true ); |
| 73 | void tick(); | 73 | void tick(); |
| 74 | 74 | ||
| 75 | virtual void onNewConnection( Client *pClient, int nPort )=0; | 75 | virtual void onNewConnection( Client *pClient, int nPort )=0; |
| 76 | virtual void onClosedConnection( Client *pClient )=0; | 76 | virtual void onClosedConnection( Client *pClient )=0; |
| 77 | 77 | ||
| 78 | void shutdown(); | 78 | void shutdown(); |
| 79 | 79 | ||
| 80 | private: | 80 | private: |
| 81 | void closeClient( socket_t iSocket ); | 81 | void closeClient( socket_t iSocket ); |
| 82 | class SrvClientLink : public Bu::ClientLink | 82 | class SrvClientLink : public Bu::ClientLink |
| 83 | { | 83 | { |
| 84 | public: | 84 | public: |
| 85 | SrvClientLink( Bu::Client *pClient ); | 85 | SrvClientLink( Bu::Client *pClient ); |
| 86 | virtual ~SrvClientLink(); | 86 | virtual ~SrvClientLink(); |
| 87 | 87 | ||
| 88 | virtual void sendMessage( const Bu::String &sMsg ); | 88 | virtual void sendMessage( const Bu::String &sMsg ); |
| 89 | 89 | ||
| 90 | private: | 90 | private: |
| 91 | Bu::Client *pClient; | 91 | Bu::Client *pClient; |
| 92 | }; | 92 | }; |
| 93 | 93 | ||
| 94 | class SrvClientLinkFactory : public Bu::ClientLinkFactory | 94 | class SrvClientLinkFactory : public Bu::ClientLinkFactory |
| 95 | { | 95 | { |
| 96 | public: | 96 | public: |
| 97 | SrvClientLinkFactory(); | 97 | SrvClientLinkFactory(); |
| 98 | virtual ~SrvClientLinkFactory(); | 98 | virtual ~SrvClientLinkFactory(); |
| 99 | 99 | ||
| 100 | virtual Bu::ClientLink *createLink( Bu::Client *pClient ); | 100 | virtual Bu::ClientLink *createLink( Bu::Client *pClient ); |
| 101 | }; | 101 | }; |
| 102 | 102 | ||
| 103 | int nTimeoutSec; | 103 | int nTimeoutSec; |
| 104 | int nTimeoutUSec; | 104 | int nTimeoutUSec; |
| 105 | fd_set fdActive; | 105 | fd_set fdActive; |
| 106 | typedef Hash<socket_t,TcpServerSocket *> SrvHash; | 106 | typedef Hash<socket_t,TcpServerSocket *> SrvHash; |
| 107 | SrvHash hServers; | 107 | SrvHash hServers; |
| 108 | typedef Hash<socket_t,Client *> ClientHash; | 108 | typedef Hash<socket_t,Client *> ClientHash; |
| 109 | ClientHash hClients; | 109 | ClientHash hClients; |
| 110 | bool bAutoTick; | 110 | bool bAutoTick; |
| 111 | }; | 111 | }; |
| 112 | } | 112 | } |
| 113 | 113 | ||
| 114 | #endif | 114 | #endif |
