Blame view

src/Parameters/ServicesServer.hh 7.13 KB
fbe3c2bb   Benjamin Renard   First commit
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
/*
 * ServicesServer.h
 *
 *  Created on: Nov 12, 2012
 *      Author: g.schneller
 */

#ifndef SERVICESSERVER_H_
#define SERVICESSERVER_H_


#include <map>
#include <string>
#include <typeinfo>
#include <list>

#include <boost/any.hpp>
#include <boost/function.hpp>
#include <boost/bind.hpp>
#include <boost/functional/factory.hpp>
#include <boost/shared_ptr.hpp>

#include "dsgpatt_Singleton.hh"
#include "Demangle.hh"

#include "AMDA_exception.hh"

namespace AMDA {
namespace Parameters {

//use class
class ServicesServer;
class ParamGet;
class Process;
class ParamOutput;
class Parameter;
class StatisticProcess;

typedef boost::shared_ptr<ServicesServer> ServicesServerSPtr;

// ParamGet factory definition
typedef boost::function < ParamGet*(Parameter &) > ParamGetFactory;
typedef std::map<std::string, ParamGetFactory> ParamGetFactories;

// Process factory definition
typedef boost::function < Process*(Parameter &) > ProcessFactory;
typedef std::map<std::string, ProcessFactory> ProcessFactories;

// ParamOutput factory definition
typedef boost::function < ParamOutput*() > ParamOutputFactory;
typedef std::map<std::string, ParamOutputFactory> ParamOutputFactories;

// StatisticProcess factory definition
a4698d47   Benjamin Renard   Fix StatisticProc...
54
typedef boost::function < StatisticProcess*(Parameter &, const int&) > StatisticProcessFactory;
fbe3c2bb   Benjamin Renard   First commit
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
typedef std::map<std::string, StatisticProcessFactory> StatisticProcessFactories;

class FileConfigurator;
typedef boost::shared_ptr<FileConfigurator> ParameterConfiguratorSPtr;

/**
 * @class ServicesServer
 * @brief To call to register needed Services or to notify implemented Services
 * @details This Singleton class is frequently called into the registerPlugin method to notify one or more Services implementation as Process, ParamGet and ParamOutput.
 */
class ServicesServer : public ::Singleton<ServicesServer>{
public:
	// Design pattern
	 friend class Singleton<ServicesServer>;
     typedef std::list<boost::any> ServiceList;
     struct exception: virtual AMDA_exception { };

     /**
      *  @brief Add a Service implementation
      */
     template<typename T>
     void addService(T v) {
       _serviceList.push_back(v);
     }

     /**
      *  @brief Add a Service implementation
      */
     template<typename T>
     void declareService() {
    	 typedef typename std::map<std::string,T> TServiceImpList;
         for ( ServiceList::const_reverse_iterator rit = _serviceList.rbegin(); rit != _serviceList.rend(); ++rit ) {
             if ( (*rit).type() == typeid(TServiceImpList)) {
 				std::stringstream oss;
 				oss << "Service already declared: " <<  Helpers::Demangle(typeid(T).name());
            	 BOOST_THROW_EXCEPTION(exception() << AMDA::ex_msg(oss.str()));
             }
         }
         _serviceList.push_back(TServiceImpList());
     }

     /**
      *  @brief Add a Service implementation
      */
     template<typename T>
     void addServiceImpl(std::string name, T t) {
    	 typedef typename std::map<std::string,T> TServiceImpList;
    	 ServiceList::iterator it = _serviceList.begin();
         for ( ; it != _serviceList.end(); ++it ) {
             if ( (*it).type() == typeid(TServiceImpList)) {
            	 TServiceImpList& list = boost::any_cast<TServiceImpList&>(*it);
            	 list.insert(make_pair(name,t));
            	 break;
             }
         }
         if( it == _serviceList.end()) {
             _serviceList.push_back(TServiceImpList());
             ServiceList::iterator it =_serviceList.end();
        	 TServiceImpList& list = boost::any_cast<TServiceImpList&>(*(--it));
        	 list.insert(make_pair(name,t));
         }
     }

