Changeset 4483 for source/ariba/utility/system/StartupWrapper.cpp

Timestamp:

Jun 25, 2009, 11:06:52 AM (15 years ago)

Author:

Christoph Mayer

Message:

-StartupWrapper bisschen umgeschrieben, erste Schritte für sauberes runterfahren

File:

• source/ariba/utility/system/StartupWrapper.cpp (modified) (5 diffs)

source/ariba/utility/system/StartupWrapper.cpp

@@ -48 +48 @@
 
 SystemEventType StartupWrapperEventStartup("StartupWrapperEventStartup");
-SystemEventType StartupWrapperEventShutdown("StartupWrapperEventShutdown");
 
 StartupWrapper::StartupWrapper(StartupInterface* _service) : service( _service ){
@@ -73 +72 @@
 #endif
 
-void StartupWrapper::initSystem(){
-
-        static bool initialized = false;
-        if( initialized ) return;
-        initialized = true;
+void StartupWrapper::startSystem(){
 
         //
@@ -121 +116 @@
 }
 
+void StartupWrapper::stopSystem(){
+        SystemQueue::instance().cancel();
+}
+
 void StartupWrapper::initConfig(string filename){
         configurations.push( filename );
@@ -142 +141 @@
 
                 service->startup();
-
-        } else if( event.getType() == StartupWrapperEventShutdown ){
-
-                service->shutdown();
-                SystemQueue::instance().cancel();
 
         }
@@ -174 +168 @@
 
         if(block){
-                SystemEvent ev (service->wrapper, StartupWrapperEventShutdown);
-                service->wrapper->handleSystemEvent(ev);
-
+                // call directly
+                service->shutdown();
         }else{
-                SystemQueue::instance().scheduleEvent(
-                                SystemEvent( service->wrapper, StartupWrapperEventShutdown, NULL), 0 );
+                // call async, but not using systemqueue! // TODO: mem leak
+                AsyncShutdown* async = new AsyncShutdown(service);
+                async->runBlockingMethod();
         }
 }
 
+StartupWrapper::AsyncShutdown::AsyncShutdown(StartupInterface* _service)
+        : service(_service){
+}
+
+void StartupWrapper::AsyncShutdown::blockingFunction(){
+        service->shutdown();
+}
+
+void StartupWrapper::AsyncShutdown::dispatchFunction(){
+        //unused
+}
+
 }} // namespace ariba, utility