1 /* Copyright (C) 2013 BMW Group
2 * Author: Manfred Bathelt (manfred.bathelt@bmw.de)
3 * Author: Juergen Gehring (juergen.gehring@bmw.de)
4 * This Source Code Form is subject to the terms of the Mozilla Public
5 * License, v. 2.0. If a copy of the MPL was not distributed with this
6 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
7 // Workaround for libstdc++ bug
8 #ifndef _GLIBCXX_USE_NANOSLEEP
9 #define _GLIBCXX_USE_NANOSLEEP
12 #include "DBusProxy.h"
13 #include "DBusUtils.h"
21 DBusProxyStatusEvent::DBusProxyStatusEvent(DBusProxy* dbusProxy) :
22 dbusProxy_(dbusProxy) {
25 void DBusProxyStatusEvent::onListenerAdded(const CancellableListener& listener) {
26 if (dbusProxy_->isAvailable())
27 listener(AvailabilityStatus::AVAILABLE);
31 DBusProxy::DBusProxy(const std::string& commonApiAddress,
32 const std::string& dbusInterfaceName,
33 const std::string& dbusBusName,
34 const std::string& dbusObjectPath,
35 const std::shared_ptr<DBusProxyConnection>& dbusConnection):
36 DBusProxyBase(split(commonApiAddress, ':')[1],
37 split(commonApiAddress, ':')[2],
42 dbusProxyStatusEvent_(this),
43 availabilityStatus_(AvailabilityStatus::UNKNOWN),
44 interfaceVersionAttribute_(*this, "getInterfaceVersion"),
45 dbusServiceRegistry_(dbusConnection->getDBusServiceRegistry()) {
47 const std::string commonApiDomain = split(commonApiAddress, ':')[0];
48 assert(commonApiDomain == "local");
50 dbusServiceRegistrySubscription_ = dbusServiceRegistry_->subscribeAvailabilityListener(
52 std::bind(&DBusProxy::onDBusServiceInstanceStatus, this, std::placeholders::_1));
55 DBusProxy::~DBusProxy() {
56 dbusServiceRegistry_->unsubscribeAvailabilityListener(
58 dbusServiceRegistrySubscription_);
61 bool DBusProxy::isAvailable() const {
62 return (availabilityStatus_ == AvailabilityStatus::AVAILABLE);
65 bool DBusProxy::isAvailableBlocking() const {
66 if (availabilityStatus_ == AvailabilityStatus::UNKNOWN) {
67 std::chrono::milliseconds singleWaitDuration(2);
69 // Wait for the service registry
70 while (availabilityStatus_ == AvailabilityStatus::UNKNOWN) {
71 std::this_thread::sleep_for(singleWaitDuration);
78 ProxyStatusEvent& DBusProxy::getProxyStatusEvent() {
79 return dbusProxyStatusEvent_;
82 InterfaceVersionAttribute& DBusProxy::getInterfaceVersionAttribute() {
83 return interfaceVersionAttribute_;
86 void DBusProxy::onDBusServiceInstanceStatus(const AvailabilityStatus& availabilityStatus) {
87 availabilityStatus_ = availabilityStatus;
88 dbusProxyStatusEvent_.notifyListeners(availabilityStatus);
92 } // namespace CommonAPI