blob: becd6e82c87e2dee4448a2498c86811eedd9b03b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
|
//
// Copyright 2015 Google, Inc.
//
// 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 "service/ipc/binder/ipc_handler_binder.h"
#include <base/bind.h>
#include <base/logging.h>
#include <base/message_loop/message_loop.h>
#include <binder/IPCThreadState.h>
#include <binder/IServiceManager.h>
#include <binder/ProcessState.h>
#include "service/ipc/binder/bluetooth_binder_server.h"
using android::defaultServiceManager;
using android::sp;
using android::status_t;
using android::String8;
using android::String16;
namespace ipc {
std::string kServiceName = "bluetooth-service";
IPCHandlerBinder::IPCHandlerBinder(bluetooth::Adapter* adapter,
IPCManager::Delegate* delegate)
: IPCHandler(adapter, delegate) {}
IPCHandlerBinder::~IPCHandlerBinder() {}
bool IPCHandlerBinder::Run() {
CHECK(adapter());
// Register the IBluetooth service with the Android ServiceManager.
android::sp<binder::BluetoothBinderServer> bt_server =
new binder::BluetoothBinderServer(adapter());
status_t status = defaultServiceManager()->addService(
String16(String8(kServiceName.c_str())), bt_server);
if (status != android::NO_ERROR) {
LOG(ERROR) << "Failed to register Bluetooth service with ServiceManager";
return false;
}
// Notify the delegate. We do this in the message loop to avoid reentrancy.
if (delegate()) {
base::MessageLoop::current()->task_runner()->PostTask(
FROM_HERE, base::Bind(&IPCHandlerBinder::NotifyStarted, this));
}
android::ProcessState::self()->startThreadPool();
return true;
}
void IPCHandlerBinder::Stop() {
// TODO(armansito): There are several methods in android::IPCThreadState that
// are related to shutting down the threadpool, however I haven't been able to
// make them shut things down cleanly. Figure out the right way to stop the
// Binder IPC here.
}
void IPCHandlerBinder::NotifyStarted() {
if (delegate()) delegate()->OnIPCHandlerStarted(IPCManager::TYPE_BINDER);
}
} // namespace ipc
|
