diff options
author | Mike Buland <eichlan@xagasoft.com> | 2006-11-02 11:29:19 +0000 |
---|---|---|
committer | Mike Buland <eichlan@xagasoft.com> | 2006-11-02 11:29:19 +0000 |
commit | 80153a5bb5d3b41101e6bd6755b61fd0e57fadbc (patch) | |
tree | 6a2989723396348d509b63466bf53023f4f82739 /src/connectionmanager.cpp | |
parent | 54ef2750aef0c64df56daff50af7719f85017c33 (diff) | |
download | libbu++-80153a5bb5d3b41101e6bd6755b61fd0e57fadbc.tar.gz libbu++-80153a5bb5d3b41101e6bd6755b61fd0e57fadbc.tar.bz2 libbu++-80153a5bb5d3b41101e6bd6755b61fd0e57fadbc.tar.xz libbu++-80153a5bb5d3b41101e6bd6755b61fd0e57fadbc.zip |
Added the new features that you need to make the connection manager, protocols,
and the connection monitor work in two-way-mode. Effectively you should be able
to write systems that both serve and initiate connections, and only write one
protocol.
Diffstat (limited to '')
-rw-r--r-- | src/connectionmanager.cpp | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/src/connectionmanager.cpp b/src/connectionmanager.cpp index 3e9f1a8..367b9d7 100644 --- a/src/connectionmanager.cpp +++ b/src/connectionmanager.cpp | |||
@@ -195,6 +195,7 @@ bool ConnectionManager::scanConnections( int nTimeout, bool bForceTimeout ) | |||
195 | lActive.erase( l ); | 195 | lActive.erase( l ); |
196 | continue; | 196 | continue; |
197 | } | 197 | } |
198 | (*i)->poll(); | ||
198 | if( (*i)->hasOutput() ) | 199 | if( (*i)->hasOutput() ) |
199 | { | 200 | { |
200 | (*i)->writeOutput(); | 201 | (*i)->writeOutput(); |
@@ -324,6 +325,23 @@ bool ConnectionManager::addConnection( int nSocket ) | |||
324 | return true; | 325 | return true; |
325 | } | 326 | } |
326 | 327 | ||
328 | void ConnectionManager::connect( | ||
329 | const char *lpAddress, | ||
330 | int nPort, | ||
331 | int nProtocolPort | ||
332 | ) | ||
333 | { | ||
334 | Connection *pCon = getInactiveConnection(); | ||
335 | pCon->open( lpAddress, nPort ); | ||
336 | int nSocket = pCon->getSocket(); | ||
337 | FD_SET( nSocket, &fdActive ); | ||
338 | |||
339 | pMonitor->onNewClientConnection( pCon, nProtocolPort ); | ||
340 | pCon->getProtocol()->onNewClientConnection(); | ||
341 | |||
342 | lActive.insert( lActive.end(), pCon ); | ||
343 | } | ||
344 | |||
327 | Connection *ConnectionManager::getInactiveConnection() | 345 | Connection *ConnectionManager::getInactiveConnection() |
328 | { | 346 | { |
329 | if( lInactive.empty() ) | 347 | if( lInactive.empty() ) |