added OnConnect Callback

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