c97fe7b714f2314c3b81cf25295128a1a9191d59
[anna.git] / example / diameter / launcher / Launcher.hpp
1 // ANNA - Anna is Not Nothingness Anymore                                                         //
2 //                                                                                                //
3 // (c) Copyright 2005-2015 Eduardo Ramos Testillano & Francisco Ruiz Rayo                         //
4 //                                                                                                //
5 // See project site at http://redmine.teslayout.com/projects/anna-suite                           //
6 // See accompanying file LICENSE or copy at http://www.teslayout.com/projects/public/anna.LICENSE //
7
8
9 #ifndef example_diameter_launcher_Launcher_hpp
10 #define example_diameter_launcher_Launcher_hpp
11
12 // Standard
13 #include <fstream>
14 #include <string>
15 #include <map>
16
17 // Project
18 #include <anna/core/core.hpp>
19 #include <anna/comm/comm.hpp>
20 #include <anna/time/Date.hpp>
21 #include <anna/diameter/codec/Message.hpp>
22
23 // Process
24 #include <MyCommunicator.hpp>
25 #include <MyCounterRecorder.hpp>
26 #include <anna/testing/TestManager.hpp>
27
28
29 namespace anna {
30   namespace timex {
31     class Engine;
32   }
33   namespace diameter {
34     namespace codec {
35       class Engine;
36     }
37     namespace comm {
38       class OriginHost;
39     }
40   }
41 }
42
43 class TestManager;
44 class MyDiameterEntity;
45 class MyLocalServer;
46 class MyDiameterEngine;
47
48 // OriginHost resources
49 typedef std::map<std::string, anna::diameter::comm::OriginHost*> origin_hosts_t;
50 typedef std::map<std::string, anna::diameter::comm::OriginHost*>::const_iterator origin_hosts_it;
51 typedef std::map<std::string, anna::diameter::comm::OriginHost*>::iterator origin_hosts_nc_it;
52
53
54 class Launcher : public anna::comm::Application {
55
56   // Start time:
57   anna::time::Date a_start_time;
58   std::string a_initialWorkingDirectory;
59
60   // Core engines:
61   MyCommunicator *a_communicator;
62   anna::timex::Engine* a_timeEngine;
63   MyCounterRecorder *a_counterRecorder;
64   anna::Millisecond a_admlMinResolution;
65   MyCounterRecorderClock *a_counterRecorderClock;
66
67   // Nodes deployment:
68   anna::diameter::comm::OriginHost *a_workingNode;
69   anna::diameter::comm::OriginHost *a_operatedHost; // auxiliary for eventOperation
70
71   // comm resources:
72   anna::comm::ServerSocket* a_httpServerSocket; // HTTP
73
74   std::string getSignalUSR2InputFile() const throw();
75   std::string getSignalUSR2OutputFile() const throw();
76
77   void servicesFromXML(const anna::xml::Node* servicesNode, bool eventOperation) throw(anna::RuntimeException);
78   anna::Millisecond checkTimeMeasure(const std::string &parameter, const std::string &value) throw(anna::RuntimeException);
79   void initialize() throw(anna::RuntimeException); // HTTP
80   void run() throw(anna::RuntimeException);
81
82
83
84 public:
85   Launcher();
86   //~Launcher(); TODO
87
88   void loadServices(const std::string & xmlPathFile, bool eventOperation = false) throw(anna::RuntimeException);
89   void startServices() throw(anna::RuntimeException);
90
91   bool setWorkingNode(const std::string &name) throw();
92   anna::diameter::comm::OriginHost *getOriginHost(const std::string &name) const throw(anna::RuntimeException);
93   anna::diameter::comm::OriginHost *getOriginHost(const anna::diameter::codec::Message &message) const throw(anna::RuntimeException);
94   bool uniqueOriginHost() const throw();
95
96   // Operated host for communication resources smart assignment ////////////////////////////////////////////////////////////
97   void updateOperatedOriginHostWithMessage(const anna::diameter::codec::Message &message) throw(anna::RuntimeException);
98   anna::diameter::comm::OriginHost *getWorkingNode() const throw(anna::RuntimeException);
99   anna::diameter::comm::OriginHost *getOperatedHost() const throw(anna::RuntimeException);
100   MyDiameterEntity *getOperatedEntity() const throw(anna::RuntimeException);
101   MyLocalServer *getOperatedServer() const throw(anna::RuntimeException);
102   MyDiameterEngine *getOperatedEngine() const throw(anna::RuntimeException);
103   ///////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
104
105
106   MyCommunicator *getCommunicator() throw() { return a_communicator; }
107   void eventOperation(const std::string &, std::string &) throw(anna::RuntimeException);
108   void forceCountersRecord() throw(anna::RuntimeException) { if (a_counterRecorderClock) a_counterRecorderClock->tick(); }
109   void logStatisticsSamples(const std::string &conceptsList) throw();
110
111
112   anna::xml::Node* asXML(anna::xml::Node* parent) const throw();
113   void resetStatistics() throw();
114   void resetCounters() throw();
115   void signalUSR2() throw(anna::RuntimeException);
116   void signalTerminate() throw(anna::RuntimeException);
117   std::string help() const throw();
118   anna::xml::Node* oamAsXML(anna::xml::Node* parent) const throw();
119   anna::xml::Node* statsAsXML(anna::xml::Node* parent) const throw();
120
121   // helpers
122   bool getDataBlockFromHexFile(const std::string &pathfile, anna::DataBlock &db) const throw(anna::RuntimeException);
123   bool getContentFromFile(const std::string &pathfile, std::string &content) const throw(anna::RuntimeException);
124
125   friend class TestManager;
126 };
127
128 #endif