diff options
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), |