114 lines
2.8 KiB
C++
114 lines
2.8 KiB
C++
/* -*- Mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; tab-width: 40 -*- */
|
|
/* 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 "RawDBusConnection.h"
|
|
#include "base/message_loop.h"
|
|
#include "mozilla/ipc/DBusHelpers.h"
|
|
#include "mozilla/ipc/DBusWatcher.h"
|
|
|
|
namespace mozilla {
|
|
namespace ipc {
|
|
|
|
//
|
|
// RawDBusConnection
|
|
//
|
|
|
|
bool RawDBusConnection::sDBusIsInit(false);
|
|
|
|
RawDBusConnection::RawDBusConnection()
|
|
{
|
|
}
|
|
|
|
RawDBusConnection::~RawDBusConnection()
|
|
{
|
|
}
|
|
|
|
nsresult RawDBusConnection::EstablishDBusConnection()
|
|
{
|
|
if (!sDBusIsInit) {
|
|
dbus_bool_t success = dbus_threads_init_default();
|
|
NS_ENSURE_TRUE(success == TRUE, NS_ERROR_FAILURE);
|
|
sDBusIsInit = true;
|
|
}
|
|
|
|
DBusError err;
|
|
dbus_error_init(&err);
|
|
|
|
mConnection = already_AddRefed<DBusConnection>(
|
|
dbus_bus_get_private(DBUS_BUS_SYSTEM, &err));
|
|
|
|
if (dbus_error_is_set(&err)) {
|
|
dbus_error_free(&err);
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
dbus_connection_set_exit_on_disconnect(mConnection, FALSE);
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
bool RawDBusConnection::Watch()
|
|
{
|
|
MOZ_ASSERT(MessageLoop::current());
|
|
|
|
return NS_SUCCEEDED(DBusWatchConnection(mConnection));
|
|
}
|
|
|
|
bool RawDBusConnection::Send(DBusMessage* aMessage)
|
|
{
|
|
MOZ_ASSERT(MessageLoop::current());
|
|
|
|
auto rv = DBusSendMessage(mConnection, aMessage);
|
|
|
|
if (NS_FAILED(rv)) {
|
|
dbus_message_unref(aMessage);
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
bool RawDBusConnection::SendWithReply(DBusReplyCallback aCallback,
|
|
void* aData,
|
|
int aTimeout,
|
|
DBusMessage* aMessage)
|
|
{
|
|
MOZ_ASSERT(MessageLoop::current());
|
|
|
|
auto rv = DBusSendMessageWithReply(mConnection, aCallback, aData, aTimeout,
|
|
aMessage);
|
|
if (NS_FAILED(rv)) {
|
|
return false;
|
|
}
|
|
|
|
dbus_message_unref(aMessage);
|
|
|
|
return true;
|
|
}
|
|
|
|
bool RawDBusConnection::SendWithReply(DBusReplyCallback aCallback,
|
|
void* aData,
|
|
int aTimeout,
|
|
const char* aDestination,
|
|
const char* aPath,
|
|
const char* aIntf,
|
|
const char* aFunc,
|
|
int aFirstArgType,
|
|
...)
|
|
{
|
|
va_list args;
|
|
va_start(args, aFirstArgType);
|
|
|
|
auto rv = DBusSendMessageWithReply(mConnection, aCallback, aData,
|
|
aTimeout, aDestination, aPath, aIntf,
|
|
aFunc, aFirstArgType, args);
|
|
va_end(args);
|
|
|
|
return NS_SUCCEEDED(rv);
|
|
}
|
|
|
|
}
|
|
}
|