source: mainline/uspace/srv/hid/input/generic/input.c@ cce8a83

lfn serial ticket/834-toolchain-update topic/msim-upgrade topic/simplify-dev-export
Last change on this file since cce8a83 was cce8a83, checked in by Jiri Svoboda <jiri@…>, 14 years ago

loc_service_get_name() to translate service ID to name.
  • Property mode set to 100644
File size: 15.0 KB
Line 
1/*
2 * Copyright (c) 2006 Josef Cejka
3 * Copyright (c) 2011 Jiri Svoboda
4 * All rights reserved.
5 *
6 * Redistribution and use in source and binary forms, with or without
7 * modification, are permitted provided that the following conditions
8 * are met:
9 *
10 * - Redistributions of source code must retain the above copyright
11 * notice, this list of conditions and the following disclaimer.
12 * - Redistributions in binary form must reproduce the above copyright
13 * notice, this list of conditions and the following disclaimer in the
14 * documentation and/or other materials provided with the distribution.
15 * - The name of the author may not be used to endorse or promote products
16 * derived from this software without specific prior written permission.
17 *
18 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
19 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
20 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
21 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
22 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
23 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
24 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
25 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
26 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
27 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
28 */
29
30/**
31 * @addtogroup inputgen generic
32 * @brief HelenOS input server.
33 * @ingroup input
34 * @{
35 */
36/** @file
37 */
38
39#include <adt/list.h>
40#include <bool.h>
41#include <ipc/services.h>
42#include <ipc/input.h>
43#include <sysinfo.h>
44#include <stdio.h>
45#include <unistd.h>
46#include <stdlib.h>
47#include <stdio.h>
48#include <ns.h>
49#include <ns_obsolete.h>
50#include <async.h>
51#include <async_obsolete.h>
52#include <errno.h>
53#include <adt/fifo.h>
54#include <io/console.h>
55#include <io/keycode.h>
56#include <loc.h>
57#include <input.h>
58#include <kbd.h>
59#include <kbd_port.h>
60#include <kbd_ctl.h>
61#include <mouse_proto.h>
62#include <layout.h>
63#include <mouse.h>
64
65// FIXME: remove this header
66#include <abi/ipc/methods.h>
67
68/* In microseconds */
69#define DISCOVERY_POLL_INTERVAL (10 * 1000 * 1000)
70
71#define NUM_LAYOUTS 3
72
73static layout_ops_t *layout[NUM_LAYOUTS] = {
74 &us_qwerty_ops,
75 &us_dvorak_ops,
76 &cz_ops
77};
78
79static void kbd_devs_yield(void);
80static void kbd_devs_reclaim(void);
81
82int client_phone = -1;
83
84/** List of keyboard devices */
85static list_t kbd_devs;
86
87/** List of mouse devices */
88static list_t mouse_devs;
89
90bool irc_service = false;
91int irc_phone = -1;
92
93void kbd_push_data(kbd_dev_t *kdev, sysarg_t data)
94{
95 (*kdev->ctl_ops->parse)(data);
96}
97
98void mouse_push_data(mouse_dev_t *mdev, sysarg_t data)
99{
100 (*mdev->proto_ops->parse)(data);
101}
102
103void kbd_push_event(kbd_dev_t *kdev, int type, unsigned int key)
104{
105 kbd_event_t ev;
106 unsigned int mod_mask;
107
108 switch (key) {
109 case KC_LCTRL: mod_mask = KM_LCTRL; break;
110 case KC_RCTRL: mod_mask = KM_RCTRL; break;
111 case KC_LSHIFT: mod_mask = KM_LSHIFT; break;
112 case KC_RSHIFT: mod_mask = KM_RSHIFT; break;
113 case KC_LALT: mod_mask = KM_LALT; break;
114 case KC_RALT: mod_mask = KM_RALT; break;
115 default: mod_mask = 0; break;
116 }
117
118 if (mod_mask != 0) {
119 if (type == KEY_PRESS)
120 kdev->mods = kdev->mods | mod_mask;
121 else
122 kdev->mods = kdev->mods & ~mod_mask;
123 }
124
125 switch (key) {
126 case KC_CAPS_LOCK: mod_mask = KM_CAPS_LOCK; break;
127 case KC_NUM_LOCK: mod_mask = KM_NUM_LOCK; break;
128 case KC_SCROLL_LOCK: mod_mask = KM_SCROLL_LOCK; break;
129 default: mod_mask = 0; break;
130 }
131
132 if (mod_mask != 0) {
133 if (type == KEY_PRESS) {
134 /*
135 * Only change lock state on transition from released
136 * to pressed. This prevents autorepeat from messing
137 * up the lock state.
138 */
139 kdev->mods = kdev->mods ^ (mod_mask & ~kdev->lock_keys);
140 kdev->lock_keys = kdev->lock_keys | mod_mask;
141
142 /* Update keyboard lock indicator lights. */
143 (*kdev->ctl_ops->set_ind)(kdev, kdev->mods);
144 } else {
145 kdev->lock_keys = kdev->lock_keys & ~mod_mask;
146 }
147 }
148
149 if (type == KEY_PRESS && (kdev->mods & KM_LCTRL) &&
150 key == KC_F1) {
151 layout_destroy(kdev->active_layout);
152 kdev->active_layout = layout_create(layout[0]);
153 return;
154 }
155
156 if (type == KEY_PRESS && (kdev->mods & KM_LCTRL) &&
157 key == KC_F2) {
158 layout_destroy(kdev->active_layout);
159 kdev->active_layout = layout_create(layout[1]);
160 return;
161 }
162
163 if (type == KEY_PRESS && (kdev->mods & KM_LCTRL) &&
164 key == KC_F3) {
165 layout_destroy(kdev->active_layout);
166 kdev->active_layout = layout_create(layout[2]);
167 return;
168 }
169
170 ev.type = type;
171 ev.key = key;
172 ev.mods = kdev->mods;
173
174 ev.c = layout_parse_ev(kdev->active_layout, &ev);
175 async_obsolete_msg_4(client_phone, INPUT_EVENT_KEY, ev.type, ev.key,
176 ev.mods, ev.c);
177}
178
179/** Mouse pointer has moved. */
180void mouse_push_event_move(mouse_dev_t *mdev, int dx, int dy)
181{
182 async_obsolete_msg_2(client_phone, INPUT_EVENT_MOVE, dx, dy);
183}
184
185/** Mouse button has been pressed. */
186void mouse_push_event_button(mouse_dev_t *mdev, int bnum, int press)
187{
188 async_obsolete_msg_2(client_phone, INPUT_EVENT_BUTTON, bnum, press);
189}
190
191static void client_connection(ipc_callid_t iid, ipc_call_t *icall, void *arg)
192{
193 ipc_callid_t callid;
194 ipc_call_t call;
195 int retval;
196
197 async_answer_0(iid, EOK);
198
199 while (true) {
200 callid = async_get_call(&call);
201
202 if (!IPC_GET_IMETHOD(call)) {
203 if (client_phone != -1) {
204 async_obsolete_hangup(client_phone);
205 client_phone = -1;
206 }
207
208 async_answer_0(callid, EOK);
209 return;
210 }
211
212 switch (IPC_GET_IMETHOD(call)) {
213 case IPC_M_CONNECT_TO_ME:
214 if (client_phone != -1) {
215 retval = ELIMIT;
216 break;
217 }
218 client_phone = IPC_GET_ARG5(call);
219 retval = 0;
220 break;
221 case INPUT_YIELD:
222 kbd_devs_yield();
223 retval = 0;
224 break;
225 case INPUT_RECLAIM:
226 kbd_devs_reclaim();
227 retval = 0;
228 break;
229 default:
230 retval = EINVAL;
231 }
232
233 async_answer_0(callid, retval);
234 }
235}
236
237static kbd_dev_t *kbd_dev_new(void)
238{
239 kbd_dev_t *kdev = calloc(1, sizeof(kbd_dev_t));
240 if (kdev == NULL) {
241 printf("%s: Error allocating keyboard device. "
242 "Out of memory.\n", NAME);
243 return NULL;
244 }
245
246 link_initialize(&kdev->kbd_devs);
247
248 kdev->mods = KM_NUM_LOCK;
249 kdev->lock_keys = 0;
250 kdev->active_layout = layout_create(layout[0]);
251
252 return kdev;
253}
254
255static mouse_dev_t *mouse_dev_new(void)
256{
257 mouse_dev_t *mdev = calloc(1, sizeof(mouse_dev_t));
258 if (mdev == NULL) {
259 printf("%s: Error allocating keyboard device. "
260 "Out of memory.\n", NAME);
261 return NULL;
262 }
263
264 link_initialize(&mdev->mouse_devs);
265
266 return mdev;
267}
268
269/** Add new legacy keyboard device. */
270static void kbd_add_dev(kbd_port_ops_t *port, kbd_ctl_ops_t *ctl)
271{
272 kbd_dev_t *kdev = kbd_dev_new();
273 if (kdev == NULL)
274 return;
275
276 kdev->port_ops = port;
277 kdev->ctl_ops = ctl;
278 kdev->svc_id = 0;
279
280 /* Initialize port driver. */
281 if ((*kdev->port_ops->init)(kdev) != 0)
282 goto fail;
283
284 /* Initialize controller driver. */
285 if ((*kdev->ctl_ops->init)(kdev) != 0) {
286 /* XXX Uninit port */
287 goto fail;
288 }
289
290 list_append(&kdev->kbd_devs, &kbd_devs);
291 return;
292
293fail:
294 free(kdev);
295}
296
297/** Add new legacy mouse device. */
298static void mouse_add_dev(mouse_port_ops_t *port, mouse_proto_ops_t *proto)
299{
300 mouse_dev_t *mdev = mouse_dev_new();
301 if (mdev == NULL)
302 return;
303
304 mdev->port_ops = port;
305 mdev->proto_ops = proto;
306 mdev->svc_id = 0;
307
308 /* Initialize port driver. */
309 if ((*mdev->port_ops->init)(mdev) != 0)
310 goto fail;
311
312 /* Initialize protocol driver. */
313 if ((*mdev->proto_ops->init)(mdev) != 0) {
314 /* XXX Uninit port */
315 goto fail;
316 }
317
318 list_append(&mdev->mouse_devs, &mouse_devs);
319 return;
320
321fail:
322 free(mdev);
323}
324
325/** Add new kbdev device.
326 *
327 * @param service_id Service ID of the keyboard device
328 *
329 */
330static int kbd_add_kbdev(service_id_t service_id, kbd_dev_t **kdevp)
331{
332 kbd_dev_t *kdev = kbd_dev_new();
333 if (kdev == NULL)
334 return -1;
335
336 kdev->svc_id = service_id;
337 kdev->port_ops = NULL;
338 kdev->ctl_ops = &kbdev_ctl;
339
340 int rc = loc_service_get_name(service_id, &kdev->svc_name);
341 if (rc != EOK) {
342 kdev->svc_name = NULL;
343 goto fail;
344 }
345
346 /* Initialize controller driver. */
347 if ((*kdev->ctl_ops->init)(kdev) != 0) {
348 goto fail;
349 }
350
351 list_append(&kdev->kbd_devs, &kbd_devs);
352 *kdevp = kdev;
353 return EOK;
354
355fail:
356 if (kdev->svc_name != NULL)
357 free(kdev->svc_name);
358 free(kdev);
359 return -1;
360}
361
362/** Add new mousedev device.
363 *
364 * @param service_id Service ID of the mouse device
365 *
366 */
367static int mouse_add_mousedev(service_id_t service_id, mouse_dev_t **mdevp)
368{
369 mouse_dev_t *mdev = mouse_dev_new();
370 if (mdev == NULL)
371 return -1;
372
373 mdev->svc_id = service_id;
374 mdev->port_ops = NULL;
375 mdev->proto_ops = &mousedev_proto;
376
377 int rc = loc_service_get_name(service_id, &mdev->svc_name);
378 if (rc != EOK) {
379 mdev->svc_name = NULL;
380 goto fail;
381 }
382
383 /* Initialize controller driver. */
384 if ((*mdev->proto_ops->init)(mdev) != 0) {
385 goto fail;
386 }
387
388 list_append(&mdev->mouse_devs, &mouse_devs);
389 *mdevp = mdev;
390 return EOK;
391
392fail:
393 free(mdev);
394 return -1;
395}
396
397/** Add legacy drivers/devices. */
398static void kbd_add_legacy_devs(void)
399{
400 /*
401 * Need to add these drivers based on config unless we can probe
402 * them automatically.
403 */
404#if defined(UARCH_amd64)
405 kbd_add_dev(&chardev_port, &pc_ctl);
406#endif
407#if defined(UARCH_arm32) && defined(MACHINE_gta02)
408 kbd_add_dev(&chardev_port, &stty_ctl);
409#endif
410#if defined(UARCH_arm32) && defined(MACHINE_testarm) && defined(CONFIG_FB)
411 kbd_add_dev(&gxemul_port, &gxe_fb_ctl);
412#endif
413#if defined(UARCH_arm32) && defined(MACHINE_testarm) && !defined(CONFIG_FB)
414 kbd_add_dev(&gxemul_port, &stty_ctl);
415#endif
416#if defined(UARCH_arm32) && defined(MACHINE_integratorcp)
417 kbd_add_dev(&pl050_port, &pc_ctl);
418#endif
419#if defined(UARCH_ia32)
420 kbd_add_dev(&chardev_port, &pc_ctl);
421#endif
422#if defined(MACHINE_i460GX)
423 kbd_add_dev(&chardev_port, &pc_ctl);
424#endif
425#if defined(MACHINE_ski)
426 kbd_add_dev(&ski_port, &stty_ctl);
427#endif
428#if defined(MACHINE_msim)
429 kbd_add_dev(&msim_port, &stty_ctl);
430#endif
431#if (defined(MACHINE_lgxemul) || defined(MACHINE_bgxemul)) && defined(CONFIG_FB)
432 kbd_add_dev(&gxemul_port, &gxe_fb_ctl);
433#endif
434#if defined(MACHINE_lgxemul) || defined(MACHINE_bgxemul) && !defined(CONFIG_FB)
435 kbd_add_dev(&gxemul_port, &stty_ctl);
436#endif
437#if defined(UARCH_ppc32)
438 kbd_add_dev(&adb_port, &apple_ctl);
439#endif
440#if defined(UARCH_sparc64) && defined(PROCESSOR_sun4v)
441 kbd_add_dev(&niagara_port, &stty_ctl);
442#endif
443#if defined(UARCH_sparc64) && defined(MACHINE_generic)
444 kbd_add_dev(&ns16550_port, &sun_ctl);
445#endif
446 /* Silence warning on abs32le about kbd_add_dev() being unused */
447 (void) kbd_add_dev;
448}
449
450/** Add legacy drivers/devices. */
451static void mouse_add_legacy_devs(void)
452{
453 /*
454 * Need to add these drivers based on config unless we can probe
455 * them automatically.
456 */
457#if defined(UARCH_amd64)
458 mouse_add_dev(&chardev_mouse_port, &ps2_proto);
459#endif
460#if defined(UARCH_ia32)
461 mouse_add_dev(&chardev_mouse_port, &ps2_proto);
462#endif
463#if defined(MACHINE_i460GX)
464 mouse_add_dev(&chardev_mouse_port, &ps2_proto);
465#endif
466#if defined(UARCH_ppc32)
467 mouse_add_dev(&adb_mouse_port, &adb_proto);
468#endif
469 /* Silence warning on abs32le about mouse_add_dev() being unused */
470 (void) mouse_add_dev;
471}
472
473static void kbd_devs_yield(void)
474{
475 /* For each keyboard device */
476 list_foreach(kbd_devs, kdev_link) {
477 kbd_dev_t *kdev = list_get_instance(kdev_link, kbd_dev_t,
478 kbd_devs);
479
480 /* Yield port */
481 if (kdev->port_ops != NULL)
482 (*kdev->port_ops->yield)();
483 }
484}
485
486static void kbd_devs_reclaim(void)
487{
488 /* For each keyboard device */
489 list_foreach(kbd_devs, kdev_link) {
490 kbd_dev_t *kdev = list_get_instance(kdev_link, kbd_dev_t,
491 kbd_devs);
492
493 /* Reclaim port */
494 if (kdev->port_ops != NULL)
495 (*kdev->port_ops->reclaim)();
496 }
497}
498
499/** Periodically check for new input devices.
500 *
501 * Looks under /loc/class/keyboard and /loc/class/mouse.
502 *
503 * @param arg Ignored
504 *
505 */
506static int dev_discovery_fibril(void *arg)
507{
508 category_id_t keyboard_cat, mouse_cat;
509 service_id_t *svcs;
510 size_t count, i;
511 bool already_known;
512 int rc;
513
514 rc = loc_category_get_id("keyboard", &keyboard_cat, IPC_FLAG_BLOCKING);
515 if (rc != EOK) {
516 printf("%s: Failed resolving category 'keyboard'.\n", NAME);
517 return ENOENT;
518 }
519
520 rc = loc_category_get_id("mouse", &mouse_cat, IPC_FLAG_BLOCKING);
521 if (rc != EOK) {
522 printf("%s: Failed resolving category 'mouse'.\n", NAME);
523 return ENOENT;
524 }
525
526 while (true) {
527 async_usleep(DISCOVERY_POLL_INTERVAL);
528
529 /*
530 * Check for new keyboard devices
531 */
532 rc = loc_category_get_svcs(keyboard_cat, &svcs, &count);
533 if (rc != EOK) {
534 printf("%s: Failed getting list of keyboard devices.\n",
535 NAME);
536 continue;
537 }
538
539 for (i = 0; i < count; i++) {
540 already_known = false;
541
542 /* Determine whether we already know this device. */
543 list_foreach(kbd_devs, kdev_link) {
544 kbd_dev_t *kdev = list_get_instance(kdev_link,
545 kbd_dev_t, kbd_devs);
546 if (kdev->svc_id == svcs[i]) {
547 already_known = true;
548 break;
549 }
550 }
551
552 if (!already_known) {
553 kbd_dev_t *kdev;
554 if (kbd_add_kbdev(svcs[i], &kdev) == EOK) {
555 printf("%s: Connected keyboard device '%s'\n",
556 NAME, kdev->svc_name);
557 }
558 }
559 }
560
561 /* XXX Handle device removal */
562
563 /*
564 * Check for new mouse devices
565 */
566 rc = loc_category_get_svcs(mouse_cat, &svcs, &count);
567 if (rc != EOK) {
568 printf("%s: Failed getting list of mouse devices.\n",
569 NAME);
570 continue;
571 }
572
573 for (i = 0; i < count; i++) {
574 already_known = false;
575
576 /* Determine whether we already know this device. */
577 list_foreach(mouse_devs, mdev_link) {
578 mouse_dev_t *mdev = list_get_instance(mdev_link,
579 mouse_dev_t, mouse_devs);
580 if (mdev->svc_id == svcs[i]) {
581 already_known = true;
582 break;
583 }
584 }
585
586 if (!already_known) {
587 mouse_dev_t *mdev;
588 if (mouse_add_mousedev(svcs[i], &mdev) == EOK) {
589 printf("%s: Connected mouse device '%s'\n",
590 NAME, mdev->svc_name);
591 }
592 }
593 }
594
595 /* XXX Handle device removal */
596 }
597
598 return EOK;
599}
600
601/** Start a fibril for discovering new devices. */
602static void input_start_dev_discovery(void)
603{
604 fid_t fid = fibril_create(dev_discovery_fibril, NULL);
605 if (!fid) {
606 printf("%s: Failed to create device discovery fibril.\n",
607 NAME);
608 return;
609 }
610
611 fibril_add_ready(fid);
612}
613
614int main(int argc, char **argv)
615{
616 printf("%s: HelenOS input service\n", NAME);
617
618 sysarg_t obio;
619
620 list_initialize(&kbd_devs);
621 list_initialize(&mouse_devs);
622
623 if ((sysinfo_get_value("kbd.cir.obio", &obio) == EOK) && (obio))
624 irc_service = true;
625
626 if (irc_service) {
627 while (irc_phone < 0)
628 irc_phone = service_obsolete_connect_blocking(SERVICE_IRC, 0, 0);
629 }
630
631 /* Add legacy keyboard devices. */
632 kbd_add_legacy_devs();
633
634 /* Add legacy mouse devices. */
635 mouse_add_legacy_devs();
636
637 /* Register driver */
638 int rc = loc_server_register(NAME, client_connection);
639 if (rc < 0) {
640 printf("%s: Unable to register server (%d)\n", NAME, rc);
641 return -1;
642 }
643
644 char kbd[LOC_NAME_MAXLEN + 1];
645 snprintf(kbd, LOC_NAME_MAXLEN, "%s/%s", NAMESPACE, NAME);
646
647 service_id_t service_id;
648 if (loc_service_register(kbd, &service_id) != EOK) {
649 printf("%s: Unable to register service %s\n", NAME, kbd);
650 return -1;
651 }
652
653 /* Start looking for new input devices */
654 input_start_dev_discovery();
655
656 printf("%s: Accepting connections\n", NAME);
657 async_manager();
658
659 /* Not reached. */
660 return 0;
661}
662
663/**
664 * @}
665 */
Note: See TracBrowser for help on using the repository browser.