summaryrefslogtreecommitdiff
path: root/src/syncTcpConnection.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/syncTcpConnection.cpp')
-rw-r--r--src/syncTcpConnection.cpp42
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),