syncSocket.cpp

   1 #include <sstream>
   2 #include <iostream>
   3 #include <string>
   4
   5 #include <boost/archive/text_oarchive.hpp>
   6 #include <boost/archive/text_iarchive.hpp>
   7
   8
   9 //#include "connectionParam.h"
  10 #include "Sockets/Utility.h"
  11 #include "syncSocket.h"
  12 #include "syncCommand.h"
  13 #include "buffer.h"
  14 //#include "log.h"
  15
  16 SyncSocket::SyncSocket(ISocketHandler& h,ConnectionList & cl)
  17 :TcpSocket(h),cl_(cl)
  18 {
  19         SetConnectTimeout(12);
  20 }
  21
  22
  23
  24 void SyncSocket::OnAccept()
  25 {
  26 //      Send( Utility::GetLocalHostname() + "\n");
  27 //      Send( Utility::GetLocalAddress() + "\n");
  28 //      Send("Number of sockets in list : " + Utility::l2string(Handler().GetCount()) + "\n");
  29 //      Send("\n");
  30         if( ! cl_.empty())
  31         {
  32                 std::ostringstream sout;
  33                 boost::archive::text_oarchive oa(sout);
  34                 const SyncCommand scom(cl_,0);
  35                 oa << scom;
  36                 Send(sout.str());
  37         }
  38 }
  39
  40 //void StatusSocket::InitSSLServer()
  41 //{
  42 //      InitializeContext("server.pem", "keypwd", SSLv23_method());
  43 //}
  44 //
  45 //
  46 //void StatusSocket::Init()
  47 //{
  48 //      EnableSSL();
  49 //}