зеркало из https://github.com/mozilla/gecko-dev.git
1377 строки
38 KiB
C++
1377 строки
38 KiB
C++
/* -*- Mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; tab-width: 40 -*- */
|
|
/* vim: set ts=2 et sw=2 tw=80: */
|
|
/* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this file,
|
|
* You can obtain one at http://mozilla.org/MPL/2.0/. */
|
|
|
|
#include "base/basictypes.h"
|
|
|
|
#include "BluetoothHfpManager.h"
|
|
|
|
#include "BluetoothReplyRunnable.h"
|
|
#include "BluetoothScoManager.h"
|
|
#include "BluetoothService.h"
|
|
#include "BluetoothSocket.h"
|
|
#include "BluetoothUtils.h"
|
|
#include "BluetoothUuid.h"
|
|
|
|
#include "MobileConnection.h"
|
|
#include "mozilla/dom/bluetooth/BluetoothTypes.h"
|
|
#include "mozilla/Hal.h"
|
|
#include "mozilla/Services.h"
|
|
#include "mozilla/StaticPtr.h"
|
|
#include "nsContentUtils.h"
|
|
#include "nsIAudioManager.h"
|
|
#include "nsIObserverService.h"
|
|
#include "nsISettingsService.h"
|
|
#include "nsITelephonyProvider.h"
|
|
#include "nsRadioInterfaceLayer.h"
|
|
|
|
#define AUDIO_VOLUME_BT_SCO "audio.volume.bt_sco"
|
|
#define MOZSETTINGS_CHANGED_ID "mozsettings-changed"
|
|
#define MOBILE_CONNECTION_ICCINFO_CHANGED "mobile-connection-iccinfo-changed"
|
|
#define MOBILE_CONNECTION_VOICE_CHANGED "mobile-connection-voice-changed"
|
|
|
|
/**
|
|
* These constants are used in result code such as +CLIP and +CCWA. The value
|
|
* of these constants is the same as TOA_INTERNATIONAL/TOA_UNKNOWN defined in
|
|
* ril_consts.js
|
|
*/
|
|
#define TOA_UNKNOWN 0x81
|
|
#define TOA_INTERNATIONAL 0x91
|
|
|
|
#define CR_LF "\xd\xa";
|
|
|
|
using namespace mozilla;
|
|
using namespace mozilla::ipc;
|
|
USING_BLUETOOTH_NAMESPACE
|
|
|
|
namespace {
|
|
StaticAutoPtr<BluetoothHfpManager> gBluetoothHfpManager;
|
|
StaticRefPtr<BluetoothHfpManagerObserver> sHfpObserver;
|
|
bool gInShutdown = false;
|
|
static bool sStopSendingRingFlag = true;
|
|
static int sRingInterval = 3000; //unit: ms
|
|
static const char kHfpCrlf[] = "\xd\xa";
|
|
} // anonymous namespace
|
|
|
|
/* CallState for sCINDItems[CINDType::CALL].value
|
|
* - NO_CALL: there are no calls in progress
|
|
* - IN_PROGRESS: at least one call is in progress
|
|
*/
|
|
enum CallState {
|
|
NO_CALL,
|
|
IN_PROGRESS
|
|
};
|
|
|
|
/* CallSetupState for sCINDItems[CINDType::CALLSETUP].value
|
|
* - NO_CALLSETUP: not currently in call set up
|
|
* - INCOMING: an incoming call process ongoing
|
|
* - OUTGOING: an outgoing call set up is ongoing
|
|
* - OUTGOING_ALERTING: remote party being alerted in an outgoing call
|
|
*/
|
|
enum CallSetupState {
|
|
NO_CALLSETUP,
|
|
INCOMING,
|
|
OUTGOING,
|
|
OUTGOING_ALERTING
|
|
};
|
|
|
|
/* CallHeldState for sCINDItems[CINDType::CALLHELD].value
|
|
* - NO_CALLHELD: no calls held
|
|
* - ONHOLD_ACTIVE: both an active and a held call
|
|
* - ONHOLD_NOACTIVE: call on hold, no active call
|
|
*/
|
|
enum CallHeldState {
|
|
NO_CALLHELD,
|
|
ONHOLD_ACTIVE,
|
|
ONHOLD_NOACTIVE
|
|
};
|
|
|
|
typedef struct {
|
|
const char* name;
|
|
const char* range;
|
|
int value;
|
|
} CINDItem;
|
|
|
|
enum CINDType {
|
|
BATTCHG = 1,
|
|
CALL,
|
|
CALLHELD,
|
|
CALLSETUP,
|
|
SERVICE,
|
|
SIGNAL,
|
|
ROAM
|
|
};
|
|
|
|
static CINDItem sCINDItems[] = {
|
|
{},
|
|
{"battchg", "0-5", 5},
|
|
{"call", "0,1", CallState::NO_CALL},
|
|
{"callheld", "0-2", CallHeldState::NO_CALLHELD},
|
|
{"callsetup", "0-3", CallSetupState::NO_CALLSETUP},
|
|
{"service", "0,1", 0},
|
|
{"signal", "0-5", 0},
|
|
{"roam", "0,1", 0}
|
|
};
|
|
|
|
class mozilla::dom::bluetooth::Call {
|
|
public:
|
|
Call(uint16_t aState = nsITelephonyProvider::CALL_STATE_DISCONNECTED,
|
|
bool aDirection = false,
|
|
const nsAString& aNumber = NS_LITERAL_STRING(""),
|
|
int aType = TOA_UNKNOWN)
|
|
: mState(aState), mDirection(aDirection), mNumber(aNumber), mType(aType)
|
|
{
|
|
}
|
|
|
|
uint16_t mState;
|
|
bool mDirection; // true: incoming call; false: outgoing call
|
|
nsString mNumber;
|
|
int mType;
|
|
};
|
|
|
|
class mozilla::dom::bluetooth::BluetoothHfpManagerObserver : public nsIObserver
|
|
, public BatteryObserver
|
|
{
|
|
public:
|
|
NS_DECL_ISUPPORTS
|
|
NS_DECL_NSIOBSERVER
|
|
|
|
BluetoothHfpManagerObserver()
|
|
{
|
|
}
|
|
|
|
bool Init()
|
|
{
|
|
nsCOMPtr<nsIObserverService> obs = services::GetObserverService();
|
|
MOZ_ASSERT(obs);
|
|
if (NS_FAILED(obs->AddObserver(this, MOZSETTINGS_CHANGED_ID, false))) {
|
|
NS_WARNING("Failed to add settings change observer!");
|
|
return false;
|
|
}
|
|
|
|
if (NS_FAILED(obs->AddObserver(this, NS_XPCOM_SHUTDOWN_OBSERVER_ID, false))) {
|
|
NS_WARNING("Failed to add shutdown observer!");
|
|
return false;
|
|
}
|
|
|
|
if (NS_FAILED(obs->AddObserver(this, MOBILE_CONNECTION_ICCINFO_CHANGED, false))) {
|
|
NS_WARNING("Failed to add mobile connection iccinfo change observer!");
|
|
return false;
|
|
}
|
|
|
|
if (NS_FAILED(obs->AddObserver(this, MOBILE_CONNECTION_VOICE_CHANGED, false))) {
|
|
NS_WARNING("Failed to add mobile connection voice change observer!");
|
|
return false;
|
|
}
|
|
|
|
hal::RegisterBatteryObserver(this);
|
|
|
|
return true;
|
|
}
|
|
|
|
bool Shutdown()
|
|
{
|
|
nsCOMPtr<nsIObserverService> obs = services::GetObserverService();
|
|
if (!obs ||
|
|
NS_FAILED(obs->RemoveObserver(this, NS_XPCOM_SHUTDOWN_OBSERVER_ID)) ||
|
|
NS_FAILED(obs->RemoveObserver(this, MOZSETTINGS_CHANGED_ID)) ||
|
|
NS_FAILED(obs->RemoveObserver(this, MOBILE_CONNECTION_ICCINFO_CHANGED)) ||
|
|
NS_FAILED(obs->RemoveObserver(this, MOBILE_CONNECTION_VOICE_CHANGED))) {
|
|
NS_WARNING("Can't unregister observers, or already unregistered!");
|
|
return false;
|
|
}
|
|
|
|
hal::UnregisterBatteryObserver(this);
|
|
|
|
return true;
|
|
}
|
|
|
|
~BluetoothHfpManagerObserver()
|
|
{
|
|
Shutdown();
|
|
}
|
|
|
|
void Notify(const hal::BatteryInformation& aBatteryInfo)
|
|
{
|
|
// Range of battery level: [0, 1], double
|
|
// Range of CIND::BATTCHG: [0, 5], int
|
|
int level = ceil(aBatteryInfo.level() * 5.0);
|
|
if (level != sCINDItems[CINDType::BATTCHG].value) {
|
|
sCINDItems[CINDType::BATTCHG].value = level;
|
|
gBluetoothHfpManager->SendCommand("+CIEV: ", CINDType::BATTCHG);
|
|
}
|
|
}
|
|
};
|
|
|
|
class BluetoothHfpManager::GetVolumeTask : public nsISettingsServiceCallback
|
|
{
|
|
public:
|
|
NS_DECL_ISUPPORTS
|
|
|
|
NS_IMETHOD
|
|
Handle(const nsAString& aName, const JS::Value& aResult)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
JSContext *cx = nsContentUtils::GetCurrentJSContext();
|
|
NS_ENSURE_TRUE(cx, NS_OK);
|
|
|
|
if (!aResult.isNumber()) {
|
|
NS_WARNING("'" AUDIO_VOLUME_BT_SCO "' is not a number!");
|
|
return NS_OK;
|
|
}
|
|
|
|
BluetoothHfpManager* hfp = BluetoothHfpManager::Get();
|
|
hfp->mCurrentVgs = aResult.toNumber();
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
NS_IMETHOD
|
|
HandleError(const nsAString& aName)
|
|
{
|
|
NS_WARNING("Unable to get value for '" AUDIO_VOLUME_BT_SCO "'");
|
|
return NS_OK;
|
|
}
|
|
};
|
|
|
|
NS_IMPL_ISUPPORTS1(BluetoothHfpManager::GetVolumeTask,
|
|
nsISettingsServiceCallback);
|
|
|
|
NS_IMETHODIMP
|
|
BluetoothHfpManagerObserver::Observe(nsISupports* aSubject,
|
|
const char* aTopic,
|
|
const PRUnichar* aData)
|
|
{
|
|
MOZ_ASSERT(gBluetoothHfpManager);
|
|
|
|
if (!strcmp(aTopic, MOZSETTINGS_CHANGED_ID)) {
|
|
return gBluetoothHfpManager->HandleVolumeChanged(nsDependentString(aData));
|
|
} else if (!strcmp(aTopic, NS_XPCOM_SHUTDOWN_OBSERVER_ID)) {
|
|
return gBluetoothHfpManager->HandleShutdown();
|
|
} else if (!strcmp(aTopic, MOBILE_CONNECTION_ICCINFO_CHANGED)) {
|
|
return gBluetoothHfpManager->HandleIccInfoChanged();
|
|
} else if (!strcmp(aTopic, MOBILE_CONNECTION_VOICE_CHANGED)) {
|
|
return gBluetoothHfpManager->HandleVoiceConnectionChanged();
|
|
}
|
|
|
|
MOZ_ASSERT(false, "BluetoothHfpManager got unexpected topic!");
|
|
return NS_ERROR_UNEXPECTED;
|
|
}
|
|
|
|
NS_IMPL_ISUPPORTS1(BluetoothHfpManagerObserver, nsIObserver)
|
|
|
|
class BluetoothHfpManager::SendRingIndicatorTask : public Task
|
|
{
|
|
public:
|
|
SendRingIndicatorTask(const nsAString& aNumber, int aType)
|
|
: mNumber(aNumber)
|
|
, mType(aType)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
}
|
|
|
|
void Run() MOZ_OVERRIDE
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
// Stop sending RING indicator
|
|
if (sStopSendingRingFlag) {
|
|
return;
|
|
}
|
|
|
|
if (!gBluetoothHfpManager) {
|
|
NS_WARNING("BluetoothHfpManager no longer exists, cannot send ring!");
|
|
return;
|
|
}
|
|
|
|
nsAutoCString ringMsg(kHfpCrlf);
|
|
ringMsg.AppendLiteral("RING");
|
|
ringMsg.AppendLiteral(kHfpCrlf);
|
|
gBluetoothHfpManager->SendLine(ringMsg.get());
|
|
|
|
if (!mNumber.IsEmpty()) {
|
|
nsAutoCString clipMsg(kHfpCrlf);
|
|
clipMsg.AppendLiteral("+CLIP: \"");
|
|
clipMsg.Append(NS_ConvertUTF16toUTF8(mNumber).get());
|
|
clipMsg.AppendLiteral("\",");
|
|
clipMsg.AppendInt(mType);
|
|
clipMsg.AppendLiteral(kHfpCrlf);
|
|
gBluetoothHfpManager->SendLine(clipMsg.get());
|
|
}
|
|
|
|
MessageLoop::current()->
|
|
PostDelayedTask(FROM_HERE,
|
|
new SendRingIndicatorTask(mNumber, mType),
|
|
sRingInterval);
|
|
}
|
|
|
|
private:
|
|
nsString mNumber;
|
|
int mType;
|
|
};
|
|
|
|
void
|
|
OpenScoSocket(const nsAString& aDeviceAddress)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
BluetoothScoManager* sco = BluetoothScoManager::Get();
|
|
if (!sco) {
|
|
NS_WARNING("BluetoothScoManager is not available!");
|
|
return;
|
|
}
|
|
|
|
if (!sco->Connect(aDeviceAddress)) {
|
|
NS_WARNING("Failed to create a sco socket!");
|
|
}
|
|
}
|
|
|
|
void
|
|
CloseScoSocket()
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
BluetoothScoManager* sco = BluetoothScoManager::Get();
|
|
if (!sco) {
|
|
NS_WARNING("BluetoothScoManager is not available!");
|
|
return;
|
|
}
|
|
sco->Disconnect();
|
|
}
|
|
|
|
static bool
|
|
IsValidDtmf(const char aChar) {
|
|
// Valid DTMF: [*#0-9ABCD]
|
|
if (aChar == '*' || aChar == '#') {
|
|
return true;
|
|
} else if (aChar >= '0' && aChar <= '9') {
|
|
return true;
|
|
} else if (aChar >= 'A' && aChar <= 'D') {
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
BluetoothHfpManager::BluetoothHfpManager()
|
|
{
|
|
Reset();
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::ResetCallArray()
|
|
{
|
|
mCurrentCallIndex = 0;
|
|
mCurrentCallArray.Clear();
|
|
// Append a call object at the beginning of mCurrentCallArray since call
|
|
// index from RIL starts at 1.
|
|
Call call;
|
|
mCurrentCallArray.AppendElement(call);
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::Reset()
|
|
{
|
|
sStopSendingRingFlag = true;
|
|
sCINDItems[CINDType::CALL].value = CallState::NO_CALL;
|
|
sCINDItems[CINDType::CALLSETUP].value = CallSetupState::NO_CALLSETUP;
|
|
sCINDItems[CINDType::CALLHELD].value = CallHeldState::NO_CALLHELD;
|
|
|
|
mCCWA = false;
|
|
mCLIP = false;
|
|
mCMEE = false;
|
|
mCMER = false;
|
|
mReceiveVgsFlag = false;
|
|
|
|
ResetCallArray();
|
|
}
|
|
|
|
bool
|
|
BluetoothHfpManager::Init()
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
mSocket = new BluetoothSocket(this,
|
|
BluetoothSocketType::RFCOMM,
|
|
true,
|
|
true);
|
|
mPrevSocketStatus = mSocket->GetConnectionStatus();
|
|
|
|
sHfpObserver = new BluetoothHfpManagerObserver();
|
|
if (!sHfpObserver->Init()) {
|
|
NS_WARNING("Cannot set up Hfp Observers!");
|
|
}
|
|
|
|
mListener = new BluetoothTelephonyListener();
|
|
if (!mListener->StartListening()) {
|
|
NS_WARNING("Failed to start listening RIL");
|
|
return false;
|
|
}
|
|
|
|
nsCOMPtr<nsISettingsService> settings =
|
|
do_GetService("@mozilla.org/settingsService;1");
|
|
NS_ENSURE_TRUE(settings, false);
|
|
|
|
nsCOMPtr<nsISettingsServiceLock> settingsLock;
|
|
nsresult rv = settings->CreateLock(getter_AddRefs(settingsLock));
|
|
NS_ENSURE_SUCCESS(rv, false);
|
|
|
|
nsRefPtr<GetVolumeTask> callback = new GetVolumeTask();
|
|
rv = settingsLock->Get(AUDIO_VOLUME_BT_SCO, callback);
|
|
NS_ENSURE_SUCCESS(rv, false);
|
|
|
|
return true;
|
|
}
|
|
|
|
BluetoothHfpManager::~BluetoothHfpManager()
|
|
{
|
|
Cleanup();
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::Cleanup()
|
|
{
|
|
if (!mListener->StopListening()) {
|
|
NS_WARNING("Failed to stop listening RIL");
|
|
}
|
|
mListener = nullptr;
|
|
|
|
sHfpObserver->Shutdown();
|
|
sHfpObserver = nullptr;
|
|
}
|
|
|
|
//static
|
|
BluetoothHfpManager*
|
|
BluetoothHfpManager::Get()
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
// If we already exist, exit early
|
|
if (gBluetoothHfpManager) {
|
|
return gBluetoothHfpManager;
|
|
}
|
|
|
|
// If we're in shutdown, don't create a new instance
|
|
if (gInShutdown) {
|
|
NS_WARNING("BluetoothHfpManager can't be created during shutdown");
|
|
return nullptr;
|
|
}
|
|
|
|
// Create new instance, register, return
|
|
BluetoothHfpManager* manager = new BluetoothHfpManager();
|
|
NS_ENSURE_TRUE(manager->Init(), nullptr);
|
|
|
|
gBluetoothHfpManager = manager;
|
|
return gBluetoothHfpManager;
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::NotifySettings()
|
|
{
|
|
nsString type, name;
|
|
BluetoothValue v;
|
|
InfallibleTArray<BluetoothNamedValue> parameters;
|
|
type.AssignLiteral("bluetooth-hfp-status-changed");
|
|
|
|
name.AssignLiteral("connected");
|
|
v = (mSocket->GetConnectionStatus() ==
|
|
SocketConnectionStatus::SOCKET_CONNECTED);
|
|
parameters.AppendElement(BluetoothNamedValue(name, v));
|
|
|
|
name.AssignLiteral("address");
|
|
v = mDevicePath;
|
|
parameters.AppendElement(BluetoothNamedValue(name, v));
|
|
|
|
if (!BroadcastSystemMessage(type, parameters)) {
|
|
NS_WARNING("Failed to broadcast system message to settings");
|
|
return;
|
|
}
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::NotifyDialer(const nsAString& aCommand)
|
|
{
|
|
nsString type, name;
|
|
BluetoothValue v;
|
|
InfallibleTArray<BluetoothNamedValue> parameters;
|
|
type.AssignLiteral("bluetooth-dialer-command");
|
|
|
|
name.AssignLiteral("command");
|
|
v = nsString(aCommand);
|
|
parameters.AppendElement(BluetoothNamedValue(name, v));
|
|
|
|
if (!BroadcastSystemMessage(type, parameters)) {
|
|
NS_WARNING("Failed to broadcast system message to dialer");
|
|
return;
|
|
}
|
|
}
|
|
|
|
nsresult
|
|
BluetoothHfpManager::HandleVolumeChanged(const nsAString& aData)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
// The string that we're interested in will be a JSON string that looks like:
|
|
// {"key":"volumeup", "value":10}
|
|
// {"key":"volumedown", "value":2}
|
|
|
|
JSContext* cx = nsContentUtils::GetSafeJSContext();
|
|
if (!cx) {
|
|
NS_WARNING("Failed to get JSContext");
|
|
return NS_OK;
|
|
}
|
|
|
|
JS::Value val;
|
|
if (!JS_ParseJSON(cx, aData.BeginReading(), aData.Length(), &val)) {
|
|
return JS_ReportPendingException(cx) ? NS_OK : NS_ERROR_OUT_OF_MEMORY;
|
|
}
|
|
|
|
if (!val.isObject()) {
|
|
return NS_OK;
|
|
}
|
|
|
|
JSObject& obj(val.toObject());
|
|
|
|
JS::Value key;
|
|
if (!JS_GetProperty(cx, &obj, "key", &key)) {
|
|
MOZ_ASSERT(!JS_IsExceptionPending(cx));
|
|
return NS_ERROR_OUT_OF_MEMORY;
|
|
}
|
|
|
|
if (!key.isString()) {
|
|
return NS_OK;
|
|
}
|
|
|
|
JSBool match;
|
|
if (!JS_StringEqualsAscii(cx, key.toString(), AUDIO_VOLUME_BT_SCO, &match)) {
|
|
MOZ_ASSERT(!JS_IsExceptionPending(cx));
|
|
return NS_ERROR_OUT_OF_MEMORY;
|
|
}
|
|
|
|
if (!match) {
|
|
return NS_OK;
|
|
}
|
|
|
|
JS::Value value;
|
|
if (!JS_GetProperty(cx, &obj, "value", &value)) {
|
|
MOZ_ASSERT(!JS_IsExceptionPending(cx));
|
|
return NS_ERROR_OUT_OF_MEMORY;
|
|
}
|
|
|
|
if (!value.isNumber()) {
|
|
return NS_ERROR_UNEXPECTED;
|
|
}
|
|
|
|
mCurrentVgs = value.toNumber();
|
|
|
|
// Adjust volume by headset and we don't have to send volume back to headset
|
|
if (mReceiveVgsFlag) {
|
|
mReceiveVgsFlag = false;
|
|
return NS_OK;
|
|
}
|
|
|
|
// Only send volume back when there's a connected headset
|
|
if (mSocket->GetConnectionStatus() == SocketConnectionStatus::SOCKET_CONNECTED) {
|
|
SendCommand("+VGS: ", mCurrentVgs);
|
|
}
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
nsresult
|
|
BluetoothHfpManager::HandleVoiceConnectionChanged()
|
|
{
|
|
nsCOMPtr<nsIMobileConnectionProvider> connection =
|
|
do_GetService(NS_RILCONTENTHELPER_CONTRACTID);
|
|
NS_ENSURE_TRUE(connection, NS_ERROR_FAILURE);
|
|
|
|
nsIDOMMozMobileConnectionInfo* voiceInfo;
|
|
connection->GetVoiceConnectionInfo(&voiceInfo);
|
|
NS_ENSURE_TRUE(voiceInfo, NS_ERROR_FAILURE);
|
|
|
|
bool roaming;
|
|
voiceInfo->GetRoaming(&roaming);
|
|
if (roaming != sCINDItems[CINDType::ROAM].value) {
|
|
sCINDItems[CINDType::ROAM].value = roaming;
|
|
SendCommand("+CIEV: ", CINDType::ROAM);
|
|
}
|
|
|
|
bool service = false;
|
|
nsString regState;
|
|
voiceInfo->GetState(regState);
|
|
if (regState.EqualsLiteral("registered")) {
|
|
service = true;
|
|
}
|
|
if (service != sCINDItems[CINDType::SERVICE].value) {
|
|
sCINDItems[CINDType::SERVICE].value = service;
|
|
SendCommand("+CIEV: ", CINDType::SERVICE);
|
|
}
|
|
|
|
uint8_t signal;
|
|
JS::Value value;
|
|
voiceInfo->GetRelSignalStrength(&value);
|
|
if (!value.isNumber()) {
|
|
NS_WARNING("Failed to get relSignalStrength in BluetoothHfpManager");
|
|
return NS_ERROR_FAILURE;
|
|
}
|
|
signal = ceil(value.toNumber() / 20.0);
|
|
|
|
if (signal != sCINDItems[CINDType::SIGNAL].value) {
|
|
sCINDItems[CINDType::SIGNAL].value = signal;
|
|
SendCommand("+CIEV: ", CINDType::SIGNAL);
|
|
}
|
|
|
|
/**
|
|
* Possible return values for mode are:
|
|
* - null (unknown): set mNetworkSelectionMode to 0 (auto)
|
|
* - automatic: set mNetworkSelectionMode to 0 (auto)
|
|
* - manual: set mNetworkSelectionMode to 1 (manual)
|
|
*/
|
|
nsString mode;
|
|
connection->GetNetworkSelectionMode(mode);
|
|
if (mode.EqualsLiteral("manual")) {
|
|
mNetworkSelectionMode = 1;
|
|
} else {
|
|
mNetworkSelectionMode = 0;
|
|
}
|
|
|
|
nsIDOMMozMobileNetworkInfo* network;
|
|
voiceInfo->GetNetwork(&network);
|
|
NS_ENSURE_TRUE(network, NS_ERROR_FAILURE);
|
|
network->GetLongName(mOperatorName);
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
nsresult
|
|
BluetoothHfpManager::HandleIccInfoChanged()
|
|
{
|
|
nsCOMPtr<nsIMobileConnectionProvider> connection =
|
|
do_GetService(NS_RILCONTENTHELPER_CONTRACTID);
|
|
NS_ENSURE_TRUE(connection, NS_ERROR_FAILURE);
|
|
|
|
nsIDOMMozMobileICCInfo* iccInfo;
|
|
connection->GetIccInfo(&iccInfo);
|
|
NS_ENSURE_TRUE(iccInfo, NS_ERROR_FAILURE);
|
|
iccInfo->GetMsisdn(mMsisdn);
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
nsresult
|
|
BluetoothHfpManager::HandleShutdown()
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
gInShutdown = true;
|
|
Disconnect();
|
|
gBluetoothHfpManager = nullptr;
|
|
return NS_OK;
|
|
}
|
|
|
|
// Virtual function of class SocketConsumer
|
|
void
|
|
BluetoothHfpManager::ReceiveSocketData(BluetoothSocket* aSocket,
|
|
nsAutoPtr<UnixSocketRawData>& aMessage)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
nsAutoCString msg((const char*)aMessage->mData.get(), aMessage->mSize);
|
|
msg.StripWhitespace();
|
|
|
|
nsTArray<nsCString> atCommandValues;
|
|
|
|
// For more information, please refer to 4.34.1 "Bluetooth Defined AT
|
|
// Capabilities" in Bluetooth hands-free profile 1.6
|
|
if (msg.Find("AT+BRSF=") != -1) {
|
|
SendCommand("+BRSF: ", 97);
|
|
} else if (msg.Find("AT+CIND=?") != -1) {
|
|
// Asking for CIND range
|
|
SendCommand("+CIND: ", 0);
|
|
} else if (msg.Find("AT+CIND?") != -1) {
|
|
// Asking for CIND value
|
|
SendCommand("+CIND: ", 1);
|
|
} else if (msg.Find("AT+CMER=") != -1) {
|
|
/**
|
|
* SLC establishment is done when AT+CMER has been received.
|
|
* Do nothing but respond with "OK".
|
|
*/
|
|
ParseAtCommand(msg, 8, atCommandValues);
|
|
|
|
if (atCommandValues.Length() < 4) {
|
|
NS_WARNING("Could't get the value of command [AT+CMER=]");
|
|
goto respond_with_ok;
|
|
}
|
|
|
|
if (!atCommandValues[0].EqualsLiteral("3") ||
|
|
!atCommandValues[1].EqualsLiteral("0") ||
|
|
!atCommandValues[2].EqualsLiteral("0")) {
|
|
NS_WARNING("Wrong value of CMER");
|
|
goto respond_with_ok;
|
|
}
|
|
|
|
mCMER = atCommandValues[3].EqualsLiteral("1");
|
|
} else if (msg.Find("AT+CMEE=") != -1) {
|
|
ParseAtCommand(msg, 8, atCommandValues);
|
|
|
|
if (atCommandValues.IsEmpty()) {
|
|
NS_WARNING("Could't get the value of command [AT+CMEE=]");
|
|
goto respond_with_ok;
|
|
}
|
|
|
|
// AT+CMEE = 0: +CME ERROR shall not be used
|
|
// AT+CMEE = 1: use numeric <err>
|
|
// AT+CMEE = 2: use verbose <err>
|
|
mCMEE = !atCommandValues[0].EqualsLiteral("0");
|
|
} else if (msg.Find("AT+COPS=") != -1) {
|
|
ParseAtCommand(msg, 8, atCommandValues);
|
|
|
|
if (atCommandValues.Length() != 2) {
|
|
NS_WARNING("Could't get the value of command [AT+COPS=]");
|
|
goto respond_with_ok;
|
|
}
|
|
|
|
// Handsfree only support AT+COPS=3,0
|
|
if (!atCommandValues[0].EqualsLiteral("3") ||
|
|
!atCommandValues[1].EqualsLiteral("0")) {
|
|
if (mCMEE) {
|
|
SendCommand("+CME ERROR: ", BluetoothCmeError::OPERATION_NOT_SUPPORTED);
|
|
} else {
|
|
SendLine("ERROR");
|
|
}
|
|
return;
|
|
}
|
|
} else if (msg.Find("AT+COPS?") != -1) {
|
|
nsAutoCString message("+COPS: ");
|
|
message.AppendInt(mNetworkSelectionMode);
|
|
message.AppendLiteral(",0,\"");
|
|
message.Append(NS_ConvertUTF16toUTF8(mOperatorName));
|
|
message.AppendLiteral("\"");
|
|
SendLine(message.get());
|
|
return;
|
|
} else if (msg.Find("AT+VTS=") != -1) {
|
|
ParseAtCommand(msg, 7, atCommandValues);
|
|
|
|
if (atCommandValues.Length() != 1) {
|
|
NS_WARNING("Couldn't get the value of command [AT+VTS=]");
|
|
goto respond_with_ok;
|
|
}
|
|
|
|
if (IsValidDtmf(atCommandValues[0].get()[0])) {
|
|
nsAutoCString message("VTS=");
|
|
message += atCommandValues[0].get()[0];
|
|
NotifyDialer(NS_ConvertUTF8toUTF16(message));
|
|
}
|
|
} else if (msg.Find("AT+VGM=") != -1) {
|
|
ParseAtCommand(msg, 7, atCommandValues);
|
|
|
|
if (atCommandValues.IsEmpty()) {
|
|
NS_WARNING("Couldn't get the value of command [AT+VGM]");
|
|
goto respond_with_ok;
|
|
}
|
|
|
|
nsresult rv;
|
|
int vgm = atCommandValues[0].ToInteger(&rv);
|
|
if (NS_FAILED(rv)) {
|
|
NS_WARNING("Failed to extract microphone volume from bluetooth headset!");
|
|
goto respond_with_ok;
|
|
}
|
|
|
|
NS_ASSERTION(vgm >= 0 && vgm <= 15, "Received invalid VGM value");
|
|
mCurrentVgm = vgm;
|
|
} else if (msg.Find("AT+CHLD=?") != -1) {
|
|
SendLine("+CHLD: (1,2)");
|
|
} else if (msg.Find("AT+CHLD=") != -1) {
|
|
ParseAtCommand(msg, 8, atCommandValues);
|
|
|
|
if (atCommandValues.IsEmpty()) {
|
|
NS_WARNING("Could't get the value of command [AT+CHLD=]");
|
|
goto respond_with_ok;
|
|
}
|
|
|
|
char chld = atCommandValues[0][0];
|
|
if (chld < '0' || chld > '4') {
|
|
NS_WARNING("Wrong value of command [AT+CHLD]");
|
|
SendLine("ERROR");
|
|
return;
|
|
}
|
|
|
|
/**
|
|
* The following two cases are supported:
|
|
* AT+CHLD=1 - Releases active calls and accepts the other (held or
|
|
* waiting) call
|
|
* AT+CHLD=2 - Places active calls on hold and accepts the other (held
|
|
* or waiting) call
|
|
*
|
|
* The following cases are NOT supported yet:
|
|
* AT+CHLD=0, AT+CHLD=1<idx>, AT+CHLD=2<idx>, AT+CHLD=3, AT+CHLD=4
|
|
* Please see 4.33.2 in Bluetooth hands-free profile 1.6 for more
|
|
* information.
|
|
*/
|
|
|
|
// No idx shall be included
|
|
if (atCommandValues[0].Length() > 1) {
|
|
SendLine("ERROR");
|
|
return;
|
|
}
|
|
|
|
if (chld == '1') {
|
|
NotifyDialer(NS_LITERAL_STRING("CHUP+ATA"));
|
|
} else if (chld == '2') {
|
|
NotifyDialer(NS_LITERAL_STRING("CHLD+ATA"));
|
|
} else {
|
|
NS_WARNING("Not handling chld value");
|
|
}
|
|
} else if (msg.Find("AT+VGS=") != -1) {
|
|
// Adjust volume by headset
|
|
mReceiveVgsFlag = true;
|
|
ParseAtCommand(msg, 7, atCommandValues);
|
|
|
|
if (atCommandValues.IsEmpty()) {
|
|
NS_WARNING("Could't get the value of command [AT+VGS=]");
|
|
goto respond_with_ok;
|
|
}
|
|
|
|
nsresult rv;
|
|
int newVgs = atCommandValues[0].ToInteger(&rv);
|
|
if (NS_FAILED(rv)) {
|
|
NS_WARNING("Failed to extract volume value from bluetooth headset!");
|
|
goto respond_with_ok;
|
|
}
|
|
|
|
if (newVgs == mCurrentVgs) {
|
|
goto respond_with_ok;
|
|
}
|
|
|
|
NS_ASSERTION(newVgs >= 0 && newVgs <= 15, "Received invalid VGS value");
|
|
|
|
nsString data;
|
|
nsCOMPtr<nsIObserverService> os = mozilla::services::GetObserverService();
|
|
data.AppendInt(newVgs);
|
|
os->NotifyObservers(nullptr, "bluetooth-volume-change", data.get());
|
|
} else if (msg.Find("AT+BLDN") != -1) {
|
|
NotifyDialer(NS_LITERAL_STRING("BLDN"));
|
|
} else if (msg.Find("ATA") != -1) {
|
|
NotifyDialer(NS_LITERAL_STRING("ATA"));
|
|
} else if (msg.Find("AT+CHUP") != -1) {
|
|
NotifyDialer(NS_LITERAL_STRING("CHUP"));
|
|
} else if (msg.Find("ATD>") != -1) {
|
|
// Currently, we don't support memory dialing in Dialer app
|
|
SendLine("ERROR");
|
|
return;
|
|
} else if (msg.Find("AT+CLCC") != -1) {
|
|
SendCommand("+CLCC: ");
|
|
} else if (msg.Find("ATD") != -1) {
|
|
nsAutoCString message(msg), newMsg;
|
|
int end = message.FindChar(';');
|
|
if (end < 0) {
|
|
NS_WARNING("Could't get the value of command [ATD]");
|
|
goto respond_with_ok;
|
|
}
|
|
|
|
newMsg += nsDependentCSubstring(message, 0, end);
|
|
NotifyDialer(NS_ConvertUTF8toUTF16(newMsg));
|
|
} else if (msg.Find("AT+CLIP=") != -1) {
|
|
ParseAtCommand(msg, 8, atCommandValues);
|
|
|
|
if (atCommandValues.IsEmpty()) {
|
|
NS_WARNING("Could't get the value of command [AT+CLIP=]");
|
|
goto respond_with_ok;
|
|
}
|
|
|
|
mCLIP = atCommandValues[0].EqualsLiteral("1");
|
|
} else if (msg.Find("AT+CCWA=") != -1) {
|
|
ParseAtCommand(msg, 8, atCommandValues);
|
|
|
|
if (atCommandValues.IsEmpty()) {
|
|
NS_WARNING("Could't get the value of command [AT+CCWA=]");
|
|
goto respond_with_ok;
|
|
}
|
|
|
|
mCCWA = atCommandValues[0].EqualsLiteral("1");
|
|
} else if (msg.Find("AT+CKPD") != -1) {
|
|
// For Headset Profile (HSP)
|
|
switch (mCurrentCallArray[mCurrentCallIndex].mState) {
|
|
case nsITelephonyProvider::CALL_STATE_INCOMING:
|
|
NotifyDialer(NS_LITERAL_STRING("ATA"));
|
|
break;
|
|
case nsITelephonyProvider::CALL_STATE_CONNECTED:
|
|
case nsITelephonyProvider::CALL_STATE_DIALING:
|
|
case nsITelephonyProvider::CALL_STATE_ALERTING:
|
|
NotifyDialer(NS_LITERAL_STRING("CHUP"));
|
|
break;
|
|
case nsITelephonyProvider::CALL_STATE_DISCONNECTED:
|
|
NotifyDialer(NS_LITERAL_STRING("BLDN"));
|
|
break;
|
|
default:
|
|
NS_WARNING("Not handling state changed");
|
|
break;
|
|
}
|
|
} else if (msg.Find("AT+CNUM") != -1) {
|
|
if (!mMsisdn.IsEmpty()) {
|
|
nsAutoCString message("+CNUM: ,\"");
|
|
message.Append(NS_ConvertUTF16toUTF8(mMsisdn).get());
|
|
message.AppendLiteral("\",");
|
|
message.AppendInt(TOA_UNKNOWN);
|
|
message.AppendLiteral(",,4");
|
|
SendLine(message.get());
|
|
}
|
|
} else {
|
|
nsCString warningMsg;
|
|
warningMsg.Append(NS_LITERAL_CSTRING("Unsupported AT command: "));
|
|
warningMsg.Append(msg);
|
|
warningMsg.Append(NS_LITERAL_CSTRING(", reply with ERROR"));
|
|
NS_WARNING(warningMsg.get());
|
|
|
|
SendLine("ERROR");
|
|
return;
|
|
}
|
|
|
|
respond_with_ok:
|
|
// We always respond to remote device with "OK" in general cases.
|
|
SendLine("OK");
|
|
}
|
|
|
|
bool
|
|
BluetoothHfpManager::Connect(const nsAString& aDevicePath,
|
|
const bool aIsHandsfree,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
if (gInShutdown) {
|
|
NS_WARNING("Connect called while in shutdown!");
|
|
return false;
|
|
}
|
|
|
|
SocketConnectionStatus s = mSocket->GetConnectionStatus();
|
|
|
|
if (s == SocketConnectionStatus::SOCKET_CONNECTED ||
|
|
s == SocketConnectionStatus::SOCKET_CONNECTING) {
|
|
NS_WARNING("BluetoothHfpManager has been already connected");
|
|
return false;
|
|
}
|
|
|
|
mSocket->Disconnect();
|
|
|
|
BluetoothService* bs = BluetoothService::Get();
|
|
NS_ENSURE_TRUE(bs, false);
|
|
|
|
nsString uuid;
|
|
if (aIsHandsfree) {
|
|
BluetoothUuidHelper::GetString(BluetoothServiceClass::HANDSFREE, uuid);
|
|
} else {
|
|
BluetoothUuidHelper::GetString(BluetoothServiceClass::HEADSET, uuid);
|
|
}
|
|
|
|
mRunnable = aRunnable;
|
|
|
|
nsresult rv = bs->GetSocketViaService(aDevicePath,
|
|
uuid,
|
|
BluetoothSocketType::RFCOMM,
|
|
true,
|
|
true,
|
|
mSocket,
|
|
mRunnable);
|
|
|
|
return NS_FAILED(rv) ? false : true;
|
|
}
|
|
|
|
bool
|
|
BluetoothHfpManager::Listen()
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
if (gInShutdown) {
|
|
MOZ_ASSERT(false, "Listen called while in shutdown!");
|
|
return false;
|
|
}
|
|
|
|
if (mSocket->GetConnectionStatus() ==
|
|
SocketConnectionStatus::SOCKET_LISTENING) {
|
|
NS_WARNING("BluetoothHfpManager has been already listening");
|
|
return true;
|
|
}
|
|
|
|
mSocket->Disconnect();
|
|
|
|
if (!mSocket->Listen(BluetoothReservedChannels::CHANNEL_HANDSFREE_AG)) {
|
|
NS_WARNING("[HFP] Can't listen on socket!");
|
|
return false;
|
|
}
|
|
|
|
mPrevSocketStatus = mSocket->GetConnectionStatus();
|
|
return true;
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::Disconnect()
|
|
{
|
|
mSocket->Disconnect();
|
|
}
|
|
|
|
bool
|
|
BluetoothHfpManager::SendLine(const char* aMessage)
|
|
{
|
|
nsAutoCString msg;
|
|
|
|
msg.AppendLiteral(kHfpCrlf);
|
|
msg.Append(aMessage);
|
|
msg.AppendLiteral(kHfpCrlf);
|
|
|
|
return mSocket->SendSocketData(msg);
|
|
}
|
|
|
|
bool
|
|
BluetoothHfpManager::SendCommand(const char* aCommand, uint8_t aValue)
|
|
{
|
|
if (mPrevSocketStatus != SocketConnectionStatus::SOCKET_CONNECTED) {
|
|
return false;
|
|
}
|
|
|
|
nsAutoCString message;
|
|
int value = aValue;
|
|
message += aCommand;
|
|
|
|
if (!strcmp(aCommand, "+CIEV: ")) {
|
|
if (!mCMER) {
|
|
// Indicator status update is disabled
|
|
return true;
|
|
}
|
|
|
|
if ((aValue < 1) || (aValue > ArrayLength(sCINDItems) - 1)) {
|
|
NS_WARNING("unexpected CINDType for CIEV command");
|
|
return false;
|
|
}
|
|
|
|
message.AppendInt(aValue);
|
|
message.AppendLiteral(",");
|
|
message.AppendInt(sCINDItems[aValue].value);
|
|
} else if (!strcmp(aCommand, "+CIND: ")) {
|
|
if (!aValue) {
|
|
// Query for range
|
|
for (uint8_t i = 1; i < ArrayLength(sCINDItems); i++) {
|
|
message.AppendLiteral("(\"");
|
|
message.Append(sCINDItems[i].name);
|
|
message.AppendLiteral("\",(");
|
|
message.Append(sCINDItems[i].range);
|
|
message.AppendLiteral(")");
|
|
if (i == (ArrayLength(sCINDItems) - 1)) {
|
|
message.AppendLiteral(")");
|
|
break;
|
|
}
|
|
message.AppendLiteral("),");
|
|
}
|
|
} else {
|
|
// Query for value
|
|
for (uint8_t i = 1; i < ArrayLength(sCINDItems); i++) {
|
|
message.AppendInt(sCINDItems[i].value);
|
|
if (i == (ArrayLength(sCINDItems) - 1)) {
|
|
break;
|
|
}
|
|
message.AppendLiteral(",");
|
|
}
|
|
}
|
|
} else if (!strcmp(aCommand, "+CLCC: ")) {
|
|
bool rv = true;
|
|
uint32_t callNumbers = mCurrentCallArray.Length();
|
|
for (uint32_t i = 1; i < callNumbers; i++) {
|
|
Call& call = mCurrentCallArray[i];
|
|
if (call.mState == nsITelephonyProvider::CALL_STATE_DISCONNECTED) {
|
|
continue;
|
|
}
|
|
|
|
message.AssignLiteral("+CLCC: ");
|
|
message.AppendInt(i);
|
|
message.AppendLiteral(",");
|
|
message.AppendInt(call.mDirection);
|
|
message.AppendLiteral(",");
|
|
|
|
switch (call.mState) {
|
|
case nsITelephonyProvider::CALL_STATE_CONNECTED:
|
|
message.AppendInt(0);
|
|
break;
|
|
case nsITelephonyProvider::CALL_STATE_HELD:
|
|
message.AppendInt(1);
|
|
break;
|
|
case nsITelephonyProvider::CALL_STATE_DIALING:
|
|
message.AppendInt(2);
|
|
break;
|
|
case nsITelephonyProvider::CALL_STATE_ALERTING:
|
|
message.AppendInt(3);
|
|
break;
|
|
case nsITelephonyProvider::CALL_STATE_INCOMING:
|
|
message.AppendInt((i == mCurrentCallIndex) ? 4 : 5);
|
|
break;
|
|
default:
|
|
NS_WARNING("Not handling call status for CLCC");
|
|
break;
|
|
}
|
|
message.AppendLiteral(",0,0,\"");
|
|
message.Append(NS_ConvertUTF16toUTF8(call.mNumber));
|
|
message.AppendLiteral("\",");
|
|
message.AppendInt(call.mType);
|
|
|
|
rv &= SendLine(message.get());
|
|
}
|
|
return rv;
|
|
} else {
|
|
message.AppendInt(value);
|
|
}
|
|
|
|
return SendLine(message.get());
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::UpdateCIND(uint8_t aType, uint8_t aValue, bool aSend)
|
|
{
|
|
if (sCINDItems[aType].value != aValue) {
|
|
sCINDItems[aType].value = aValue;
|
|
// Indicator status update is enabled
|
|
if (aSend && mCMER) {
|
|
SendCommand("+CIEV: ", aType);
|
|
}
|
|
}
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::HandleCallStateChanged(uint32_t aCallIndex,
|
|
uint16_t aCallState,
|
|
const nsAString& aNumber,
|
|
bool aSend)
|
|
{
|
|
if (mSocket->GetConnectionStatus() !=
|
|
SocketConnectionStatus::SOCKET_CONNECTED) {
|
|
return;
|
|
}
|
|
|
|
while (aCallIndex >= mCurrentCallArray.Length()) {
|
|
Call call;
|
|
mCurrentCallArray.AppendElement(call);
|
|
}
|
|
|
|
uint16_t prevCallState = mCurrentCallArray[aCallIndex].mState;
|
|
mCurrentCallArray[aCallIndex].mState = aCallState;
|
|
|
|
// Same logic as implementation in ril_worker.js
|
|
if (aNumber.Length() && aNumber[0] == '+') {
|
|
mCurrentCallArray[aCallIndex].mType = TOA_INTERNATIONAL;
|
|
}
|
|
mCurrentCallArray[aCallIndex].mNumber = aNumber;
|
|
|
|
nsRefPtr<nsRunnable> sendRingTask;
|
|
nsString address;
|
|
uint32_t callArrayLength = mCurrentCallArray.Length();
|
|
uint32_t index = 1;
|
|
|
|
switch (aCallState) {
|
|
case nsITelephonyProvider::CALL_STATE_HELD:
|
|
sCINDItems[CINDType::CALLHELD].value = CallHeldState::ONHOLD_ACTIVE;
|
|
SendCommand("+CIEV: ", CINDType::CALLHELD);
|
|
break;
|
|
case nsITelephonyProvider::CALL_STATE_INCOMING:
|
|
mCurrentCallArray[aCallIndex].mDirection = true;
|
|
|
|
if (mCurrentCallIndex) {
|
|
if (mCCWA) {
|
|
nsAutoCString ccwaMsg("+CCWA: \"");
|
|
ccwaMsg.Append(NS_ConvertUTF16toUTF8(aNumber));
|
|
ccwaMsg.AppendLiteral("\",");
|
|
ccwaMsg.AppendInt(mCurrentCallArray[aCallIndex].mType);
|
|
SendLine(ccwaMsg.get());
|
|
}
|
|
UpdateCIND(CINDType::CALLSETUP, CallSetupState::INCOMING, aSend);
|
|
} else {
|
|
// Start sending RING indicator to HF
|
|
sStopSendingRingFlag = false;
|
|
UpdateCIND(CINDType::CALLSETUP, CallSetupState::INCOMING, aSend);
|
|
|
|
nsAutoString number(aNumber);
|
|
if (!mCLIP) {
|
|
number.AssignLiteral("");
|
|
}
|
|
|
|
MessageLoop::current()->PostDelayedTask(FROM_HERE,
|
|
new SendRingIndicatorTask(number, mCurrentCallArray[aCallIndex].mType),
|
|
sRingInterval);
|
|
}
|
|
break;
|
|
case nsITelephonyProvider::CALL_STATE_DIALING:
|
|
mCurrentCallArray[aCallIndex].mDirection = false;
|
|
UpdateCIND(CINDType::CALLSETUP, CallSetupState::OUTGOING, aSend);
|
|
|
|
mSocket->GetAddress(address);
|
|
OpenScoSocket(address);
|
|
break;
|
|
case nsITelephonyProvider::CALL_STATE_ALERTING:
|
|
mCurrentCallArray[aCallIndex].mDirection = false;
|
|
UpdateCIND(CINDType::CALLSETUP, CallSetupState::OUTGOING_ALERTING, aSend);
|
|
|
|
// If there's an ongoing call when the headset is just connected, we have
|
|
// to open a sco socket here.
|
|
mSocket->GetAddress(address);
|
|
OpenScoSocket(address);
|
|
break;
|
|
case nsITelephonyProvider::CALL_STATE_CONNECTED:
|
|
mCurrentCallIndex = aCallIndex;
|
|
switch (prevCallState) {
|
|
case nsITelephonyProvider::CALL_STATE_INCOMING:
|
|
case nsITelephonyProvider::CALL_STATE_DISCONNECTED:
|
|
// Incoming call, no break
|
|
sStopSendingRingFlag = true;
|
|
|
|
mSocket->GetAddress(address);
|
|
OpenScoSocket(address);
|
|
case nsITelephonyProvider::CALL_STATE_ALERTING:
|
|
// Outgoing call
|
|
UpdateCIND(CINDType::CALL, CallState::IN_PROGRESS, aSend);
|
|
UpdateCIND(CINDType::CALLSETUP, CallSetupState::NO_CALLSETUP, aSend);
|
|
break;
|
|
case nsITelephonyProvider::CALL_STATE_HELD:
|
|
// Check whether to update CINDType::CALLHELD or not
|
|
while (index < callArrayLength) {
|
|
if (index == mCurrentCallIndex) {
|
|
index++;
|
|
continue;
|
|
}
|
|
|
|
uint16_t state = mCurrentCallArray[index].mState;
|
|
// If there's another call on hold or other calls exist, no need to
|
|
// update CINDType::CALLHELD
|
|
if (state != nsITelephonyProvider::CALL_STATE_DISCONNECTED) {
|
|
break;
|
|
}
|
|
index++;
|
|
}
|
|
|
|
if (index == callArrayLength) {
|
|
UpdateCIND(CINDType::CALLHELD, CallHeldState::NO_CALLHELD, aSend);
|
|
}
|
|
break;
|
|
default:
|
|
NS_WARNING("Not handling state changed");
|
|
}
|
|
break;
|
|
case nsITelephonyProvider::CALL_STATE_DISCONNECTED:
|
|
switch (prevCallState) {
|
|
case nsITelephonyProvider::CALL_STATE_INCOMING:
|
|
case nsITelephonyProvider::CALL_STATE_BUSY:
|
|
// Incoming call, no break
|
|
sStopSendingRingFlag = true;
|
|
case nsITelephonyProvider::CALL_STATE_DIALING:
|
|
case nsITelephonyProvider::CALL_STATE_ALERTING:
|
|
// Outgoing call
|
|
UpdateCIND(CINDType::CALLSETUP, CallSetupState::NO_CALLSETUP, aSend);
|
|
break;
|
|
case nsITelephonyProvider::CALL_STATE_CONNECTED:
|
|
// No call is ongoing
|
|
if (sCINDItems[CINDType::CALLHELD].value == CallHeldState::NO_CALLHELD) {
|
|
UpdateCIND(CINDType::CALL, CallState::NO_CALL, aSend);
|
|
}
|
|
break;
|
|
case nsITelephonyProvider::CALL_STATE_HELD:
|
|
UpdateCIND(CINDType::CALLHELD, CallHeldState::NO_CALLHELD, aSend);
|
|
break;
|
|
default:
|
|
NS_WARNING("Not handling state changed");
|
|
}
|
|
|
|
if (aCallIndex == mCurrentCallIndex) {
|
|
// Find the first non-disconnected call (like connected, held),
|
|
// and update mCurrentCallIndex
|
|
while (index < callArrayLength) {
|
|
if (mCurrentCallArray[index].mState !=
|
|
nsITelephonyProvider::CALL_STATE_DISCONNECTED) {
|
|
mCurrentCallIndex = index;
|
|
break;
|
|
}
|
|
index++;
|
|
}
|
|
|
|
// There is no call, close Sco and clear mCurrentCallArray
|
|
if (index == callArrayLength) {
|
|
CloseScoSocket();
|
|
ResetCallArray();
|
|
}
|
|
}
|
|
break;
|
|
default:
|
|
NS_WARNING("Not handling state changed");
|
|
sCINDItems[CINDType::CALL].value = CallState::NO_CALL;
|
|
sCINDItems[CINDType::CALLSETUP].value = CallSetupState::NO_CALLSETUP;
|
|
sCINDItems[CINDType::CALLHELD].value = CallHeldState::NO_CALLHELD;
|
|
}
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::OnConnectSuccess(BluetoothSocket* aSocket)
|
|
{
|
|
MOZ_ASSERT(aSocket == mSocket);
|
|
|
|
nsCOMPtr<nsITelephonyProvider> provider =
|
|
do_GetService(NS_RILCONTENTHELPER_CONTRACTID);
|
|
NS_ENSURE_TRUE_VOID(provider);
|
|
provider->EnumerateCalls(mListener->GetListener());
|
|
|
|
// For active connection request, we need to reply the DOMRequest
|
|
if (mRunnable) {
|
|
BluetoothValue v = true;
|
|
nsString errorStr;
|
|
DispatchBluetoothReply(mRunnable, v, errorStr);
|
|
|
|
mRunnable.forget();
|
|
}
|
|
|
|
// Cache device path for NotifySettings() since we can't get socket address
|
|
// when a headset disconnect with us
|
|
mSocket->GetAddress(mDevicePath);
|
|
mPrevSocketStatus = mSocket->GetConnectionStatus();
|
|
|
|
NotifySettings();
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::OnConnectError(BluetoothSocket* aSocket)
|
|
{
|
|
MOZ_ASSERT(aSocket == mSocket);
|
|
|
|
// For active connection request, we need to reply the DOMRequest
|
|
if (mRunnable) {
|
|
BluetoothValue v;
|
|
nsString errorStr;
|
|
errorStr.AssignLiteral("Failed to connect with a bluetooth headset!");
|
|
DispatchBluetoothReply(mRunnable, v, errorStr);
|
|
|
|
mRunnable.forget();
|
|
}
|
|
|
|
// If connecting for some reason didn't work, restart listening
|
|
Listen();
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::OnDisconnect(BluetoothSocket* aSocket)
|
|
{
|
|
MOZ_ASSERT(aSocket == mSocket);
|
|
|
|
// When we close a connected socket, then restart listening again and
|
|
// notify Settings app.
|
|
if (mPrevSocketStatus == SocketConnectionStatus::SOCKET_CONNECTED) {
|
|
Listen();
|
|
NotifySettings();
|
|
} else if (mPrevSocketStatus == SocketConnectionStatus::SOCKET_CONNECTING) {
|
|
NS_WARNING("BluetoothHfpManager got unexpected socket status!");
|
|
}
|
|
|
|
CloseScoSocket();
|
|
Reset();
|
|
}
|
|
|
|
bool
|
|
BluetoothHfpManager::IsConnected()
|
|
{
|
|
return mSocket->GetConnectionStatus() ==
|
|
SocketConnectionStatus::SOCKET_CONNECTED;
|
|
}
|