summaryrefslogtreecommitdiff
path: root/syncSocket.cpp
diff options
context:
space:
mode:
authorOthmar Gsenger <otti@anytun.org>2008-04-12 11:38:42 +0000
committerOthmar Gsenger <otti@anytun.org>2008-04-12 11:38:42 +0000
commitfffd213c8cba2135afda493d797c41c10354770e (patch)
treebb5eea1b12871d8c3fed0e687d83be3e504d11b2 /syncSocket.cpp
parentsvn cleanup (diff)
big svn cleanup
Diffstat (limited to 'syncSocket.cpp')
-rw-r--r--syncSocket.cpp82
1 files changed, 0 insertions, 82 deletions
diff --git a/syncSocket.cpp b/syncSocket.cpp
deleted file mode 100644
index 96da70c..0000000
--- a/syncSocket.cpp
+++ /dev/null
@@ -1,82 +0,0 @@
-#include <sstream>
-#include <iostream>
-#include <string>
-#include "routingTable.h"
-#include "rtpSessionTable.h"
-#include <boost/archive/text_oarchive.hpp>
-#include <boost/archive/text_iarchive.hpp>
-
-
-//#include "connectionParam.h"
-#include "Sockets/Utility.h"
-#include "syncSocket.h"
-#include "syncCommand.h"
-#include "buffer.h"
-//#include "log.h"
-
-SyncSocket::SyncSocket(ISocketHandler& h,ConnectionList & cl)
-:TcpSocket(h),cl_(cl)
-{
- SetConnectTimeout(12);
-}
-
-
-
-void SyncSocket::OnAccept()
-{
-// Send( Utility::GetLocalHostname() + "\n");
-// Send( Utility::GetLocalAddress() + "\n");
-// Send("Number of sockets in list : " + Utility::l2string(Handler().GetCount()) + "\n");
-// Send("\n");
- //TODO Locking here
- 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());
- }
-}
-
-//void StatusSocket::InitSSLServer()
-//{
-// InitializeContext("server.pem", "keypwd", SSLv23_method());
-//}
-//
-//
-//void StatusSocket::Init()
-//{
-// EnableSSL();
-//}