From fffd213c8cba2135afda493d797c41c10354770e Mon Sep 17 00:00:00 2001 From: Othmar Gsenger Date: Sat, 12 Apr 2008 11:38:42 +0000 Subject: big svn cleanup --- syncClientSocket.cpp | 96 ---------------------------------------------------- 1 file changed, 96 deletions(-) delete mode 100644 syncClientSocket.cpp (limited to 'syncClientSocket.cpp') 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 -#include -#include - -#include -#include - - -#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;index5) - { - 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() <<" "<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() <<" \""<> 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 #"<