1//
2//  Copyright (C) 2015 Google, Inc.
3//
4//  Licensed under the Apache License, Version 2.0 (the "License");
5//  you may not use this file except in compliance with the License.
6//  You may obtain a copy of the License at:
7//
8//  http://www.apache.org/licenses/LICENSE-2.0
9//
10//  Unless required by applicable law or agreed to in writing, software
11//  distributed under the License is distributed on an "AS IS" BASIS,
12//  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13//  See the License for the specific language governing permissions and
14//  limitations under the License.
15//
16
17#include "service/ipc/ipc_manager.h"
18
19#if !defined(OS_GENERIC)
20#include "service/ipc/binder/ipc_handler_binder.h"
21#else
22#include "service/ipc/dbus/ipc_handler_dbus.h"
23#endif  // !defined(OS_GENERIC)
24#include "service/ipc/ipc_handler_linux.h"
25
26namespace ipc {
27
28IPCManager::IPCManager(bluetooth::Adapter* adapter) : adapter_(adapter) {
29  CHECK(adapter_);
30}
31
32IPCManager::~IPCManager() {
33  // Don't rely on the handlers getting destroyed since another thread might be
34  // holding a reference to them. Instead, explicitly stop them here.
35  if (BinderStarted()) binder_handler_->Stop();
36  if (LinuxStarted()) linux_handler_->Stop();
37  if (DBusStarted()) dbus_handler_->Stop();
38}
39
40bool IPCManager::Start(Type type, Delegate* delegate) {
41  switch (type) {
42    case TYPE_LINUX:
43      if (LinuxStarted()) {
44        LOG(ERROR) << "IPCManagerLinux already started.";
45        return false;
46      }
47
48      linux_handler_ = new IPCHandlerLinux(adapter_, delegate);
49      if (!linux_handler_->Run()) {
50        linux_handler_ = nullptr;
51        return false;
52      }
53      return true;
54
55#if !defined(OS_GENERIC)
56    case TYPE_BINDER:
57      if (BinderStarted()) {
58        LOG(ERROR) << "IPCManagerBinder already started.";
59        return false;
60      }
61
62      binder_handler_ = new IPCHandlerBinder(adapter_, delegate);
63      if (!binder_handler_->Run()) {
64        binder_handler_ = nullptr;
65        return false;
66      }
67      return true;
68#else
69    case TYPE_DBUS:
70      if (DBusStarted()) {
71        LOG(ERROR) << "IPCManagerDBus already started.";
72        return false;
73      }
74
75      dbus_handler_ = new IPCHandlerDBus(adapter_, delegate);
76      if (!dbus_handler_->Run()) {
77        dbus_handler_ = nullptr;
78        return false;
79      }
80      return true;
81#endif  // !defined(OS_GENERIC)
82
83    default:
84      LOG(ERROR) << "Unsupported IPC type given: " << type;
85  }
86
87  return false;
88}
89
90bool IPCManager::BinderStarted() const { return binder_handler_.get(); }
91
92bool IPCManager::LinuxStarted() const { return linux_handler_.get(); }
93
94bool IPCManager::DBusStarted() const { return dbus_handler_.get(); }
95
96}  // namespace ipc
97