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
|
/* Copyright (C) 2013 BMW Group
* Author: Manfred Bathelt (manfred.bathelt@bmw.de)
* Author: Juergen Gehring (juergen.gehring@bmw.de)
* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
#include "DBusServiceStatusEvent.h"
#include "DBusServiceRegistry.h"
#include <cassert>
namespace CommonAPI {
namespace DBus {
DBusServiceStatusEvent::DBusServiceStatusEvent(std::shared_ptr<DBusServiceRegistry> registry) :
registry_(registry) {
}
void DBusServiceStatusEvent::onFirstListenerAdded(const std::string& commonApiServiceName, const Listener& listener) {
}
SubscriptionStatus DBusServiceStatusEvent::availabilityEvent(const std::string& commonApiServiceName, const AvailabilityStatus& availabilityStatus) {
notifyListeners(commonApiServiceName, availabilityStatus);
return SubscriptionStatus::RETAIN;
}
void DBusServiceStatusEvent::onListenerAdded(const std::string& commonApiServiceName, const Listener& listener) {
if (registry_) {
registry_->subscribeAvailabilityListener(commonApiServiceName, std::bind(
&DBusServiceStatusEvent::availabilityEvent,
this,
commonApiServiceName,
std::placeholders::_1));
std::string dbusInterfaceName;
std::string dbusConnectionName;
std::string dbusObjectPath;
DBusAddressTranslator::getInstance().searchForDBusAddress(
commonApiServiceName,
dbusInterfaceName,
dbusConnectionName,
dbusObjectPath);
const AvailabilityStatus availabilityStatus =
!registry_->isServiceInstanceAlive(dbusInterfaceName, dbusConnectionName, dbusObjectPath) ? AvailabilityStatus::NOT_AVAILABLE :
AvailabilityStatus::AVAILABLE;
notifyListeners(commonApiServiceName, availabilityStatus);
}
}
} // namespace DBus
} // namespace CommonAPI
|
