Changeset 4924

Timestamp:

Jul 15, 2009, 8:22:38 AM (15 years ago)

Author:

huebsch

Message:

-bootstrap und ablauf

Files:

• sample/pingpong/main.cpp (modified) (3 diffs)
• source/ariba/utility/bootstrap/modules/periodicbroadcast/PeriodicBroadcast.cpp (modified) (1 diff)
• source/ariba/utility/bootstrap/modules/periodicbroadcast/PeriodicBroadcast.h (modified) (1 diff)

sample/pingpong/main.cpp

@@ -6 +6 @@
 using ariba::utility::StartupWrapper;
 using ariba::application::pingpong::PingPong;
-
 
 //*************************************************
@@ -16 +15 @@
         StartupWrapper::startSystem();
 
+        std::cout << "yyyyyyyyy!" << std::endl;
+
         BootstrapManager& manager = BootstrapManager::instance();
         manager.registerModule( BootstrapManager::BootstrapTypePeriodicBroadcast );
+
+        std::cout << "xxxxxxxxxxxxyyyyyyyyy!" << std::endl;
 
         manager.publish("testname", "testinfo1", "testinfo2", "testinfo3");
@@ -31 +34 @@
 int main( int argc, char** argv ) {
 
-        //debug();
-        //return 0;
+        debug();
+        return 0;
 
 

source/ariba/utility/bootstrap/modules/periodicbroadcast/PeriodicBroadcast.cpp

@@ -67 +67 @@
         server(io_service, &newRemoteServices, &newRemoteServicesMutex) {
 
-        io_service.run();
+        io_service_thread = new boost::thread(
+                boost::bind(&PeriodicBroadcast::threadFunc, this) );
 }
 
 PeriodicBroadcast::~PeriodicBroadcast(){
         io_service.stop();
+        io_service_thread->join();
+        delete io_service_thread;
+        io_service_thread = NULL;
+}
+
+void PeriodicBroadcast::threadFunc(PeriodicBroadcast* obj){
+        obj->io_service.run();
 }
 

source/ariba/utility/bootstrap/modules/periodicbroadcast/PeriodicBroadcast.h

@@ -113 +113 @@
 
         boost::asio::io_service io_service;
+        boost::thread* io_service_thread;
+        static void threadFunc(PeriodicBroadcast* obj);
 
         class udp_server {