mirrors/raylib
1
0
Fork 0
mirror of https://github.com/raysan5/raylib.git synced 2025-10-26 12:27:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Review RPI keyboard inputs -WIP-

Browse Source
This commit is contained in:
Ray
2018-12-18 19:11:12 +01:00
parent 39c05e30d0
commit a22ee0c0e1
1 changed files with 41 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

72
src/core.c
View File

@@ -473,8 +473,8 @@ static void InitKeyboard(void); // Init raw keyboard sys
static void ProcessKeyboard(void); // Process keyboard events static void ProcessKeyboard(void); // Process keyboard events
static void RestoreKeyboard(void); // Restore keyboard system static void RestoreKeyboard(void); // Restore keyboard system
static void InitMouse(void); // Mouse initialization (including mouse thread) static void InitMouse(void); // Mouse initialization (including mouse thread)
static void EventThreadSpawn(char *device); // Indetifies a input device and spawns a thread to handle it if needed static void EventThreadSpawn(char *device); // Identifies a input device and spawns a thread to handle it if needed
static void *EventThread(void *arg); // Input device event reading thread static void *EventThread(void *arg); // Input device events reading thread
static void InitGamepad(void); // Init raw gamepad input static void InitGamepad(void); // Init raw gamepad input
static void *GamepadThread(void *arg); // Mouse reading thread static void *GamepadThread(void *arg); // Mouse reading thread
#endif #endif
@@ -3782,12 +3782,17 @@ static void ProcessKeyboard(void)
int bufferByteCount = 0; // Bytes available on the buffer int bufferByteCount = 0; // Bytes available on the buffer
char keysBuffer[MAX_KEYBUFFER_SIZE]; // Max keys to be read at a time char keysBuffer[MAX_KEYBUFFER_SIZE]; // Max keys to be read at a time
// Reset pressed keys array
for (int i = 0; i < 512; i++) currentKeyState[i] = 0;
// Read availables keycodes from stdin // Read availables keycodes from stdin
bufferByteCount = read(STDIN_FILENO, keysBuffer, MAX_KEYBUFFER_SIZE); // POSIX system call bufferByteCount = read(STDIN_FILENO, keysBuffer, MAX_KEYBUFFER_SIZE); // POSIX system call
if (bufferByteCount > 0)
{
// Reset pressed keys array (it will be filled below)
for (int i = 0; i < 512; i++) currentKeyState[i] = 0;
// ISSUE: If pressed key is the same as previous one, currentKeyState is never reseted...
}
// Fill all read bytes (looking for keys) // Fill all read bytes (looking for keys)
for (int i = 0; i < bufferByteCount; i++) for (int i = 0; i < bufferByteCount; i++)
{ {
@@ -3860,6 +3865,8 @@ static void ProcessKeyboard(void)
currentKeyState[(int)keysBuffer[i] - 32] = 1; currentKeyState[(int)keysBuffer[i] - 32] = 1;
} }
else currentKeyState[(int)keysBuffer[i]] = 1; else currentKeyState[(int)keysBuffer[i]] = 1;
lastKeyPressed = keysBuffer[i]; // Register last key pressed
} }
} }
@@ -3889,7 +3896,7 @@ static void RestoreKeyboard(void)
// Mouse initialization (including mouse thread) // Mouse initialization (including mouse thread)
static void InitMouse(void) static void InitMouse(void)
{ {
char Path[MAX_FILEPATH_LENGTH]; char path[MAX_FILEPATH_LENGTH];
DIR *directory; DIR *directory;
struct dirent *entity; struct dirent *entity;
@@ -3908,19 +3915,17 @@ static void InitMouse(void)
{ {
if (strncmp("event", entity->d_name, strlen("event")) == 0) // Search for devices named "event*" if (strncmp("event", entity->d_name, strlen("event")) == 0) // Search for devices named "event*"
{ {
sprintf(Path, "%s%s", DEFAULT_EVDEV_PATH, entity->d_name); sprintf(path, "%s%s", DEFAULT_EVDEV_PATH, entity->d_name);
EventThreadSpawn(Path); // Identify the device and spawn a thread for it EventThreadSpawn(path); // Identify the device and spawn a thread for it
} }
} }
closedir(directory); closedir(directory);
} }
else else TraceLog(LOG_WARNING, "Unable to open linux event directory: %s", DEFAULT_EVDEV_PATH);
{
TraceLog(LOG_WARNING, "Unable to open linux event directory %s", DEFAULT_EVDEV_PATH);
}
} }
// Identifies a input device and spawns a thread to handle it if needed
static void EventThreadSpawn(char *device) static void EventThreadSpawn(char *device)
{ {
#define BITS_PER_LONG (sizeof(long)*8) #define BITS_PER_LONG (sizeof(long)*8)
@@ -3943,8 +3948,8 @@ static void EventThreadSpawn(char *device)
InputEventWorker *worker; InputEventWorker *worker;
/////////////////////////////////// Open the device and allocate worker ///////////////////////////////////////////// // Open the device and allocate worker
//-------------------------------------------------------------------------------------------------------
// Find a free spot in the workers array // Find a free spot in the workers array
for (int i = 0; i < sizeof(eventWorkers)/sizeof(InputEventWorker); ++i) for (int i = 0; i < sizeof(eventWorkers)/sizeof(InputEventWorker); ++i)
{ {
@@ -3963,7 +3968,7 @@ static void EventThreadSpawn(char *device)
} }
else else
{ {
TraceLog(LOG_WARNING, "Error creating input device thread for '%s': Out of worker slots", device); TraceLog(LOG_WARNING, "Error creating input device thread for [%s]: Out of worker slots", device);
return; return;
} }
@@ -3971,12 +3976,12 @@ static void EventThreadSpawn(char *device)
fd = open(device, O_RDONLY | O_NONBLOCK); fd = open(device, O_RDONLY | O_NONBLOCK);
if (fd < 0) if (fd < 0)
{ {
TraceLog(LOG_WARNING, "Error creating input device thread for '%s': Can't open device (Err: %d)", device, worker->fd); TraceLog(LOG_WARNING, "Error creating input device thread for [%s]: Can't open device (Error: %d)", device, worker->fd);
return; return;
} }
worker->fd = fd; worker->fd = fd;
//Grab number on the end of the devices name "event<N>" // Grab number on the end of the devices name "event<N>"
int devNum = 0; int devNum = 0;
char *ptrDevName = strrchr(device, 't'); char *ptrDevName = strrchr(device, 't');
worker->eventNum = -1; worker->eventNum = -1;
@@ -3987,12 +3992,12 @@ static void EventThreadSpawn(char *device)
worker->eventNum = devNum; worker->eventNum = devNum;
} }
// At this point we have a connection to the device, // At this point we have a connection to the device, but we don't yet know what the device is.
// but we don't yet know what the device is (Could be // It could be many things, even as simple as a power button...
// many things, even as simple as a power button) //-------------------------------------------------------------------------------------------------------
/////////////////////////////////// Identify the device /////////////////////////////////////////////
// Identify the device
//-------------------------------------------------------------------------------------------------------
ioctl(fd, EVIOCGBIT(0, sizeof(evBits)), evBits); // Read a bitfield of the avalable device properties ioctl(fd, EVIOCGBIT(0, sizeof(evBits)), evBits); // Read a bitfield of the avalable device properties
// Check for absolute input devices // Check for absolute input devices
@@ -4065,13 +4070,14 @@ static void EventThreadSpawn(char *device)
if (TEST_BIT(keyBits, KEY_SPACE)) worker->isKeyboard = true; // This is a keyboard if (TEST_BIT(keyBits, KEY_SPACE)) worker->isKeyboard = true; // This is a keyboard
} }
//-------------------------------------------------------------------------------------------------------
// Decide what to do with the device
/////////////////////////////////// Decide what to do with the device ///////////////////////////////////////////// //-------------------------------------------------------------------------------------------------------
if (worker->isTouch || worker->isMouse) if (worker->isTouch || worker->isMouse)
{ {
// Looks like a interesting device // Looks like a interesting device
TraceLog(LOG_INFO, "Opening input device '%s' (%s%s%s%s%s)", device, TraceLog(LOG_INFO, "Opening input device [%s] (%s%s%s%s%s)", device,
worker->isMouse ? "mouse " : "", worker->isMouse ? "mouse " : "",
worker->isMultitouch ? "multitouch " : "", worker->isMultitouch ? "multitouch " : "",
worker->isTouch ? "touchscreen " : "", worker->isTouch ? "touchscreen " : "",
@@ -4082,7 +4088,7 @@ static void EventThreadSpawn(char *device)
int error = pthread_create(&worker->threadId, NULL, &EventThread, (void *)worker); int error = pthread_create(&worker->threadId, NULL, &EventThread, (void *)worker);
if (error != 0) if (error != 0)
{ {
TraceLog(LOG_WARNING, "Error creating input device thread for '%s': Can't create thread (Err: %d)", device, error); TraceLog(LOG_WARNING, "Error creating input device thread for [%s]: Can't create thread (Error: %d)", device, error);
worker->threadId = 0; worker->threadId = 0;
close(fd); close(fd);
} }
@@ -4103,7 +4109,7 @@ static void EventThreadSpawn(char *device)
{ {
if (eventWorkers[i].threadId != 0) if (eventWorkers[i].threadId != 0)
{ {
TraceLog(LOG_WARNING, "Duplicate touchscreen found, killing toucnscreen on event%d", i); TraceLog(LOG_WARNING, "Duplicate touchscreen found, killing touchscreen on event: %d", i);
pthread_cancel(eventWorkers[i].threadId); pthread_cancel(eventWorkers[i].threadId);
close(eventWorkers[i].fd); close(eventWorkers[i].fd);
} }
@@ -4112,8 +4118,10 @@ static void EventThreadSpawn(char *device)
#endif #endif
} }
else close(fd); // We are not interested in this device else close(fd); // We are not interested in this device
//-------------------------------------------------------------------------------------------------------
} }
// Input device events reading thread
static void *EventThread(void *arg) static void *EventThread(void *arg)
{ {
struct input_event event; struct input_event event;
@@ -4125,7 +4133,7 @@ static void *EventThread(void *arg)
{ {
if (read(worker->fd, &event, sizeof(event)) == (int)sizeof(event)) if (read(worker->fd, &event, sizeof(event)) == (int)sizeof(event))
{ {
/////////////////////////////// Relative movement parsing //////////////////////////////////// // Relative movement parsing
if (event.type == EV_REL) if (event.type == EV_REL)
{ {
if (event.code == REL_X) if (event.code == REL_X)
@@ -4150,7 +4158,7 @@ static void *EventThread(void *arg)
} }
} }
/////////////////////////////// Absolute movement parsing //////////////////////////////////// // Absolute movement parsing
if (event.type == EV_ABS) if (event.type == EV_ABS)
{ {
// Basic movement // Basic movement
@@ -4197,7 +4205,7 @@ static void *EventThread(void *arg)
} }
} }
/////////////////////////////// Button parsing //////////////////////////////////// // Button parsing
if (event.type == EV_KEY) if (event.type == EV_KEY)
{ {
if((event.code == BTN_TOUCH) || (event.code == BTN_LEFT)) if((event.code == BTN_TOUCH) || (event.code == BTN_LEFT))
@@ -4213,14 +4221,14 @@ static void *EventThread(void *arg)
if (event.code == BTN_MIDDLE) currentMouseStateEvdev[MOUSE_MIDDLE_BUTTON] = event.value; if (event.code == BTN_MIDDLE) currentMouseStateEvdev[MOUSE_MIDDLE_BUTTON] = event.value;
} }
/////////////////////////////// Screen confinement //////////////////////////////////// // Screen confinement
if (mousePosition.x < 0) mousePosition.x = 0; if (mousePosition.x < 0) mousePosition.x = 0;
if (mousePosition.x > screenWidth/mouseScale) mousePosition.x = screenWidth/mouseScale; if (mousePosition.x > screenWidth/mouseScale) mousePosition.x = screenWidth/mouseScale;
if (mousePosition.y < 0) mousePosition.y = 0; if (mousePosition.y < 0) mousePosition.y = 0;
if (mousePosition.y > screenHeight/mouseScale) mousePosition.y = screenHeight/mouseScale; if (mousePosition.y > screenHeight/mouseScale) mousePosition.y = screenHeight/mouseScale;
/////////////////////////////// Gesture update //////////////////////////////////// // Gesture update
if (GestureNeedsUpdate) if (GestureNeedsUpdate)
{ {
gestureEvent.pointCount = 0; gestureEvent.pointCount = 0;