diff options
Diffstat (limited to 'src/syncClient.cpp')
-rw-r--r-- | src/syncClient.cpp | 153 |
1 files changed, 153 insertions, 0 deletions
diff --git a/src/syncClient.cpp b/src/syncClient.cpp new file mode 100644 index 0000000..d6ede4a --- /dev/null +++ b/src/syncClient.cpp @@ -0,0 +1,153 @@ +/* + * anytun + * + * The secure anycast tunneling protocol (satp) defines a protocol used + * for communication between any combination of unicast and anycast + * tunnel endpoints. It has less protocol overhead than IPSec in Tunnel + * mode and allows tunneling of every ETHER TYPE protocol (e.g. + * ethernet, ip, arp ...). satp directly includes cryptography and + * message authentication based on the methodes used by SRTP. It is + * intended to deliver a generic, scaleable and secure solution for + * tunneling and relaying of packets of any protocol. + * + * + * Copyright (C) 2007-2008 Othmar Gsenger, Erwin Nindl, + * Christian Pointner <satp@wirdorange.org> + * + * This file is part of Anytun. + * + * Anytun is free software: you can redistribute it and/or modify + * it under the terms of the GNU General Public License version 3 as + * published by the Free Software Foundation. + * + * Anytun is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with anytun. If not, see <http://www.gnu.org/licenses/>. + */ +#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 "syncClient.h" +#include "buffer.h" +#include <boost/array.hpp> + + +SyncClient::SyncClient(std::string hostname,uint16_t port) +:hostname_( hostname),port_(port) +{ +} + +void SyncClient::run() +{ + try + { + asio::io_service io_service; + for(;;) + { + std::stringstream portsrt; + portsrt << port_; + asio::ip::tcp::resolver resolver(io_service); + asio::ip::tcp::resolver::query query( hostname_, portsrt.str()); + asio::ip::tcp::resolver::iterator endpoint_iterator = resolver.resolve(query); + asio::ip::tcp::resolver::iterator end; + + asio::ip::tcp::socket socket(io_service); + asio::error_code error = asio::error::host_not_found; + while (error && endpoint_iterator != end) + { + socket.close(); + socket.connect(*endpoint_iterator++, error); + } + if (error) + throw asio::system_error(error); + + for (;;) + { + boost::array<char, 128> buf; + asio::error_code error; + + size_t len = socket.read_some(asio::buffer(buf), error); + + if (error == asio::error::eof) + break; // Connection closed cleanly by peer. + else if (error) + throw asio::system_error(error); // Some other error. + + OnRawData(buf.data(), len); + } + } + sleep(10); + } + catch (std::exception& e) + { + std::cerr << e.what() << std::endl; + } +} + +void SyncClient::OnRawData(const char *buf,size_t len) +//void SyncClientSocket::OnLine(const std::string& line) +{ + ConnectionList & cl_ (gConnectionList); + 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(); +//} |