src/syncClientSocket.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 "log.h"
  10 //#include "connectionParam.h"
  11 #include "Sockets/Utility.h"
  12 #include "syncClientSocket.h"
  13 #include "buffer.h"
  14
  15
  16 SyncClientSocket::SyncClientSocket(ISocketHandler& h,ConnectionList & cl)
  17 :TcpSocket(h),cl_(cl),missing_chars(-1),buffer_size_(0)
  18 {
  19         // initial connection timeout setting and number of retries
  20         SetConnectTimeout(12);
  21         SetConnectionRetry(-1); //infinite reties
  22
  23         // Also reconnect broken link
  24         SetReconnect(true);
  25 }
  26
  27
  28 bool SyncClientSocket::OnConnectRetry()
  29 {
  30         return true;
  31 }
  32
  33
  34 void SyncClientSocket::OnReconnect()
  35 {
  36   cLog.msg(Log::PRIO_NOTICE) << "reconnected with " << GetRemoteHostname() << std::endl;
  37         // ...
  38         //Send("Welcome back\r\n");
  39 }
  40
  41
  42 void SyncClientSocket::OnRawData(const char *buf,size_t len)
  43 //void SyncClientSocket::OnLine(const std::string& line)
  44 {
  45         for(size_t index=0;index<len;index++)
  46         {
  47 //              std::cout << buf[index];
  48                 iss_ << buf[index];
  49                 buffer_size_++;
  50         }
  51         while (1)
  52         {
  53 //              cLog.msg(Log::PRIO_NOTICE) << "buffer size "<< buffer_size_ << " missing_chars " << missing_chars;
  54                 if(missing_chars==-1 && buffer_size_>5)
  55                 {
  56       char * buffer = new char [6+1];
  57       iss_.read(buffer,6);
  58       std::stringstream tmp;
  59       tmp.write(buffer,6);
  60                         tmp>>missing_chars;
  61 //                      cLog.msg(Log::PRIO_NOTICE) << "recieved sync inforamtaion length from " << GetRemoteHostname() <<" "<<tmp.str()<<"bytes of data"<< std::endl;
  62                         delete[] buffer;
  63                         buffer_size_-=6;
  64                 } else
  65                 if(missing_chars>0 && missing_chars<=buffer_size_)
  66                 {
  67                         char * buffer = new char [missing_chars+1];
  68                         iss_.read(buffer,missing_chars);
  69                         std::stringstream tmp;
  70                         tmp.write(buffer,missing_chars);
  71 //                      cLog.msg(Log::PRIO_NOTICE) << "recieved sync inforamtaion from " << GetRemoteHostname() <<" \""<<tmp.str()<<'"'<< std::endl;
  72                         boost::archive::text_iarchive ia(tmp);
  73                         SyncCommand scom(cl_);
  74                         ia >> scom;
  75                         buffer_size_-=missing_chars;
  76                         missing_chars=-1;
  77                         delete[] buffer;
  78                 } else
  79                 break;
  80         }
  81
  82         //u_int16_t mux = scom.getMux();
  83         //const ConnectionParam & conn = cl_.getConnection(mux)->second;
  84   //cLog.msg(Log::PRIO_NOTICE) << "sync connection #"<<mux<<" remote host " << conn.remote_host_ << ":" << conn.remote_port_ << std::endl;
  85 }
  86
  87 //void StatusClientSocket::InitSSLServer()
  88 //{
  89 //      InitializeContext("server.pem", "keypwd", SSLv23_method());
  90 //}
  91 //
  92 //
  93 //void StatusClientSocket::Init()
  94 //{
  95 //      EnableSSL();
  96 //}