1 /*
2 * Copyright (C) 2010 The Android Open Source Project
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 #define LOG_TAG "InputManager"
18
19 //#define LOG_NDEBUG 0
20
21 #include "InputManager.h"
22
23 #include <cutils/log.h>
24
25 namespace android {
26
InputManager(const sp<EventHubInterface> & eventHub,const sp<InputReaderPolicyInterface> & readerPolicy,const sp<InputDispatcherPolicyInterface> & dispatcherPolicy)27 InputManager::InputManager(
28 const sp<EventHubInterface>& eventHub,
29 const sp<InputReaderPolicyInterface>& readerPolicy,
30 const sp<InputDispatcherPolicyInterface>& dispatcherPolicy) {
31 mDispatcher = new InputDispatcher(dispatcherPolicy);
32 mReader = new InputReader(eventHub, readerPolicy, mDispatcher);
33 initialize();
34 }
35
InputManager(const sp<InputReaderInterface> & reader,const sp<InputDispatcherInterface> & dispatcher)36 InputManager::InputManager(
37 const sp<InputReaderInterface>& reader,
38 const sp<InputDispatcherInterface>& dispatcher) :
39 mReader(reader),
40 mDispatcher(dispatcher) {
41 initialize();
42 }
43
~InputManager()44 InputManager::~InputManager() {
45 stop();
46 }
47
initialize()48 void InputManager::initialize() {
49 mReaderThread = new InputReaderThread(mReader);
50 mDispatcherThread = new InputDispatcherThread(mDispatcher);
51 }
52
start()53 status_t InputManager::start() {
54 status_t result = mDispatcherThread->run("InputDispatcher", PRIORITY_URGENT_DISPLAY);
55 if (result) {
56 ALOGE("Could not start InputDispatcher thread due to error %d.", result);
57 return result;
58 }
59
60 result = mReaderThread->run("InputReader", PRIORITY_URGENT_DISPLAY);
61 if (result) {
62 ALOGE("Could not start InputReader thread due to error %d.", result);
63
64 mDispatcherThread->requestExit();
65 return result;
66 }
67
68 return OK;
69 }
70
stop()71 status_t InputManager::stop() {
72 status_t result = mReaderThread->requestExitAndWait();
73 if (result) {
74 ALOGW("Could not stop InputReader thread due to error %d.", result);
75 }
76
77 result = mDispatcherThread->requestExitAndWait();
78 if (result) {
79 ALOGW("Could not stop InputDispatcher thread due to error %d.", result);
80 }
81
82 return OK;
83 }
84
getReader()85 sp<InputReaderInterface> InputManager::getReader() {
86 return mReader;
87 }
88
getDispatcher()89 sp<InputDispatcherInterface> InputManager::getDispatcher() {
90 return mDispatcher;
91 }
92
93 } // namespace android
94