diff options
Diffstat (limited to 'syncClientSocket.cpp')
-rw-r--r-- | syncClientSocket.cpp | 96 |
1 files changed, 0 insertions, 96 deletions
diff --git a/syncClientSocket.cpp b/syncClientSocket.cpp deleted file mode 100644 index e7eb0d2..0000000 --- a/syncClientSocket.cpp +++ /dev/null @@ -1,96 +0,0 @@ -#include <sstream> -#include <iostream> -#include <string> - -#include <boost/archive/text_oarchive.hpp> -#include <boost/archive/text_iarchive.hpp> - - -#include "log.h" -//#include "connectionParam.h" -#include "Sockets/Utility.h" -#include "syncClientSocket.h" -#include "buffer.h" - - -SyncClientSocket::SyncClientSocket(ISocketHandler& h,ConnectionList & cl) -:TcpSocket(h),cl_(cl),missing_chars(-1),buffer_size_(0) -{ - // initial connection timeout setting and number of retries - SetConnectTimeout(12); - SetConnectionRetry(-1); //infinite reties - - // Also reconnect broken link - SetReconnect(true); -} - - -bool SyncClientSocket::OnConnectRetry() -{ - return true; -} - - -void SyncClientSocket::OnReconnect() -{ - cLog.msg(Log::PRIO_NOTICE) << "reconnected with " << GetRemoteHostname() << std::endl; - // ... - //Send("Welcome back\r\n"); -} - - -void SyncClientSocket::OnRawData(const char *buf,size_t len) -//void SyncClientSocket::OnLine(const std::string& line) -{ - for(size_t index=0;index<len;index++) - { -// std::cout << buf[index]; - iss_ << buf[index]; - buffer_size_++; - } - while (1) - { -// cLog.msg(Log::PRIO_NOTICE) << "buffer size "<< buffer_size_ << " missing_chars " << missing_chars; - if(missing_chars==-1 && buffer_size_>5) - { - char * buffer = new char [6+1]; - iss_.read(buffer,6); - std::stringstream tmp; - tmp.write(buffer,6); - tmp>>missing_chars; -// cLog.msg(Log::PRIO_NOTICE) << "recieved sync inforamtaion length from " << GetRemoteHostname() <<" "<<tmp.str()<<"bytes of data"<< std::endl; - delete[] buffer; - buffer_size_-=6; - } else - if(missing_chars>0 && missing_chars<=buffer_size_) - { - char * buffer = new char [missing_chars+1]; - iss_.read(buffer,missing_chars); - std::stringstream tmp; - tmp.write(buffer,missing_chars); -// cLog.msg(Log::PRIO_NOTICE) << "recieved sync inforamtaion from " << GetRemoteHostname() <<" \""<<tmp.str()<<'"'<< std::endl; - boost::archive::text_iarchive ia(tmp); - SyncCommand scom(cl_); - ia >> scom; - buffer_size_-=missing_chars; - missing_chars=-1; - delete[] buffer; - } else - break; - } - - //u_int16_t mux = scom.getMux(); - //const ConnectionParam & conn = cl_.getConnection(mux)->second; - //cLog.msg(Log::PRIO_NOTICE) << "sync connection #"<<mux<<" remote host " << conn.remote_host_ << ":" << conn.remote_port_ << std::endl; -} - -//void StatusClientSocket::InitSSLServer() -//{ -// InitializeContext("server.pem", "keypwd", SSLv23_method()); -//} -// -// -//void StatusClientSocket::Init() -//{ -// EnableSSL(); -//} |