Stone Of Days

3월부터 개인적인 시간이 생기면서, 그동안 부족했던 부분들을 채워 보고자 Coursera.org에서 강의를 신청 했었다.

두 개의 강으로 나누어져 있는 알고리즘 강의가 있었는데, Part I은 주경야독으로 빡세게 진행 했었고, 나머지 Part II를 마져 수강 신청 했었다.

그러고는, 요즘 인공지능, 머신러닝 얘기가 하도 많아서, 상식차원에서 좀 알아야 되지 않겠나 하는 충동으로 별 생각없이 첫 강의를 본다는게 수강 신청이 되어 버렸다. ㅎㅎ

그러고는 거의 3개월 가까이, 알고리즘과 머신러닝 강의를 소화 해 내느라, 계획에 없던 정신없는 생활을 해야 했고, 결국 certi를 획득 했다. ;ㅁ;

두 강의 모두, 마지막 주차 강의를 듣는 동안에는 두 교수님들의 말씀들에 뭉클하기 까지 하더라.

어느 블로그에서, 미국에 유학을 가면, 첫 학기에는 두 과목 수강하기도 힘들다는 내용을 본 적이 있는데, 실제 학위를 받기위해 직접 수강을 하는 경우에는 온라인 수강보다 몇 배 더 어렵겠다는 생각이 들었고, 미국 유학가서 학위를 받은 사람들을 다시 바라보게 되는 계기가 되었다.

어쨌든 이 강의를 통해 알고 느끼게 된 점은

• 머신러닝이 무엇인지에 대해서 알게 되었다.
• MATLAB은 논문 쓸 때 그래프 그리는 것이 주 용도가 아니었다.
• 선형대수(Linear algebra)는 정말 중요하고 요긴하다.
• 고등학교 때 이후로 손 놓고 있었던 미분이 어렴풋이 기억 나더라.
• 3D 그래픽하면서 다시 공부했던 수학이 큰 도움이 되었다.
• 퀴즈와 과제는 문제와 지문의 이해 자체도 큰 허들이다.
• 해외(미국) 유학은 쉽지 않겠다.

기-승-전-수학이군...

끝.

Input Device의 input event를 App.에서 직접 받아 볼 필요가 있어, NDK로 epoll을 이용해 구현 했던 내용을 정리 해 본다.

epoll 관련 설명은 The Event Poll Interface를 참고 하였다.

우선, device driver file의 fd를 사용해야 하기 때문에, 해당 device file을 열 수 있는 권한을 App.이 가지고 있어야 한다. (예를 들면 App.이 system 권한을 가지고 있어야 한다.)

아래 예제 소스 각각의 특징에 대해서, 간략하게만 정리 해 둔다. 구현 했던 걸, 생각나는 대로 다시 정리한 것이라서, 그대로 copy & paste 하면 제대로 빌드가 되지 않을 수는 있겠으나, 전체적인 맥락은 유효하니 나중에 필요할 때 다시 볼 수 있을 것으로 믿는다.ㅎㅎ

[Header]

• epoll이나 device driver 파일을 열고나면, 열린 file descriptor를 복사한다는거 자체가 적절하지 않으므로, 복사/대입을 막아 두었다.
• epoll로 이벤트를 받고 처리하기위해 thread를 하나 만들었으며, 전달 받은 이벤트를 container에 저장 해 두고 사용하기 위해서 mutex를 하나 두었다.
• JNI에서 instance를 생성하고 사용해야 하므로, 간단하게 constructor에서 모든 초기화를 마치고, destructor에서 file descriptor등을 닫도록 처리 했다.

#ifndef __EPOLL_SAMPLE_H__ #define __EPOLL_SAMPLE_H__ #include <string> #include <thread> #include <mutex> class EpollSample { private: const int EPOLL_HINT_SIZE = 1; private: bool mInitialized; int mEpollFd; int mDeviceFd; bool mThreadDone; std::thread mEventThread; std::mutex mMutex; public: explicit EpollSample(std::string const& devicePath); virtual ~EpollSample(); EpollSample(EpollSample const&) = delete; EpollSample(EpollSample&&) = delete; EpollSample& operator=(EpollSample const&) = delete; EpollSample& operator=(EpollSample&&) = delete; bool isInitialized() const noexcept { return mInitialized; } int getEpollFd() const noexcept { return mEpollFd; } int getDeviceFd() const noexcept { return mDeviceFd; } bool isEventThreadAvilable() const noexcept { return !mThreadDone; } void terminateEventThread() noexcept; }; #endif //__EPOLL_SAMPLE_H__

[Source]

• threadHandler에서는 epoll_wait으로 이벤트를 무한정 대기한다.(timeout 시간을 지정할 수도 있음)
• 정상적으로 이벤트를 받은 경우, epoll_wait이 이벤트의 개수를 반환한다. 이 개수 만큼, 대상 file descriptor를 통해 이벤트 데이터를 읽어 들인다.
• 오류를 검사하고, input_event 구조체를 통해 이벤트 데이터를 활용한다.

