1 /* 2 * Copyright (C) 2018 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 #include "eventgatherer.h" 17 #include "defines.h" 18 #include <utils/Log.h> 19 20 using namespace com::android::car::keventreader; 21 22 EventGatherer::EventGatherer(int argc, const char** argv) { 23 for (auto i = 1; i < argc; ++i) { 24 auto dev = std::make_unique<InputSource>(argv[i]); 25 if (dev && *dev) { 26 ALOGD("opened input source file %s", argv[i]); 27 mFds.push_back({dev->descriptor(), POLLIN, 0}); 28 mDevices.emplace(dev->descriptor(), std::move(dev)); 29 } else { 30 ALOGW("failed to open input source file %s", argv[i]); 31 } 32 } 33 } 34 35 size_t EventGatherer::size() const { 36 return mDevices.size(); 37 } 38 39 std::vector<com::android::car::keventreader::KeypressEvent> EventGatherer::read() { 40 constexpr int FOREVER = -1; 41 std::vector<com::android::car::keventreader::KeypressEvent> result; 42 43 int count = poll(&mFds[0], mFds.size(), FOREVER); 44 if (count < 0) { 45 ALOGE("poll failed: errno = %d", errno); 46 return result; 47 } 48 49 for (auto& fd : mFds) { 50 if (fd.revents != 0) { 51 if (fd.revents == POLLIN) { 52 if (auto dev = mDevices[fd.fd].get()) { 53 while(auto evt = dev->read()) { 54 result.push_back(*evt); 55 } 56 --count; // found one source of events we care abour 57 } 58 } 59 fd.revents = 0; 60 if (count == 0) break; // if we read all events, no point in continuing the scan 61 } 62 } 63 64 return result; 65 } 66
