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