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

lfn serial ticket/834-toolchain-update topic/msim-upgrade topic/simplify-dev-export
Last change on this file since 5da7199 was 5da7199, checked in by Martin Decky <martin@…>, 14 years ago

remove the obsolete async API
  • Property mode set to 100644
File size: 15.3 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 <async.h>
50#include <errno.h>
51#include <adt/fifo.h>
52#include <io/console.h>
53#include <io/keycode.h>
54#include <loc.h>
55#include <input.h>
56#include <kbd.h>
57#include <kbd_port.h>
58#include <kbd_ctl.h>
59#include <mouse_proto.h>
60#include <layout.h>
61#include <mouse.h>
62
63#define NUM_LAYOUTS 3
64
65static layout_ops_t *layout[NUM_LAYOUTS] = {
66 &us_qwerty_ops,
67 &us_dvorak_ops,
68 &cz_ops
69};
70
71static void kbd_devs_yield(void);
72static void kbd_devs_reclaim(void);
73
74async_sess_t *client_sess = NULL;
75
76/** List of keyboard devices */
77static list_t kbd_devs;
78
79/** List of mouse devices */
80static list_t mouse_devs;
81
82bool irc_service = false;
83async_sess_t *irc_sess = NULL;
84
85void kbd_push_data(kbd_dev_t *kdev, sysarg_t data)
86{
87 (*kdev->ctl_ops->parse)(data);
88}
89
90void mouse_push_data(mouse_dev_t *mdev, sysarg_t data)
91{
92 (*mdev->proto_ops->parse)(data);
93}
94
95void kbd_push_event(kbd_dev_t *kdev, int type, unsigned int key)
96{
97 kbd_event_t ev;
98 unsigned int mod_mask;
99
100 switch (key) {
101 case KC_LCTRL: mod_mask = KM_LCTRL; break;
102 case KC_RCTRL: mod_mask = KM_RCTRL; break;
103 case KC_LSHIFT: mod_mask = KM_LSHIFT; break;
104 case KC_RSHIFT: mod_mask = KM_RSHIFT; break;
105 case KC_LALT: mod_mask = KM_LALT; break;
106 case KC_RALT: mod_mask = KM_RALT; break;
107 default: mod_mask = 0; break;
108 }
109
110 if (mod_mask != 0) {
111 if (type == KEY_PRESS)
112 kdev->mods = kdev->mods | mod_mask;
113 else
114 kdev->mods = kdev->mods & ~mod_mask;
115 }
116
117 switch (key) {
118 case KC_CAPS_LOCK: mod_mask = KM_CAPS_LOCK; break;
119 case KC_NUM_LOCK: mod_mask = KM_NUM_LOCK; break;
120 case KC_SCROLL_LOCK: mod_mask = KM_SCROLL_LOCK; break;
121 default: mod_mask = 0; break;
122 }
123
124 if (mod_mask != 0) {
125 if (type == KEY_PRESS) {
126 /*
127 * Only change lock state on transition from released
128 * to pressed. This prevents autorepeat from messing
129 * up the lock state.
130 */
131 kdev->mods = kdev->mods ^ (mod_mask & ~kdev->lock_keys);
132 kdev->lock_keys = kdev->lock_keys | mod_mask;
133
134 /* Update keyboard lock indicator lights. */
135 (*kdev->ctl_ops->set_ind)(kdev, kdev->mods);
136 } else {
137 kdev->lock_keys = kdev->lock_keys & ~mod_mask;
138 }
139 }
140
141 if (type == KEY_PRESS && (kdev->mods & KM_LCTRL) &&
142 key == KC_F1) {
143 layout_destroy(kdev->active_layout);
144 kdev->active_layout = layout_create(layout[0]);
145 return;
146 }
147
148 if (type == KEY_PRESS && (kdev->mods & KM_LCTRL) &&
149 key == KC_F2) {
150 layout_destroy(kdev->active_layout);
151 kdev->active_layout = layout_create(layout[1]);
152 return;
153 }
154
155 if (type == KEY_PRESS && (kdev->mods & KM_LCTRL) &&
156 key == KC_F3) {
157 layout_destroy(kdev->active_layout);
158 kdev->active_layout = layout_create(layout[2]);
159 return;
160 }
161
162 ev.type = type;
163 ev.key = key;
164 ev.mods = kdev->mods;
165
166 ev.c = layout_parse_ev(kdev->active_layout, &ev);
167
168 async_exch_t *exch = async_exchange_begin(client_sess);
169 async_msg_4(exch, INPUT_EVENT_KEY, ev.type, ev.key, ev.mods, ev.c);
170 async_exchange_end(exch);
171}
172
173/** Mouse pointer has moved. */
174void mouse_push_event_move(mouse_dev_t *mdev, int dx, int dy)
175{
176 async_exch_t *exch = async_exchange_begin(client_sess);
177 async_msg_2(exch, INPUT_EVENT_MOVE, dx, dy);
178 async_exchange_end(exch);
179}
180
181/** Mouse button has been pressed. */
182void mouse_push_event_button(mouse_dev_t *mdev, int bnum, int press)
183{
184 async_exch_t *exch = async_exchange_begin(client_sess);
185 async_msg_2(exch, INPUT_EVENT_BUTTON, bnum, press);
186 async_exchange_end(exch);
187}
188
189static void client_connection(ipc_callid_t iid, ipc_call_t *icall, void *arg)
190{
191 async_answer_0(iid, EOK);
192
193 while (true) {
194 ipc_call_t call;
195 ipc_callid_t callid = async_get_call(&call);
196
197 if (!IPC_GET_IMETHOD(call)) {
198 if (client_sess != NULL) {
199 async_hangup(client_sess);
200 client_sess = NULL;
201 }
202
203 async_answer_0(callid, EOK);
204 return;
205 }
206
207 async_sess_t *sess =
208 async_callback_receive_start(EXCHANGE_SERIALIZE, &call);
209 if (sess != NULL) {
210 if (client_sess == NULL) {
211 client_sess = sess;
212 async_answer_0(callid, EOK);
213 } else
214 async_answer_0(callid, ELIMIT);
215 } else {
216 switch (IPC_GET_IMETHOD(call)) {
217 case INPUT_YIELD:
218 kbd_devs_yield();
219 async_answer_0(callid, EOK);
220 break;
221 case INPUT_RECLAIM:
222 kbd_devs_reclaim();
223 async_answer_0(callid, EOK);
224 break;
225 default:
226 async_answer_0(callid, EINVAL);
227 }
228 }
229 }
230}
231
232static kbd_dev_t *kbd_dev_new(void)
233{
234 kbd_dev_t *kdev = calloc(1, sizeof(kbd_dev_t));
235 if (kdev == NULL) {
236 printf("%s: Error allocating keyboard device. "
237 "Out of memory.\n", NAME);
238 return NULL;
239 }
240
241 link_initialize(&kdev->kbd_devs);
242
243 kdev->mods = KM_NUM_LOCK;
244 kdev->lock_keys = 0;
245 kdev->active_layout = layout_create(layout[0]);
246
247 return kdev;
248}
249
250static mouse_dev_t *mouse_dev_new(void)
251{
252 mouse_dev_t *mdev = calloc(1, sizeof(mouse_dev_t));
253 if (mdev == NULL) {
254 printf("%s: Error allocating keyboard device. "
255 "Out of memory.\n", NAME);
256 return NULL;
257 }
258
259 link_initialize(&mdev->mouse_devs);
260
261 return mdev;
262}
263
264/** Add new legacy keyboard device. */
265static void kbd_add_dev(kbd_port_ops_t *port, kbd_ctl_ops_t *ctl)
266{
267 kbd_dev_t *kdev = kbd_dev_new();
268 if (kdev == NULL)
269 return;
270
271 kdev->port_ops = port;
272 kdev->ctl_ops = ctl;
273 kdev->svc_id = 0;
274
275 /* Initialize port driver. */
276 if ((*kdev->port_ops->init)(kdev) != 0)
277 goto fail;
278
279 /* Initialize controller driver. */
280 if ((*kdev->ctl_ops->init)(kdev) != 0) {
281 /* XXX Uninit port */
282 goto fail;
283 }
284
285 list_append(&kdev->kbd_devs, &kbd_devs);
286 return;
287
288fail:
289 free(kdev);
290}
291
292/** Add new legacy mouse device. */
293static void mouse_add_dev(mouse_port_ops_t *port, mouse_proto_ops_t *proto)
294{
295 mouse_dev_t *mdev = mouse_dev_new();
296 if (mdev == NULL)
297 return;
298
299 mdev->port_ops = port;
300 mdev->proto_ops = proto;
301 mdev->svc_id = 0;
302
303 /* Initialize port driver. */
304 if ((*mdev->port_ops->init)(mdev) != 0)
305 goto fail;
306
307 /* Initialize protocol driver. */
308 if ((*mdev->proto_ops->init)(mdev) != 0) {
309 /* XXX Uninit port */
310 goto fail;
311 }
312
313 list_append(&mdev->mouse_devs, &mouse_devs);
314 return;
315
316fail:
317 free(mdev);
318}
319
320/** Add new kbdev device.
321 *
322 * @param service_id Service ID of the keyboard device
323 *
324 */
325static int kbd_add_kbdev(service_id_t service_id, kbd_dev_t **kdevp)
326{
327 kbd_dev_t *kdev = kbd_dev_new();
328 if (kdev == NULL)
329 return -1;
330
331 kdev->svc_id = service_id;
332 kdev->port_ops = NULL;
333 kdev->ctl_ops = &kbdev_ctl;
334
335 int rc = loc_service_get_name(service_id, &kdev->svc_name);
336 if (rc != EOK) {
337 kdev->svc_name = NULL;
338 goto fail;
339 }
340
341 /* Initialize controller driver. */
342 if ((*kdev->ctl_ops->init)(kdev) != 0) {
343 goto fail;
344 }
345
346 list_append(&kdev->kbd_devs, &kbd_devs);
347 *kdevp = kdev;
348 return EOK;
349
350fail:
351 if (kdev->svc_name != NULL)
352 free(kdev->svc_name);
353 free(kdev);
354 return -1;
355}
356
357/** Add new mousedev device.
358 *
359 * @param service_id Service ID of the mouse device
360 *
361 */
362static int mouse_add_mousedev(service_id_t service_id, mouse_dev_t **mdevp)
363{
364 mouse_dev_t *mdev = mouse_dev_new();
365 if (mdev == NULL)
366 return -1;
367
368 mdev->svc_id = service_id;
369 mdev->port_ops = NULL;
370 mdev->proto_ops = &mousedev_proto;
371
372 int rc = loc_service_get_name(service_id, &mdev->svc_name);
373 if (rc != EOK) {
374 mdev->svc_name = NULL;
375 goto fail;
376 }
377
378 /* Initialize controller driver. */
379 if ((*mdev->proto_ops->init)(mdev) != 0) {
380 goto fail;
381 }
382
383 list_append(&mdev->mouse_devs, &mouse_devs);
384 *mdevp = mdev;
385 return EOK;
386
387fail:
388 free(mdev);
389 return -1;
390}
391
392/** Add legacy drivers/devices. */
393static void kbd_add_legacy_devs(void)
394{
395 /*
396 * Need to add these drivers based on config unless we can probe
397 * them automatically.
398 */
399#if defined(UARCH_amd64)
400 kbd_add_dev(&chardev_port, &pc_ctl);
401#endif
402#if defined(UARCH_arm32) && defined(MACHINE_gta02)
403 kbd_add_dev(&chardev_port, &stty_ctl);
404#endif
405#if defined(UARCH_arm32) && defined(MACHINE_testarm) && defined(CONFIG_FB)
406 kbd_add_dev(&gxemul_port, &gxe_fb_ctl);
407#endif
408#if defined(UARCH_arm32) && defined(MACHINE_testarm) && !defined(CONFIG_FB)
409 kbd_add_dev(&gxemul_port, &stty_ctl);
410#endif
411#if defined(UARCH_arm32) && defined(MACHINE_integratorcp)
412 kbd_add_dev(&pl050_port, &pc_ctl);
413#endif
414#if defined(UARCH_ia32)
415 kbd_add_dev(&chardev_port, &pc_ctl);
416#endif
417#if defined(MACHINE_i460GX)
418 kbd_add_dev(&chardev_port, &pc_ctl);
419#endif
420#if defined(MACHINE_ski)
421 kbd_add_dev(&ski_port, &stty_ctl);
422#endif
423#if defined(MACHINE_msim)
424 kbd_add_dev(&msim_port, &stty_ctl);
425#endif
426#if (defined(MACHINE_lgxemul) || defined(MACHINE_bgxemul)) && defined(CONFIG_FB)
427 kbd_add_dev(&gxemul_port, &gxe_fb_ctl);
428#endif
429#if defined(MACHINE_lgxemul) || defined(MACHINE_bgxemul) && !defined(CONFIG_FB)
430 kbd_add_dev(&gxemul_port, &stty_ctl);
431#endif
432#if defined(UARCH_ppc32)
433 kbd_add_dev(&adb_port, &apple_ctl);
434#endif
435#if defined(UARCH_sparc64) && defined(PROCESSOR_sun4v)
436 kbd_add_dev(&niagara_port, &stty_ctl);
437#endif
438#if defined(UARCH_sparc64) && defined(MACHINE_generic)
439 kbd_add_dev(&ns16550_port, &sun_ctl);
440#endif
441 /* Silence warning on abs32le about kbd_add_dev() being unused */
442 (void) kbd_add_dev;
443}
444
445/** Add legacy drivers/devices. */
446static void mouse_add_legacy_devs(void)
447{
448 /*
449 * Need to add these drivers based on config unless we can probe
450 * them automatically.
451 */
452#if defined(UARCH_amd64)
453 mouse_add_dev(&chardev_mouse_port, &ps2_proto);
454#endif
455#if defined(UARCH_ia32)
456 mouse_add_dev(&chardev_mouse_port, &ps2_proto);
457#endif
458#if defined(MACHINE_i460GX)
459 mouse_add_dev(&chardev_mouse_port, &ps2_proto);
460#endif
461#if defined(UARCH_ppc32)
462 mouse_add_dev(&adb_mouse_port, &adb_proto);
463#endif
464 /* Silence warning on abs32le about mouse_add_dev() being unused */
465 (void) mouse_add_dev;
466}
467
468static void kbd_devs_yield(void)
469{
470 /* For each keyboard device */
471 list_foreach(kbd_devs, kdev_link) {
472 kbd_dev_t *kdev = list_get_instance(kdev_link, kbd_dev_t,
473 kbd_devs);
474
475 /* Yield port */
476 if (kdev->port_ops != NULL)
477 (*kdev->port_ops->yield)();
478 }
479}
480
481static void kbd_devs_reclaim(void)
482{
483 /* For each keyboard device */
484 list_foreach(kbd_devs, kdev_link) {
485 kbd_dev_t *kdev = list_get_instance(kdev_link, kbd_dev_t,
486 kbd_devs);
487
488 /* Reclaim port */
489 if (kdev->port_ops != NULL)
490 (*kdev->port_ops->reclaim)();
491 }
492}
493
494static int dev_check_new_kbdevs(void)
495{
496 category_id_t keyboard_cat;
497 service_id_t *svcs;
498 size_t count, i;
499 bool already_known;
500 int rc;
501
502 rc = loc_category_get_id("keyboard", &keyboard_cat, IPC_FLAG_BLOCKING);
503 if (rc != EOK) {
504 printf("%s: Failed resolving category 'keyboard'.\n", NAME);
505 return ENOENT;
506 }
507
508 /*
509 * Check for new keyboard devices
510 */
511 rc = loc_category_get_svcs(keyboard_cat, &svcs, &count);
512 if (rc != EOK) {
513 printf("%s: Failed getting list of keyboard devices.\n",
514 NAME);
515 return EIO;
516 }
517
518 for (i = 0; i < count; i++) {
519 already_known = false;
520
521 /* Determine whether we already know this device. */
522 list_foreach(kbd_devs, kdev_link) {
523 kbd_dev_t *kdev = list_get_instance(kdev_link,
524 kbd_dev_t, kbd_devs);
525 if (kdev->svc_id == svcs[i]) {
526 already_known = true;
527 break;
528 }
529 }
530
531 if (!already_known) {
532 kbd_dev_t *kdev;
533 if (kbd_add_kbdev(svcs[i], &kdev) == EOK) {
534 printf("%s: Connected keyboard device '%s'\n",
535 NAME, kdev->svc_name);
536 }
537 }
538 }
539
540 free(svcs);
541
542 /* XXX Handle device removal */
543
544 return EOK;
545}
546
547static int dev_check_new_mousedevs(void)
548{
549 category_id_t mouse_cat;
550 service_id_t *svcs;
551 size_t count, i;
552 bool already_known;
553 int rc;
554
555 rc = loc_category_get_id("mouse", &mouse_cat, IPC_FLAG_BLOCKING);
556 if (rc != EOK) {
557 printf("%s: Failed resolving category 'mouse'.\n", NAME);
558 return ENOENT;
559 }
560
561 /*
562 * Check for new mouse devices
563 */
564 rc = loc_category_get_svcs(mouse_cat, &svcs, &count);
565 if (rc != EOK) {
566 printf("%s: Failed getting list of mouse devices.\n",
567 NAME);
568 return EIO;
569 }
570
571 for (i = 0; i < count; i++) {
572 already_known = false;
573
574 /* Determine whether we already know this device. */
575 list_foreach(mouse_devs, mdev_link) {
576 mouse_dev_t *mdev = list_get_instance(mdev_link,
577 mouse_dev_t, mouse_devs);
578 if (mdev->svc_id == svcs[i]) {
579 already_known = true;
580 break;
581 }
582 }
583
584 if (!already_known) {
585 mouse_dev_t *mdev;
586 if (mouse_add_mousedev(svcs[i], &mdev) == EOK) {
587 printf("%s: Connected mouse device '%s'\n",
588 NAME, mdev->svc_name);
589 }
590 }
591 }
592
593 free(svcs);
594
595 /* XXX Handle device removal */
596
597 return EOK;
598}
599
600static int dev_check_new(void)
601{
602 int rc;
603
604 rc = dev_check_new_kbdevs();
605 if (rc != EOK)
606 return rc;
607
608 rc = dev_check_new_mousedevs();
609 if (rc != EOK)
610 return rc;
611
612 return EOK;
613}
614
615static void cat_change_cb(void)
616{
617 dev_check_new();
618}
619
620/** Start listening for new devices. */
621static int input_start_dev_discovery(void)
622{
623 int rc;
624
625 rc = loc_register_cat_change_cb(cat_change_cb);
626 if (rc != EOK) {
627 printf("%s: Failed registering callback for device discovery. "
628 "(%d)\n", NAME, rc);
629 return rc;
630 }
631
632 return dev_check_new();
633}
634
635int main(int argc, char **argv)
636{
637 printf("%s: HelenOS input service\n", NAME);
638
639 sysarg_t obio;
640
641 list_initialize(&kbd_devs);
642 list_initialize(&mouse_devs);
643
644 if ((sysinfo_get_value("kbd.cir.obio", &obio) == EOK) && (obio))
645 irc_service = true;
646
647 if (irc_service) {
648 while (irc_sess == NULL)
649 irc_sess = service_connect_blocking(EXCHANGE_SERIALIZE,
650 SERVICE_IRC, 0, 0);
651 }
652
653 /* Add legacy keyboard devices. */
654 kbd_add_legacy_devs();
655
656 /* Add legacy mouse devices. */
657 mouse_add_legacy_devs();
658
659 /* Register driver */
660 int rc = loc_server_register(NAME, client_connection);
661 if (rc < 0) {
662 printf("%s: Unable to register server (%d)\n", NAME, rc);
663 return -1;
664 }
665
666 char kbd[LOC_NAME_MAXLEN + 1];
667 snprintf(kbd, LOC_NAME_MAXLEN, "%s/%s", NAMESPACE, NAME);
668
669 service_id_t service_id;
670 if (loc_service_register(kbd, &service_id) != EOK) {
671 printf("%s: Unable to register service %s\n", NAME, kbd);
672 return -1;
673 }
674
675 /* Start looking for new input devices */
676 input_start_dev_discovery();
677
678 printf("%s: Accepting connections\n", NAME);
679 async_manager();
680
681 /* Not reached. */
682 return 0;
683}
684
685/**
686 * @}
687 */
Note: See TracBrowser for help on using the repository browser.