mirror of
https://gitlab.winehq.org/wine/wine-gecko.git
synced 2024-09-13 09:24:08 -07:00
1ef970d776
The method is unused and obsolete. --HG-- extra : rebase_source : 5604d428a3d91452b84224c2033126f1a2c32927
3198 lines
100 KiB
C++
3198 lines
100 KiB
C++
/* -*- Mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; tab-width: 40 -*- */
|
|
/* vim: set ts=2 et sw=2 tw=80: */
|
|
/*
|
|
** Copyright 2006, The Android Open Source Project
|
|
**
|
|
** Licensed under the Apache License, Version 2.0 (the "License");
|
|
** you may not use this file except in compliance with the License.
|
|
** You may obtain a copy of the License at
|
|
**
|
|
** http://www.apache.org/licenses/LICENSE-2.0
|
|
**
|
|
** Unless required by applicable law or agreed to in writing, software
|
|
** distributed under the License is distributed on an "AS IS" BASIS,
|
|
** WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
** See the License for the specific language governing permissions and
|
|
** limitations under the License.
|
|
*/
|
|
|
|
#include "base/basictypes.h"
|
|
#include "BluetoothDBusService.h"
|
|
#include "BluetoothA2dpManager.h"
|
|
#include "BluetoothHfpManager.h"
|
|
#include "BluetoothHidManager.h"
|
|
#include "BluetoothOppManager.h"
|
|
#include "BluetoothProfileController.h"
|
|
#include "BluetoothReplyRunnable.h"
|
|
#include "BluetoothUnixSocketConnector.h"
|
|
#include "BluetoothUtils.h"
|
|
#include "BluetoothUuid.h"
|
|
|
|
#include <cstdio>
|
|
#include <dbus/dbus.h>
|
|
|
|
#include "nsAutoPtr.h"
|
|
#include "nsThreadUtils.h"
|
|
#include "nsDebug.h"
|
|
#include "nsDataHashtable.h"
|
|
#include "mozilla/Atomics.h"
|
|
#include "mozilla/dom/bluetooth/BluetoothTypes.h"
|
|
#include "mozilla/Hal.h"
|
|
#include "mozilla/ipc/UnixSocket.h"
|
|
#include "mozilla/ipc/DBusThread.h"
|
|
#include "mozilla/ipc/DBusUtils.h"
|
|
#include "mozilla/ipc/RawDBusConnection.h"
|
|
#include "mozilla/Mutex.h"
|
|
#include "mozilla/NullPtr.h"
|
|
#include "mozilla/StaticMutex.h"
|
|
#include "mozilla/Util.h"
|
|
#if defined(MOZ_WIDGET_GONK)
|
|
#include "cutils/properties.h"
|
|
#endif
|
|
|
|
/**
|
|
* Some rules for dealing with memory in DBus:
|
|
* - A DBusError only needs to be deleted if it's been set, not just
|
|
* initialized. This is why LOG_AND_FREE... is called only when an error is
|
|
* set, and the macro cleans up the error itself.
|
|
* - A DBusMessage needs to be unrefed when it is newed explicitly. DBusMessages
|
|
* from signals do not need to be unrefed, as they will be cleaned by DBus
|
|
* after DBUS_HANDLER_RESULT_HANDLED is returned from the filter.
|
|
*/
|
|
|
|
using namespace mozilla;
|
|
using namespace mozilla::ipc;
|
|
USING_BLUETOOTH_NAMESPACE
|
|
|
|
#define B2G_AGENT_CAPABILITIES "DisplayYesNo"
|
|
#define DBUS_MANAGER_IFACE BLUEZ_DBUS_BASE_IFC ".Manager"
|
|
#define DBUS_ADAPTER_IFACE BLUEZ_DBUS_BASE_IFC ".Adapter"
|
|
#define DBUS_DEVICE_IFACE BLUEZ_DBUS_BASE_IFC ".Device"
|
|
#define DBUS_AGENT_IFACE BLUEZ_DBUS_BASE_IFC ".Agent"
|
|
#define DBUS_SINK_IFACE BLUEZ_DBUS_BASE_IFC ".AudioSink"
|
|
#define DBUS_CTL_IFACE BLUEZ_DBUS_BASE_IFC ".Control"
|
|
#define DBUS_INPUT_IFACE BLUEZ_DBUS_BASE_IFC ".Input"
|
|
#define BLUEZ_DBUS_BASE_PATH "/org/bluez"
|
|
#define BLUEZ_DBUS_BASE_IFC "org.bluez"
|
|
#define BLUEZ_ERROR_IFC "org.bluez.Error"
|
|
|
|
#define ERR_A2DP_IS_DISCONNECTED "A2dpIsDisconnected"
|
|
#define ERR_AVRCP_IS_DISCONNECTED "AvrcpIsDisconnected"
|
|
|
|
/**
|
|
* To not lock Bluetooth switch button on Settings UI because of any accident,
|
|
* we will force disabling Bluetooth 5 seconds after the user requesting to
|
|
* turn off Bluetooth.
|
|
*/
|
|
#define TIMEOUT_FORCE_TO_DISABLE_BT 5
|
|
|
|
typedef struct {
|
|
const char* name;
|
|
int type;
|
|
} Properties;
|
|
|
|
static Properties sDeviceProperties[] = {
|
|
{"Address", DBUS_TYPE_STRING},
|
|
{"Name", DBUS_TYPE_STRING},
|
|
{"Icon", DBUS_TYPE_STRING},
|
|
{"Class", DBUS_TYPE_UINT32},
|
|
{"UUIDs", DBUS_TYPE_ARRAY},
|
|
{"Paired", DBUS_TYPE_BOOLEAN},
|
|
{"Connected", DBUS_TYPE_BOOLEAN},
|
|
{"Trusted", DBUS_TYPE_BOOLEAN},
|
|
{"Blocked", DBUS_TYPE_BOOLEAN},
|
|
{"Alias", DBUS_TYPE_STRING},
|
|
{"Nodes", DBUS_TYPE_ARRAY},
|
|
{"Adapter", DBUS_TYPE_OBJECT_PATH},
|
|
{"LegacyPairing", DBUS_TYPE_BOOLEAN},
|
|
{"RSSI", DBUS_TYPE_INT16},
|
|
{"TX", DBUS_TYPE_UINT32},
|
|
{"Type", DBUS_TYPE_STRING},
|
|
{"Broadcaster", DBUS_TYPE_BOOLEAN},
|
|
{"Services", DBUS_TYPE_ARRAY}
|
|
};
|
|
|
|
static Properties sAdapterProperties[] = {
|
|
{"Address", DBUS_TYPE_STRING},
|
|
{"Name", DBUS_TYPE_STRING},
|
|
{"Class", DBUS_TYPE_UINT32},
|
|
{"Powered", DBUS_TYPE_BOOLEAN},
|
|
{"Discoverable", DBUS_TYPE_BOOLEAN},
|
|
{"DiscoverableTimeout", DBUS_TYPE_UINT32},
|
|
{"Pairable", DBUS_TYPE_BOOLEAN},
|
|
{"PairableTimeout", DBUS_TYPE_UINT32},
|
|
{"Discovering", DBUS_TYPE_BOOLEAN},
|
|
{"Devices", DBUS_TYPE_ARRAY},
|
|
{"UUIDs", DBUS_TYPE_ARRAY},
|
|
{"Type", DBUS_TYPE_STRING}
|
|
};
|
|
|
|
static Properties sManagerProperties[] = {
|
|
{"Adapters", DBUS_TYPE_ARRAY},
|
|
};
|
|
|
|
static Properties sSinkProperties[] = {
|
|
{"State", DBUS_TYPE_STRING},
|
|
{"Connected", DBUS_TYPE_BOOLEAN},
|
|
{"Playing", DBUS_TYPE_BOOLEAN}
|
|
};
|
|
|
|
static Properties sControlProperties[] = {
|
|
{"Connected", DBUS_TYPE_BOOLEAN}
|
|
};
|
|
|
|
static Properties sInputProperties[] = {
|
|
{"Connected", DBUS_TYPE_BOOLEAN}
|
|
};
|
|
|
|
static const char* sBluetoothDBusIfaces[] =
|
|
{
|
|
DBUS_MANAGER_IFACE,
|
|
DBUS_ADAPTER_IFACE,
|
|
DBUS_DEVICE_IFACE
|
|
};
|
|
|
|
static const char* sBluetoothDBusSignals[] =
|
|
{
|
|
"type='signal',interface='org.freedesktop.DBus'",
|
|
"type='signal',interface='org.bluez.Adapter'",
|
|
"type='signal',interface='org.bluez.Manager'",
|
|
"type='signal',interface='org.bluez.Device'",
|
|
"type='signal',interface='org.bluez.Input'",
|
|
"type='signal',interface='org.bluez.Network'",
|
|
"type='signal',interface='org.bluez.NetworkServer'",
|
|
"type='signal',interface='org.bluez.HealthDevice'",
|
|
"type='signal',interface='org.bluez.AudioSink'",
|
|
"type='signal',interface='org.bluez.Control'"
|
|
};
|
|
|
|
/**
|
|
* DBus Connection held for the BluetoothCommandThread to use. Should never be
|
|
* used by any other thread.
|
|
*/
|
|
static nsRefPtr<RawDBusConnection> gThreadConnection;
|
|
static nsDataHashtable<nsStringHashKey, DBusMessage* >* sPairingReqTable;
|
|
static nsTArray<uint32_t> sAuthorizedServiceClass;
|
|
static nsString sAdapterPath;
|
|
static Atomic<int32_t> sIsPairing(0);
|
|
static int sConnectedDeviceCount = 0;
|
|
static StaticAutoPtr<Monitor> sStopBluetoothMonitor;
|
|
StaticRefPtr<BluetoothProfileController> sController;
|
|
|
|
typedef void (*UnpackFunc)(DBusMessage*, DBusError*, BluetoothValue&, nsAString&);
|
|
typedef bool (*FilterFunc)(const BluetoothValue&);
|
|
|
|
BluetoothDBusService::BluetoothDBusService()
|
|
{
|
|
sStopBluetoothMonitor = new Monitor("BluetoothService.sStopBluetoothMonitor");
|
|
}
|
|
|
|
BluetoothDBusService::~BluetoothDBusService()
|
|
{
|
|
sStopBluetoothMonitor = nullptr;
|
|
}
|
|
|
|
static bool
|
|
GetConnectedDevicesFilter(const BluetoothValue& aValue)
|
|
{
|
|
// We don't have to filter device here
|
|
return true;
|
|
}
|
|
|
|
static bool
|
|
GetPairedDevicesFilter(const BluetoothValue& aValue)
|
|
{
|
|
// Check property 'Paired' and only paired device will be returned
|
|
if (aValue.type() != BluetoothValue::TArrayOfBluetoothNamedValue) {
|
|
BT_WARNING("Not a BluetoothNamedValue array!");
|
|
return false;
|
|
}
|
|
|
|
const InfallibleTArray<BluetoothNamedValue>& deviceProperties =
|
|
aValue.get_ArrayOfBluetoothNamedValue();
|
|
uint32_t length = deviceProperties.Length();
|
|
for (uint32_t p = 0; p < length; ++p) {
|
|
if (deviceProperties[p].name().EqualsLiteral("Paired")) {
|
|
return deviceProperties[p].value().get_bool();
|
|
}
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
class DistributeBluetoothSignalTask : public nsRunnable
|
|
{
|
|
public:
|
|
DistributeBluetoothSignalTask(const BluetoothSignal& aSignal)
|
|
: mSignal(aSignal)
|
|
{
|
|
}
|
|
|
|
nsresult Run()
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
BluetoothService* bs = BluetoothService::Get();
|
|
NS_ENSURE_TRUE(bs, NS_ERROR_FAILURE);
|
|
bs->DistributeSignal(mSignal);
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
private:
|
|
BluetoothSignal mSignal;
|
|
};
|
|
|
|
class ControlPropertyChangedHandler : public nsRunnable
|
|
{
|
|
public:
|
|
ControlPropertyChangedHandler(const BluetoothSignal& aSignal)
|
|
: mSignal(aSignal)
|
|
{
|
|
}
|
|
|
|
nsresult Run()
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
if (mSignal.value().type() != BluetoothValue::TArrayOfBluetoothNamedValue) {
|
|
BT_WARNING("Wrong value type for ControlPropertyChangedHandler");
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
InfallibleTArray<BluetoothNamedValue>& arr =
|
|
mSignal.value().get_ArrayOfBluetoothNamedValue();
|
|
MOZ_ASSERT(arr[0].name().EqualsLiteral("Connected"));
|
|
MOZ_ASSERT(arr[0].value().type() == BluetoothValue::Tbool);
|
|
bool connected = arr[0].value().get_bool();
|
|
|
|
BluetoothA2dpManager* a2dp = BluetoothA2dpManager::Get();
|
|
NS_ENSURE_TRUE(a2dp, NS_ERROR_FAILURE);
|
|
a2dp->SetAvrcpConnected(connected);
|
|
return NS_OK;
|
|
}
|
|
|
|
private:
|
|
BluetoothSignal mSignal;
|
|
};
|
|
|
|
class SinkPropertyChangedHandler : public nsRunnable
|
|
{
|
|
public:
|
|
SinkPropertyChangedHandler(const BluetoothSignal& aSignal)
|
|
: mSignal(aSignal)
|
|
{
|
|
}
|
|
|
|
NS_IMETHOD
|
|
Run()
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
MOZ_ASSERT(mSignal.name().EqualsLiteral("PropertyChanged"));
|
|
MOZ_ASSERT(mSignal.value().type() ==
|
|
BluetoothValue::TArrayOfBluetoothNamedValue);
|
|
|
|
// Replace object path with device address
|
|
nsString address = GetAddressFromObjectPath(mSignal.path());
|
|
mSignal.path() = address;
|
|
|
|
BluetoothA2dpManager* a2dp = BluetoothA2dpManager::Get();
|
|
NS_ENSURE_TRUE(a2dp, NS_ERROR_FAILURE);
|
|
a2dp->HandleSinkPropertyChanged(mSignal);
|
|
return NS_OK;
|
|
}
|
|
|
|
private:
|
|
BluetoothSignal mSignal;
|
|
};
|
|
|
|
class InputPropertyChangedHandler : public nsRunnable
|
|
{
|
|
public:
|
|
InputPropertyChangedHandler(const BluetoothSignal& aSignal)
|
|
: mSignal(aSignal)
|
|
{
|
|
}
|
|
|
|
NS_IMETHOD
|
|
Run()
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
MOZ_ASSERT(mSignal.name().EqualsLiteral("PropertyChanged"));
|
|
MOZ_ASSERT(mSignal.value().type() == BluetoothValue::TArrayOfBluetoothNamedValue);
|
|
|
|
// Replace object path with device address
|
|
nsString address = GetAddressFromObjectPath(mSignal.path());
|
|
mSignal.path() = address;
|
|
|
|
BluetoothHidManager* hid = BluetoothHidManager::Get();
|
|
NS_ENSURE_TRUE(hid, NS_ERROR_FAILURE);
|
|
hid->HandleInputPropertyChanged(mSignal);
|
|
return NS_OK;
|
|
}
|
|
|
|
private:
|
|
BluetoothSignal mSignal;
|
|
};
|
|
|
|
static bool
|
|
IsDBusMessageError(DBusMessage* aMsg, DBusError* aErr, nsAString& aErrorStr)
|
|
{
|
|
if (aErr && dbus_error_is_set(aErr)) {
|
|
aErrorStr = NS_ConvertUTF8toUTF16(aErr->message);
|
|
LOG_AND_FREE_DBUS_ERROR(aErr);
|
|
return true;
|
|
}
|
|
|
|
DBusError err;
|
|
dbus_error_init(&err);
|
|
if (dbus_message_get_type(aMsg) == DBUS_MESSAGE_TYPE_ERROR) {
|
|
const char* error_msg;
|
|
if (!dbus_message_get_args(aMsg, &err, DBUS_TYPE_STRING,
|
|
&error_msg, DBUS_TYPE_INVALID) ||
|
|
!error_msg) {
|
|
if (dbus_error_is_set(&err)) {
|
|
aErrorStr = NS_ConvertUTF8toUTF16(err.message);
|
|
LOG_AND_FREE_DBUS_ERROR(&err);
|
|
return true;
|
|
} else {
|
|
aErrorStr.AssignLiteral("Unknown Error");
|
|
return true;
|
|
}
|
|
} else {
|
|
aErrorStr = NS_ConvertUTF8toUTF16(error_msg);
|
|
return true;
|
|
}
|
|
}
|
|
return false;
|
|
}
|
|
|
|
static void
|
|
UnpackObjectPathMessage(DBusMessage* aMsg, DBusError* aErr,
|
|
BluetoothValue& aValue, nsAString& aErrorStr)
|
|
{
|
|
DBusError err;
|
|
dbus_error_init(&err);
|
|
if (!IsDBusMessageError(aMsg, aErr, aErrorStr)) {
|
|
MOZ_ASSERT(dbus_message_get_type(aMsg) == DBUS_MESSAGE_TYPE_METHOD_RETURN,
|
|
"Got dbus callback that's not a METHOD_RETURN!");
|
|
const char* object_path;
|
|
if (!dbus_message_get_args(aMsg, &err, DBUS_TYPE_OBJECT_PATH,
|
|
&object_path, DBUS_TYPE_INVALID) ||
|
|
!object_path) {
|
|
if (dbus_error_is_set(&err)) {
|
|
aErrorStr = NS_ConvertUTF8toUTF16(err.message);
|
|
LOG_AND_FREE_DBUS_ERROR(&err);
|
|
}
|
|
} else {
|
|
aValue = NS_ConvertUTF8toUTF16(object_path);
|
|
}
|
|
}
|
|
}
|
|
|
|
class PrepareProfileManagersRunnable : public nsRunnable
|
|
{
|
|
public:
|
|
nsresult Run()
|
|
{
|
|
BluetoothHfpManager* hfp = BluetoothHfpManager::Get();
|
|
if (!hfp || !hfp->Listen()) {
|
|
BT_WARNING("Failed to start listening for BluetoothHfpManager!");
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
BluetoothOppManager* opp = BluetoothOppManager::Get();
|
|
if (!opp || !opp->Listen()) {
|
|
BT_WARNING("Failed to start listening for BluetoothOppManager!");
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
BluetoothA2dpManager* a2dp = BluetoothA2dpManager::Get();
|
|
NS_ENSURE_TRUE(a2dp, NS_ERROR_FAILURE);
|
|
a2dp->ResetA2dp();
|
|
a2dp->ResetAvrcp();
|
|
|
|
return NS_OK;
|
|
}
|
|
};
|
|
|
|
static void
|
|
RunDBusCallback(DBusMessage* aMsg, void* aBluetoothReplyRunnable,
|
|
UnpackFunc aFunc)
|
|
{
|
|
#ifdef MOZ_WIDGET_GONK
|
|
// Due to the fact that we're running two dbus loops on desktop implicitly by
|
|
// being gtk based, sometimes we'll get signals/reply coming in on the main
|
|
// thread. There's not a lot we can do about that for the time being and it
|
|
// (technically) shouldn't hurt anything. However, on gonk, die.
|
|
MOZ_ASSERT(!NS_IsMainThread());
|
|
#endif
|
|
nsRefPtr<BluetoothReplyRunnable> replyRunnable =
|
|
dont_AddRef(static_cast< BluetoothReplyRunnable* >(aBluetoothReplyRunnable));
|
|
|
|
MOZ_ASSERT(replyRunnable, "Callback reply runnable is null!");
|
|
|
|
nsAutoString replyError;
|
|
BluetoothValue v;
|
|
aFunc(aMsg, nullptr, v, replyError);
|
|
DispatchBluetoothReply(replyRunnable, v, replyError);
|
|
}
|
|
|
|
static void
|
|
GetObjectPathCallback(DBusMessage* aMsg, void* aBluetoothReplyRunnable)
|
|
{
|
|
if (sIsPairing) {
|
|
RunDBusCallback(aMsg, aBluetoothReplyRunnable,
|
|
UnpackObjectPathMessage);
|
|
sIsPairing--;
|
|
}
|
|
}
|
|
|
|
static void
|
|
UnpackVoidMessage(DBusMessage* aMsg, DBusError* aErr, BluetoothValue& aValue,
|
|
nsAString& aErrorStr)
|
|
{
|
|
DBusError err;
|
|
dbus_error_init(&err);
|
|
if (!IsDBusMessageError(aMsg, aErr, aErrorStr) &&
|
|
dbus_message_get_type(aMsg) == DBUS_MESSAGE_TYPE_METHOD_RETURN &&
|
|
!dbus_message_get_args(aMsg, &err, DBUS_TYPE_INVALID)) {
|
|
if (dbus_error_is_set(&err)) {
|
|
aErrorStr = NS_ConvertUTF8toUTF16(err.message);
|
|
LOG_AND_FREE_DBUS_ERROR(&err);
|
|
}
|
|
}
|
|
aValue = aErrorStr.IsEmpty();
|
|
}
|
|
|
|
static void
|
|
GetVoidCallback(DBusMessage* aMsg, void* aBluetoothReplyRunnable)
|
|
{
|
|
RunDBusCallback(aMsg, aBluetoothReplyRunnable,
|
|
UnpackVoidMessage);
|
|
}
|
|
|
|
class ReplyErrorToProfileManager : public nsRunnable
|
|
{
|
|
public:
|
|
ReplyErrorToProfileManager(BluetoothServiceClass aServiceClass,
|
|
bool aConnect,
|
|
const nsAString& aErrorString)
|
|
: mServiceClass(aServiceClass)
|
|
, mConnect(aConnect)
|
|
, mErrorString(aErrorString)
|
|
{
|
|
MOZ_ASSERT(!NS_IsMainThread());
|
|
}
|
|
|
|
nsresult Run()
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
BluetoothProfileManagerBase* profile;
|
|
if (mServiceClass == BluetoothServiceClass::HID) {
|
|
profile = BluetoothHidManager::Get();
|
|
} else if (mServiceClass == BluetoothServiceClass::A2DP) {
|
|
profile = BluetoothA2dpManager::Get();
|
|
} else {
|
|
MOZ_ASSERT(false);
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
if (mConnect) {
|
|
profile->OnConnect(mErrorString);
|
|
} else {
|
|
profile->OnDisconnect(mErrorString);
|
|
}
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
private:
|
|
BluetoothServiceClass mServiceClass;
|
|
bool mConnect;
|
|
nsString mErrorString;
|
|
};
|
|
|
|
static void
|
|
CheckDBusReply(DBusMessage* aMsg, void* aServiceClass, bool aConnect)
|
|
{
|
|
MOZ_ASSERT(!NS_IsMainThread());
|
|
|
|
NS_ENSURE_TRUE_VOID(aMsg);
|
|
|
|
BluetoothValue v;
|
|
nsAutoString replyError;
|
|
UnpackVoidMessage(aMsg, nullptr, v, replyError);
|
|
|
|
nsAutoPtr<BluetoothServiceClass> serviceClass(
|
|
static_cast<BluetoothServiceClass*>(aServiceClass));
|
|
|
|
if (!replyError.IsEmpty()) {
|
|
NS_DispatchToMainThread(
|
|
new ReplyErrorToProfileManager(*serviceClass, aConnect, replyError));
|
|
}
|
|
}
|
|
|
|
static void
|
|
InputConnectCallback(DBusMessage* aMsg, void* aParam)
|
|
{
|
|
CheckDBusReply(aMsg, aParam, true);
|
|
}
|
|
|
|
static void
|
|
InputDisconnectCallback(DBusMessage* aMsg, void* aParam)
|
|
{
|
|
CheckDBusReply(aMsg, aParam, false);
|
|
}
|
|
|
|
static void
|
|
SinkConnectCallback(DBusMessage* aMsg, void* aParam)
|
|
{
|
|
CheckDBusReply(aMsg, aParam, true);
|
|
}
|
|
|
|
static void
|
|
SinkDisconnectCallback(DBusMessage* aMsg, void* aParam)
|
|
{
|
|
CheckDBusReply(aMsg, aParam, false);
|
|
}
|
|
|
|
static bool
|
|
HasAudioService(uint32_t aCodValue)
|
|
{
|
|
return ((aCodValue & 0x200000) == 0x200000);
|
|
}
|
|
|
|
static bool
|
|
ContainsIcon(const InfallibleTArray<BluetoothNamedValue>& aProperties)
|
|
{
|
|
for (uint8_t i = 0; i < aProperties.Length(); i++) {
|
|
if (aProperties[i].name().EqualsLiteral("Icon")) {
|
|
return true;
|
|
}
|
|
}
|
|
return false;
|
|
}
|
|
|
|
static bool
|
|
GetProperty(DBusMessageIter aIter, Properties* aPropertyTypes,
|
|
int aPropertyTypeLen, int* aPropIndex,
|
|
InfallibleTArray<BluetoothNamedValue>& aProperties)
|
|
{
|
|
DBusMessageIter prop_val, array_val_iter;
|
|
char* property = NULL;
|
|
uint32_t array_type;
|
|
int i, expectedType, receivedType;
|
|
|
|
if (dbus_message_iter_get_arg_type(&aIter) != DBUS_TYPE_STRING) {
|
|
return false;
|
|
}
|
|
|
|
dbus_message_iter_get_basic(&aIter, &property);
|
|
|
|
if (!dbus_message_iter_next(&aIter) ||
|
|
dbus_message_iter_get_arg_type(&aIter) != DBUS_TYPE_VARIANT) {
|
|
return false;
|
|
}
|
|
|
|
for (i = 0; i < aPropertyTypeLen; i++) {
|
|
if (!strncmp(property, aPropertyTypes[i].name, strlen(property))) {
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (i == aPropertyTypeLen) {
|
|
return false;
|
|
}
|
|
|
|
nsAutoString propertyName;
|
|
propertyName.AssignASCII(aPropertyTypes[i].name);
|
|
*aPropIndex = i;
|
|
|
|
dbus_message_iter_recurse(&aIter, &prop_val);
|
|
expectedType = aPropertyTypes[*aPropIndex].type;
|
|
receivedType = dbus_message_iter_get_arg_type(&prop_val);
|
|
|
|
/**
|
|
* Bug 857896. Since device property "Connected" could be a boolean value or
|
|
* an 2-byte array, we need to check the value type here and convert the
|
|
* first byte into a boolean manually.
|
|
*/
|
|
bool convert = false;
|
|
if (propertyName.EqualsLiteral("Connected") &&
|
|
receivedType == DBUS_TYPE_ARRAY) {
|
|
convert = true;
|
|
}
|
|
|
|
if ((receivedType != expectedType) && !convert) {
|
|
BT_WARNING("Iterator not type we expect! Property name: %s,"
|
|
"Property Type Expected: %d, Property Type Received: %d",
|
|
NS_ConvertUTF16toUTF8(propertyName).get(), expectedType, receivedType);
|
|
return false;
|
|
}
|
|
|
|
BluetoothValue propertyValue;
|
|
switch (receivedType) {
|
|
case DBUS_TYPE_STRING:
|
|
case DBUS_TYPE_OBJECT_PATH:
|
|
const char* c;
|
|
dbus_message_iter_get_basic(&prop_val, &c);
|
|
propertyValue = NS_ConvertUTF8toUTF16(c);
|
|
break;
|
|
case DBUS_TYPE_UINT32:
|
|
case DBUS_TYPE_INT16:
|
|
uint32_t i;
|
|
dbus_message_iter_get_basic(&prop_val, &i);
|
|
propertyValue = i;
|
|
break;
|
|
case DBUS_TYPE_BOOLEAN:
|
|
bool b;
|
|
dbus_message_iter_get_basic(&prop_val, &b);
|
|
propertyValue = b;
|
|
break;
|
|
case DBUS_TYPE_ARRAY:
|
|
dbus_message_iter_recurse(&prop_val, &array_val_iter);
|
|
array_type = dbus_message_iter_get_arg_type(&array_val_iter);
|
|
if (array_type == DBUS_TYPE_OBJECT_PATH ||
|
|
array_type == DBUS_TYPE_STRING) {
|
|
InfallibleTArray<nsString> arr;
|
|
do {
|
|
const char* tmp;
|
|
dbus_message_iter_get_basic(&array_val_iter, &tmp);
|
|
nsAutoString s;
|
|
s = NS_ConvertUTF8toUTF16(tmp);
|
|
arr.AppendElement(s);
|
|
} while (dbus_message_iter_next(&array_val_iter));
|
|
propertyValue = arr;
|
|
} else if (array_type == DBUS_TYPE_BYTE) {
|
|
InfallibleTArray<uint8_t> arr;
|
|
do {
|
|
uint8_t tmp;
|
|
dbus_message_iter_get_basic(&array_val_iter, &tmp);
|
|
arr.AppendElement(tmp);
|
|
} while (dbus_message_iter_next(&array_val_iter));
|
|
propertyValue = arr;
|
|
} else {
|
|
// This happens when the array is 0-length. Apparently we get a
|
|
// DBUS_TYPE_INVALID type.
|
|
propertyValue = InfallibleTArray<nsString>();
|
|
}
|
|
break;
|
|
default:
|
|
NS_NOTREACHED("Cannot find dbus message type!");
|
|
}
|
|
|
|
if (convert) {
|
|
MOZ_ASSERT(propertyValue.type() == BluetoothValue::TArrayOfuint8_t);
|
|
|
|
bool b = propertyValue.get_ArrayOfuint8_t()[0];
|
|
propertyValue = BluetoothValue(b);
|
|
}
|
|
|
|
aProperties.AppendElement(BluetoothNamedValue(propertyName, propertyValue));
|
|
return true;
|
|
}
|
|
|
|
static void
|
|
ParseProperties(DBusMessageIter* aIter,
|
|
BluetoothValue& aValue,
|
|
nsAString& aErrorStr,
|
|
Properties* aPropertyTypes,
|
|
const int aPropertyTypeLen)
|
|
{
|
|
DBusMessageIter dict_entry, dict;
|
|
int prop_index = -1;
|
|
|
|
MOZ_ASSERT(dbus_message_iter_get_arg_type(aIter) == DBUS_TYPE_ARRAY,
|
|
"Trying to parse a property from sth. that's not an array");
|
|
|
|
dbus_message_iter_recurse(aIter, &dict);
|
|
InfallibleTArray<BluetoothNamedValue> props;
|
|
do {
|
|
MOZ_ASSERT(dbus_message_iter_get_arg_type(&dict) == DBUS_TYPE_DICT_ENTRY,
|
|
"Trying to parse a property from sth. that's not an dict!");
|
|
dbus_message_iter_recurse(&dict, &dict_entry);
|
|
|
|
if (!GetProperty(dict_entry, aPropertyTypes, aPropertyTypeLen, &prop_index,
|
|
props)) {
|
|
aErrorStr.AssignLiteral("Can't Create Property!");
|
|
BT_WARNING("Can't create property!");
|
|
return;
|
|
}
|
|
} while (dbus_message_iter_next(&dict));
|
|
|
|
aValue = props;
|
|
}
|
|
|
|
static bool
|
|
UnpackPropertiesMessage(DBusMessage* aMsg, DBusError* aErr,
|
|
BluetoothValue& aValue, const char* aIface)
|
|
{
|
|
MOZ_ASSERT(aMsg);
|
|
|
|
Properties* propertyTypes;
|
|
int propertyTypesLength;
|
|
|
|
nsAutoString errorStr;
|
|
if (IsDBusMessageError(aMsg, aErr, errorStr) ||
|
|
dbus_message_get_type(aMsg) != DBUS_MESSAGE_TYPE_METHOD_RETURN) {
|
|
BT_WARNING("dbus message has an error.");
|
|
return false;
|
|
}
|
|
|
|
DBusMessageIter iter;
|
|
if (!dbus_message_iter_init(aMsg, &iter)) {
|
|
BT_WARNING("Cannot create dbus message iter!");
|
|
return false;
|
|
}
|
|
|
|
if (!strcmp(aIface, DBUS_DEVICE_IFACE)) {
|
|
propertyTypes = sDeviceProperties;
|
|
propertyTypesLength = ArrayLength(sDeviceProperties);
|
|
} else if (!strcmp(aIface, DBUS_ADAPTER_IFACE)) {
|
|
propertyTypes = sAdapterProperties;
|
|
propertyTypesLength = ArrayLength(sAdapterProperties);
|
|
} else if (!strcmp(aIface, DBUS_MANAGER_IFACE)) {
|
|
propertyTypes = sManagerProperties;
|
|
propertyTypesLength = ArrayLength(sManagerProperties);
|
|
} else {
|
|
return false;
|
|
}
|
|
|
|
ParseProperties(&iter, aValue, errorStr, propertyTypes,
|
|
propertyTypesLength);
|
|
return true;
|
|
}
|
|
|
|
static void
|
|
ParsePropertyChange(DBusMessage* aMsg, BluetoothValue& aValue,
|
|
nsAString& aErrorStr, Properties* aPropertyTypes,
|
|
const int aPropertyTypeLen)
|
|
{
|
|
DBusMessageIter iter;
|
|
DBusError err;
|
|
int prop_index = -1;
|
|
InfallibleTArray<BluetoothNamedValue> props;
|
|
|
|
dbus_error_init(&err);
|
|
if (!dbus_message_iter_init(aMsg, &iter)) {
|
|
BT_WARNING("Can't create iterator!");
|
|
return;
|
|
}
|
|
|
|
if (!GetProperty(iter, aPropertyTypes, aPropertyTypeLen,
|
|
&prop_index, props)) {
|
|
BT_WARNING("Can't get property!");
|
|
aErrorStr.AssignLiteral("Can't get property!");
|
|
return;
|
|
}
|
|
aValue = props;
|
|
}
|
|
|
|
class AppendDeviceNameReplyHandler: public DBusReplyHandler
|
|
{
|
|
public:
|
|
AppendDeviceNameReplyHandler(const nsCString& aIface,
|
|
const nsString& aDevicePath,
|
|
const BluetoothSignal& aSignal)
|
|
: mIface(aIface)
|
|
, mDevicePath(aDevicePath)
|
|
, mSignal(aSignal)
|
|
{
|
|
MOZ_ASSERT(!mIface.IsEmpty());
|
|
MOZ_ASSERT(!mDevicePath.IsEmpty());
|
|
}
|
|
|
|
void Handle(DBusMessage* aReply) MOZ_OVERRIDE
|
|
{
|
|
MOZ_ASSERT(!NS_IsMainThread()); // DBus thread
|
|
|
|
if (!aReply || (dbus_message_get_type(aReply) == DBUS_MESSAGE_TYPE_ERROR)) {
|
|
return;
|
|
}
|
|
|
|
// Get device properties from result of GetProperties
|
|
|
|
DBusError err;
|
|
dbus_error_init(&err);
|
|
|
|
BluetoothValue deviceProperties;
|
|
|
|
bool success = UnpackPropertiesMessage(aReply, &err, deviceProperties,
|
|
mIface.get());
|
|
if (!success) {
|
|
BT_WARNING("Failed to get device properties");
|
|
return;
|
|
}
|
|
|
|
// First we replace object path with device address.
|
|
|
|
InfallibleTArray<BluetoothNamedValue>& parameters =
|
|
mSignal.value().get_ArrayOfBluetoothNamedValue();
|
|
nsString address =
|
|
GetAddressFromObjectPath(mDevicePath);
|
|
parameters[0].name().AssignLiteral("address");
|
|
parameters[0].value() = address;
|
|
|
|
// Then we append the device's name to the original signal's data.
|
|
|
|
InfallibleTArray<BluetoothNamedValue>& properties =
|
|
deviceProperties.get_ArrayOfBluetoothNamedValue();
|
|
InfallibleTArray<BluetoothNamedValue>::size_type i;
|
|
for (i = 0; i < properties.Length(); i++) {
|
|
if (properties[i].name().EqualsLiteral("Name")) {
|
|
properties[i].name().AssignLiteral("name");
|
|
parameters.AppendElement(properties[i]);
|
|
break;
|
|
}
|
|
}
|
|
MOZ_ASSERT_IF(i == properties.Length(), "failed to get device name");
|
|
|
|
nsRefPtr<DistributeBluetoothSignalTask> task =
|
|
new DistributeBluetoothSignalTask(mSignal);
|
|
NS_DispatchToMainThread(task);
|
|
}
|
|
|
|
private:
|
|
nsCString mIface;
|
|
nsString mDevicePath;
|
|
BluetoothSignal mSignal;
|
|
};
|
|
|
|
static void
|
|
AppendDeviceName(BluetoothSignal& aSignal)
|
|
{
|
|
BluetoothValue v = aSignal.value();
|
|
if (v.type() != BluetoothValue::TArrayOfBluetoothNamedValue ||
|
|
v.get_ArrayOfBluetoothNamedValue().Length() == 0) {
|
|
BT_WARNING("Invalid argument type for AppendDeviceNameRunnable");
|
|
return;
|
|
}
|
|
const InfallibleTArray<BluetoothNamedValue>& arr =
|
|
v.get_ArrayOfBluetoothNamedValue();
|
|
|
|
// Device object path should be put in the first element
|
|
if (!arr[0].name().EqualsLiteral("path") ||
|
|
arr[0].value().type() != BluetoothValue::TnsString) {
|
|
BT_WARNING("Invalid object path for AppendDeviceNameRunnable");
|
|
return;
|
|
}
|
|
|
|
nsString devicePath = arr[0].value().get_nsString();
|
|
|
|
nsRefPtr<RawDBusConnection> threadConnection = gThreadConnection;
|
|
|
|
if (!threadConnection.get()) {
|
|
BT_WARNING("%s: DBus connection has been closed.", __FUNCTION__);
|
|
return;
|
|
}
|
|
|
|
nsRefPtr<AppendDeviceNameReplyHandler> handler =
|
|
new AppendDeviceNameReplyHandler(nsCString(DBUS_DEVICE_IFACE),
|
|
devicePath, aSignal);
|
|
|
|
bool success = threadConnection->SendWithReply(
|
|
AppendDeviceNameReplyHandler::Callback, handler.get(), 1000,
|
|
NS_ConvertUTF16toUTF8(devicePath).get(), DBUS_DEVICE_IFACE,
|
|
"GetProperties", DBUS_TYPE_INVALID);
|
|
|
|
NS_ENSURE_TRUE_VOID(success);
|
|
|
|
handler.forget();
|
|
}
|
|
|
|
static DBusHandlerResult
|
|
AgentEventFilter(DBusConnection *conn, DBusMessage *msg, void *data)
|
|
{
|
|
if (dbus_message_get_type(msg) != DBUS_MESSAGE_TYPE_METHOD_CALL) {
|
|
BT_WARNING("%s: agent handler not interested (not a method call).\n",
|
|
__FUNCTION__);
|
|
return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
|
|
}
|
|
|
|
DBusError err;
|
|
dbus_error_init(&err);
|
|
|
|
BT_LOGD("%s: %s, %s", __FUNCTION__,
|
|
dbus_message_get_path(msg),
|
|
dbus_message_get_member(msg));
|
|
|
|
nsString signalPath = NS_ConvertUTF8toUTF16(dbus_message_get_path(msg));
|
|
nsString signalName = NS_ConvertUTF8toUTF16(dbus_message_get_member(msg));
|
|
nsString errorStr;
|
|
BluetoothValue v;
|
|
InfallibleTArray<BluetoothNamedValue> parameters;
|
|
bool isPairingReq = false;
|
|
BluetoothSignal signal(signalName, signalPath, v);
|
|
char *objectPath;
|
|
|
|
// The following descriptions of each signal are retrieved from:
|
|
//
|
|
// http://maemo.org/api_refs/5.0/beta/bluez/agent.html
|
|
//
|
|
if (dbus_message_is_method_call(msg, DBUS_AGENT_IFACE, "Cancel")) {
|
|
// This method gets called to indicate that the agent request failed before
|
|
// a reply was returned.
|
|
|
|
// Return directly
|
|
DBusMessage *reply = dbus_message_new_method_return(msg);
|
|
|
|
if (!reply) {
|
|
errorStr.AssignLiteral("Memory can't be allocated for the message.");
|
|
goto handle_error;
|
|
}
|
|
|
|
dbus_connection_send(conn, reply, NULL);
|
|
dbus_message_unref(reply);
|
|
v = parameters;
|
|
} else if (dbus_message_is_method_call(msg, DBUS_AGENT_IFACE, "Authorize")) {
|
|
// This method gets called when the service daemon needs to authorize a
|
|
// connection/service request.
|
|
const char *uuid;
|
|
if (!dbus_message_get_args(msg, NULL,
|
|
DBUS_TYPE_OBJECT_PATH, &objectPath,
|
|
DBUS_TYPE_STRING, &uuid,
|
|
DBUS_TYPE_INVALID)) {
|
|
errorStr.AssignLiteral("Invalid arguments for Authorize() method");
|
|
goto handle_error;
|
|
}
|
|
|
|
NS_ConvertUTF8toUTF16 uuidStr(uuid);
|
|
BluetoothServiceClass serviceClass =
|
|
BluetoothUuidHelper::GetBluetoothServiceClass(uuidStr);
|
|
if (serviceClass == BluetoothServiceClass::UNKNOWN) {
|
|
errorStr.AssignLiteral("Failed to get service class");
|
|
goto handle_error;
|
|
}
|
|
|
|
DBusMessage* reply = nullptr;
|
|
int i;
|
|
int length = sAuthorizedServiceClass.Length();
|
|
for (i = 0; i < length; i++) {
|
|
if (serviceClass == sAuthorizedServiceClass[i]) {
|
|
reply = dbus_message_new_method_return(msg);
|
|
break;
|
|
}
|
|
}
|
|
|
|
// The uuid isn't authorized
|
|
if (i == length) {
|
|
BT_WARNING("Uuid is not authorized.");
|
|
reply = dbus_message_new_error(msg, "org.bluez.Error.Rejected",
|
|
"The uuid is not authorized");
|
|
}
|
|
|
|
if (!reply) {
|
|
errorStr.AssignLiteral("Memory can't be allocated for the message.");
|
|
goto handle_error;
|
|
}
|
|
|
|
dbus_connection_send(conn, reply, NULL);
|
|
dbus_message_unref(reply);
|
|
return DBUS_HANDLER_RESULT_HANDLED;
|
|
} else if (dbus_message_is_method_call(msg, DBUS_AGENT_IFACE,
|
|
"RequestConfirmation")) {
|
|
// This method gets called when the service daemon needs to confirm a
|
|
// passkey for an authentication.
|
|
uint32_t passkey;
|
|
if (!dbus_message_get_args(msg, NULL,
|
|
DBUS_TYPE_OBJECT_PATH, &objectPath,
|
|
DBUS_TYPE_UINT32, &passkey,
|
|
DBUS_TYPE_INVALID)) {
|
|
errorStr.AssignLiteral("Invalid arguments: RequestConfirmation()");
|
|
goto handle_error;
|
|
}
|
|
|
|
parameters.AppendElement(
|
|
BluetoothNamedValue(NS_LITERAL_STRING("path"),
|
|
NS_ConvertUTF8toUTF16(objectPath)));
|
|
parameters.AppendElement(
|
|
BluetoothNamedValue(NS_LITERAL_STRING("method"),
|
|
NS_LITERAL_STRING("confirmation")));
|
|
parameters.AppendElement(
|
|
BluetoothNamedValue(NS_LITERAL_STRING("passkey"), passkey));
|
|
|
|
v = parameters;
|
|
isPairingReq = true;
|
|
} else if (dbus_message_is_method_call(msg, DBUS_AGENT_IFACE,
|
|
"RequestPinCode")) {
|
|
// This method gets called when the service daemon needs to get the passkey
|
|
// for an authentication. The return value should be a string of 1-16
|
|
// characters length. The string can be alphanumeric.
|
|
if (!dbus_message_get_args(msg, NULL,
|
|
DBUS_TYPE_OBJECT_PATH, &objectPath,
|
|
DBUS_TYPE_INVALID)) {
|
|
errorStr.AssignLiteral("Invalid arguments for RequestPinCode() method");
|
|
goto handle_error;
|
|
}
|
|
|
|
parameters.AppendElement(
|
|
BluetoothNamedValue(NS_LITERAL_STRING("path"),
|
|
NS_ConvertUTF8toUTF16(objectPath)));
|
|
parameters.AppendElement(
|
|
BluetoothNamedValue(NS_LITERAL_STRING("method"),
|
|
NS_LITERAL_STRING("pincode")));
|
|
|
|
v = parameters;
|
|
isPairingReq = true;
|
|
} else if (dbus_message_is_method_call(msg, DBUS_AGENT_IFACE,
|
|
"RequestPasskey")) {
|
|
// This method gets called when the service daemon needs to get the passkey
|
|
// for an authentication. The return value should be a numeric value
|
|
// between 0-999999.
|
|
if (!dbus_message_get_args(msg, NULL,
|
|
DBUS_TYPE_OBJECT_PATH, &objectPath,
|
|
DBUS_TYPE_INVALID)) {
|
|
errorStr.AssignLiteral("Invalid arguments for RequestPasskey() method");
|
|
goto handle_error;
|
|
}
|
|
|
|
parameters.AppendElement(BluetoothNamedValue(
|
|
NS_LITERAL_STRING("path"),
|
|
NS_ConvertUTF8toUTF16(objectPath)));
|
|
parameters.AppendElement(BluetoothNamedValue(
|
|
NS_LITERAL_STRING("method"),
|
|
NS_LITERAL_STRING("passkey")));
|
|
|
|
v = parameters;
|
|
isPairingReq = true;
|
|
} else if (dbus_message_is_method_call(msg, DBUS_AGENT_IFACE, "Release")) {
|
|
// This method gets called when the service daemon unregisters the agent.
|
|
// An agent can use it to do cleanup tasks. There is no need to unregister
|
|
// the agent, because when this method gets called it has already been
|
|
// unregistered.
|
|
DBusMessage *reply = dbus_message_new_method_return(msg);
|
|
|
|
if (!reply) {
|
|
errorStr.AssignLiteral("Memory can't be allocated for the message.");
|
|
goto handle_error;
|
|
}
|
|
|
|
dbus_connection_send(conn, reply, NULL);
|
|
dbus_message_unref(reply);
|
|
|
|
// Do not send an notification to upper layer, too annoying.
|
|
return DBUS_HANDLER_RESULT_HANDLED;
|
|
} else {
|
|
#ifdef DEBUG
|
|
BT_WARNING("agent handler %s: Unhandled event. Ignore.", __FUNCTION__);
|
|
#endif
|
|
return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
|
|
}
|
|
|
|
if (!errorStr.IsEmpty()) {
|
|
BT_WARNING(NS_ConvertUTF16toUTF8(errorStr).get());
|
|
return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
|
|
}
|
|
|
|
// Update value after parsing DBus message
|
|
signal.value() = v;
|
|
|
|
if (isPairingReq) {
|
|
sPairingReqTable->Put(
|
|
GetAddressFromObjectPath(NS_ConvertUTF8toUTF16(objectPath)), msg);
|
|
|
|
// Increase ref count here because we need this message later.
|
|
// It'll be unrefed when set*Internal() is called.
|
|
dbus_message_ref(msg);
|
|
|
|
AppendDeviceName(signal);
|
|
} else {
|
|
NS_DispatchToMainThread(new DistributeBluetoothSignalTask(signal));
|
|
}
|
|
|
|
return DBUS_HANDLER_RESULT_HANDLED;
|
|
|
|
handle_error:
|
|
BT_WARNING(NS_ConvertUTF16toUTF8(errorStr).get());
|
|
return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
|
|
}
|
|
|
|
class RegisterAgentReplyHandler : public DBusReplyHandler
|
|
{
|
|
public:
|
|
RegisterAgentReplyHandler(const DBusObjectPathVTable* aAgentVTable)
|
|
: mAgentVTable(aAgentVTable)
|
|
{
|
|
MOZ_ASSERT(aAgentVTable);
|
|
}
|
|
|
|
void Handle(DBusMessage* aReply)
|
|
{
|
|
MOZ_ASSERT(!NS_IsMainThread()); // DBus thread
|
|
|
|
if (!aReply || (dbus_message_get_type(aReply) == DBUS_MESSAGE_TYPE_ERROR)) {
|
|
return;
|
|
}
|
|
|
|
nsRefPtr<RawDBusConnection> threadConnection = gThreadConnection;
|
|
|
|
if (!threadConnection.get()) {
|
|
BT_WARNING("%s: DBus connection has been closed.", __FUNCTION__);
|
|
return;
|
|
}
|
|
|
|
// There is no "RegisterAgent" function defined in device interface.
|
|
// When we call "CreatePairedDevice", it will do device agent registration
|
|
// for us. (See maemo.org/api_refs/5.0/beta/bluez/adapter.html)
|
|
if (!dbus_connection_register_object_path(threadConnection->GetConnection(),
|
|
KEY_REMOTE_AGENT,
|
|
mAgentVTable,
|
|
NULL)) {
|
|
BT_WARNING("%s: Can't register object path %s for remote device agent!",
|
|
__FUNCTION__, KEY_REMOTE_AGENT);
|
|
return;
|
|
}
|
|
|
|
NS_DispatchToMainThread(new PrepareProfileManagersRunnable());
|
|
}
|
|
|
|
private:
|
|
const DBusObjectPathVTable* mAgentVTable;
|
|
};
|
|
|
|
class AddReservedServiceRecordsReplyHandler : public DBusReplyHandler
|
|
{
|
|
public:
|
|
void Handle(DBusMessage* aReply)
|
|
{
|
|
static const DBusObjectPathVTable sAgentVTable = {
|
|
NULL, AgentEventFilter, NULL, NULL, NULL, NULL
|
|
};
|
|
|
|
MOZ_ASSERT(!NS_IsMainThread()); // DBus thread
|
|
|
|
if (!aReply || (dbus_message_get_type(aReply) == DBUS_MESSAGE_TYPE_ERROR)) {
|
|
return;
|
|
}
|
|
|
|
// TODO/qdot: This needs to be held for the life of the bluetooth connection
|
|
// so we could clean it up. For right now though, we can throw it away.
|
|
nsTArray<uint32_t> handles;
|
|
|
|
ExtractHandles(aReply, handles);
|
|
|
|
if(!RegisterAgent(&sAgentVTable)) {
|
|
BT_WARNING("Failed to register agent");
|
|
}
|
|
}
|
|
|
|
private:
|
|
void ExtractHandles(DBusMessage *aMessage, nsTArray<uint32_t>& aOutHandles)
|
|
{
|
|
DBusError error;
|
|
int length;
|
|
uint32_t* handles = nullptr;
|
|
|
|
dbus_error_init(&error);
|
|
|
|
bool success = dbus_message_get_args(aMessage, &error,
|
|
DBUS_TYPE_ARRAY,
|
|
DBUS_TYPE_UINT32,
|
|
&handles, &length,
|
|
DBUS_TYPE_INVALID);
|
|
if (success != TRUE) {
|
|
LOG_AND_FREE_DBUS_ERROR(&error);
|
|
return;
|
|
}
|
|
|
|
if (!handles) {
|
|
BT_WARNING("Null array in extract_handles");
|
|
return;
|
|
}
|
|
|
|
for (int i = 0; i < length; ++i) {
|
|
aOutHandles.AppendElement(handles[i]);
|
|
}
|
|
}
|
|
|
|
bool RegisterAgent(const DBusObjectPathVTable* aAgentVTable)
|
|
{
|
|
const char* agentPath = KEY_LOCAL_AGENT;
|
|
const char* capabilities = B2G_AGENT_CAPABILITIES;
|
|
|
|
nsRefPtr<RawDBusConnection> threadConnection = gThreadConnection;
|
|
|
|
if (!threadConnection.get()) {
|
|
BT_WARNING("%s: DBus connection has been closed.", __FUNCTION__);
|
|
return false;
|
|
}
|
|
|
|
// Local agent means agent for Adapter, not agent for Device. Some signals
|
|
// will be passed to local agent, some will be passed to device agent.
|
|
// For example, if a remote device would like to pair with us, then the
|
|
// signal will be passed to local agent. If we start pairing process with
|
|
// calling CreatePairedDevice, we'll get signal which should be passed to
|
|
// device agent.
|
|
if (!dbus_connection_register_object_path(threadConnection->GetConnection(),
|
|
KEY_LOCAL_AGENT,
|
|
aAgentVTable,
|
|
NULL)) {
|
|
BT_WARNING("%s: Can't register object path %s for agent!",
|
|
__FUNCTION__, KEY_LOCAL_AGENT);
|
|
return false;
|
|
}
|
|
|
|
nsRefPtr<RegisterAgentReplyHandler> handler =
|
|
new RegisterAgentReplyHandler(aAgentVTable);
|
|
MOZ_ASSERT(handler.get());
|
|
|
|
bool success = threadConnection->SendWithReply(
|
|
RegisterAgentReplyHandler::Callback, handler.get(), -1,
|
|
NS_ConvertUTF16toUTF8(sAdapterPath).get(),
|
|
DBUS_ADAPTER_IFACE, "RegisterAgent",
|
|
DBUS_TYPE_OBJECT_PATH, &agentPath,
|
|
DBUS_TYPE_STRING, &capabilities,
|
|
DBUS_TYPE_INVALID);
|
|
|
|
NS_ENSURE_TRUE(success, false);
|
|
|
|
handler.forget();
|
|
|
|
return true;
|
|
}
|
|
};
|
|
|
|
class PrepareAdapterRunnable : public nsRunnable
|
|
{
|
|
public:
|
|
PrepareAdapterRunnable(const nsAString& aAdapterPath)
|
|
: mAdapterPath(aAdapterPath)
|
|
{ }
|
|
|
|
NS_IMETHOD Run()
|
|
{
|
|
static const dbus_uint32_t sServices[] = {
|
|
BluetoothServiceClass::HANDSFREE_AG,
|
|
BluetoothServiceClass::HEADSET_AG,
|
|
BluetoothServiceClass::OBJECT_PUSH
|
|
};
|
|
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
nsRefPtr<RawDBusConnection> threadConnection = gThreadConnection;
|
|
|
|
if (!threadConnection.get()) {
|
|
BT_WARNING("%s: DBus connection has been closed.", __FUNCTION__);
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
sAdapterPath = mAdapterPath;
|
|
sAuthorizedServiceClass.AppendElement(BluetoothServiceClass::A2DP);
|
|
sAuthorizedServiceClass.AppendElement(BluetoothServiceClass::HID);
|
|
|
|
nsRefPtr<DBusReplyHandler> handler =
|
|
new AddReservedServiceRecordsReplyHandler();
|
|
|
|
const dbus_uint32_t* services = sServices;
|
|
|
|
bool success = threadConnection->SendWithReply(
|
|
DBusReplyHandler::Callback, handler.get(), -1,
|
|
NS_ConvertUTF16toUTF8(sAdapterPath).get(),
|
|
DBUS_ADAPTER_IFACE, "AddReservedServiceRecords",
|
|
DBUS_TYPE_ARRAY, DBUS_TYPE_UINT32,
|
|
&services, NS_ARRAY_LENGTH(sServices), DBUS_TYPE_INVALID);
|
|
|
|
NS_ENSURE_TRUE(success, NS_ERROR_FAILURE);
|
|
|
|
handler.forget();
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
private:
|
|
nsString mAdapterPath;
|
|
};
|
|
|
|
class RequestPlayStatusTask : public nsRunnable
|
|
{
|
|
public:
|
|
RequestPlayStatusTask()
|
|
{
|
|
MOZ_ASSERT(!NS_IsMainThread());
|
|
}
|
|
|
|
nsresult Run()
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
BluetoothSignal signal(NS_LITERAL_STRING(REQUEST_MEDIA_PLAYSTATUS_ID),
|
|
NS_LITERAL_STRING(KEY_ADAPTER),
|
|
InfallibleTArray<BluetoothNamedValue>());
|
|
|
|
BluetoothService* bs = BluetoothService::Get();
|
|
NS_ENSURE_TRUE(bs, NS_ERROR_FAILURE);
|
|
bs->DistributeSignal(signal);
|
|
|
|
return NS_OK;
|
|
}
|
|
};
|
|
|
|
// Called by dbus during WaitForAndDispatchEventNative()
|
|
// This function is called on the IOThread
|
|
static DBusHandlerResult
|
|
EventFilter(DBusConnection* aConn, DBusMessage* aMsg, void* aData)
|
|
{
|
|
MOZ_ASSERT(!NS_IsMainThread(), "Shouldn't be called from Main Thread!");
|
|
|
|
if (dbus_message_get_type(aMsg) != DBUS_MESSAGE_TYPE_SIGNAL) {
|
|
BT_WARNING("%s: event handler not interested in %s (not a signal).\n",
|
|
__FUNCTION__, dbus_message_get_member(aMsg));
|
|
return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
|
|
}
|
|
|
|
if (dbus_message_get_path(aMsg) == NULL) {
|
|
BT_WARNING("DBusMessage %s has no bluetooth destination, ignoring\n",
|
|
dbus_message_get_member(aMsg));
|
|
return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
|
|
}
|
|
|
|
DBusError err;
|
|
dbus_error_init(&err);
|
|
|
|
nsAutoString signalPath;
|
|
nsAutoString signalName;
|
|
nsAutoString signalInterface;
|
|
|
|
BT_LOGD("%s: %s, %s, %s", __FUNCTION__,
|
|
dbus_message_get_interface(aMsg),
|
|
dbus_message_get_path(aMsg),
|
|
dbus_message_get_member(aMsg));
|
|
|
|
signalInterface = NS_ConvertUTF8toUTF16(dbus_message_get_interface(aMsg));
|
|
signalPath = NS_ConvertUTF8toUTF16(dbus_message_get_path(aMsg));
|
|
signalName = NS_ConvertUTF8toUTF16(dbus_message_get_member(aMsg));
|
|
nsString errorStr;
|
|
BluetoothValue v;
|
|
|
|
// Since the signalPath extracted from dbus message is a object path,
|
|
// we'd like to re-assign them to corresponding key entry in
|
|
// BluetoothSignalObserverTable
|
|
if (signalInterface.EqualsLiteral(DBUS_MANAGER_IFACE)) {
|
|
signalPath.AssignLiteral(KEY_MANAGER);
|
|
} else if (signalInterface.EqualsLiteral(DBUS_ADAPTER_IFACE)) {
|
|
signalPath.AssignLiteral(KEY_ADAPTER);
|
|
} else if (signalInterface.EqualsLiteral(DBUS_DEVICE_IFACE)){
|
|
signalPath = GetAddressFromObjectPath(signalPath);
|
|
}
|
|
|
|
if (dbus_message_is_signal(aMsg, DBUS_ADAPTER_IFACE, "DeviceFound")) {
|
|
DBusMessageIter iter;
|
|
|
|
if (!dbus_message_iter_init(aMsg, &iter)) {
|
|
BT_WARNING("Can't create iterator!");
|
|
return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
|
|
}
|
|
|
|
const char* addr;
|
|
dbus_message_iter_get_basic(&iter, &addr);
|
|
|
|
if (!dbus_message_iter_next(&iter)) {
|
|
errorStr.AssignLiteral("Unexpected message struct in msg DeviceFound");
|
|
} else {
|
|
ParseProperties(&iter,
|
|
v,
|
|
errorStr,
|
|
sDeviceProperties,
|
|
ArrayLength(sDeviceProperties));
|
|
|
|
InfallibleTArray<BluetoothNamedValue>& properties =
|
|
v.get_ArrayOfBluetoothNamedValue();
|
|
|
|
// The DBus DeviceFound message actually passes back a key value object
|
|
// with the address as the key and the rest of the device properties as
|
|
// a dict value. After we parse out the properties, we need to go back
|
|
// and add the address to the ipdl dict we've created to make sure we
|
|
// have all of the information to correctly build the device.
|
|
nsAutoString address = NS_ConvertUTF8toUTF16(addr);
|
|
properties.AppendElement(
|
|
BluetoothNamedValue(NS_LITERAL_STRING("Address"), address));
|
|
properties.AppendElement(
|
|
BluetoothNamedValue(NS_LITERAL_STRING("Path"),
|
|
GetObjectPathFromAddress(signalPath, address)));
|
|
|
|
if (!ContainsIcon(properties)) {
|
|
for (uint8_t i = 0; i < properties.Length(); i++) {
|
|
// It is possible that property Icon missed due to CoD of major
|
|
// class is TOY but service class is "Audio", we need to assign
|
|
// Icon as audio-card. This is for PTS test TC_AG_COD_BV_02_I.
|
|
// As HFP specification defined that
|
|
// service class is "Audio" can be considered as HFP AG.
|
|
if (properties[i].name().EqualsLiteral("Class")) {
|
|
if (HasAudioService(properties[i].value().get_uint32_t())) {
|
|
v.get_ArrayOfBluetoothNamedValue().AppendElement(
|
|
BluetoothNamedValue(NS_LITERAL_STRING("Icon"),
|
|
NS_LITERAL_STRING("audio-card")));
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
} else if (dbus_message_is_signal(aMsg, DBUS_ADAPTER_IFACE,
|
|
"DeviceDisappeared")) {
|
|
const char* str;
|
|
if (!dbus_message_get_args(aMsg, &err,
|
|
DBUS_TYPE_STRING, &str,
|
|
DBUS_TYPE_INVALID)) {
|
|
LOG_AND_FREE_DBUS_ERROR_WITH_MSG(&err, aMsg);
|
|
errorStr.AssignLiteral("Cannot parse device address!");
|
|
} else {
|
|
v = NS_ConvertUTF8toUTF16(str);
|
|
}
|
|
} else if (dbus_message_is_signal(aMsg, DBUS_ADAPTER_IFACE,
|
|
"DeviceCreated")) {
|
|
const char* str;
|
|
if (!dbus_message_get_args(aMsg, &err,
|
|
DBUS_TYPE_OBJECT_PATH, &str,
|
|
DBUS_TYPE_INVALID)) {
|
|
LOG_AND_FREE_DBUS_ERROR_WITH_MSG(&err, aMsg);
|
|
errorStr.AssignLiteral("Cannot parse device path!");
|
|
} else {
|
|
v = NS_ConvertUTF8toUTF16(str);
|
|
}
|
|
} else if (dbus_message_is_signal(aMsg, DBUS_ADAPTER_IFACE,
|
|
"DeviceRemoved")) {
|
|
const char* str;
|
|
if (!dbus_message_get_args(aMsg, &err,
|
|
DBUS_TYPE_OBJECT_PATH, &str,
|
|
DBUS_TYPE_INVALID)) {
|
|
LOG_AND_FREE_DBUS_ERROR_WITH_MSG(&err, aMsg);
|
|
errorStr.AssignLiteral("Cannot parse device path!");
|
|
} else {
|
|
v = NS_ConvertUTF8toUTF16(str);
|
|
}
|
|
} else if (dbus_message_is_signal(aMsg, DBUS_ADAPTER_IFACE,
|
|
"PropertyChanged")) {
|
|
ParsePropertyChange(aMsg,
|
|
v,
|
|
errorStr,
|
|
sAdapterProperties,
|
|
ArrayLength(sAdapterProperties));
|
|
} else if (dbus_message_is_signal(aMsg, DBUS_DEVICE_IFACE,
|
|
"PropertyChanged")) {
|
|
ParsePropertyChange(aMsg,
|
|
v,
|
|
errorStr,
|
|
sDeviceProperties,
|
|
ArrayLength(sDeviceProperties));
|
|
|
|
BluetoothNamedValue& property = v.get_ArrayOfBluetoothNamedValue()[0];
|
|
if (property.name().EqualsLiteral("Paired")) {
|
|
// Original approach: Broadcast system message of
|
|
// "bluetooth-pairedstatuschanged" from BluetoothService.
|
|
BluetoothValue newValue(v);
|
|
ToLowerCase(newValue.get_ArrayOfBluetoothNamedValue()[0].name());
|
|
BluetoothSignal signal(NS_LITERAL_STRING(PAIRED_STATUS_CHANGED_ID),
|
|
NS_LITERAL_STRING(KEY_LOCAL_AGENT),
|
|
newValue);
|
|
NS_DispatchToMainThread(new DistributeBluetoothSignalTask(signal));
|
|
|
|
// New approach: Dispatch event from BluetoothAdapter
|
|
bool status = property.value();
|
|
InfallibleTArray<BluetoothNamedValue> parameters;
|
|
parameters.AppendElement(
|
|
BluetoothNamedValue(NS_LITERAL_STRING("address"), signalPath));
|
|
parameters.AppendElement(
|
|
BluetoothNamedValue(NS_LITERAL_STRING("status"), status));
|
|
signal.path() = NS_LITERAL_STRING(KEY_ADAPTER);
|
|
signal.value() = parameters;
|
|
NS_DispatchToMainThread(new DistributeBluetoothSignalTask(signal));
|
|
} else if (property.name().EqualsLiteral("Connected")) {
|
|
MonitorAutoLock lock(*sStopBluetoothMonitor);
|
|
|
|
if (property.value().get_bool()) {
|
|
++sConnectedDeviceCount;
|
|
} else {
|
|
MOZ_ASSERT(sConnectedDeviceCount > 0);
|
|
if (--sConnectedDeviceCount == 0) {
|
|
lock.Notify();
|
|
}
|
|
}
|
|
}
|
|
} else if (dbus_message_is_signal(aMsg, DBUS_MANAGER_IFACE, "AdapterAdded")) {
|
|
const char* str;
|
|
if (!dbus_message_get_args(aMsg, &err,
|
|
DBUS_TYPE_OBJECT_PATH, &str,
|
|
DBUS_TYPE_INVALID)) {
|
|
LOG_AND_FREE_DBUS_ERROR_WITH_MSG(&err, aMsg);
|
|
errorStr.AssignLiteral("Cannot parse manager path!");
|
|
} else {
|
|
v = NS_ConvertUTF8toUTF16(str);
|
|
NS_DispatchToMainThread(new PrepareAdapterRunnable(v.get_nsString()));
|
|
}
|
|
} else if (dbus_message_is_signal(aMsg, DBUS_MANAGER_IFACE,
|
|
"PropertyChanged")) {
|
|
ParsePropertyChange(aMsg,
|
|
v,
|
|
errorStr,
|
|
sManagerProperties,
|
|
ArrayLength(sManagerProperties));
|
|
} else if (dbus_message_is_signal(aMsg, DBUS_SINK_IFACE,
|
|
"PropertyChanged")) {
|
|
ParsePropertyChange(aMsg,
|
|
v,
|
|
errorStr,
|
|
sSinkProperties,
|
|
ArrayLength(sSinkProperties));
|
|
} else if (dbus_message_is_signal(aMsg, DBUS_CTL_IFACE, "GetPlayStatus")) {
|
|
NS_DispatchToMainThread(new RequestPlayStatusTask());
|
|
return DBUS_HANDLER_RESULT_HANDLED;
|
|
} else if (dbus_message_is_signal(aMsg, DBUS_CTL_IFACE, "PropertyChanged")) {
|
|
ParsePropertyChange(aMsg,
|
|
v,
|
|
errorStr,
|
|
sControlProperties,
|
|
ArrayLength(sControlProperties));
|
|
} else if (dbus_message_is_signal(aMsg, DBUS_INPUT_IFACE,
|
|
"PropertyChanged")) {
|
|
ParsePropertyChange(aMsg,
|
|
v,
|
|
errorStr,
|
|
sInputProperties,
|
|
ArrayLength(sInputProperties));
|
|
} else {
|
|
errorStr = NS_ConvertUTF8toUTF16(dbus_message_get_member(aMsg));
|
|
errorStr.AppendLiteral(" Signal not handled!");
|
|
}
|
|
|
|
if (!errorStr.IsEmpty()) {
|
|
BT_WARNING(NS_ConvertUTF16toUTF8(errorStr).get());
|
|
return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
|
|
}
|
|
|
|
BluetoothSignal signal(signalName, signalPath, v);
|
|
nsRefPtr<nsRunnable> task;
|
|
if (signalInterface.EqualsLiteral(DBUS_SINK_IFACE)) {
|
|
task = new SinkPropertyChangedHandler(signal);
|
|
} else if (signalInterface.EqualsLiteral(DBUS_CTL_IFACE)) {
|
|
task = new ControlPropertyChangedHandler(signal);
|
|
} else if (signalInterface.EqualsLiteral(DBUS_INPUT_IFACE)) {
|
|
task = new InputPropertyChangedHandler(signal);
|
|
} else {
|
|
task = new DistributeBluetoothSignalTask(signal);
|
|
}
|
|
|
|
NS_DispatchToMainThread(task);
|
|
|
|
return DBUS_HANDLER_RESULT_HANDLED;
|
|
}
|
|
|
|
static bool
|
|
GetDefaultAdapterPath(BluetoothValue& aValue, nsString& aError)
|
|
{
|
|
// This could block. It should never be run on the main thread.
|
|
MOZ_ASSERT(!NS_IsMainThread());
|
|
|
|
DBusError err;
|
|
dbus_error_init(&err);
|
|
|
|
DBusMessage* msg;
|
|
bool success = gThreadConnection->SendWithError(&msg, &err, 1000, "/",
|
|
DBUS_MANAGER_IFACE,
|
|
"DefaultAdapter",
|
|
DBUS_TYPE_INVALID);
|
|
NS_ENSURE_TRUE(success, false);
|
|
|
|
UnpackObjectPathMessage(msg, &err, aValue, aError);
|
|
|
|
dbus_message_unref(msg);
|
|
|
|
return aError.IsEmpty();
|
|
}
|
|
|
|
bool
|
|
BluetoothDBusService::IsReady()
|
|
{
|
|
if (!IsEnabled() || !mConnection || !gThreadConnection || IsToggling()) {
|
|
BT_WARNING("Bluetooth service is not ready yet!");
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
nsresult
|
|
BluetoothDBusService::StartInternal()
|
|
{
|
|
// This could block. It should never be run on the main thread.
|
|
MOZ_ASSERT(!NS_IsMainThread());
|
|
|
|
if (!StartDBus()) {
|
|
BT_WARNING("Cannot start DBus thread!");
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
if (mConnection) {
|
|
return NS_OK;
|
|
}
|
|
|
|
if (NS_FAILED(EstablishDBusConnection())) {
|
|
BT_WARNING("Cannot start Main Thread DBus connection!");
|
|
StopDBus();
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
gThreadConnection = new RawDBusConnection();
|
|
|
|
if (NS_FAILED(gThreadConnection->EstablishDBusConnection())) {
|
|
BT_WARNING("Cannot start Sync Thread DBus connection!");
|
|
StopDBus();
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
DBusError err;
|
|
dbus_error_init(&err);
|
|
|
|
// Set which messages will be processed by this dbus connection.
|
|
// Since we are maintaining a single thread for all the DBus bluez
|
|
// signals we want, register all of them in this thread at startup.
|
|
// The event handler will sort the destinations out as needed.
|
|
for (uint32_t i = 0; i < ArrayLength(sBluetoothDBusSignals); ++i) {
|
|
dbus_bus_add_match(mConnection,
|
|
sBluetoothDBusSignals[i],
|
|
&err);
|
|
if (dbus_error_is_set(&err)) {
|
|
LOG_AND_FREE_DBUS_ERROR(&err);
|
|
}
|
|
}
|
|
|
|
// Add a filter for all incoming messages_base
|
|
if (!dbus_connection_add_filter(mConnection, EventFilter,
|
|
NULL, NULL)) {
|
|
BT_WARNING("Cannot create DBus Event Filter for DBus Thread!");
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
if (!sPairingReqTable) {
|
|
sPairingReqTable = new nsDataHashtable<nsStringHashKey, DBusMessage* >;
|
|
}
|
|
|
|
BluetoothValue v;
|
|
nsAutoString replyError;
|
|
if (!GetDefaultAdapterPath(v, replyError)) {
|
|
// Adapter path is not ready yet
|
|
// Let's do PrepareAdapterRunnable when we receive signal 'AdapterAdded'
|
|
} else {
|
|
// Adapter path has been ready. let's do PrepareAdapterRunnable now
|
|
nsRefPtr<PrepareAdapterRunnable> b = new PrepareAdapterRunnable(v.get_nsString());
|
|
if (NS_FAILED(NS_DispatchToMainThread(b))) {
|
|
BT_WARNING("Failed to dispatch to main thread!");
|
|
}
|
|
}
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
PLDHashOperator
|
|
UnrefDBusMessages(const nsAString& key, DBusMessage* value, void* arg)
|
|
{
|
|
dbus_message_unref(value);
|
|
|
|
return PL_DHASH_NEXT;
|
|
}
|
|
|
|
nsresult
|
|
BluetoothDBusService::StopInternal()
|
|
{
|
|
// This could block. It should never be run on the main thread.
|
|
MOZ_ASSERT(!NS_IsMainThread());
|
|
|
|
{
|
|
MonitorAutoLock lock(*sStopBluetoothMonitor);
|
|
if (sConnectedDeviceCount > 0) {
|
|
lock.Wait(PR_SecondsToInterval(TIMEOUT_FORCE_TO_DISABLE_BT));
|
|
}
|
|
}
|
|
|
|
if (!mConnection) {
|
|
StopDBus();
|
|
return NS_OK;
|
|
}
|
|
|
|
DBusError err;
|
|
dbus_error_init(&err);
|
|
for (uint32_t i = 0; i < ArrayLength(sBluetoothDBusSignals); ++i) {
|
|
dbus_bus_remove_match(mConnection,
|
|
sBluetoothDBusSignals[i],
|
|
&err);
|
|
if (dbus_error_is_set(&err)) {
|
|
LOG_AND_FREE_DBUS_ERROR(&err);
|
|
}
|
|
}
|
|
|
|
dbus_connection_remove_filter(mConnection, EventFilter, nullptr);
|
|
|
|
if (!dbus_connection_unregister_object_path(gThreadConnection->GetConnection(),
|
|
KEY_LOCAL_AGENT)) {
|
|
BT_WARNING("%s: Can't unregister object path %s for agent!",
|
|
__FUNCTION__, KEY_LOCAL_AGENT);
|
|
}
|
|
|
|
if (!dbus_connection_unregister_object_path(gThreadConnection->GetConnection(),
|
|
KEY_REMOTE_AGENT)) {
|
|
BT_WARNING("%s: Can't unregister object path %s for agent!",
|
|
__FUNCTION__, KEY_REMOTE_AGENT);
|
|
}
|
|
|
|
mConnection = nullptr;
|
|
gThreadConnection = nullptr;
|
|
|
|
// unref stored DBusMessages before clear the hashtable
|
|
sPairingReqTable->EnumerateRead(UnrefDBusMessages, nullptr);
|
|
sPairingReqTable->Clear();
|
|
|
|
sIsPairing = 0;
|
|
sConnectedDeviceCount = 0;
|
|
|
|
sAuthorizedServiceClass.Clear();
|
|
|
|
StopDBus();
|
|
return NS_OK;
|
|
}
|
|
|
|
bool
|
|
BluetoothDBusService::IsEnabledInternal()
|
|
{
|
|
return mEnabled;
|
|
}
|
|
|
|
class DefaultAdapterPathReplyHandler : public DBusReplyHandler
|
|
{
|
|
public:
|
|
DefaultAdapterPathReplyHandler(BluetoothReplyRunnable* aRunnable)
|
|
: mRunnable(aRunnable)
|
|
{
|
|
MOZ_ASSERT(mRunnable);
|
|
}
|
|
|
|
void Handle(DBusMessage* aReply) MOZ_OVERRIDE
|
|
{
|
|
MOZ_ASSERT(!NS_IsMainThread()); // DBus thread
|
|
|
|
if (!aReply || (dbus_message_get_type(aReply) == DBUS_MESSAGE_TYPE_ERROR)) {
|
|
const char* errStr = "Timeout in DefaultAdapterPathReplyHandler";
|
|
if (aReply) {
|
|
errStr = dbus_message_get_error_name(aReply);
|
|
if (!errStr) {
|
|
errStr = "Bluetooth DBus Error";
|
|
}
|
|
}
|
|
DispatchBluetoothReply(mRunnable, BluetoothValue(),
|
|
NS_ConvertUTF8toUTF16(errStr));
|
|
return;
|
|
}
|
|
|
|
bool success;
|
|
nsAutoString replyError;
|
|
|
|
if (mAdapterPath.IsEmpty()) {
|
|
success = HandleDefaultAdapterPathReply(aReply, replyError);
|
|
} else {
|
|
success = HandleGetPropertiesReply(aReply, replyError);
|
|
}
|
|
|
|
if (!success) {
|
|
DispatchBluetoothReply(mRunnable, BluetoothValue(), replyError);
|
|
}
|
|
}
|
|
|
|
protected:
|
|
bool HandleDefaultAdapterPathReply(DBusMessage* aReply,
|
|
nsAString& aReplyError)
|
|
{
|
|
BluetoothValue value;
|
|
DBusError error;
|
|
dbus_error_init(&error);
|
|
|
|
MOZ_ASSERT(!NS_IsMainThread()); // DBus thread
|
|
|
|
UnpackObjectPathMessage(aReply, &error, value, aReplyError);
|
|
|
|
if (!aReplyError.IsEmpty()) {
|
|
return false;
|
|
}
|
|
|
|
mAdapterPath = value.get_nsString();
|
|
|
|
// Acquire another reference to this reply handler
|
|
nsRefPtr<DefaultAdapterPathReplyHandler> handler = this;
|
|
|
|
nsRefPtr<RawDBusConnection> threadConnection = gThreadConnection;
|
|
|
|
if (!threadConnection.get()) {
|
|
aReplyError = NS_LITERAL_STRING("DBus connection has been closed.");
|
|
return false;
|
|
}
|
|
|
|
bool success = threadConnection->SendWithReply(
|
|
DefaultAdapterPathReplyHandler::Callback, handler.get(), 1000,
|
|
NS_ConvertUTF16toUTF8(mAdapterPath).get(),
|
|
DBUS_ADAPTER_IFACE, "GetProperties", DBUS_TYPE_INVALID);
|
|
|
|
if (!success) {
|
|
aReplyError = NS_LITERAL_STRING("SendWithReply failed");
|
|
return false;
|
|
}
|
|
|
|
handler.forget();
|
|
|
|
return true;
|
|
}
|
|
|
|
bool HandleGetPropertiesReply(DBusMessage* aReply,
|
|
nsAutoString& aReplyError)
|
|
{
|
|
BluetoothValue value;
|
|
DBusError error;
|
|
dbus_error_init(&error);
|
|
|
|
MOZ_ASSERT(!NS_IsMainThread()); // DBus thread
|
|
|
|
bool success = UnpackPropertiesMessage(aReply, &error, value,
|
|
DBUS_ADAPTER_IFACE);
|
|
if (!success) {
|
|
aReplyError = NS_ConvertUTF8toUTF16(error.message);
|
|
return false;
|
|
}
|
|
|
|
// We have to manually attach the path to the rest of the elements
|
|
value.get_ArrayOfBluetoothNamedValue().AppendElement(
|
|
BluetoothNamedValue(NS_LITERAL_STRING("Path"), mAdapterPath));
|
|
|
|
// Dispatch result
|
|
DispatchBluetoothReply(mRunnable, value, aReplyError);
|
|
|
|
return true;
|
|
}
|
|
|
|
private:
|
|
nsRefPtr<BluetoothReplyRunnable> mRunnable;
|
|
nsString mAdapterPath;
|
|
};
|
|
|
|
nsresult
|
|
BluetoothDBusService::GetDefaultAdapterPathInternal(
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
if (!IsReady()) {
|
|
NS_NAMED_LITERAL_STRING(errorStr, "Bluetooth service is not ready yet!");
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(), errorStr);
|
|
return NS_OK;
|
|
}
|
|
|
|
nsRefPtr<DefaultAdapterPathReplyHandler> handler =
|
|
new DefaultAdapterPathReplyHandler(aRunnable);
|
|
|
|
bool success = SendWithReply(DefaultAdapterPathReplyHandler::Callback,
|
|
handler.get(), 1000,
|
|
"/", DBUS_MANAGER_IFACE, "DefaultAdapter",
|
|
DBUS_TYPE_INVALID);
|
|
|
|
NS_ENSURE_TRUE(success, NS_ERROR_FAILURE);
|
|
|
|
handler.forget();
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
static void
|
|
OnSendDiscoveryMessageReply(DBusMessage *aReply, void *aData)
|
|
{
|
|
MOZ_ASSERT(!NS_IsMainThread());
|
|
|
|
nsAutoString errorStr;
|
|
|
|
if (!aReply) {
|
|
errorStr.AssignLiteral("SendDiscovery failed");
|
|
}
|
|
|
|
nsRefPtr<BluetoothReplyRunnable> runnable =
|
|
dont_AddRef<BluetoothReplyRunnable>(static_cast<BluetoothReplyRunnable*>(aData));
|
|
|
|
DispatchBluetoothReply(runnable.get(), BluetoothValue(true), errorStr);
|
|
}
|
|
|
|
nsresult
|
|
BluetoothDBusService::SendDiscoveryMessage(const char* aMessageName,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
if (!IsReady()) {
|
|
NS_NAMED_LITERAL_STRING(errorStr, "Bluetooth service is not ready yet!");
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(), errorStr);
|
|
return NS_OK;
|
|
}
|
|
|
|
nsRefPtr<BluetoothReplyRunnable> runnable(aRunnable);
|
|
|
|
bool success = SendWithReply(OnSendDiscoveryMessageReply,
|
|
static_cast<void*>(aRunnable), -1,
|
|
NS_ConvertUTF16toUTF8(sAdapterPath).get(),
|
|
DBUS_ADAPTER_IFACE, aMessageName,
|
|
DBUS_TYPE_INVALID);
|
|
|
|
NS_ENSURE_TRUE(success, NS_ERROR_FAILURE);
|
|
|
|
runnable.forget();
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
nsresult
|
|
BluetoothDBusService::SendInputMessage(const nsAString& aDeviceAddress,
|
|
const nsAString& aMessage)
|
|
{
|
|
DBusReplyCallback callback;
|
|
if (aMessage.EqualsLiteral("Connect")) {
|
|
callback = InputConnectCallback;
|
|
} else if (aMessage.EqualsLiteral("Disconnect")) {
|
|
callback = InputDisconnectCallback;
|
|
} else {
|
|
MOZ_ASSERT(false);
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
nsString objectPath = GetObjectPathFromAddress(sAdapterPath, aDeviceAddress);
|
|
return SendAsyncDBusMessage(objectPath, DBUS_INPUT_IFACE, aMessage, callback);
|
|
}
|
|
|
|
nsresult
|
|
BluetoothDBusService::SendAsyncDBusMessage(const nsAString& aObjectPath,
|
|
const char* aInterface,
|
|
const nsAString& aMessage,
|
|
DBusReplyCallback aCallback)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
MOZ_ASSERT(mConnection);
|
|
MOZ_ASSERT(IsEnabled());
|
|
MOZ_ASSERT(aCallback);
|
|
MOZ_ASSERT(!aObjectPath.IsEmpty());
|
|
MOZ_ASSERT(aInterface);
|
|
|
|
nsAutoPtr<BluetoothServiceClass> serviceClass(new BluetoothServiceClass());
|
|
if (!strcmp(aInterface, DBUS_SINK_IFACE)) {
|
|
*serviceClass = BluetoothServiceClass::A2DP;
|
|
} else if (!strcmp(aInterface, DBUS_INPUT_IFACE)) {
|
|
*serviceClass = BluetoothServiceClass::HID;
|
|
} else {
|
|
MOZ_ASSERT(false);
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
bool ret = SendWithReply(aCallback,
|
|
static_cast<void*>(serviceClass.forget()), -1,
|
|
NS_ConvertUTF16toUTF8(aObjectPath).get(),
|
|
aInterface, NS_ConvertUTF16toUTF8(aMessage).get(),
|
|
DBUS_TYPE_INVALID);
|
|
|
|
NS_ENSURE_TRUE(ret, NS_ERROR_FAILURE);
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
nsresult
|
|
BluetoothDBusService::SendSinkMessage(const nsAString& aDeviceAddress,
|
|
const nsAString& aMessage)
|
|
{
|
|
DBusReplyCallback callback;
|
|
if (aMessage.EqualsLiteral("Connect")) {
|
|
callback = SinkConnectCallback;
|
|
} else if (aMessage.EqualsLiteral("Disconnect")) {
|
|
callback = SinkDisconnectCallback;
|
|
} else {
|
|
MOZ_ASSERT(false);
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
nsString objectPath = GetObjectPathFromAddress(sAdapterPath, aDeviceAddress);
|
|
return SendAsyncDBusMessage(objectPath, DBUS_SINK_IFACE, aMessage, callback);
|
|
}
|
|
|
|
nsresult
|
|
BluetoothDBusService::StopDiscoveryInternal(BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
return SendDiscoveryMessage("StopDiscovery", aRunnable);
|
|
}
|
|
|
|
nsresult
|
|
BluetoothDBusService::StartDiscoveryInternal(BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
return SendDiscoveryMessage("StartDiscovery", aRunnable);
|
|
}
|
|
|
|
class BluetoothArrayOfDevicePropertiesReplyHandler : public DBusReplyHandler
|
|
{
|
|
public:
|
|
BluetoothArrayOfDevicePropertiesReplyHandler(
|
|
const nsTArray<nsString>& aDeviceAddresses,
|
|
const FilterFunc aFilterFunc, BluetoothReplyRunnable* aRunnable)
|
|
: mDeviceAddresses(aDeviceAddresses)
|
|
, mProcessedDeviceAddresses(0)
|
|
, mFilterFunc(aFilterFunc)
|
|
, mRunnable(aRunnable)
|
|
, mValues(InfallibleTArray<BluetoothNamedValue>())
|
|
{
|
|
MOZ_ASSERT(mRunnable);
|
|
}
|
|
|
|
void Handle(DBusMessage* aReply) MOZ_OVERRIDE
|
|
{
|
|
MOZ_ASSERT(!NS_IsMainThread()); // DBus thread
|
|
MOZ_ASSERT(!mObjectPath.IsEmpty());
|
|
MOZ_ASSERT(mProcessedDeviceAddresses < mDeviceAddresses.Length());
|
|
|
|
const nsTArray<nsString>::index_type i = mProcessedDeviceAddresses++;
|
|
|
|
if (!aReply ||
|
|
(dbus_message_get_type(aReply) == DBUS_MESSAGE_TYPE_ERROR)) {
|
|
BT_WARNING("Invalid DBus message");
|
|
ProcessRemainingDeviceAddresses();
|
|
return;
|
|
}
|
|
|
|
// Get device properties from result of GetProperties
|
|
|
|
DBusError err;
|
|
dbus_error_init(&err);
|
|
|
|
BluetoothValue deviceProperties;
|
|
|
|
bool success = UnpackPropertiesMessage(aReply, &err, deviceProperties,
|
|
DBUS_DEVICE_IFACE);
|
|
if (!success) {
|
|
BT_WARNING("Failed to get device properties");
|
|
ProcessRemainingDeviceAddresses();
|
|
return;
|
|
}
|
|
|
|
InfallibleTArray<BluetoothNamedValue>& devicePropertiesArray =
|
|
deviceProperties.get_ArrayOfBluetoothNamedValue();
|
|
|
|
// We have to manually attach the path to the rest of the elements
|
|
devicePropertiesArray.AppendElement(
|
|
BluetoothNamedValue(NS_LITERAL_STRING("Path"), mObjectPath));
|
|
|
|
// It is possible that property Icon missed due to CoD of major
|
|
// class is TOY but service class is "Audio", we need to assign
|
|
// Icon as audio-card. This is for PTS test TC_AG_COD_BV_02_I.
|
|
// As HFP specification defined that
|
|
// service class is "Audio" can be considered as HFP AG.
|
|
if (!ContainsIcon(devicePropertiesArray)) {
|
|
InfallibleTArray<BluetoothNamedValue>::size_type j;
|
|
for (j = 0; j < devicePropertiesArray.Length(); ++j) {
|
|
BluetoothNamedValue& deviceProperty = devicePropertiesArray[j];
|
|
if (deviceProperty.name().EqualsLiteral("Class")) {
|
|
if (HasAudioService(deviceProperty.value().get_uint32_t())) {
|
|
devicePropertiesArray.AppendElement(
|
|
BluetoothNamedValue(NS_LITERAL_STRING("Icon"),
|
|
NS_LITERAL_STRING("audio-card")));
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
if (mFilterFunc(deviceProperties)) {
|
|
mValues.get_ArrayOfBluetoothNamedValue().AppendElement(
|
|
BluetoothNamedValue(mDeviceAddresses[i], deviceProperties));
|
|
}
|
|
|
|
ProcessRemainingDeviceAddresses();
|
|
}
|
|
|
|
void ProcessRemainingDeviceAddresses()
|
|
{
|
|
if (mProcessedDeviceAddresses < mDeviceAddresses.Length()) {
|
|
if (!SendNextGetProperties()) {
|
|
DispatchBluetoothReply(mRunnable, BluetoothValue(),
|
|
NS_LITERAL_STRING(
|
|
"SendNextGetProperties failed"));
|
|
}
|
|
} else {
|
|
// Send resulting device properties
|
|
DispatchBluetoothReply(mRunnable, mValues, EmptyString());
|
|
}
|
|
}
|
|
|
|
protected:
|
|
bool SendNextGetProperties()
|
|
{
|
|
MOZ_ASSERT(mProcessedDeviceAddresses < mDeviceAddresses.Length());
|
|
|
|
// cache object path for reply
|
|
mObjectPath = GetObjectPathFromAddress(sAdapterPath,
|
|
mDeviceAddresses[mProcessedDeviceAddresses]);
|
|
|
|
nsRefPtr<RawDBusConnection> threadConnection = gThreadConnection;
|
|
|
|
if (!threadConnection.get()) {
|
|
BT_WARNING("%s: DBus connection has been closed.", __FUNCTION__);
|
|
return false;
|
|
}
|
|
|
|
nsRefPtr<BluetoothArrayOfDevicePropertiesReplyHandler> handler = this;
|
|
|
|
bool success = threadConnection->SendWithReply(
|
|
BluetoothArrayOfDevicePropertiesReplyHandler::Callback,
|
|
handler.get(), 1000,
|
|
NS_ConvertUTF16toUTF8(mObjectPath).get(),
|
|
DBUS_DEVICE_IFACE, "GetProperties",
|
|
DBUS_TYPE_INVALID);
|
|
|
|
NS_ENSURE_TRUE(success, false);
|
|
|
|
handler.forget();
|
|
|
|
return true;
|
|
}
|
|
|
|
private:
|
|
nsString mObjectPath;
|
|
const nsTArray<nsString> mDeviceAddresses;
|
|
nsTArray<nsString>::size_type mProcessedDeviceAddresses;
|
|
const FilterFunc mFilterFunc;
|
|
nsRefPtr<BluetoothReplyRunnable> mRunnable;
|
|
BluetoothValue mValues;
|
|
};
|
|
|
|
nsresult
|
|
BluetoothDBusService::GetConnectedDevicePropertiesInternal(uint16_t aServiceUuid,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
nsAutoString errorStr;
|
|
BluetoothValue values = InfallibleTArray<BluetoothNamedValue>();
|
|
if (!IsReady()) {
|
|
NS_NAMED_LITERAL_STRING(errorStr, "Bluetooth service is not ready yet!");
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(), errorStr);
|
|
return NS_OK;
|
|
}
|
|
|
|
nsTArray<nsString> deviceAddresses;
|
|
BluetoothProfileManagerBase* profile =
|
|
BluetoothUuidHelper::GetBluetoothProfileManager(aServiceUuid);
|
|
if (!profile) {
|
|
DispatchBluetoothReply(aRunnable, values,
|
|
NS_LITERAL_STRING(ERR_UNKNOWN_PROFILE));
|
|
return NS_OK;
|
|
}
|
|
|
|
if (profile->IsConnected()) {
|
|
nsString address;
|
|
profile->GetAddress(address);
|
|
deviceAddresses.AppendElement(address);
|
|
}
|
|
|
|
nsRefPtr<BluetoothReplyRunnable> runnable = aRunnable;
|
|
nsRefPtr<BluetoothArrayOfDevicePropertiesReplyHandler> handler =
|
|
new BluetoothArrayOfDevicePropertiesReplyHandler(deviceAddresses,
|
|
GetConnectedDevicesFilter,
|
|
runnable);
|
|
handler->ProcessRemainingDeviceAddresses();
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
nsresult
|
|
BluetoothDBusService::GetPairedDevicePropertiesInternal(
|
|
const nsTArray<nsString>& aDeviceAddresses,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
if (!IsReady()) {
|
|
NS_NAMED_LITERAL_STRING(errorStr, "Bluetooth service is not ready yet!");
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(), errorStr);
|
|
return NS_OK;
|
|
}
|
|
|
|
nsRefPtr<BluetoothReplyRunnable> runnable = aRunnable;
|
|
nsRefPtr<BluetoothArrayOfDevicePropertiesReplyHandler> handler =
|
|
new BluetoothArrayOfDevicePropertiesReplyHandler(aDeviceAddresses,
|
|
GetPairedDevicesFilter,
|
|
runnable);
|
|
handler->ProcessRemainingDeviceAddresses();
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
nsresult
|
|
BluetoothDBusService::SetProperty(BluetoothObjectType aType,
|
|
const BluetoothNamedValue& aValue,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
if (!IsReady()) {
|
|
NS_NAMED_LITERAL_STRING(errorStr, "Bluetooth service is not ready yet!");
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(), errorStr);
|
|
return NS_OK;
|
|
}
|
|
|
|
MOZ_ASSERT(aType < ArrayLength(sBluetoothDBusIfaces));
|
|
const char* interface = sBluetoothDBusIfaces[aType];
|
|
|
|
/* Compose the command */
|
|
DBusMessage* msg = dbus_message_new_method_call(
|
|
"org.bluez",
|
|
NS_ConvertUTF16toUTF8(sAdapterPath).get(),
|
|
interface,
|
|
"SetProperty");
|
|
|
|
if (!msg) {
|
|
BT_WARNING("Could not allocate D-Bus message object!");
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
nsCString intermediatePropName(NS_ConvertUTF16toUTF8(aValue.name()));
|
|
const char* propName = intermediatePropName.get();
|
|
if (!dbus_message_append_args(msg, DBUS_TYPE_STRING, &propName,
|
|
DBUS_TYPE_INVALID)) {
|
|
BT_WARNING("Couldn't append arguments to dbus message!");
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
int type;
|
|
int tmp_int;
|
|
void* val;
|
|
nsCString str;
|
|
if (aValue.value().type() == BluetoothValue::Tuint32_t) {
|
|
tmp_int = aValue.value().get_uint32_t();
|
|
val = &tmp_int;
|
|
type = DBUS_TYPE_UINT32;
|
|
} else if (aValue.value().type() == BluetoothValue::TnsString) {
|
|
str = NS_ConvertUTF16toUTF8(aValue.value().get_nsString());
|
|
const char* tempStr = str.get();
|
|
val = &tempStr;
|
|
type = DBUS_TYPE_STRING;
|
|
} else if (aValue.value().type() == BluetoothValue::Tbool) {
|
|
tmp_int = aValue.value().get_bool() ? 1 : 0;
|
|
val = &(tmp_int);
|
|
type = DBUS_TYPE_BOOLEAN;
|
|
} else {
|
|
BT_WARNING("Property type not handled!");
|
|
dbus_message_unref(msg);
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
DBusMessageIter value_iter, iter;
|
|
dbus_message_iter_init_append(msg, &iter);
|
|
char var_type[2] = {(char)type, '\0'};
|
|
if (!dbus_message_iter_open_container(&iter, DBUS_TYPE_VARIANT,
|
|
var_type, &value_iter) ||
|
|
!dbus_message_iter_append_basic(&value_iter, type, val) ||
|
|
!dbus_message_iter_close_container(&iter, &value_iter)) {
|
|
BT_WARNING("Could not append argument to method call!");
|
|
dbus_message_unref(msg);
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
nsRefPtr<BluetoothReplyRunnable> runnable = aRunnable;
|
|
|
|
// msg is unref'd as part of SendWithReply
|
|
if (!SendWithReply(GetVoidCallback, (void*)aRunnable, 1000, msg)) {
|
|
BT_WARNING("SendWithReply failed");
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
runnable.forget();
|
|
return NS_OK;
|
|
}
|
|
|
|
bool
|
|
BluetoothDBusService::GetDevicePath(const nsAString& aAdapterPath,
|
|
const nsAString& aDeviceAddress,
|
|
nsAString& aDevicePath)
|
|
{
|
|
aDevicePath = GetObjectPathFromAddress(aAdapterPath, aDeviceAddress);
|
|
return true;
|
|
}
|
|
|
|
nsresult
|
|
BluetoothDBusService::CreatePairedDeviceInternal(
|
|
const nsAString& aDeviceAddress,
|
|
int aTimeout,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
const char *capabilities = B2G_AGENT_CAPABILITIES;
|
|
const char *deviceAgentPath = KEY_REMOTE_AGENT;
|
|
|
|
nsCString tempDeviceAddress = NS_ConvertUTF16toUTF8(aDeviceAddress);
|
|
const char *deviceAddress = tempDeviceAddress.get();
|
|
|
|
/**
|
|
* FIXME: Bug 820274
|
|
*
|
|
* If the user turns off Bluetooth in the middle of pairing process, the
|
|
* callback function GetObjectPathCallback (see the third argument of the
|
|
* function call above) may still be called while enabling next time by
|
|
* dbus daemon. To prevent this from happening, added a flag to distinguish
|
|
* if Bluetooth has been turned off. Nevertheless, we need a check if there
|
|
* is a better solution.
|
|
*
|
|
* Please see Bug 818696 for more information.
|
|
*/
|
|
sIsPairing++;
|
|
|
|
nsRefPtr<BluetoothReplyRunnable> runnable = aRunnable;
|
|
|
|
// Then send CreatePairedDevice, it will register a temp device agent then
|
|
// unregister it after pairing process is over
|
|
bool ret = SendWithReply(GetObjectPathCallback, (void*)runnable, aTimeout,
|
|
NS_ConvertUTF16toUTF8(sAdapterPath).get(),
|
|
DBUS_ADAPTER_IFACE,
|
|
"CreatePairedDevice",
|
|
DBUS_TYPE_STRING, &deviceAddress,
|
|
DBUS_TYPE_OBJECT_PATH, &deviceAgentPath,
|
|
DBUS_TYPE_STRING, &capabilities,
|
|
DBUS_TYPE_INVALID);
|
|
if (!ret) {
|
|
BT_WARNING("Could not start async function!");
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
runnable.forget();
|
|
return NS_OK;
|
|
}
|
|
|
|
static void
|
|
OnRemoveDeviceReply(DBusMessage *aReply, void *aData)
|
|
{
|
|
nsAutoString errorStr;
|
|
|
|
if (!aReply) {
|
|
errorStr.AssignLiteral("RemoveDevice failed");
|
|
}
|
|
|
|
nsRefPtr<BluetoothReplyRunnable> runnable =
|
|
dont_AddRef<BluetoothReplyRunnable>(static_cast<BluetoothReplyRunnable*>(aData));
|
|
|
|
DispatchBluetoothReply(runnable.get(), BluetoothValue(true), errorStr);
|
|
}
|
|
|
|
nsresult
|
|
BluetoothDBusService::RemoveDeviceInternal(const nsAString& aDeviceAddress,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
if (!IsReady()) {
|
|
NS_NAMED_LITERAL_STRING(errorStr, "Bluetooth service is not ready yet!");
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(), errorStr);
|
|
return NS_OK;
|
|
}
|
|
|
|
nsCString deviceObjectPath =
|
|
NS_ConvertUTF16toUTF8(GetObjectPathFromAddress(sAdapterPath,
|
|
aDeviceAddress));
|
|
const char* cstrDeviceObjectPath = deviceObjectPath.get();
|
|
|
|
nsRefPtr<BluetoothReplyRunnable> runnable(aRunnable);
|
|
|
|
bool success = SendWithReply(OnRemoveDeviceReply,
|
|
static_cast<void*>(runnable.get()), -1,
|
|
NS_ConvertUTF16toUTF8(sAdapterPath).get(),
|
|
DBUS_ADAPTER_IFACE, "RemoveDevice",
|
|
DBUS_TYPE_OBJECT_PATH, &cstrDeviceObjectPath,
|
|
DBUS_TYPE_INVALID);
|
|
|
|
NS_ENSURE_TRUE(success, NS_ERROR_FAILURE);
|
|
|
|
runnable.forget();
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
bool
|
|
BluetoothDBusService::SetPinCodeInternal(const nsAString& aDeviceAddress,
|
|
const nsAString& aPinCode,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
nsAutoString errorStr;
|
|
BluetoothValue v = true;
|
|
DBusMessage *msg;
|
|
if (!sPairingReqTable->Get(aDeviceAddress, &msg)) {
|
|
BT_WARNING("%s: Couldn't get original request message.", __FUNCTION__);
|
|
errorStr.AssignLiteral("Couldn't get original request message.");
|
|
DispatchBluetoothReply(aRunnable, v, errorStr);
|
|
return false;
|
|
}
|
|
|
|
DBusMessage *reply = dbus_message_new_method_return(msg);
|
|
|
|
if (!reply) {
|
|
BT_WARNING("%s: Memory can't be allocated for the message.", __FUNCTION__);
|
|
dbus_message_unref(msg);
|
|
errorStr.AssignLiteral("Memory can't be allocated for the message.");
|
|
DispatchBluetoothReply(aRunnable, v, errorStr);
|
|
return false;
|
|
}
|
|
|
|
bool result;
|
|
|
|
nsCString tempPinCode = NS_ConvertUTF16toUTF8(aPinCode);
|
|
const char* pinCode = tempPinCode.get();
|
|
|
|
if (!dbus_message_append_args(reply,
|
|
DBUS_TYPE_STRING, &pinCode,
|
|
DBUS_TYPE_INVALID)) {
|
|
BT_WARNING("%s: Couldn't append arguments to dbus message.", __FUNCTION__);
|
|
errorStr.AssignLiteral("Couldn't append arguments to dbus message.");
|
|
result = false;
|
|
} else {
|
|
result = Send(reply);
|
|
}
|
|
|
|
dbus_message_unref(msg);
|
|
dbus_message_unref(reply);
|
|
|
|
sPairingReqTable->Remove(aDeviceAddress);
|
|
DispatchBluetoothReply(aRunnable, v, errorStr);
|
|
return result;
|
|
}
|
|
|
|
bool
|
|
BluetoothDBusService::SetPasskeyInternal(const nsAString& aDeviceAddress,
|
|
uint32_t aPasskey,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
nsAutoString errorStr;
|
|
BluetoothValue v = true;
|
|
DBusMessage *msg;
|
|
if (!sPairingReqTable->Get(aDeviceAddress, &msg)) {
|
|
BT_WARNING("%s: Couldn't get original request message.", __FUNCTION__);
|
|
errorStr.AssignLiteral("Couldn't get original request message.");
|
|
DispatchBluetoothReply(aRunnable, v, errorStr);
|
|
return false;
|
|
}
|
|
|
|
DBusMessage *reply = dbus_message_new_method_return(msg);
|
|
|
|
if (!reply) {
|
|
BT_WARNING("%s: Memory can't be allocated for the message.", __FUNCTION__);
|
|
dbus_message_unref(msg);
|
|
errorStr.AssignLiteral("Memory can't be allocated for the message.");
|
|
DispatchBluetoothReply(aRunnable, v, errorStr);
|
|
return false;
|
|
}
|
|
|
|
uint32_t passkey = aPasskey;
|
|
bool result;
|
|
|
|
if (!dbus_message_append_args(reply,
|
|
DBUS_TYPE_UINT32, &passkey,
|
|
DBUS_TYPE_INVALID)) {
|
|
BT_WARNING("%s: Couldn't append arguments to dbus message.", __FUNCTION__);
|
|
errorStr.AssignLiteral("Couldn't append arguments to dbus message.");
|
|
result = false;
|
|
} else {
|
|
result = Send(reply);
|
|
}
|
|
|
|
dbus_message_unref(msg);
|
|
dbus_message_unref(reply);
|
|
|
|
sPairingReqTable->Remove(aDeviceAddress);
|
|
DispatchBluetoothReply(aRunnable, v, errorStr);
|
|
return result;
|
|
}
|
|
|
|
bool
|
|
BluetoothDBusService::SetPairingConfirmationInternal(
|
|
const nsAString& aDeviceAddress,
|
|
bool aConfirm,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
nsAutoString errorStr;
|
|
BluetoothValue v = true;
|
|
DBusMessage *msg;
|
|
if (!sPairingReqTable->Get(aDeviceAddress, &msg)) {
|
|
BT_WARNING("%s: Couldn't get original request message.", __FUNCTION__);
|
|
errorStr.AssignLiteral("Couldn't get original request message.");
|
|
DispatchBluetoothReply(aRunnable, v, errorStr);
|
|
return false;
|
|
}
|
|
|
|
DBusMessage *reply;
|
|
|
|
if (aConfirm) {
|
|
reply = dbus_message_new_method_return(msg);
|
|
} else {
|
|
reply = dbus_message_new_error(msg, "org.bluez.Error.Rejected",
|
|
"User rejected confirmation");
|
|
}
|
|
|
|
if (!reply) {
|
|
BT_WARNING("%s: Memory can't be allocated for the message.", __FUNCTION__);
|
|
dbus_message_unref(msg);
|
|
errorStr.AssignLiteral("Memory can't be allocated for the message.");
|
|
DispatchBluetoothReply(aRunnable, v, errorStr);
|
|
return false;
|
|
}
|
|
|
|
bool result = Send(reply);
|
|
if (!result) {
|
|
errorStr.AssignLiteral("Can't send message!");
|
|
}
|
|
dbus_message_unref(msg);
|
|
dbus_message_unref(reply);
|
|
|
|
sPairingReqTable->Remove(aDeviceAddress);
|
|
DispatchBluetoothReply(aRunnable, v, errorStr);
|
|
return result;
|
|
}
|
|
|
|
static void
|
|
DestroyBluetoothProfileController()
|
|
{
|
|
sController = nullptr;
|
|
}
|
|
|
|
void
|
|
BluetoothDBusService::Connect(const nsAString& aDeviceAddress,
|
|
uint32_t aCod,
|
|
uint16_t aServiceUuid,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
MOZ_ASSERT(aRunnable);
|
|
|
|
BluetoothServiceClass serviceClass =
|
|
BluetoothUuidHelper::GetBluetoothServiceClass(aServiceUuid);
|
|
|
|
if (sController) {
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(),
|
|
NS_LITERAL_STRING(ERR_NO_AVAILABLE_RESOURCE));
|
|
return;
|
|
}
|
|
|
|
sController =
|
|
new BluetoothProfileController(aDeviceAddress, aRunnable,
|
|
DestroyBluetoothProfileController);
|
|
if (aServiceUuid) {
|
|
sController->Connect(serviceClass);
|
|
} else {
|
|
sController->Connect(aCod);
|
|
}
|
|
}
|
|
|
|
void
|
|
BluetoothDBusService::Disconnect(const nsAString& aDeviceAddress,
|
|
uint16_t aServiceUuid,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
MOZ_ASSERT(aRunnable);
|
|
|
|
BluetoothServiceClass serviceClass =
|
|
BluetoothUuidHelper::GetBluetoothServiceClass(aServiceUuid);
|
|
|
|
if (sController) {
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(),
|
|
NS_LITERAL_STRING(ERR_NO_AVAILABLE_RESOURCE));
|
|
return;
|
|
}
|
|
|
|
sController =
|
|
new BluetoothProfileController(aDeviceAddress, aRunnable,
|
|
DestroyBluetoothProfileController);
|
|
if (aServiceUuid) {
|
|
sController->Disconnect(serviceClass);
|
|
} else {
|
|
sController->Disconnect();
|
|
}
|
|
}
|
|
|
|
bool
|
|
BluetoothDBusService::IsConnected(const uint16_t aServiceUuid)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
BluetoothProfileManagerBase* profile =
|
|
BluetoothUuidHelper::GetBluetoothProfileManager(aServiceUuid);
|
|
if (!profile) {
|
|
BT_WARNING(ERR_UNKNOWN_PROFILE);
|
|
return false;
|
|
}
|
|
|
|
NS_ENSURE_TRUE(profile, false);
|
|
return profile->IsConnected();
|
|
}
|
|
|
|
class OnUpdateSdpRecordsRunnable : public nsRunnable
|
|
{
|
|
public:
|
|
OnUpdateSdpRecordsRunnable(const nsAString& aObjectPath,
|
|
BluetoothProfileManagerBase* aManager)
|
|
: mManager(aManager)
|
|
{
|
|
MOZ_ASSERT(!aObjectPath.IsEmpty());
|
|
MOZ_ASSERT(aManager);
|
|
|
|
mDeviceAddress = GetAddressFromObjectPath(aObjectPath);
|
|
}
|
|
|
|
nsresult
|
|
Run()
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
mManager->OnUpdateSdpRecords(mDeviceAddress);
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
private:
|
|
nsString mDeviceAddress;
|
|
BluetoothProfileManagerBase* mManager;
|
|
};
|
|
|
|
class OnGetServiceChannelRunnable : public nsRunnable
|
|
{
|
|
public:
|
|
OnGetServiceChannelRunnable(const nsAString& aObjectPath,
|
|
const nsAString& aServiceUuid,
|
|
int aChannel,
|
|
BluetoothProfileManagerBase* aManager)
|
|
: mServiceUuid(aServiceUuid),
|
|
mChannel(aChannel),
|
|
mManager(aManager)
|
|
{
|
|
MOZ_ASSERT(!aObjectPath.IsEmpty());
|
|
MOZ_ASSERT(!aServiceUuid.IsEmpty());
|
|
MOZ_ASSERT(aManager);
|
|
|
|
mDeviceAddress = GetAddressFromObjectPath(aObjectPath);
|
|
}
|
|
|
|
NS_IMETHOD Run()
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
mManager->OnGetServiceChannel(mDeviceAddress, mServiceUuid, mChannel);
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
private:
|
|
nsString mDeviceAddress;
|
|
nsString mServiceUuid;
|
|
int mChannel;
|
|
BluetoothProfileManagerBase* mManager;
|
|
};
|
|
|
|
class OnGetServiceChannelReplyHandler : public DBusReplyHandler
|
|
{
|
|
public:
|
|
OnGetServiceChannelReplyHandler(const nsAString& aObjectPath,
|
|
const nsAString& aServiceUUID,
|
|
BluetoothProfileManagerBase* aBluetoothProfileManager)
|
|
: mObjectPath(aObjectPath),
|
|
mServiceUUID(aServiceUUID),
|
|
mBluetoothProfileManager(aBluetoothProfileManager)
|
|
{
|
|
MOZ_ASSERT(mBluetoothProfileManager);
|
|
}
|
|
|
|
void Handle(DBusMessage* aReply)
|
|
{
|
|
MOZ_ASSERT(!NS_IsMainThread()); // DBus thread
|
|
|
|
// The default channel is an invalid value of -1. We
|
|
// update it if we have received a correct reply. Both
|
|
// cases, valid and invalid channel numbers, are handled
|
|
// in BluetoothProfileManagerBase::OnGetServiceChannel.
|
|
|
|
int channel = -1;
|
|
|
|
if (aReply && (dbus_message_get_type(aReply) != DBUS_MESSAGE_TYPE_ERROR)) {
|
|
channel = dbus_returns_int32(aReply);
|
|
}
|
|
|
|
nsRefPtr<nsRunnable> r = new OnGetServiceChannelRunnable(mObjectPath,
|
|
mServiceUUID,
|
|
channel,
|
|
mBluetoothProfileManager);
|
|
nsresult rv = NS_DispatchToMainThread(r);
|
|
NS_ENSURE_SUCCESS_VOID(rv);
|
|
}
|
|
|
|
private:
|
|
nsString mObjectPath;
|
|
nsString mServiceUUID;
|
|
BluetoothProfileManagerBase* mBluetoothProfileManager;
|
|
};
|
|
|
|
nsresult
|
|
BluetoothDBusService::GetServiceChannel(const nsAString& aDeviceAddress,
|
|
const nsAString& aServiceUUID,
|
|
BluetoothProfileManagerBase* aManager)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
nsString objectPath(GetObjectPathFromAddress(sAdapterPath, aDeviceAddress));
|
|
|
|
#ifdef MOZ_WIDGET_GONK
|
|
static const int sProtocolDescriptorList = 0x0004;
|
|
|
|
// GetServiceAttributeValue only exists in android's bluez dbus binding
|
|
// implementation
|
|
nsCString serviceUUID = NS_ConvertUTF16toUTF8(aServiceUUID);
|
|
const char* cstrServiceUUID = serviceUUID.get();
|
|
|
|
nsRefPtr<OnGetServiceChannelReplyHandler> handler =
|
|
new OnGetServiceChannelReplyHandler(objectPath, aServiceUUID, aManager);
|
|
|
|
bool success = SendWithReply(OnGetServiceChannelReplyHandler::Callback,
|
|
handler, -1,
|
|
NS_ConvertUTF16toUTF8(objectPath).get(),
|
|
DBUS_DEVICE_IFACE, "GetServiceAttributeValue",
|
|
DBUS_TYPE_STRING, &cstrServiceUUID,
|
|
DBUS_TYPE_UINT16, &sProtocolDescriptorList,
|
|
DBUS_TYPE_INVALID);
|
|
NS_ENSURE_TRUE(success, NS_ERROR_FAILURE);
|
|
|
|
handler.forget();
|
|
#else
|
|
// FIXME/Bug 793977 qdot: Just set something for desktop, until we have a
|
|
// parser for the GetServiceAttributes xml block
|
|
//
|
|
// Even though we are on the main thread already, we need to dispatch a
|
|
// runnable here. OnGetServiceChannel needs mRunnable to be set, which
|
|
// happens after GetServiceChannel returns.
|
|
nsRefPtr<nsRunnable> r = new OnGetServiceChannelRunnable(objectPath,
|
|
aServiceUUID,
|
|
1,
|
|
aManager);
|
|
NS_DispatchToMainThread(r);
|
|
#endif
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
static void
|
|
DiscoverServicesCallback(DBusMessage* aMsg, void* aData)
|
|
{
|
|
MOZ_ASSERT(!NS_IsMainThread());
|
|
|
|
nsRefPtr<OnUpdateSdpRecordsRunnable> r(
|
|
static_cast<OnUpdateSdpRecordsRunnable*>(aData));
|
|
NS_DispatchToMainThread(r);
|
|
}
|
|
|
|
bool
|
|
BluetoothDBusService::UpdateSdpRecords(const nsAString& aDeviceAddress,
|
|
BluetoothProfileManagerBase* aManager)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
MOZ_ASSERT(!aDeviceAddress.IsEmpty());
|
|
MOZ_ASSERT(aManager);
|
|
MOZ_ASSERT(mConnection);
|
|
|
|
nsString objectPath(GetObjectPathFromAddress(sAdapterPath, aDeviceAddress));
|
|
|
|
// I choose to use raw pointer here because this is going to be passed as an
|
|
// argument into SendWithReply() at once.
|
|
OnUpdateSdpRecordsRunnable* callbackRunnable =
|
|
new OnUpdateSdpRecordsRunnable(objectPath, aManager);
|
|
|
|
return SendWithReply(DiscoverServicesCallback,
|
|
(void*)callbackRunnable, -1,
|
|
NS_ConvertUTF16toUTF8(objectPath).get(),
|
|
DBUS_DEVICE_IFACE,
|
|
"DiscoverServices",
|
|
DBUS_TYPE_STRING, &EmptyCString(),
|
|
DBUS_TYPE_INVALID);
|
|
}
|
|
|
|
nsresult
|
|
BluetoothDBusService::GetScoSocket(const nsAString& aAddress,
|
|
bool aAuth,
|
|
bool aEncrypt,
|
|
mozilla::ipc::UnixSocketConsumer* aConsumer)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
if (!mConnection || !gThreadConnection) {
|
|
NS_ERROR("Bluetooth service not started yet!");
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
BluetoothUnixSocketConnector* c =
|
|
new BluetoothUnixSocketConnector(BluetoothSocketType::SCO, -1,
|
|
aAuth, aEncrypt);
|
|
|
|
if (!aConsumer->ConnectSocket(c, NS_ConvertUTF16toUTF8(aAddress).get())) {
|
|
nsAutoString replyError;
|
|
replyError.AssignLiteral("SocketConnectionError");
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
void
|
|
BluetoothDBusService::SendFile(const nsAString& aDeviceAddress,
|
|
BlobParent* aBlobParent,
|
|
BlobChild* aBlobChild,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
// Currently we only support one device sending one file at a time,
|
|
// so we don't need aDeviceAddress here because the target device
|
|
// has been determined when calling 'Connect()'. Nevertheless, keep
|
|
// it for future use.
|
|
BluetoothOppManager* opp = BluetoothOppManager::Get();
|
|
NS_ENSURE_TRUE_VOID(opp);
|
|
|
|
nsAutoString errorStr;
|
|
if (!opp->SendFile(aDeviceAddress, aBlobParent)) {
|
|
errorStr.AssignLiteral("Calling SendFile() failed");
|
|
}
|
|
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(true), errorStr);
|
|
}
|
|
|
|
void
|
|
BluetoothDBusService::StopSendingFile(const nsAString& aDeviceAddress,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
// Currently we only support one device sending one file at a time,
|
|
// so we don't need aDeviceAddress here because the target device
|
|
// has been determined when calling 'Connect()'. Nevertheless, keep
|
|
// it for future use.
|
|
BluetoothOppManager* opp = BluetoothOppManager::Get();
|
|
NS_ENSURE_TRUE_VOID(opp);
|
|
|
|
nsAutoString errorStr;
|
|
if (!opp->StopSendingFile()) {
|
|
errorStr.AssignLiteral("Calling StopSendingFile() failed");
|
|
}
|
|
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(true), errorStr);
|
|
}
|
|
|
|
void
|
|
BluetoothDBusService::ConfirmReceivingFile(const nsAString& aDeviceAddress,
|
|
bool aConfirm,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
NS_ASSERTION(NS_IsMainThread(), "Must be called from main thread!");
|
|
|
|
// Currently we only support one device sending one file at a time,
|
|
// so we don't need aDeviceAddress here because the target device
|
|
// has been determined when calling 'Connect()'. Nevertheless, keep
|
|
// it for future use.
|
|
BluetoothOppManager* opp = BluetoothOppManager::Get();
|
|
NS_ENSURE_TRUE_VOID(opp);
|
|
|
|
nsAutoString errorStr;
|
|
if (!opp->ConfirmReceivingFile(aConfirm)) {
|
|
errorStr.AssignLiteral("Calling ConfirmReceivingFile() failed");
|
|
}
|
|
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(true), errorStr);
|
|
}
|
|
|
|
void
|
|
BluetoothDBusService::ConnectSco(BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
BluetoothHfpManager* hfp = BluetoothHfpManager::Get();
|
|
NS_ENSURE_TRUE_VOID(hfp);
|
|
if (!hfp->ConnectSco(aRunnable)) {
|
|
NS_NAMED_LITERAL_STRING(replyError,
|
|
"SCO socket exists or HFP is not connected");
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(), replyError);
|
|
}
|
|
}
|
|
|
|
void
|
|
BluetoothDBusService::DisconnectSco(BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
BluetoothHfpManager* hfp = BluetoothHfpManager::Get();
|
|
NS_ENSURE_TRUE_VOID(hfp);
|
|
if (hfp->DisconnectSco()) {
|
|
DispatchBluetoothReply(aRunnable,
|
|
BluetoothValue(true), NS_LITERAL_STRING(""));
|
|
return;
|
|
}
|
|
|
|
NS_NAMED_LITERAL_STRING(replyError,
|
|
"SCO socket doesn't exist or HFP is not connected");
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(), replyError);
|
|
}
|
|
|
|
void
|
|
BluetoothDBusService::IsScoConnected(BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
BluetoothHfpManager* hfp = BluetoothHfpManager::Get();
|
|
NS_ENSURE_TRUE_VOID(hfp);
|
|
DispatchBluetoothReply(aRunnable,
|
|
hfp->IsScoConnected(), EmptyString());
|
|
}
|
|
|
|
void
|
|
BluetoothDBusService::SendMetaData(const nsAString& aTitle,
|
|
const nsAString& aArtist,
|
|
const nsAString& aAlbum,
|
|
int64_t aMediaNumber,
|
|
int64_t aTotalMediaCount,
|
|
int64_t aDuration,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
if (!IsReady()) {
|
|
NS_NAMED_LITERAL_STRING(errorStr, "Bluetooth service is not ready yet!");
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(), errorStr);
|
|
return;
|
|
}
|
|
|
|
BluetoothA2dpManager* a2dp = BluetoothA2dpManager::Get();
|
|
NS_ENSURE_TRUE_VOID(a2dp);
|
|
|
|
if (!a2dp->IsConnected()) {
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(),
|
|
NS_LITERAL_STRING(ERR_A2DP_IS_DISCONNECTED));
|
|
return;
|
|
} else if (!a2dp->IsAvrcpConnected()) {
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(),
|
|
NS_LITERAL_STRING(ERR_AVRCP_IS_DISCONNECTED));
|
|
return;
|
|
}
|
|
|
|
nsAutoString address;
|
|
a2dp->GetAddress(address);
|
|
nsString objectPath =
|
|
GetObjectPathFromAddress(sAdapterPath, address);
|
|
|
|
nsCString tempTitle = NS_ConvertUTF16toUTF8(aTitle);
|
|
nsCString tempArtist = NS_ConvertUTF16toUTF8(aArtist);
|
|
nsCString tempAlbum = NS_ConvertUTF16toUTF8(aAlbum);
|
|
|
|
nsCString tempMediaNumber = EmptyCString();
|
|
nsCString tempTotalMediaCount = EmptyCString();
|
|
nsCString tempDuration = EmptyCString();
|
|
if (aMediaNumber >= 0) {
|
|
tempMediaNumber.AppendInt(aMediaNumber);
|
|
}
|
|
if (aTotalMediaCount >= 0) {
|
|
tempTotalMediaCount.AppendInt(aTotalMediaCount);
|
|
}
|
|
if (aDuration >= 0) {
|
|
tempDuration.AppendInt(aDuration);
|
|
}
|
|
|
|
const char* title = tempTitle.get();
|
|
const char* album = tempAlbum.get();
|
|
const char* artist = tempArtist.get();
|
|
const char* mediaNumber = tempMediaNumber.get();
|
|
const char* totalMediaCount = tempTotalMediaCount.get();
|
|
const char* duration = tempDuration.get();
|
|
|
|
nsAutoString prevTitle, prevAlbum;
|
|
a2dp->GetTitle(prevTitle);
|
|
a2dp->GetAlbum(prevAlbum);
|
|
|
|
if (aMediaNumber != a2dp->GetMediaNumber() ||
|
|
!aTitle.Equals(prevTitle) ||
|
|
!aAlbum.Equals(prevAlbum)) {
|
|
UpdateNotification(ControlEventId::EVENT_TRACK_CHANGED, aMediaNumber);
|
|
}
|
|
|
|
nsRefPtr<BluetoothReplyRunnable> runnable(aRunnable);
|
|
|
|
bool ret = SendWithReply(GetVoidCallback, (void*)runnable.get(), -1,
|
|
NS_ConvertUTF16toUTF8(objectPath).get(),
|
|
DBUS_CTL_IFACE, "UpdateMetaData",
|
|
DBUS_TYPE_STRING, &title,
|
|
DBUS_TYPE_STRING, &artist,
|
|
DBUS_TYPE_STRING, &album,
|
|
DBUS_TYPE_STRING, &mediaNumber,
|
|
DBUS_TYPE_STRING, &totalMediaCount,
|
|
DBUS_TYPE_STRING, &duration,
|
|
DBUS_TYPE_INVALID);
|
|
NS_ENSURE_TRUE_VOID(ret);
|
|
|
|
runnable.forget();
|
|
|
|
a2dp->UpdateMetaData(aTitle, aArtist, aAlbum,
|
|
aMediaNumber, aTotalMediaCount, aDuration);
|
|
}
|
|
|
|
static ControlPlayStatus
|
|
PlayStatusStringToControlPlayStatus(const nsAString& aPlayStatus)
|
|
{
|
|
ControlPlayStatus playStatus = ControlPlayStatus::PLAYSTATUS_UNKNOWN;
|
|
if (aPlayStatus.EqualsLiteral("STOPPED")) {
|
|
playStatus = ControlPlayStatus::PLAYSTATUS_STOPPED;
|
|
} else if (aPlayStatus.EqualsLiteral("PLAYING")) {
|
|
playStatus = ControlPlayStatus::PLAYSTATUS_PLAYING;
|
|
} else if (aPlayStatus.EqualsLiteral("PAUSED")) {
|
|
playStatus = ControlPlayStatus::PLAYSTATUS_PAUSED;
|
|
} else if (aPlayStatus.EqualsLiteral("FWD_SEEK")) {
|
|
playStatus = ControlPlayStatus::PLAYSTATUS_FWD_SEEK;
|
|
} else if (aPlayStatus.EqualsLiteral("REV_SEEK")) {
|
|
playStatus = ControlPlayStatus::PLAYSTATUS_REV_SEEK;
|
|
} else if (aPlayStatus.EqualsLiteral("ERROR")) {
|
|
playStatus = ControlPlayStatus::PLAYSTATUS_ERROR;
|
|
}
|
|
|
|
return playStatus;
|
|
}
|
|
|
|
void
|
|
BluetoothDBusService::SendPlayStatus(int64_t aDuration,
|
|
int64_t aPosition,
|
|
const nsAString& aPlayStatus,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
if (!IsReady()) {
|
|
NS_NAMED_LITERAL_STRING(errorStr, "Bluetooth service is not ready yet!");
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(), errorStr);
|
|
return;
|
|
}
|
|
|
|
ControlPlayStatus playStatus =
|
|
PlayStatusStringToControlPlayStatus(aPlayStatus);
|
|
if (playStatus == ControlPlayStatus::PLAYSTATUS_UNKNOWN) {
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(),
|
|
NS_LITERAL_STRING("Invalid play status"));
|
|
return;
|
|
} else if (aDuration < 0) {
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(),
|
|
NS_LITERAL_STRING("Invalid duration"));
|
|
return;
|
|
} else if (aPosition < 0) {
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(),
|
|
NS_LITERAL_STRING("Invalid position"));
|
|
return;
|
|
}
|
|
|
|
BluetoothA2dpManager* a2dp = BluetoothA2dpManager::Get();
|
|
NS_ENSURE_TRUE_VOID(a2dp);
|
|
|
|
if (!a2dp->IsConnected()) {
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(),
|
|
NS_LITERAL_STRING(ERR_A2DP_IS_DISCONNECTED));
|
|
return;
|
|
} else if (!a2dp->IsAvrcpConnected()) {
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(),
|
|
NS_LITERAL_STRING(ERR_AVRCP_IS_DISCONNECTED));
|
|
return;
|
|
}
|
|
|
|
uint32_t tempPlayStatus = playStatus;
|
|
if (playStatus != a2dp->GetPlayStatus()) {
|
|
UpdateNotification(ControlEventId::EVENT_PLAYBACK_STATUS_CHANGED,
|
|
tempPlayStatus);
|
|
} else if (aPosition != a2dp->GetPosition()) {
|
|
UpdateNotification(ControlEventId::EVENT_PLAYBACK_POS_CHANGED, aPosition);
|
|
}
|
|
|
|
nsAutoString address;
|
|
a2dp->GetAddress(address);
|
|
nsString objectPath =
|
|
GetObjectPathFromAddress(sAdapterPath, address);
|
|
|
|
nsRefPtr<BluetoothReplyRunnable> runnable(aRunnable);
|
|
|
|
bool ret = SendWithReply(GetVoidCallback, (void*)runnable.get(), -1,
|
|
NS_ConvertUTF16toUTF8(objectPath).get(),
|
|
DBUS_CTL_IFACE, "UpdatePlayStatus",
|
|
DBUS_TYPE_UINT32, &aDuration,
|
|
DBUS_TYPE_UINT32, &aPosition,
|
|
DBUS_TYPE_UINT32, &tempPlayStatus,
|
|
DBUS_TYPE_INVALID);
|
|
NS_ENSURE_TRUE_VOID(ret);
|
|
|
|
runnable.forget();
|
|
|
|
a2dp->UpdatePlayStatus(aDuration, aPosition, playStatus);
|
|
}
|
|
|
|
static void
|
|
ControlCallback(DBusMessage* aMsg, void* aParam)
|
|
{
|
|
NS_ENSURE_TRUE_VOID(aMsg);
|
|
|
|
BluetoothValue v;
|
|
nsAutoString replyError;
|
|
UnpackVoidMessage(aMsg, nullptr, v, replyError);
|
|
if (!v.get_bool()) {
|
|
BT_WARNING(NS_ConvertUTF16toUTF8(replyError).get());
|
|
}
|
|
}
|
|
|
|
void
|
|
BluetoothDBusService::UpdatePlayStatus(uint32_t aDuration,
|
|
uint32_t aPosition,
|
|
ControlPlayStatus aPlayStatus)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
NS_ENSURE_TRUE_VOID(this->IsReady());
|
|
|
|
BluetoothA2dpManager* a2dp = BluetoothA2dpManager::Get();
|
|
NS_ENSURE_TRUE_VOID(a2dp);
|
|
MOZ_ASSERT(a2dp->IsConnected());
|
|
MOZ_ASSERT(a2dp->IsAvrcpConnected());
|
|
|
|
nsAutoString address;
|
|
a2dp->GetAddress(address);
|
|
nsString objectPath =
|
|
GetObjectPathFromAddress(sAdapterPath, address);
|
|
|
|
uint32_t tempPlayStatus = aPlayStatus;
|
|
|
|
bool ret = SendWithReply(ControlCallback, nullptr, -1,
|
|
NS_ConvertUTF16toUTF8(objectPath).get(),
|
|
DBUS_CTL_IFACE, "UpdatePlayStatus",
|
|
DBUS_TYPE_UINT32, &aDuration,
|
|
DBUS_TYPE_UINT32, &aPosition,
|
|
DBUS_TYPE_UINT32, &tempPlayStatus,
|
|
DBUS_TYPE_INVALID);
|
|
NS_ENSURE_TRUE_VOID(ret);
|
|
}
|
|
|
|
void
|
|
BluetoothDBusService::UpdateNotification(ControlEventId aEventId,
|
|
uint64_t aData)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
NS_ENSURE_TRUE_VOID(this->IsReady());
|
|
|
|
BluetoothA2dpManager* a2dp = BluetoothA2dpManager::Get();
|
|
NS_ENSURE_TRUE_VOID(a2dp);
|
|
MOZ_ASSERT(a2dp->IsConnected());
|
|
MOZ_ASSERT(a2dp->IsAvrcpConnected());
|
|
|
|
nsAutoString address;
|
|
a2dp->GetAddress(address);
|
|
nsString objectPath =
|
|
GetObjectPathFromAddress(sAdapterPath, address);
|
|
uint16_t eventId = aEventId;
|
|
|
|
bool ret = SendWithReply(ControlCallback, nullptr, -1,
|
|
NS_ConvertUTF16toUTF8(objectPath).get(),
|
|
DBUS_CTL_IFACE,
|
|
"UpdateNotification",
|
|
DBUS_TYPE_UINT16, &eventId,
|
|
DBUS_TYPE_UINT64, &aData,
|
|
DBUS_TYPE_INVALID);
|
|
NS_ENSURE_TRUE_VOID(ret);
|
|
}
|