X-Git-Url: https://git.syn-net.org/debian/?a=blobdiff_plain;f=src%2FsyncServer.h;h=032e97515b65458cb4f62eb3898738928733679b;hb=bf2cb4e3379948d1f2e65f2a6373cf0f8c379481;hp=138f46e8231df8f4d0d636448795e99303759750;hpb=058ae090a970436caec3b3059e9e18b310dd6b0d;p=anytun.git diff --git a/src/syncServer.h b/src/syncServer.h index 138f46e..032e975 100644 --- a/src/syncServer.h +++ b/src/syncServer.h @@ -11,14 +11,15 @@ * tunneling and relaying of packets of any protocol. * * - * Copyright (C) 2007-2008 Othmar Gsenger, Erwin Nindl, + * Copyright (C) 2007-2009 Othmar Gsenger, Erwin Nindl, * Christian Pointner * * 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. + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * any later version. * * Anytun is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of @@ -29,10 +30,9 @@ * along with anytun. If not, see . */ -#ifndef _SYNC_SERVER_H_ -#define _SYNC_SERVER_H_ -//#include -//#include +#ifndef ANYTUN_syncServer_h_INCLUDED +#define ANYTUN_syncServer_h_INCLUDED + #include #include #include @@ -50,7 +50,8 @@ class SyncServer { public: SyncServer(std::string localaddr, std::string port, ConnectCallback onConnect); - void onResolve(const SyncTcpConnection::proto::endpoint& e); + ~SyncServer(); + void onResolve(SyncTcpConnection::proto::resolver::iterator& it); void onResolvError(const std::runtime_error& e); void run(); @@ -59,13 +60,18 @@ public: std::list conns_; private: - void start_accept(); - void handle_accept(SyncTcpConnection::pointer new_connection, const boost::system::error_code& error); - Mutex mutex_; //Mutex for list conns_ boost::asio::io_service io_service_; - SyncTcpConnection::proto::acceptor acceptor_; + typedef struct { + SyncTcpConnection::proto::acceptor* acceptor_; + bool started_; + } AcceptorsElement; + std::list acceptors_; ConnectCallback onConnect_; Semaphore ready_sem_; + + void start_accept(); + void handle_accept(SyncTcpConnection::pointer new_connection, const boost::system::error_code& error, std::list::iterator it); }; + #endif