client-cpp
0.7.0
Main Page
Related Pages
Namespaces
Classes
Files
File List
File Members
ConfigurationProcessor.hpp
Go to the documentation of this file.
1
/*
2
* Copyright 2014 CyberVision, Inc.
3
*
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
* you may not use this file except in compliance with the License.
6
* You may obtain a copy of the License at
7
*
8
* http://www.apache.org/licenses/LICENSE-2.0
9
*
10
* Unless required by applicable law or agreed to in writing, software
11
* distributed under the License is distributed on an "AS IS" BASIS,
12
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
* See the License for the specific language governing permissions and
14
* limitations under the License.
15
*/
16
17
#ifndef CONFIGURATION_PROCESSOR_HPP_
18
#define CONFIGURATION_PROCESSOR_HPP_
19
20
#include <cstdint>
21
#include <memory>
22
23
#include "
kaa/observer/KaaObservable.hpp
"
24
#include "
kaa/configuration/IConfigurationProcessor.hpp
"
25
#include "
kaa/configuration/IConfigurationProcessedObservable.hpp
"
26
#include "
kaa/configuration/IDecodedDeltaObservable.hpp
"
27
28
namespace
kaa {
29
41
class
ConfigurationProcessor
:
public
IConfigurationProcessor
,
42
public
IDecodedDeltaObservable
,
43
public
IConfigurationProcessedObservable
{
44
public
:
45
typedef
avro::ValidSchema
Schema
;
46
47
ConfigurationProcessor
() {}
48
~ConfigurationProcessor
() { }
49
53
void
processConfigurationData
(
const
std::uint8_t *data, std::size_t dataLength,
bool
fullResync);
54
58
void
subscribeForUpdates
(
IGenericDeltaReceiver
&receiver);
59
void
unsubscribeFromUpdates
(
IGenericDeltaReceiver
&receiver);
60
64
void
addOnProcessedObserver
(
IConfigurationProcessedObserver
&observer);
65
void
removeOnProcessedObserver
(
IConfigurationProcessedObserver
&observer);
66
67
private
:
68
KAA_R_MUTEX_DECLARE(confProcessorMutex_);
69
70
KaaObservable<void (int, const KaaRootConfiguration&, bool), IGenericDeltaReceiver *>
deltaReceivers_;
71
KaaObservable<void (), IConfigurationProcessedObserver *>
onProcessedObservers_;
72
73
};
74
75
}
// namespace kaa
76
77
#endif
/* CONFIGURATION_PROCESSOR_HPP_ */
IDecodedDeltaObservable.hpp
kaa::ConfigurationProcessor::addOnProcessedObserver
void addOnProcessedObserver(IConfigurationProcessedObserver &observer)
kaa::ConfigurationProcessor::Schema
avro::ValidSchema Schema
Definition:
ConfigurationProcessor.hpp:45
kaa::ConfigurationProcessor::unsubscribeFromUpdates
void unsubscribeFromUpdates(IGenericDeltaReceiver &receiver)
kaa::ConfigurationProcessor::removeOnProcessedObserver
void removeOnProcessedObserver(IConfigurationProcessedObserver &observer)
kaa::IConfigurationProcessor
Definition:
IConfigurationProcessor.hpp:34
kaa::ConfigurationProcessor::~ConfigurationProcessor
~ConfigurationProcessor()
Definition:
ConfigurationProcessor.hpp:48
kaa::ConfigurationProcessor::ConfigurationProcessor
ConfigurationProcessor()
Definition:
ConfigurationProcessor.hpp:47
kaa::IDecodedDeltaObservable
Definition:
IDecodedDeltaObservable.hpp:29
kaa::IGenericDeltaReceiver
Definition:
IGenericDeltaReceiver.hpp:29
kaa::IConfigurationProcessedObserver
Definition:
IConfigurationProcessedObserver.hpp:29
IConfigurationProcessedObservable.hpp
kaa::ConfigurationProcessor
Definition:
ConfigurationProcessor.hpp:41
kaa::ConfigurationProcessor::subscribeForUpdates
void subscribeForUpdates(IGenericDeltaReceiver &receiver)
IConfigurationProcessor.hpp
kaa::KaaObservable
Definition:
KaaObservable.hpp:31
kaa::ConfigurationProcessor::processConfigurationData
void processConfigurationData(const std::uint8_t *data, std::size_t dataLength, bool fullResync)
kaa::IConfigurationProcessedObservable
Definition:
IConfigurationProcessedObservable.hpp:29
KaaObservable.hpp
var
lib
jenkins
workspace
kaa_stable
client
client-multi
client-cpp
kaa
configuration
ConfigurationProcessor.hpp
Generated on Tue Mar 31 2015 13:18:40 for client-cpp by
1.8.7