bbbee7203521e916b5d7186f9a34c97b9554ad71
[profile/ivi/automotive-message-broker.git] / ambd / core.h
1 /*
2     Copyright (C) 2012  Intel Corporation
3
4     This library is free software; you can redistribute it and/or
5     modify it under the terms of the GNU Lesser General Public
6     License as published by the Free Software Foundation; either
7     version 2.1 of the License, or (at your option) any later version.
8
9     This library is distributed in the hope that it will be useful,
10     but WITHOUT ANY WARRANTY; without even the implied warranty of
11     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
12     Lesser General Public License for more details.
13
14     You should have received a copy of the GNU Lesser General Public
15     License along with this library; if not, write to the Free Software
16     Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
17 */
18
19
20 #ifndef CORE_H
21 #define CORE_H
22
23 #include "abstractsink.h"
24 #include "abstractsource.h"
25 #include "abstractroutingengine.h"
26
27 #include <map>
28
29 class Core: public AbstractRoutingEngine
30 {
31         
32 public:
33         Core();
34         
35         /// sources:
36
37         void setSupported(PropertyList supported, AbstractSource* source);
38         void updateSupported(PropertyList added, PropertyList removed);
39         void updateProperty(VehicleProperty::Property property, AbstractPropertyType* value, string uuid);
40         
41         /// sinks:
42         
43         void registerSink(AbstractSink *self);
44         void unregisterSink(AbstractSink *self);
45         AsyncPropertyReply* getPropertyAsync(AsyncPropertyRequest request);
46         AsyncRangePropertyReply* getRangePropertyAsync(AsyncRangePropertyRequest request);
47         AsyncPropertyReply * setProperty(AsyncSetPropertyRequest request);
48         void subscribeToProperty(VehicleProperty::Property, AbstractSink* self);
49         void unsubscribeToProperty(VehicleProperty::Property, AbstractSink* self);
50         PropertyList supported() { return mMasterPropertyList; }
51     
52         ~Core();
53         
54 private:
55         PropertyList mMasterPropertyList;
56         
57         SourceList mSources;
58         SinkList mSinks;
59
60         int propertiesPerSecond;
61         
62         std::map<VehicleProperty::Property, SinkList> propertySinkMap;
63
64         std::map<VehicleProperty::Property, std::string> previousValueMap;
65     
66 };
67
68 #endif // CORE_H