diff options
Diffstat (limited to 'syncClientSocket.cpp')
-rw-r--r-- | syncClientSocket.cpp | 73 |
1 files changed, 73 insertions, 0 deletions
diff --git a/syncClientSocket.cpp b/syncClientSocket.cpp new file mode 100644 index 0000000..7dbbf67 --- /dev/null +++ b/syncClientSocket.cpp @@ -0,0 +1,73 @@ +#include <sstream> +#include <iostream> +#include <string> + +#include <boost/archive/text_oarchive.hpp> +#include <boost/archive/text_iarchive.hpp> + + +//#include "connectionParam.h" +#include "Sockets/Utility.h" +#include "syncClientSocket.h" +#include "buffer.h" +//#include "log.h" + +SyncClientSocket::SyncClientSocket(ISocketHandler& h,ConnectionList & cl) +:TcpSocket(h),cl_(cl) +{ + // initial connection timeout setting and number of retries + SetConnectTimeout(12); + SetConnectionRetry(-1); //infinite reties + + // Also reconnect broken link + SetReconnect(true); +} + + +bool SyncClientSocket::OnConnectRetry() +{ + std::cout << "SyncClientSocket::OnConnectRetry" << std::endl; + return true; +} + + +void SyncClientSocket::OnReconnect() +{ + std::cout << "SyncClientSocket::OnReconnect" << std::endl; + // ... + //Send("Welcome back\r\n"); +} + + +void SyncClientSocket::OnRawData(const char *buf,size_t len) +//void SyncClientSocket::OnLine(const std::string& line) +{ + return; + std::stringstream iss; + std::cout << "recieved sync inforamtaion:"<< std::endl; + for(size_t index=0;index<len;index++) + { + std::cout << buf[index]; + iss << buf[index]; + } + boost::archive::text_iarchive ia(iss); + SeqWindow * seq= new SeqWindow(0); + seq_nr_t seq_nr_=0; + KeyDerivation * kd = new KeyDerivation; + kd->init(::Buffer(20), ::Buffer(14)); + ConnectionParam conn ( (*kd), (*seq), seq_nr_, "", 0); + ia >> conn; + std::cout << "sync connection remote host " << conn.remote_host_ << ":" << conn.remote_port_ << std::endl; + cl_.clear(); + cl_.addConnection(conn,std::string("default")); +} +//void StatusClientSocket::InitSSLServer() +//{ +// InitializeContext("server.pem", "keypwd", SSLv23_method()); +//} +// +// +//void StatusClientSocket::Init() +//{ +// EnableSSL(); +//} |