diff options
Diffstat (limited to 'src/unstable/itoserver.cpp')
-rw-r--r-- | src/unstable/itoserver.cpp | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/src/unstable/itoserver.cpp b/src/unstable/itoserver.cpp index 5b3b5a2..7dbce6c 100644 --- a/src/unstable/itoserver.cpp +++ b/src/unstable/itoserver.cpp | |||
@@ -5,14 +5,13 @@ | |||
5 | * terms of the license contained in the file LICENSE. | 5 | * terms of the license contained in the file LICENSE. |
6 | */ | 6 | */ |
7 | 7 | ||
8 | #include "bu/config.h" | ||
8 | #include "bu/itoserver.h" | 9 | #include "bu/itoserver.h" |
9 | #include <errno.h> | 10 | #include <errno.h> |
10 | #include "bu/tcpserversocket.h" | 11 | #include "bu/tcpserversocket.h" |
11 | #include "bu/client.h" | 12 | #include "bu/client.h" |
12 | #include "bu/tcpsocket.h" | 13 | #include "bu/tcpsocket.h" |
13 | 14 | ||
14 | #include "bu/config.h" | ||
15 | |||
16 | Bu::ItoServer::ItoServer() : | 15 | Bu::ItoServer::ItoServer() : |
17 | nTimeoutSec( 1 ), | 16 | nTimeoutSec( 1 ), |
18 | nTimeoutUSec( 0 ) | 17 | nTimeoutUSec( 0 ) |
@@ -42,7 +41,7 @@ Bu::ItoServer::~ItoServer() | |||
42 | void Bu::ItoServer::addPort( int nPort, int nPoolSize ) | 41 | void Bu::ItoServer::addPort( int nPort, int nPoolSize ) |
43 | { | 42 | { |
44 | TcpServerSocket *s = new TcpServerSocket( nPort, nPoolSize ); | 43 | TcpServerSocket *s = new TcpServerSocket( nPort, nPoolSize ); |
45 | int nSocket = s->getSocket(); | 44 | socket_t nSocket = s->getSocket(); |
46 | FD_SET( nSocket, &fdActive ); | 45 | FD_SET( nSocket, &fdActive ); |
47 | hServers.insert( nSocket, s ); | 46 | hServers.insert( nSocket, s ); |
48 | } | 47 | } |
@@ -50,7 +49,7 @@ void Bu::ItoServer::addPort( int nPort, int nPoolSize ) | |||
50 | void Bu::ItoServer::addPort( const String &sAddr, int nPort, int nPoolSize ) | 49 | void Bu::ItoServer::addPort( const String &sAddr, int nPort, int nPoolSize ) |
51 | { | 50 | { |
52 | TcpServerSocket *s = new TcpServerSocket( sAddr, nPort, nPoolSize ); | 51 | TcpServerSocket *s = new TcpServerSocket( sAddr, nPort, nPoolSize ); |
53 | int nSocket = s->getSocket(); | 52 | socket_t nSocket = s->getSocket(); |
54 | FD_SET( nSocket, &fdActive ); | 53 | FD_SET( nSocket, &fdActive ); |
55 | hServers.insert( nSocket, s ); | 54 | hServers.insert( nSocket, s ); |
56 | } | 55 | } |
@@ -61,7 +60,7 @@ void Bu::ItoServer::setTimeout( int nTimeoutSec, int nTimeoutUSec ) | |||
61 | this->nTimeoutUSec = nTimeoutUSec; | 60 | this->nTimeoutUSec = nTimeoutUSec; |
62 | } | 61 | } |
63 | 62 | ||
64 | void Bu::ItoServer::addClient( int nSocket, int nPort ) | 63 | void Bu::ItoServer::addClient( socket_t nSocket, int nPort ) |
65 | { | 64 | { |
66 | ItoClient *pC = new ItoClient( *this, nSocket, nPort, nTimeoutSec, | 65 | ItoClient *pC = new ItoClient( *this, nSocket, nPort, nTimeoutSec, |
67 | nTimeoutUSec ); | 66 | nTimeoutUSec ); |
@@ -106,7 +105,7 @@ void Bu::ItoServer::run() | |||
106 | } | 105 | } |
107 | } | 106 | } |
108 | 107 | ||
109 | void Bu::ItoServer::clientCleanup( int iSocket ) | 108 | void Bu::ItoServer::clientCleanup( socket_t iSocket ) |
110 | { | 109 | { |
111 | imClients.lock(); | 110 | imClients.lock(); |
112 | ItoClient *pCli = hClients.get( iSocket ); | 111 | ItoClient *pCli = hClients.get( iSocket ); |
@@ -114,7 +113,7 @@ void Bu::ItoServer::clientCleanup( int iSocket ) | |||
114 | qClientCleanup.enqueue( pCli ); | 113 | qClientCleanup.enqueue( pCli ); |
115 | } | 114 | } |
116 | 115 | ||
117 | Bu::ItoServer::ItoClient::ItoClient( ItoServer &rSrv, int iSocket, int iPort, | 116 | Bu::ItoServer::ItoClient::ItoClient( ItoServer &rSrv, Bu::ItoServer::socket_t iSocket, int iPort, |
118 | int nTimeoutSec, int nTimeoutUSec ) : | 117 | int nTimeoutSec, int nTimeoutUSec ) : |
119 | rSrv( rSrv ), | 118 | rSrv( rSrv ), |
120 | iSocket( iSocket ), | 119 | iSocket( iSocket ), |