You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
504 lines
14 KiB
504 lines
14 KiB
/*
|
|
Copyright 2011-2013 Timothy Pearson <kb9vqf@pearsoncomputing.net>
|
|
|
|
This file is part of tdekbdledsync, the TDE Keyboard LED Synchronization Daemon
|
|
|
|
tdekbdledsync is free software: you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as
|
|
published by the Free Software Foundation, either version 3
|
|
of the License, or (at your option) any later version.
|
|
|
|
tdekbdledsync is distributed in the hope that it will be useful, but
|
|
WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public
|
|
License along with tdekbdledsync. If not, see http://www.gnu.org/licenses/.
|
|
|
|
*/
|
|
|
|
// The idea here is to periodically read the Xorg core keyboard state, and then forcibly set the physical LED states on all attached keyboards to match (via the event interface)
|
|
// Once every half second should work well enough on most systems
|
|
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <exception>
|
|
#include <string.h>
|
|
#include <unistd.h>
|
|
#include <errno.h>
|
|
#include <fcntl.h>
|
|
#include <limits.h>
|
|
#include <dirent.h>
|
|
#include <linux/vt.h>
|
|
#include <linux/input.h>
|
|
#include <linux/uinput.h>
|
|
#include <sys/file.h>
|
|
#include <sys/types.h>
|
|
#include <sys/stat.h>
|
|
#include <sys/select.h>
|
|
#include <sys/time.h>
|
|
#include <termios.h>
|
|
#include <signal.h>
|
|
#include <stdint.h>
|
|
extern "C" {
|
|
#include <libudev.h>
|
|
#include "getfd.h"
|
|
}
|
|
#include <libgen.h>
|
|
|
|
#include <X11/Xlib.h>
|
|
#include <X11/Xatom.h>
|
|
#include <X11/XKBlib.h>
|
|
#include <X11/extensions/XTest.h>
|
|
#include <X11/keysym.h>
|
|
|
|
using namespace std;
|
|
|
|
// WARNING
|
|
// MAX_KEYBOARDS must be greater than or equal to MAX_INPUT_NODE
|
|
#define MAX_KEYBOARDS 128
|
|
#define MAX_INPUT_NODE 128
|
|
|
|
#define TestBit(bit, array) (array[(bit) / 8] & (1 << ((bit) % 8)))
|
|
|
|
typedef unsigned char byte;
|
|
|
|
char filename[32];
|
|
char key_bitmask[(KEY_MAX + 7) / 8];
|
|
|
|
int keyboard_fd_num;
|
|
int keyboard_fds[MAX_KEYBOARDS];
|
|
|
|
Display* display = NULL;
|
|
|
|
int lockfd = -1;
|
|
char lockFileName[256];
|
|
|
|
// --------------------------------------------------------------------------------------
|
|
// Useful function from Stack Overflow
|
|
// http://stackoverflow.com/questions/874134/find-if-string-endswith-another-string-in-c
|
|
// --------------------------------------------------------------------------------------
|
|
/* returns 1 iff str ends with suffix */
|
|
int str_ends_with(const char * str, const char * suffix) {
|
|
|
|
if( str == NULL || suffix == NULL )
|
|
return 0;
|
|
|
|
size_t str_len = strlen(str);
|
|
size_t suffix_len = strlen(suffix);
|
|
|
|
if(suffix_len > str_len)
|
|
return 0;
|
|
|
|
return 0 == strncmp( str + str_len - suffix_len, suffix, suffix_len );
|
|
}
|
|
// --------------------------------------------------------------------------------------
|
|
|
|
// --------------------------------------------------------------------------------------
|
|
// Useful function from Stack Overflow
|
|
// http://stackoverflow.com/questions/1599459/optimal-lock-file-method
|
|
// --------------------------------------------------------------------------------------
|
|
int tryGetLock(char const *lockName) {
|
|
mode_t m = umask( 0 );
|
|
int fd = open( lockName, O_RDWR|O_CREAT, 0666 );
|
|
umask( m );
|
|
if( fd >= 0 && flock( fd, LOCK_EX | LOCK_NB ) < 0 ) {
|
|
close( fd );
|
|
fd = -1;
|
|
}
|
|
return fd;
|
|
}
|
|
|
|
// --------------------------------------------------------------------------------------
|
|
// Useful function from Stack Overflow
|
|
// http://stackoverflow.com/questions/1599459/optimal-lock-file-method
|
|
// --------------------------------------------------------------------------------------
|
|
void releaseLock(int fd, char const *lockName) {
|
|
if( fd < 0 ) {
|
|
return;
|
|
}
|
|
remove( lockName );
|
|
close( fd );
|
|
}
|
|
|
|
|
|
// --------------------------------------------------------------------------------------
|
|
// Get the VT number X is running on
|
|
// (code taken from GDM, daemon/getvt.c, GPLv2+)
|
|
// --------------------------------------------------------------------------------------
|
|
int get_x_vtnum(Display *dpy)
|
|
{
|
|
Atom prop;
|
|
Atom actualtype;
|
|
int actualformat;
|
|
unsigned long nitems;
|
|
unsigned long bytes_after;
|
|
unsigned char *buf;
|
|
int num;
|
|
|
|
prop = XInternAtom (dpy, "XFree86_VT", False);
|
|
if (prop == None)
|
|
return -1;
|
|
|
|
if (XGetWindowProperty (dpy, DefaultRootWindow (dpy), prop, 0, 1,
|
|
False, AnyPropertyType, &actualtype, &actualformat,
|
|
&nitems, &bytes_after, &buf)) {
|
|
return -1;
|
|
}
|
|
|
|
if (nitems != 1) {
|
|
XFree (buf);
|
|
return -1;
|
|
}
|
|
|
|
switch (actualtype) {
|
|
case XA_CARDINAL:
|
|
case XA_INTEGER:
|
|
case XA_WINDOW:
|
|
switch (actualformat) {
|
|
case 8:
|
|
num = (*(uint8_t *)(void *)buf);
|
|
break;
|
|
case 16:
|
|
num = (*(uint16_t *)(void *)buf);
|
|
break;
|
|
case 32:
|
|
num = (*(uint32_t *)(void *)buf);
|
|
break;
|
|
default:
|
|
XFree (buf);
|
|
return -1;
|
|
}
|
|
break;
|
|
default:
|
|
XFree (buf);
|
|
return -1;
|
|
}
|
|
|
|
XFree (buf);
|
|
|
|
return num;
|
|
}
|
|
// --------------------------------------------------------------------------------------
|
|
|
|
// --------------------------------------------------------------------------------------
|
|
// Get the specified xkb mask modifier
|
|
// (code taken from numlockx)
|
|
// --------------------------------------------------------------------------------------
|
|
unsigned int xkb_mask_modifier(XkbDescPtr xkb, const char *name) {
|
|
int i;
|
|
if( !xkb || !xkb->names ) {
|
|
return 0;
|
|
}
|
|
for( i = 0; i < XkbNumVirtualMods; i++ ) {
|
|
char* modStr = XGetAtomName( xkb->dpy, xkb->names->vmods[i] );
|
|
if( modStr != NULL && strcmp(name, modStr) == 0 ) {
|
|
unsigned int mask;
|
|
XkbVirtualModsToReal( xkb, 1 << i, &mask );
|
|
return mask;
|
|
}
|
|
}
|
|
return 0;
|
|
}
|
|
// --------------------------------------------------------------------------------------
|
|
|
|
// --------------------------------------------------------------------------------------
|
|
// Get the capslock xkb mask modifier
|
|
// --------------------------------------------------------------------------------------
|
|
unsigned int xkb_capslock_mask() {
|
|
return LockMask;
|
|
}
|
|
// --------------------------------------------------------------------------------------
|
|
|
|
// --------------------------------------------------------------------------------------
|
|
// Get the numlock xkb mask modifier
|
|
// (code taken from numlockx)
|
|
// --------------------------------------------------------------------------------------
|
|
unsigned int xkb_numlock_mask() {
|
|
XkbDescPtr xkb;
|
|
if(( xkb = XkbGetKeyboard(display, XkbAllComponentsMask, XkbUseCoreKbd )) != NULL ) {
|
|
unsigned int mask = xkb_mask_modifier( xkb, "NumLock" );
|
|
XkbFreeKeyboard( xkb, 0, True );
|
|
return mask;
|
|
}
|
|
return 0;
|
|
}
|
|
// --------------------------------------------------------------------------------------
|
|
|
|
// --------------------------------------------------------------------------------------
|
|
// Get the scroll lock xkb mask modifier
|
|
// (code taken from numlockx and modified)
|
|
// --------------------------------------------------------------------------------------
|
|
unsigned int xkb_scrolllock_mask() {
|
|
XkbDescPtr xkb;
|
|
if(( xkb = XkbGetKeyboard(display, XkbAllComponentsMask, XkbUseCoreKbd )) != NULL ) {
|
|
unsigned int mask = xkb_mask_modifier( xkb, "ScrollLock" );
|
|
XkbFreeKeyboard( xkb, 0, True );
|
|
return mask;
|
|
}
|
|
return 0;
|
|
}
|
|
// --------------------------------------------------------------------------------------
|
|
|
|
|
|
int find_keyboards() {
|
|
int i, j;
|
|
int fd;
|
|
char name[256] = "Unknown";
|
|
|
|
keyboard_fd_num = 0;
|
|
for (i=0; i<MAX_KEYBOARDS; i++) {
|
|
keyboard_fds[i] = 0;
|
|
}
|
|
|
|
for (i=0; i<MAX_INPUT_NODE; i++) {
|
|
snprintf(filename, sizeof(filename), "/dev/input/event%d", i);
|
|
|
|
fd = open(filename, O_RDWR|O_SYNC);
|
|
if (fd >= 0) {
|
|
ioctl(fd, EVIOCGBIT(EV_KEY, sizeof(key_bitmask)), key_bitmask);
|
|
|
|
// Ensure that we do not detect tsak faked keyboards
|
|
ioctl (fd, EVIOCGNAME(sizeof(name)), name);
|
|
if (str_ends_with(name, "+tsak") == 0) {
|
|
struct input_id input_info;
|
|
ioctl (fd, EVIOCGID, &input_info);
|
|
if ((input_info.vendor != 0) && (input_info.product != 0)) {
|
|
/* We assume that anything that has an alphabetic key in the
|
|
QWERTYUIOP range in it is the main keyboard. */
|
|
for (j = KEY_Q; j <= KEY_P; j++) {
|
|
if (TestBit(j, key_bitmask)) {
|
|
keyboard_fds[keyboard_fd_num] = fd;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if (keyboard_fds[keyboard_fd_num] == 0) {
|
|
close(fd);
|
|
}
|
|
else {
|
|
keyboard_fd_num++;
|
|
}
|
|
}
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
void handle_sigterm(int signum) {
|
|
if (lockfd >= 0) {
|
|
releaseLock(lockfd, lockFileName);
|
|
}
|
|
exit(0);
|
|
}
|
|
|
|
int main() {
|
|
int current_keyboard;
|
|
char name[256] = "Unknown";
|
|
unsigned int states;
|
|
struct input_event ev;
|
|
struct vt_stat vtstat;
|
|
int vt_fd;
|
|
int x11_vt_num = -1;
|
|
// XEvent xev;
|
|
XkbStateRec state;
|
|
|
|
bool num_lock_set = false;
|
|
bool caps_lock_set = false;
|
|
bool scroll_lock_set = false;
|
|
|
|
int num_lock_mask;
|
|
int caps_lock_mask;
|
|
int scroll_lock_mask;
|
|
|
|
int evBase;
|
|
int errBase;
|
|
|
|
// Register cleanup handlers
|
|
struct sigaction action;
|
|
memset(&action, 0, sizeof(struct sigaction));
|
|
action.sa_handler = handle_sigterm;
|
|
sigaction(SIGTERM, &action, NULL);
|
|
|
|
// Open X11 display
|
|
display = XOpenDisplay(NULL);
|
|
if (!display) {
|
|
printf ("[tdekbdledsync] Unable to open X11 display!\n");
|
|
return -1;
|
|
}
|
|
|
|
// Ensure only one process is running on a given display
|
|
sprintf(lockFileName, "/var/lock/tdekbdledsync-%s.lock", XDisplayString(display));
|
|
lockfd = tryGetLock(lockFileName);
|
|
if (lockfd < 0) {
|
|
printf ("[tdekbdledsync] Another instance of this program is already running on this X11 display!\n[tdekbdledsync] Lockfile detected at '%s'\n", lockFileName);
|
|
return -2;
|
|
}
|
|
|
|
// Set up Xkb extension
|
|
int i1, mn, mj;
|
|
mj = XkbMajorVersion;
|
|
mn = XkbMinorVersion;
|
|
if (!XkbQueryExtension(display, &i1, &evBase, &errBase, &mj, &mn)) {
|
|
printf("[tdekbdledsync] Server doesn't support a compatible XKB\n");
|
|
releaseLock(lockfd, lockFileName);
|
|
return -3;
|
|
}
|
|
XkbSelectEvents(display, XkbUseCoreKbd, XkbStateNotifyMask, XkbStateNotifyMask);
|
|
|
|
// Get X server VT number
|
|
x11_vt_num = get_x_vtnum(display);
|
|
|
|
// Open console socket
|
|
vt_fd = getfd(NULL);
|
|
|
|
// Monitor for hotplugged keyboards
|
|
struct udev *udev;
|
|
struct udev_device *dev;
|
|
struct udev_monitor *mon;
|
|
struct timeval tv;
|
|
|
|
// Create the udev object
|
|
udev = udev_new();
|
|
if (!udev) {
|
|
printf("[tdekbdledsync] Cannot connect to udev interface\n");
|
|
releaseLock(lockfd, lockFileName);
|
|
return -4;
|
|
}
|
|
|
|
// Set up a udev monitor to monitor input devices
|
|
mon = udev_monitor_new_from_netlink(udev, "udev");
|
|
udev_monitor_filter_add_match_subsystem_devtype(mon, "input", NULL);
|
|
udev_monitor_enable_receiving(mon);
|
|
|
|
while (1) {
|
|
// Get masks
|
|
num_lock_mask = xkb_numlock_mask();
|
|
caps_lock_mask = xkb_capslock_mask();
|
|
scroll_lock_mask = xkb_scrolllock_mask();
|
|
|
|
// Find keyboards
|
|
find_keyboards();
|
|
if (keyboard_fd_num == 0) {
|
|
printf ("[tdekbdledsync] Could not find any usable keyboard(s)!\n");
|
|
releaseLock(lockfd, lockFileName);
|
|
return -5;
|
|
}
|
|
else {
|
|
fprintf(stderr, "[tdekbdledsync] Found %d keyboard(s)\n", keyboard_fd_num);
|
|
|
|
for (current_keyboard=0;current_keyboard<keyboard_fd_num;current_keyboard++) {
|
|
// Print device name
|
|
ioctl(keyboard_fds[current_keyboard], EVIOCGNAME (sizeof (name)), name);
|
|
fprintf(stderr, "[tdekbdledsync] Syncing keyboard: (%s)\n", name);
|
|
}
|
|
|
|
while (1) {
|
|
// Get current active VT
|
|
if (ioctl(vt_fd, VT_GETSTATE, &vtstat)) {
|
|
fprintf(stderr, "[tdekbdledsync] Unable to get current VT!\n");
|
|
releaseLock(lockfd, lockFileName);
|
|
return -6;
|
|
}
|
|
|
|
if (x11_vt_num == vtstat.v_active) {
|
|
// Get Virtual Core keyboard status
|
|
if (XkbGetIndicatorState(display, XkbUseCoreKbd, &states) != Success) {
|
|
fprintf(stderr, "[tdekbdledsync] Unable to query X11 Virtual Core keyboard!\n");
|
|
releaseLock(lockfd, lockFileName);
|
|
return -7;
|
|
}
|
|
|
|
XkbGetState(display, XkbUseCoreKbd, &state);
|
|
|
|
caps_lock_set = (state.mods & caps_lock_mask);
|
|
num_lock_set = (state.mods & num_lock_mask);
|
|
scroll_lock_set = (state.mods & scroll_lock_mask);
|
|
|
|
for (current_keyboard=0;current_keyboard<keyboard_fd_num;current_keyboard++) {
|
|
// Set LEDs
|
|
ev.type = EV_LED;
|
|
ev.code = LED_CAPSL;
|
|
ev.value = caps_lock_set;
|
|
if (write(keyboard_fds[current_keyboard], &ev, sizeof(ev)) < 0) {
|
|
fprintf(stderr, "[tdekbdledsync] Unable to set LED state\n");
|
|
}
|
|
|
|
ev.type = EV_LED;
|
|
ev.code = LED_NUML;
|
|
ev.value = num_lock_set;
|
|
if (write(keyboard_fds[current_keyboard], &ev, sizeof(ev)) < 0) {
|
|
fprintf(stderr, "[tdekbdledsync] Unable to set LED state\n");
|
|
}
|
|
|
|
ev.type = EV_LED;
|
|
ev.code = LED_SCROLLL;
|
|
ev.value = scroll_lock_set;
|
|
if (write(keyboard_fds[current_keyboard], &ev, sizeof(ev)) < 0) {
|
|
fprintf(stderr, "[tdekbdledsync] Unable to set LED state\n");
|
|
}
|
|
}
|
|
}
|
|
|
|
// Check the hotplug monitoring process to see if any keyboards were added or removed
|
|
fd_set readfds;
|
|
FD_ZERO(&readfds);
|
|
FD_SET(udev_monitor_get_fd(mon), &readfds);
|
|
tv.tv_sec = 0;
|
|
tv.tv_usec = 0;
|
|
int fdcount = select(udev_monitor_get_fd(mon)+1, &readfds, NULL, NULL, &tv);
|
|
if (fdcount < 0) {
|
|
if (errno == EINTR) {
|
|
fprintf(stderr, "[tdekbdledsync] Signal caught in hotplug monitoring process; ignoring\n");
|
|
}
|
|
else {
|
|
fprintf(stderr, "[tdekbdledsync] Select failed on udev file descriptor in hotplug monitoring process\n");
|
|
}
|
|
}
|
|
else {
|
|
dev = udev_monitor_receive_device(mon);
|
|
if (dev) {
|
|
if (strcmp(udev_device_get_action(dev), "add") == 0) {
|
|
// Reload keyboards
|
|
break;
|
|
}
|
|
if (strcmp(udev_device_get_action(dev), "remove") == 0) {
|
|
// Reload keyboards
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
// Poll
|
|
usleep(250*1000);
|
|
|
|
// // Wait for an Xkb event
|
|
// // FIXME
|
|
// // This prevents the udev hotplug monitor from working, as XNextEvent does not stop blocking when a keyboard hotplug occurs
|
|
// while (1) {
|
|
// XNextEvent(display, &xev);
|
|
// if (xev.type == evBase + XkbEventCode) {
|
|
// XkbEvent *xkb_event = reinterpret_cast<XkbEvent*>(&xev);
|
|
// if (xkb_event->any.xkb_type & XkbStateNotify) {
|
|
// if ((xkb_event->state.changed & XkbModifierStateMask) || (xkb_event->state.changed & XkbModifierBaseMask)) {
|
|
// // Modifier state has changed
|
|
// // Synchronize keyboard indicators
|
|
// break;
|
|
// }
|
|
// }
|
|
// }
|
|
// }
|
|
}
|
|
}
|
|
|
|
// Close all keyboard file descriptors
|
|
for (int current_keyboard=0;current_keyboard<keyboard_fd_num;current_keyboard++) {
|
|
close(keyboard_fds[current_keyboard]);
|
|
}
|
|
}
|
|
|
|
releaseLock(lockfd, lockFileName);
|
|
return 0;
|
|
}
|