summaryrefslogtreecommitdiff
path: root/src/anytun.cpp
diff options
context:
space:
mode:
authorOthmar Gsenger <otti@anytun.org>2008-11-17 22:42:31 +0000
committerOthmar Gsenger <otti@anytun.org>2008-11-17 22:42:31 +0000
commit6b560cd6d1d2159a7cbd5be06ae5309704627f06 (patch)
treec5d516dbd7e6f41b6aab160f69fbe6ff8e225af0 /src/anytun.cpp
parentremoved outdated plain_tool code (diff)
fixed sync support
Diffstat (limited to 'src/anytun.cpp')
-rw-r--r--src/anytun.cpp5
1 files changed, 3 insertions, 2 deletions
diff --git a/src/anytun.cpp b/src/anytun.cpp
index 3d7dd5d..4bb6e14 100644
--- a/src/anytun.cpp
+++ b/src/anytun.cpp
@@ -209,7 +209,7 @@ void syncConnector(void* p )
sc.run();
}
-void syncListener(void* p )
+void syncListener(SyncQueue * queue )
{
// ThreadParam* param = reinterpret_cast<ThreadParam*>(p);
@@ -217,6 +217,7 @@ void syncListener(void* p )
{
asio::io_service io_service;
SyncServer server(io_service,asio::ip::tcp::endpoint(asio::ip::tcp::v4(), gOpt.getLocalSyncPort()));
+ queue->setSyncServerPtr(&server);
io_service.run();
}
catch (std::exception& e)
@@ -547,7 +548,7 @@ int main(int argc, char* argv[])
#ifndef ANYTUN_NOSYNC
boost::thread * syncListenerThread;
if ( gOpt.getLocalSyncPort())
- syncListenerThread = new boost::thread(boost::bind(syncListener,&p));
+ syncListenerThread = new boost::thread(boost::bind(syncListener,&queue));
std::list<boost::thread *> connectThreads;
for(ConnectToList::iterator it = connect_to.begin() ;it != connect_to.end(); ++it) {