#include <linux/input.h> #include <sys/epoll.h> #include <errno.h> #include <EpollSample.h> void threadHandler(EpollSample& instance) { if (&instance == nullptr) { //("EpollSample instance is null!"); return; } static int const EPOLL_MAX_EVENTS = 16; struct epoll_event eventItems[EPOLL_MAX_EVENTS]; static int const EVENT_BUFFER_SIZE = 256; struct input_event eventBuffer[EVENT_BUFFER_SIZE]; while (instance.isEventThreadAvilable()) { int const numEvents = epoll_wait(instance.getEpollFd(), eventItems, EPOLL_MAX_EVENTS, -1); if (numEvents < 0 && (errno == EBADF || errno == EINVAL)) { //("epfd is not a valid file descriptor or a valid epoll instance"); break; } for (auto i = 0; i < numEvents; ++i) { struct epoll_event& epollEvent = eventItems[i]; if (epollEvent.events & EPOLLIN) { int const readSize = ::read(instance.getDeviceFd(), eventBuffer, sizeof(struct input_event) * EVENT_BUFFER_SIZE); if (readSize <= 0) { //("Could not get event, errno = %d", errno); break; } else if (readSize % sizeof(struct input_event) != 0) { //("Could not get event, wrong size = %d", readSize); break; } else { auto const numInputEvents = static_cast<std::size_t>(readSize) / sizeof(struct input_event); for (auto j = 0; j < numInputEvents; ++j) { struct input_event& inputEvent = eventBuffer[j]; //Do something } } } else if (epollEvent.events & EPOLLHUP) { //("The epoll hang-up event has been received"); } else { //("Unexpected epoll event has been received, event = 0x%08x", epollEvent.events); } } } } EpollSample::EpollSample(std::string const & devicePath) : mInitialized(false), mEpollFd(-1), mDeviceFd(-1), mThreadDone(false) { mEpollFd = epoll_create(EPOLL_HINT_SIZE); if (mEpollFd < 0) { //("Could not create epoll instance!"); return; } mDeviceFd = ::open(devicePath.c_str(), O_RDWR | O_CLOEXEC); if (mDeviceFd < 0) { //("Could not open virtual device to hook: %d", mDeviceFd); //("errno: %d", errno); return; } char buffer[80]; if (ioctl(mDeviceFd, EVIOCGNAME(sizeof(buffer)-1), &buffer) < 1) { //("Could not get the device name"); } else { buffer[sizeof(buffer) - 1] = '\0'; //("The name of opened device = %s", buffer); } if (fcntl(mDeviceFd, F_SETFL, O_NONBLOCK)) { //("Error %d making device file descriptor non-blocking.", errno); return; } struct epoll_event evt; memset(&evt, 0, sizeof(evt)); evt.events = EPOLLIN; if (epoll_ctl(mEpollFd, EPOLL_CTL_ADD, mDeviceFd, &evt)) { //("Could not add device fd to epoll instance. errno=%d", errno); return; } mEventThread = std::thread(threadHandler, std::ref(*this)); mInitialized = true; } EpollSample::~EpollSample() { mInitialized = false; if (isEventThreadAvilable()) { terminateEventThread(); } if (mEpollFd >= 0) { close(mEpollFd); } if (mDeviceFd >= 0) { close(mDeviceFd); } } void EpollSample::terminateEventThread() noexcept { mThreadDone = true; mEventThread.join(); }

[JNI interface for JAVA]

• App.에서 JAVA로 호출하게 될 native 함수 정의이다.
• native도 복사/대입 금지를 하도록 되어 있으므로, JAVA interface도 singleton으로 구현하는 것이 적절하다고 판단 되므로, static으로 선언!
• native instance의 pointer를 JAVA instance에서 보관하고 활용하는 방식으로 구현되어 있으므로, native interface를 추가하고 활용하기 위해서는, long 타입의 native instance pointer를 전달하는 것이 필요하다.

private static native long nativeInit(); private static native void nativeFinalize(long ptr);

[JNI interface for C/C++]

• App.이 native 초기화를 진행하면, native instance를 생성하면서 초기화를 진행하고, 문제가 없으면 instance pointer를 반환한다.
• 현재는 device driver 파일경로를 직접 표시 했는데, android property 등의 환경변수나 다른 입력을 통해 전달 받도록 할 수 있겠다.

JNIEXPORT jlong JNICALL nativeInit(JNIEnv *, jclass) { EpollSample* epollSample = new EpollSample("/dev/input/event3"); assert(epollSample != nullptr); return reinterpret_cast<jlong>(epollSample); } JNIEXPORT void JNICALL nativeFinalize(JNIEnv *, jclass, jlong ptr) { EpollSample* epollSample = reinterpret_cast<EpollSample*>(ptr); delete epollSample; }

[Android.mk]

• 일반적인 NDK makefile이며, C++11을 사용하기위해 -std=c++11을 추가함. (Application.mk에서와 중복되어 있다)

LOCAL_PATH:=$(call my-dir) include $(CLEAR_VARS) LOCAL_CFLAGS := \ -DLOG_NDEBUG=0 \ -std=c++11 LOCAL_C_INCLUDES := \ $(JNI_H_INCLUDE) \ $(LOCAL_PATH)/include LOCAL_SRC_FILES := \ EpollSample.cpp LOCAL_LDLIBS := \ -llog LOCAL_MODULE := libepoll_sample include $(BUILD_SHARED_LIBRARY)

[Application.mk]

• GCC 4.9와 STL 사용을 위해 명시적으로 추가 해 두었다.
• platform이 32bit/64bit ABI를 사용하므로 두 종류 모두 빌드 할 수 있도록, armeabi-v7a, arm64-v8a를 추가 했다.

NDK_TOOLCHAIN_VERSION := 4.9 APP_STL := gnustl_shared APP_ABI := armeabi-v7a arm64-v8a APP_CPPFLAGS += -std=c++11