diff options
author | Othmar Gsenger <otti@anytun.org> | 2008-11-17 23:21:42 +0000 |
---|---|---|
committer | Othmar Gsenger <otti@anytun.org> | 2008-11-17 23:21:42 +0000 |
commit | 686c1ebee948a20193df1411d478693a29a0f658 (patch) | |
tree | a236388a253f919993a87e6a4a5ab7650785c45f /src/syncTcpConnection.cpp | |
parent | fixed sync support (diff) |
added OnConnect Callback
Diffstat (limited to 'src/syncTcpConnection.cpp')
-rw-r--r-- | src/syncTcpConnection.cpp | 42 |
1 files changed, 2 insertions, 40 deletions
diff --git a/src/syncTcpConnection.cpp b/src/syncTcpConnection.cpp index 185781f..dbd9ac0 100644 --- a/src/syncTcpConnection.cpp +++ b/src/syncTcpConnection.cpp @@ -21,47 +21,9 @@ void SyncTcpConnection::start() { - ConnectionList & cl_(gConnectionList); - ConnectionMap::iterator cit = cl_.getBeginUnlocked(); - for (;cit!=cl_.getEndUnlocked();++cit) - { - std::ostringstream sout; - boost::archive::text_oarchive oa(sout); - const SyncCommand scom(cl_,cit->first); - oa << scom; - std::stringstream lengthout; - lengthout << std::setw(5) << std::setfill('0') << sout.str().size()<< ' '; - Send(lengthout.str()); - Send(sout.str()); - } - //TODO Locking here - RoutingMap::iterator it = gRoutingTable.getBeginUnlocked(); - for (;it!=gRoutingTable.getEndUnlocked();++it) - { - NetworkPrefix tmp(it->first); - std::ostringstream sout; - boost::archive::text_oarchive oa(sout); - const SyncCommand scom(tmp); - oa << scom; - std::stringstream lengthout; - lengthout << std::setw(5) << std::setfill('0') << sout.str().size()<< ' '; - Send(lengthout.str()); - Send(sout.str()); - } - //TODO Locking here - RtpSessionMap::iterator rit = gRtpSessionTable.getBeginUnlocked(); - for (;rit!=gRtpSessionTable.getEndUnlocked();++rit) - { - std::ostringstream sout; - boost::archive::text_oarchive oa(sout); - const SyncCommand scom(rit->first); - oa << scom; - std::stringstream lengthout; - lengthout << std::setw(5) << std::setfill('0') << sout.str().size()<< ' '; - Send(lengthout.str()); - Send(sout.str()); - } + onConnect(this); } + void SyncTcpConnection::Send(std::string message) { asio::async_write(socket_, asio::buffer(message), |