mirror of
https://github.com/mozilla/gecko-dev.git
synced 2024-11-01 06:35:42 +00:00
f458810e2e
According to HFP spec 1.6, we should update callheld status very carefully when the status of other calls are changed.
1721 lines
48 KiB
C++
1721 lines
48 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 "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"
|
|
#define BLUETOOTH_SCO_STATUS_CHANGED "bluetooth-sco-status-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 const char kHfpCrlf[] = "\xd\xa";
|
|
|
|
// Sending ringtone related
|
|
static bool sStopSendingRingFlag = true;
|
|
static int sRingInterval = 3000; //unit: ms
|
|
|
|
// Wait for 2 seconds for Dialer processing event 'BLDN'. '2' seconds is a
|
|
// magic number. The mechanism should be revised once we can get call history.
|
|
static int sWaitingForProcessingBLDNInterval = 2000; //unit: ms
|
|
} // 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 = EmptyString(),
|
|
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::RespondToBLDNTask : public Task
|
|
{
|
|
private:
|
|
void Run() MOZ_OVERRIDE
|
|
{
|
|
MOZ_ASSERT(gBluetoothHfpManager);
|
|
|
|
if (!gBluetoothHfpManager->mBLDNProcessed) {
|
|
gBluetoothHfpManager->mBLDNProcessed = true;
|
|
gBluetoothHfpManager->SendLine("ERROR");
|
|
}
|
|
}
|
|
};
|
|
|
|
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;
|
|
};
|
|
|
|
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()
|
|
{
|
|
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;
|
|
mBLDNProcessed = true;
|
|
|
|
ResetCallArray();
|
|
}
|
|
|
|
bool
|
|
BluetoothHfpManager::Init()
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
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);
|
|
|
|
Listen();
|
|
|
|
mScoSocket = new BluetoothSocket(this,
|
|
BluetoothSocketType::SCO,
|
|
true,
|
|
false);
|
|
mScoSocketStatus = mScoSocket->GetConnectionStatus();
|
|
ListenSco();
|
|
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::NotifyStatusChanged(const nsAString& aType)
|
|
{
|
|
nsString type, name;
|
|
BluetoothValue v;
|
|
InfallibleTArray<BluetoothNamedValue> parameters;
|
|
type = aType;
|
|
|
|
name.AssignLiteral("connected");
|
|
if (type.EqualsLiteral("bluetooth-hfp-status-changed")) {
|
|
v = IsConnected();
|
|
} else if (type.EqualsLiteral("bluetooth-sco-status-changed")) {
|
|
v = IsScoConnected();
|
|
} else {
|
|
NS_WARNING("Wrong type for NotifyStatusChanged");
|
|
return;
|
|
}
|
|
parameters.AppendElement(BluetoothNamedValue(name, v));
|
|
|
|
name.AssignLiteral("address");
|
|
v = mDeviceAddress;
|
|
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;
|
|
}
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::NotifyAudioManager(const nsAString& aAddress)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
nsCOMPtr<nsIObserverService> obs =
|
|
do_GetService("@mozilla.org/observer-service;1");
|
|
NS_ENSURE_TRUE_VOID(obs);
|
|
|
|
if (NS_FAILED(obs->NotifyObservers(nullptr,
|
|
BLUETOOTH_SCO_STATUS_CHANGED,
|
|
aAddress.BeginReading()))) {
|
|
NS_WARNING("Failed to notify bluetooth-sco-status-changed observsers!");
|
|
}
|
|
}
|
|
|
|
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::Rooted<JS::Value> val(cx);
|
|
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 (IsConnected()) {
|
|
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);
|
|
|
|
// According to GSM 07.07, "<format> indicates if the format is alphanumeric
|
|
// or numeric; long alphanumeric format can be upto 16 characters long and
|
|
// short format up to 8 characters (refer GSM MoU SE.13 [9])..."
|
|
// However, we found that the operator name may sometimes be longer than 16
|
|
// characters. After discussion, we decided to fix this here but not in RIL
|
|
// or modem.
|
|
//
|
|
// Please see Bug 871366 for more information.
|
|
if (mOperatorName.Length() > 16) {
|
|
NS_WARNING("The operator name was longer than 16 characters. We cut it.");
|
|
mOperatorName.Left(mOperatorName, 16);
|
|
}
|
|
|
|
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();
|
|
DisconnectSco();
|
|
gBluetoothHfpManager = nullptr;
|
|
return NS_OK;
|
|
}
|
|
|
|
// Virtual function of class SocketConsumer
|
|
void
|
|
BluetoothHfpManager::ReceiveSocketData(BluetoothSocket* aSocket,
|
|
nsAutoPtr<UnixSocketRawData>& aMessage)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
MOZ_ASSERT(aSocket);
|
|
|
|
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());
|
|
} 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;
|
|
}
|
|
|
|
/**
|
|
* 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.
|
|
*/
|
|
char chld = atCommandValues[0][0];
|
|
bool valid = true;
|
|
if (atCommandValues[0].Length() > 1) {
|
|
NS_WARNING("No index should be included in command [AT+CHLD]");
|
|
valid = false;
|
|
} else if (chld == '0' || chld == '3' || chld == '4') {
|
|
NS_WARNING("The value of command [AT+CHLD] is not supported");
|
|
valid = false;
|
|
} else if (chld == '1') {
|
|
NotifyDialer(NS_LITERAL_STRING("CHUP+ATA"));
|
|
} else if (chld == '2') {
|
|
NotifyDialer(NS_LITERAL_STRING("CHLD+ATA"));
|
|
} else {
|
|
NS_WARNING("Wrong value of command [AT+CHLD]");
|
|
valid = false;
|
|
}
|
|
|
|
if (!valid) {
|
|
SendLine("ERROR");
|
|
return;
|
|
}
|
|
} 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) || (msg.Find("ATD>") != -1)) {
|
|
// Dialer app of FFOS v1 does not have plan to support Memory Dailing.
|
|
// However, in order to pass Bluetooth HFP certification, we have to
|
|
// make a call when we receive AT command 'ATD>n'. The solution here
|
|
// is firing a 'BLDN' event to Dialer to do 'Last Number Redial'.
|
|
mBLDNProcessed = false;
|
|
NotifyDialer(NS_LITERAL_STRING("BLDN"));
|
|
|
|
MessageLoop::current()->
|
|
PostDelayedTask(FROM_HERE, new RespondToBLDNTask(),
|
|
sWaitingForProcessingBLDNInterval);
|
|
|
|
// Don't send response 'OK' here because we'll respond later in either
|
|
// RespondToBLDNTask or HandleCallStateChanged()
|
|
return;
|
|
} 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("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) {
|
|
if (!sStopSendingRingFlag) {
|
|
// Bluetooth HSP spec 4.2.2
|
|
// There is an incoming call, notify Dialer to pick up the phone call
|
|
// and SCO will be established after we get the CallStateChanged event
|
|
// indicating the call is answered successfully.
|
|
NotifyDialer(NS_LITERAL_STRING("ATA"));
|
|
} else {
|
|
if (!IsScoConnected()) {
|
|
// Bluetooth HSP spec 4.3
|
|
// If there's no SCO, set up a SCO link.
|
|
ConnectSco();
|
|
} else if (!mFirstCKPD) {
|
|
// Bluetooth HSP spec 4.5
|
|
// There are two ways to release SCO: sending CHUP to dialer or closing
|
|
// SCO socket directly. We notify dialer only if there is at least one
|
|
// active call.
|
|
if (mCurrentCallArray.Length() > 1) {
|
|
NotifyDialer(NS_LITERAL_STRING("CHUP"));
|
|
} else {
|
|
DisconnectSco();
|
|
}
|
|
} else {
|
|
// Three conditions have to be matched to come in here:
|
|
// (1) Not sending RING indicator
|
|
// (2) A SCO link exists
|
|
// (3) This is the very first AT+CKPD=200 of this session
|
|
// It is the case of Figure 4.3, Bluetooth HSP spec. Do nothing.
|
|
NS_WARNING("AT+CKPD=200: Do nothing");
|
|
}
|
|
}
|
|
|
|
mFirstCKPD = false;
|
|
} 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");
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::Connect(const nsAString& aDeviceAddress,
|
|
const bool aIsHandsfree,
|
|
BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
NS_ENSURE_FALSE_VOID(gInShutdown);
|
|
NS_ENSURE_FALSE_VOID(mSocket);
|
|
|
|
mNeedsUpdatingSdpRecords = true;
|
|
mIsHandsfree = aIsHandsfree;
|
|
|
|
BluetoothService* bs = BluetoothService::Get();
|
|
NS_ENSURE_TRUE_VOID(bs);
|
|
|
|
nsString uuid;
|
|
if (aIsHandsfree) {
|
|
BluetoothUuidHelper::GetString(BluetoothServiceClass::HANDSFREE, uuid);
|
|
} else {
|
|
BluetoothUuidHelper::GetString(BluetoothServiceClass::HEADSET, uuid);
|
|
}
|
|
|
|
if (NS_FAILED(bs->GetServiceChannel(aDeviceAddress, uuid, this))) {
|
|
DispatchBluetoothReply(aRunnable, BluetoothValue(),
|
|
NS_LITERAL_STRING(ERR_SERVICE_CHANNEL_NOT_FOUND));
|
|
return;
|
|
}
|
|
|
|
// Stop listening because currently we only support one connection at a time.
|
|
if (mHandsfreeSocket) {
|
|
mHandsfreeSocket->Disconnect();
|
|
mHandsfreeSocket = nullptr;
|
|
}
|
|
|
|
if (mHeadsetSocket) {
|
|
mHeadsetSocket->Disconnect();
|
|
mHeadsetSocket = nullptr;
|
|
}
|
|
|
|
MOZ_ASSERT(!mRunnable);
|
|
|
|
mRunnable = aRunnable;
|
|
mSocket =
|
|
new BluetoothSocket(this, BluetoothSocketType::RFCOMM, true, true);
|
|
}
|
|
|
|
bool
|
|
BluetoothHfpManager::Listen()
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
if (gInShutdown) {
|
|
NS_WARNING("Listen called while in shutdown!");
|
|
return false;
|
|
}
|
|
|
|
if (mSocket) {
|
|
NS_WARNING("mSocket exists. Failed to listen.");
|
|
return false;
|
|
}
|
|
|
|
if (!mHandsfreeSocket) {
|
|
mHandsfreeSocket =
|
|
new BluetoothSocket(this, BluetoothSocketType::RFCOMM, true, true);
|
|
|
|
if (!mHandsfreeSocket->Listen(
|
|
BluetoothReservedChannels::CHANNEL_HANDSFREE_AG)) {
|
|
NS_WARNING("[HFP] Can't listen on RFCOMM socket!");
|
|
mHandsfreeSocket = nullptr;
|
|
return false;
|
|
}
|
|
}
|
|
|
|
if (!mHeadsetSocket) {
|
|
mHeadsetSocket =
|
|
new BluetoothSocket(this, BluetoothSocketType::RFCOMM, true, true);
|
|
|
|
if (!mHeadsetSocket->Listen(
|
|
BluetoothReservedChannels::CHANNEL_HEADSET_AG)) {
|
|
NS_WARNING("[HSP] Can't listen on RFCOMM socket!");
|
|
mHandsfreeSocket->Disconnect();
|
|
mHandsfreeSocket = nullptr;
|
|
mHeadsetSocket = nullptr;
|
|
return false;
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::Disconnect()
|
|
{
|
|
if (mSocket) {
|
|
mSocket->Disconnect();
|
|
mSocket = nullptr;
|
|
}
|
|
}
|
|
|
|
bool
|
|
BluetoothHfpManager::SendLine(const char* aMessage)
|
|
{
|
|
MOZ_ASSERT(mSocket);
|
|
|
|
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 (!IsConnected()) {
|
|
NS_WARNING("Trying to SendCommand() without a SLC");
|
|
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:
|
|
if (!FindFirstCall(nsITelephonyProvider::CALL_STATE_CONNECTED)) {
|
|
message.AppendInt(4);
|
|
} else {
|
|
message.AppendInt(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);
|
|
}
|
|
}
|
|
}
|
|
|
|
uint32_t
|
|
BluetoothHfpManager::FindFirstCall(uint16_t aState)
|
|
{
|
|
uint32_t callLength = mCurrentCallArray.Length();
|
|
|
|
for (uint32_t i = 1; i < callLength; ++i) {
|
|
if (mCurrentCallArray[i].mState == aState) {
|
|
return i;
|
|
}
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
uint32_t
|
|
BluetoothHfpManager::GetNumberOfCalls(uint16_t aState)
|
|
{
|
|
uint32_t num = 0;
|
|
uint32_t callLength = mCurrentCallArray.Length();
|
|
|
|
for (uint32_t i = 1; i < callLength; ++i) {
|
|
if (mCurrentCallArray[i].mState == aState) {
|
|
++num;
|
|
}
|
|
}
|
|
|
|
return num;
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::HandleCallStateChanged(uint32_t aCallIndex,
|
|
uint16_t aCallState,
|
|
const nsAString& aNumber,
|
|
const bool aIsOutgoing,
|
|
bool aSend)
|
|
{
|
|
if (!IsConnected()) {
|
|
// Normal case. No need to print out warnings.
|
|
return;
|
|
}
|
|
|
|
while (aCallIndex >= mCurrentCallArray.Length()) {
|
|
Call call;
|
|
mCurrentCallArray.AppendElement(call);
|
|
}
|
|
|
|
uint16_t prevCallState = mCurrentCallArray[aCallIndex].mState;
|
|
mCurrentCallArray[aCallIndex].mState = aCallState;
|
|
mCurrentCallArray[aCallIndex].mDirection = !aIsOutgoing;
|
|
|
|
// 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;
|
|
|
|
switch (aCallState) {
|
|
case nsITelephonyProvider::CALL_STATE_HELD:
|
|
if (!FindFirstCall(nsITelephonyProvider::CALL_STATE_CONNECTED)) {
|
|
sCINDItems[CINDType::CALLHELD].value = CallHeldState::ONHOLD_NOACTIVE;
|
|
} else {
|
|
sCINDItems[CINDType::CALLHELD].value = CallHeldState::ONHOLD_ACTIVE;
|
|
}
|
|
SendCommand("+CIEV: ", CINDType::CALLHELD);
|
|
break;
|
|
case nsITelephonyProvider::CALL_STATE_INCOMING:
|
|
if (FindFirstCall(nsITelephonyProvider::CALL_STATE_CONNECTED)) {
|
|
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:
|
|
if (!mBLDNProcessed) {
|
|
SendLine("OK");
|
|
mBLDNProcessed = true;
|
|
}
|
|
|
|
UpdateCIND(CINDType::CALLSETUP, CallSetupState::OUTGOING, aSend);
|
|
ConnectSco();
|
|
break;
|
|
case nsITelephonyProvider::CALL_STATE_ALERTING:
|
|
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.
|
|
ConnectSco();
|
|
break;
|
|
case nsITelephonyProvider::CALL_STATE_CONNECTED:
|
|
switch (prevCallState) {
|
|
case nsITelephonyProvider::CALL_STATE_INCOMING:
|
|
case nsITelephonyProvider::CALL_STATE_DISCONNECTED:
|
|
// Incoming call, no break
|
|
sStopSendingRingFlag = true;
|
|
ConnectSco();
|
|
case nsITelephonyProvider::CALL_STATE_ALERTING:
|
|
// Outgoing call
|
|
UpdateCIND(CINDType::CALL, CallState::IN_PROGRESS, aSend);
|
|
UpdateCIND(CINDType::CALLSETUP, CallSetupState::NO_CALLSETUP, aSend);
|
|
break;
|
|
default:
|
|
NS_WARNING("Not handling state changed");
|
|
}
|
|
|
|
// = Handle callheld separately =
|
|
// Besides checking if there is still held calls, another thing we
|
|
// need to consider is the state change when receiving AT+CHLD=2.
|
|
// Assume that there is one active call(c1) and one call on hold(c2).
|
|
// We got AT+CHLD=2, which swaps active/held position. The first
|
|
// action would be c2 -> ACTIVE, then c1 -> HELD. When we get the
|
|
// CallStateChanged event of c2 becoming ACTIVE, we enter here.
|
|
// However we can't send callheld=0 at this time because we should
|
|
// see c2 -> ACTIVE + c1 -> HELD as one operation. That's the reason
|
|
// why I added the GetNumberOfCalls() condition check.
|
|
if (GetNumberOfCalls(nsITelephonyProvider::CALL_STATE_CONNECTED) == 1) {
|
|
if (FindFirstCall(nsITelephonyProvider::CALL_STATE_HELD)) {
|
|
UpdateCIND(CINDType::CALLHELD, CallHeldState::ONHOLD_ACTIVE, aSend);
|
|
} else if (prevCallState == nsITelephonyProvider::CALL_STATE_HELD) {
|
|
UpdateCIND(CINDType::CALLHELD, CallHeldState::NO_CALLHELD, aSend);
|
|
}
|
|
}
|
|
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;
|
|
default:
|
|
NS_WARNING("Not handling state changed");
|
|
}
|
|
|
|
// Handle held calls separately
|
|
if (!FindFirstCall(nsITelephonyProvider::CALL_STATE_HELD)) {
|
|
UpdateCIND(CINDType::CALLHELD, CallHeldState::NO_CALLHELD, aSend);
|
|
} else if (!FindFirstCall(nsITelephonyProvider::CALL_STATE_CONNECTED)) {
|
|
UpdateCIND(CINDType::CALLHELD, CallHeldState::ONHOLD_NOACTIVE, aSend);
|
|
} else {
|
|
UpdateCIND(CINDType::CALLHELD, CallHeldState::ONHOLD_ACTIVE, aSend);
|
|
}
|
|
|
|
// -1 is necessary because call 0 is an invalid (padding) call object.
|
|
if (mCurrentCallArray.Length() - 1 ==
|
|
GetNumberOfCalls(nsITelephonyProvider::CALL_STATE_DISCONNECTED)) {
|
|
// There is no call, close Sco and clear mCurrentCallArray
|
|
DisconnectSco();
|
|
ResetCallArray();
|
|
}
|
|
break;
|
|
default:
|
|
NS_WARNING("Not handling state changed");
|
|
break;
|
|
}
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::OnConnectSuccess(BluetoothSocket* aSocket)
|
|
{
|
|
MOZ_ASSERT(aSocket);
|
|
|
|
// Success to create a SCO socket
|
|
if (aSocket == mScoSocket) {
|
|
OnScoConnectSuccess();
|
|
return;
|
|
}
|
|
|
|
/**
|
|
* If the created connection is an inbound connection, close another server
|
|
* socket because currently only one SLC is allowed. After that, we need to
|
|
* make sure that both server socket would be nulled out. As for outbound
|
|
* connections, we do nothing since sockets have been already handled in
|
|
* function Connect().
|
|
*/
|
|
if (aSocket == mHandsfreeSocket) {
|
|
MOZ_ASSERT(!mSocket);
|
|
mHandsfreeSocket.swap(mSocket);
|
|
|
|
mHeadsetSocket->Disconnect();
|
|
mHeadsetSocket = nullptr;
|
|
} else if (aSocket == mHeadsetSocket) {
|
|
MOZ_ASSERT(!mSocket);
|
|
mHeadsetSocket.swap(mSocket);
|
|
|
|
mHandsfreeSocket->Disconnect();
|
|
mHandsfreeSocket = nullptr;
|
|
}
|
|
|
|
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 = nullptr;
|
|
}
|
|
|
|
mFirstCKPD = true;
|
|
|
|
// Cache device path for NotifySettings() since we can't get socket address
|
|
// when a headset disconnect with us
|
|
mSocket->GetAddress(mDeviceAddress);
|
|
NotifyStatusChanged(NS_LITERAL_STRING("bluetooth-hfp-status-changed"));
|
|
|
|
ListenSco();
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::OnConnectError(BluetoothSocket* aSocket)
|
|
{
|
|
// Failed to create a SCO socket
|
|
if (aSocket == mScoSocket) {
|
|
OnScoConnectError();
|
|
return;
|
|
}
|
|
|
|
// For active connection request, we need to reply the DOMRequest
|
|
if (mRunnable) {
|
|
NS_NAMED_LITERAL_STRING(replyError,
|
|
"Failed to connect with a bluetooth headset!");
|
|
DispatchBluetoothReply(mRunnable, BluetoothValue(), replyError);
|
|
|
|
mRunnable = nullptr;
|
|
}
|
|
|
|
mSocket = nullptr;
|
|
mHandsfreeSocket = nullptr;
|
|
mHeadsetSocket = nullptr;
|
|
|
|
// If connecting for some reason didn't work, restart listening
|
|
Listen();
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::OnDisconnect(BluetoothSocket* aSocket)
|
|
{
|
|
MOZ_ASSERT(aSocket);
|
|
|
|
if (aSocket == mScoSocket) {
|
|
// SCO socket is closed
|
|
OnScoDisconnect();
|
|
return;
|
|
}
|
|
|
|
if (aSocket != mSocket) {
|
|
// Do nothing when a listening server socket is closed.
|
|
return;
|
|
}
|
|
|
|
mSocket = nullptr;
|
|
DisconnectSco();
|
|
|
|
Listen();
|
|
NotifyStatusChanged(NS_LITERAL_STRING("bluetooth-hfp-status-changed"));
|
|
Reset();
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::OnUpdateSdpRecords(const nsAString& aDeviceAddress)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
MOZ_ASSERT(!aDeviceAddress.IsEmpty());
|
|
MOZ_ASSERT(mRunnable);
|
|
|
|
BluetoothService* bs = BluetoothService::Get();
|
|
NS_ENSURE_TRUE_VOID(bs);
|
|
|
|
nsString uuid;
|
|
if (mIsHandsfree) {
|
|
BluetoothUuidHelper::GetString(BluetoothServiceClass::HANDSFREE, uuid);
|
|
} else {
|
|
BluetoothUuidHelper::GetString(BluetoothServiceClass::HEADSET, uuid);
|
|
}
|
|
|
|
// Since we have updated SDP records of the target device, we should
|
|
// try to get the channel of target service again.
|
|
if (NS_FAILED(bs->GetServiceChannel(aDeviceAddress, uuid, this))) {
|
|
DispatchBluetoothReply(mRunnable, BluetoothValue(),
|
|
NS_LITERAL_STRING(ERR_SERVICE_CHANNEL_NOT_FOUND));
|
|
mRunnable = nullptr;
|
|
mSocket = nullptr;
|
|
Listen();
|
|
}
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::OnGetServiceChannel(const nsAString& aDeviceAddress,
|
|
const nsAString& aServiceUuid,
|
|
int aChannel)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
MOZ_ASSERT(!aDeviceAddress.IsEmpty());
|
|
MOZ_ASSERT(mRunnable);
|
|
|
|
BluetoothService* bs = BluetoothService::Get();
|
|
NS_ENSURE_TRUE_VOID(bs);
|
|
|
|
BluetoothValue v;
|
|
|
|
if (aChannel < 0) {
|
|
if (mNeedsUpdatingSdpRecords) {
|
|
mNeedsUpdatingSdpRecords = false;
|
|
bs->UpdateSdpRecords(aDeviceAddress, this);
|
|
} else {
|
|
DispatchBluetoothReply(mRunnable, v,
|
|
NS_LITERAL_STRING(ERR_SERVICE_CHANNEL_NOT_FOUND));
|
|
mRunnable = nullptr;
|
|
mSocket = nullptr;
|
|
Listen();
|
|
}
|
|
|
|
return;
|
|
}
|
|
|
|
if (!mSocket->Connect(NS_ConvertUTF16toUTF8(aDeviceAddress), aChannel)) {
|
|
DispatchBluetoothReply(mRunnable, v,
|
|
NS_LITERAL_STRING("SocketConnectionError"));
|
|
mRunnable = nullptr;
|
|
mSocket = nullptr;
|
|
Listen();
|
|
}
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::OnScoConnectSuccess()
|
|
{
|
|
// For active connection request, we need to reply the DOMRequest
|
|
if (mScoRunnable) {
|
|
DispatchBluetoothReply(mScoRunnable,
|
|
BluetoothValue(true), EmptyString());
|
|
mScoRunnable = nullptr;
|
|
}
|
|
|
|
NotifyAudioManager(mDeviceAddress);
|
|
NotifyStatusChanged(NS_LITERAL_STRING("bluetooth-sco-status-changed"));
|
|
|
|
mScoSocketStatus = mScoSocket->GetConnectionStatus();
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::OnScoConnectError()
|
|
{
|
|
if (mScoRunnable) {
|
|
NS_NAMED_LITERAL_STRING(replyError, "Failed to create SCO socket!");
|
|
DispatchBluetoothReply(mScoRunnable, BluetoothValue(), replyError);
|
|
|
|
mScoRunnable = nullptr;
|
|
}
|
|
|
|
ListenSco();
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::OnScoDisconnect()
|
|
{
|
|
if (mScoSocketStatus == SocketConnectionStatus::SOCKET_CONNECTED) {
|
|
ListenSco();
|
|
NotifyAudioManager(EmptyString());
|
|
NotifyStatusChanged(NS_LITERAL_STRING("bluetooth-sco-status-changed"));
|
|
}
|
|
}
|
|
|
|
bool
|
|
BluetoothHfpManager::IsConnected()
|
|
{
|
|
if (mSocket) {
|
|
return mSocket->GetConnectionStatus() ==
|
|
SocketConnectionStatus::SOCKET_CONNECTED;
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
void
|
|
BluetoothHfpManager::GetAddress(nsAString& aDeviceAddress)
|
|
{
|
|
return mSocket->GetAddress(aDeviceAddress);
|
|
}
|
|
|
|
bool
|
|
BluetoothHfpManager::ConnectSco(BluetoothReplyRunnable* aRunnable)
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
if (gInShutdown) {
|
|
NS_WARNING("ConnecteSco called while in shutdown!");
|
|
return false;
|
|
}
|
|
|
|
if (!IsConnected()) {
|
|
NS_WARNING("BluetoothHfpManager is not connected");
|
|
return false;
|
|
}
|
|
|
|
SocketConnectionStatus status = mScoSocket->GetConnectionStatus();
|
|
if (status == SocketConnectionStatus::SOCKET_CONNECTED ||
|
|
status == SocketConnectionStatus::SOCKET_CONNECTING ||
|
|
(mScoRunnable && (mScoRunnable != aRunnable))) {
|
|
NS_WARNING("SCO connection exists or is being established");
|
|
return false;
|
|
}
|
|
|
|
mScoSocket->Disconnect();
|
|
|
|
mScoRunnable = aRunnable;
|
|
|
|
BluetoothService* bs = BluetoothService::Get();
|
|
NS_ENSURE_TRUE(bs, false);
|
|
nsresult rv = bs->GetScoSocket(mDeviceAddress, true, false, mScoSocket);
|
|
|
|
mScoSocketStatus = mSocket->GetConnectionStatus();
|
|
return NS_SUCCEEDED(rv);
|
|
}
|
|
|
|
bool
|
|
BluetoothHfpManager::DisconnectSco()
|
|
{
|
|
if (!mScoSocket) {
|
|
NS_WARNING("BluetoothHfpManager is not connected");
|
|
return false;
|
|
}
|
|
|
|
mScoSocket->Disconnect();
|
|
return true;
|
|
}
|
|
|
|
bool
|
|
BluetoothHfpManager::ListenSco()
|
|
{
|
|
MOZ_ASSERT(NS_IsMainThread());
|
|
|
|
if (gInShutdown) {
|
|
NS_WARNING("ListenSco called while in shutdown!");
|
|
return false;
|
|
}
|
|
|
|
if (mScoSocket->GetConnectionStatus() ==
|
|
SocketConnectionStatus::SOCKET_LISTENING) {
|
|
NS_WARNING("SCO socket has been already listening");
|
|
return false;
|
|
}
|
|
|
|
mScoSocket->Disconnect();
|
|
|
|
if (!mScoSocket->Listen(-1)) {
|
|
NS_WARNING("Can't listen on SCO socket!");
|
|
return false;
|
|
}
|
|
|
|
mScoSocketStatus = mScoSocket->GetConnectionStatus();
|
|
return true;
|
|
}
|
|
|
|
bool
|
|
BluetoothHfpManager::IsScoConnected()
|
|
{
|
|
if (mScoSocket) {
|
|
return mScoSocket->GetConnectionStatus() ==
|
|
SocketConnectionStatus::SOCKET_CONNECTED;
|
|
}
|
|
return false;
|
|
}
|