|  | 1 | // [License] | 
|---|
|  | 2 | // The Ariba-Underlay Copyright | 
|---|
|  | 3 | // | 
|---|
|  | 4 | // Copyright (c) 2008-2009, Institute of Telematics, UniversitÀt Karlsruhe (TH) | 
|---|
|  | 5 | // | 
|---|
|  | 6 | // Institute of Telematics | 
|---|
|  | 7 | // UniversitÀt Karlsruhe (TH) | 
|---|
|  | 8 | // Zirkel 2, 76128 Karlsruhe | 
|---|
|  | 9 | // Germany | 
|---|
|  | 10 | // | 
|---|
|  | 11 | // Redistribution and use in source and binary forms, with or without | 
|---|
|  | 12 | // modification, are permitted provided that the following conditions are | 
|---|
|  | 13 | // met: | 
|---|
|  | 14 | // | 
|---|
|  | 15 | // 1. Redistributions of source code must retain the above copyright | 
|---|
|  | 16 | // notice, this list of conditions and the following disclaimer. | 
|---|
|  | 17 | // 2. Redistributions in binary form must reproduce the above copyright | 
|---|
|  | 18 | // notice, this list of conditions and the following disclaimer in the | 
|---|
|  | 19 | // documentation and/or other materials provided with the distribution. | 
|---|
|  | 20 | // | 
|---|
|  | 21 | // THIS SOFTWARE IS PROVIDED BY THE INSTITUTE OF TELEMATICS ``AS IS'' AND | 
|---|
|  | 22 | // ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE | 
|---|
|  | 23 | // IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR | 
|---|
|  | 24 | // PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE ARIBA PROJECT OR | 
|---|
|  | 25 | // CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, | 
|---|
|  | 26 | // EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, | 
|---|
|  | 27 | // PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR | 
|---|
|  | 28 | // PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF | 
|---|
|  | 29 | // LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING | 
|---|
|  | 30 | // NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS | 
|---|
|  | 31 | // SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | 
|---|
|  | 32 | // | 
|---|
|  | 33 | // The views and conclusions contained in the software and documentation | 
|---|
|  | 34 | // are those of the authors and should not be interpreted as representing | 
|---|
|  | 35 | // official policies, either expressed or implied, of the Institute of | 
|---|
|  | 36 | // Telematics. | 
|---|
|  | 37 | // [License] | 
|---|
|  | 38 |  | 
|---|
|  | 39 | #ifndef __STARTUP_WRAPPER_H | 
|---|
|  | 40 | #define __STARTUP_WRAPPER_H | 
|---|
|  | 41 |  | 
|---|
|  | 42 | #include <string> | 
|---|
|  | 43 | #include <queue> | 
|---|
|  | 44 | #include "SystemQueue.h" | 
|---|
|  | 45 | #include "StartupInterface.h" | 
|---|
|  | 46 | #include "ariba/utility/configuration/Configuration.h" | 
|---|
|  | 47 | #include "BlockingMethod.h" | 
|---|
|  | 48 |  | 
|---|
|  | 49 | #ifdef UNDERLAY_OMNET | 
|---|
|  | 50 | namespace ariba { | 
|---|
|  | 51 | namespace communication { | 
|---|
|  | 52 | class AribaOmnetModule; | 
|---|
|  | 53 | }} | 
|---|
|  | 54 |  | 
|---|
|  | 55 | using ariba::communication::AribaOmnetModule; | 
|---|
|  | 56 | #endif | 
|---|
|  | 57 |  | 
|---|
|  | 58 | using std::queue; | 
|---|
|  | 59 | using std::string; | 
|---|
|  | 60 | using ariba::utility::SystemQueue; | 
|---|
|  | 61 | using ariba::utility::SystemEvent; | 
|---|
|  | 62 | using ariba::utility::SystemEventType; | 
|---|
|  | 63 | using ariba::utility::SystemEventListener; | 
|---|
|  | 64 | using ariba::utility::StartupInterface; | 
|---|
|  | 65 | using ariba::utility::Configuration; | 
|---|
|  | 66 |  | 
|---|
|  | 67 | namespace ariba { | 
|---|
|  | 68 | namespace utility { | 
|---|
|  | 69 |  | 
|---|
|  | 70 | class StartupWrapper : public SystemEventListener { | 
|---|
|  | 71 | public: | 
|---|
|  | 72 | static void startSystem(); | 
|---|
|  | 73 | static void stopSystem(); | 
|---|
|  | 74 |  | 
|---|
|  | 75 | static void initConfig(string filename); | 
|---|
|  | 76 | static void startup(StartupInterface* service, bool block = true); | 
|---|
|  | 77 | static void shutdown(StartupInterface* service, bool block = true); | 
|---|
|  | 78 |  | 
|---|
|  | 79 | #ifdef UNDERLAY_OMNET | 
|---|
|  | 80 | static void insertCurrentModule( AribaOmnetModule* mod ); | 
|---|
|  | 81 | static AribaOmnetModule* getCurrentModule(); | 
|---|
|  | 82 | #endif | 
|---|
|  | 83 |  | 
|---|
|  | 84 | protected: | 
|---|
|  | 85 | StartupWrapper(StartupInterface* _service); | 
|---|
|  | 86 | virtual ~StartupWrapper(); | 
|---|
|  | 87 |  | 
|---|
|  | 88 | void handleSystemEvent( const SystemEvent& event ); | 
|---|
|  | 89 |  | 
|---|
|  | 90 | private: | 
|---|
|  | 91 | typedef queue<string> ConfigurationList; | 
|---|
|  | 92 | static ConfigurationList configurations; | 
|---|
|  | 93 |  | 
|---|
|  | 94 | #ifdef UNDERLAY_OMNET | 
|---|
|  | 95 | typedef queue<AribaOmnetModule*> ModuleList; | 
|---|
|  | 96 | static ModuleList modules; | 
|---|
|  | 97 | #endif | 
|---|
|  | 98 |  | 
|---|
|  | 99 | void waitForExit(); | 
|---|
|  | 100 | StartupInterface* service; | 
|---|
|  | 101 |  | 
|---|
|  | 102 | class AsyncShutdown : public BlockingMethod { | 
|---|
|  | 103 | public: | 
|---|
|  | 104 | AsyncShutdown(StartupInterface* _service); | 
|---|
|  | 105 | protected: | 
|---|
|  | 106 | virtual void dispatchFunction(); | 
|---|
|  | 107 | virtual void blockingFunction(); // unused | 
|---|
|  | 108 | private: | 
|---|
|  | 109 | StartupInterface* service; | 
|---|
|  | 110 | }; | 
|---|
|  | 111 |  | 
|---|
|  | 112 | }; | 
|---|
|  | 113 |  | 
|---|
|  | 114 | }} // namespace ariba, common | 
|---|
|  | 115 |  | 
|---|
|  | 116 | #endif // __STARTUP_WRAPPER_H | 
|---|