#include #include #include #include "routingTable.h" #include #include //#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"); if( ! cl_.empty()) { std::ostringstream sout; boost::archive::text_oarchive oa(sout); const SyncCommand scom(cl_,0); oa << scom; Send(sout.str()); } sleep(1); if( ! gRoutingTable.empty()) { std::ostringstream sout; boost::archive::text_oarchive oa(sout); const SyncCommand scom(0); oa << scom; Send(sout.str()); } } //void StatusSocket::InitSSLServer() //{ // InitializeContext("server.pem", "keypwd", SSLv23_method()); //} // // //void StatusSocket::Init() //{ // EnableSSL(); //}