     /**
      * @brief Search a Service implementation by this type.
      * @return Service or NULL if not found.
      */
     template<typename T>
     T getService() const {
         for ( ServiceList::const_reverse_iterator rit = _serviceList.rbegin(); rit != _serviceList.rend(); ++rit ) {
             if ( (*rit).type() == typeid(T)) {
                 return boost::any_cast<T>(*rit);
             }
         }
         return NULL;
     }

     /**
      * @brief Search a Service implementation by this type.
      * @return Service or NULL if not found.
      */
     template<typename T>
     T getService(const std::string& pImplName) const {
    	 typedef typename std::map<std::string,T> TServiceImpList;
         for ( ServiceList::const_reverse_iterator rit = _serviceList.rbegin(); rit != _serviceList.rend(); ++rit ) {
             if ( (*rit).type() == typeid(TServiceImpList)) {
            	 TServiceImpList list = boost::any_cast<TServiceImpList>(*rit);
            	 typename TServiceImpList::iterator it = list.find(pImplName);
            	 if ( it != list.end()) {
            		 return it->second;
            	 } else {
            		 return NULL;
            	 }
             }
         }
         return NULL;
     }

    ParamOutput* getParamOutput(std::string paramOutputId)  {
		return _paramOutputFactory[paramOutputId]();
	}

	 void addParamOutputFactory(std::string paramOutputId, ParamOutputFactory paramOutputFactory)  {
		 _paramOutputFactory[paramOutputId] = paramOutputFactory;
	}

	StatisticProcess* getStatisticProcess(std::string processId, Parameter &parameter, int index)  {
		return _statisticProcessFactory[processId](parameter,index);
	}

	void addStatisticProcessFactory(std::string processId, StatisticProcessFactory statisticProcessFactory)  {
		_statisticProcessFactory[processId] = statisticProcessFactory;
	}

    ParamGet* getParamGet(std::string paramGetId, Parameter &parameter) {
    	return _paramGetFactory[paramGetId](parameter);
    }

    void addParamGetFactory(std::string paramGetId, ParamGetFactory paramGetFactory) {
    	 _paramGetFactory[paramGetId] = paramGetFactory;
    }

    Process* getProcess(std::string processId, Parameter &parameter) {
    	auto lIt = _processFactory.find(processId);
    	return (lIt==_processFactory.end())?nullptr:lIt->second(parameter);
    }

    void addProcessFactory(std::string processId, ProcessFactory processFactory) {
    	_processFactory[processId] = processFactory;
    }

    // Get methods
    ParameterConfiguratorSPtr& getConfigurator() {
    	return _configurator;
    }

    // Set methods
    void setConfigurator(ParameterConfiguratorSPtr &configurator){
    	_configurator = configurator;
    }

private:

	ServicesServer();
	virtual ~ServicesServer();

    /**
     * Factory of ParamGet
     * for a string are a sourceParmGet, use
     * @code ParamGet p = _paramGetFactory[souceParamGet]()
     */
    ParamGetFactories _paramGetFactory;

    /**
     * Factory of Process
     * for a string are a sourceProcess, use
     * @code Process p = _processFactory[souceProcess]()
     */
    ProcessFactories _processFactory;

    /**
     * Factory of ParamOutput
     * for a string are a sourceParmOutput, use
     * @code ParamOutput p = _paramOutputFactory[souceParamGet]()
     */
    ParamOutputFactories _paramOutputFactory;

    /**
     * Factory of StatisticProcess
     */
    StatisticProcessFactories _statisticProcessFactory;

    ParameterConfiguratorSPtr _configurator;

    /**
     * List of services.
     */
    ServiceList _serviceList;
};

} /* namespace Parameters */
} /* namespace AMDA */
#endif /* SERVICESSERVER_H_ */