1 #include "hw/qdev.h" 2 #include "sysemu/sysemu.h" 3 #include "qapi-types.h" 4 #include "qmp-commands.h" 5 #include "trace.h" 6 #include "ui/input.h" 7 #include "ui/console.h" 8 9 struct QemuInputHandlerState { 10 DeviceState *dev; 11 QemuInputHandler *handler; 12 int id; 13 int events; 14 QemuConsole *con; 15 QTAILQ_ENTRY(QemuInputHandlerState) node; 16 }; 17 18 typedef struct QemuInputEventQueue QemuInputEventQueue; 19 struct QemuInputEventQueue { 20 enum { 21 QEMU_INPUT_QUEUE_DELAY = 1, 22 QEMU_INPUT_QUEUE_EVENT, 23 QEMU_INPUT_QUEUE_SYNC, 24 } type; 25 QEMUTimer *timer; 26 uint32_t delay_ms; 27 QemuConsole *src; 28 InputEvent *evt; 29 QTAILQ_ENTRY(QemuInputEventQueue) node; 30 }; 31 32 static QTAILQ_HEAD(, QemuInputHandlerState) handlers = 33 QTAILQ_HEAD_INITIALIZER(handlers); 34 static NotifierList mouse_mode_notifiers = 35 NOTIFIER_LIST_INITIALIZER(mouse_mode_notifiers); 36 37 static QTAILQ_HEAD(QemuInputEventQueueHead, QemuInputEventQueue) kbd_queue = 38 QTAILQ_HEAD_INITIALIZER(kbd_queue); 39 static QEMUTimer *kbd_timer; 40 static uint32_t kbd_default_delay_ms = 10; 41 42 QemuInputHandlerState *qemu_input_handler_register(DeviceState *dev, 43 QemuInputHandler *handler) 44 { 45 QemuInputHandlerState *s = g_new0(QemuInputHandlerState, 1); 46 static int id = 1; 47 48 s->dev = dev; 49 s->handler = handler; 50 s->id = id++; 51 QTAILQ_INSERT_TAIL(&handlers, s, node); 52 53 qemu_input_check_mode_change(); 54 return s; 55 } 56 57 void qemu_input_handler_activate(QemuInputHandlerState *s) 58 { 59 QTAILQ_REMOVE(&handlers, s, node); 60 QTAILQ_INSERT_HEAD(&handlers, s, node); 61 qemu_input_check_mode_change(); 62 } 63 64 void qemu_input_handler_deactivate(QemuInputHandlerState *s) 65 { 66 QTAILQ_REMOVE(&handlers, s, node); 67 QTAILQ_INSERT_TAIL(&handlers, s, node); 68 qemu_input_check_mode_change(); 69 } 70 71 void qemu_input_handler_unregister(QemuInputHandlerState *s) 72 { 73 QTAILQ_REMOVE(&handlers, s, node); 74 g_free(s); 75 qemu_input_check_mode_change(); 76 } 77 78 void qemu_input_handler_bind(QemuInputHandlerState *s, 79 const char *device_id, int head, 80 Error **errp) 81 { 82 DeviceState *dev; 83 QemuConsole *con; 84 85 dev = qdev_find_recursive(sysbus_get_default(), device_id); 86 if (dev == NULL) { 87 error_set(errp, QERR_DEVICE_NOT_FOUND, device_id); 88 return; 89 } 90 91 con = qemu_console_lookup_by_device(dev, head); 92 if (con == NULL) { 93 error_setg(errp, "Device %s is not bound to a QemuConsole", device_id); 94 return; 95 } 96 97 s->con = con; 98 } 99 100 static QemuInputHandlerState* 101 qemu_input_find_handler(uint32_t mask, QemuConsole *con) 102 { 103 QemuInputHandlerState *s; 104 105 QTAILQ_FOREACH(s, &handlers, node) { 106 if (s->con == NULL || s->con != con) { 107 continue; 108 } 109 if (mask & s->handler->mask) { 110 return s; 111 } 112 } 113 114 QTAILQ_FOREACH(s, &handlers, node) { 115 if (s->con != NULL) { 116 continue; 117 } 118 if (mask & s->handler->mask) { 119 return s; 120 } 121 } 122 return NULL; 123 } 124 125 static void qemu_input_transform_abs_rotate(InputEvent *evt) 126 { 127 switch (graphic_rotate) { 128 case 90: 129 if (evt->abs->axis == INPUT_AXIS_X) { 130 evt->abs->axis = INPUT_AXIS_Y; 131 } else if (evt->abs->axis == INPUT_AXIS_Y) { 132 evt->abs->axis = INPUT_AXIS_X; 133 evt->abs->value = INPUT_EVENT_ABS_SIZE - 1 - evt->abs->value; 134 } 135 break; 136 case 180: 137 evt->abs->value = INPUT_EVENT_ABS_SIZE - 1 - evt->abs->value; 138 break; 139 case 270: 140 if (evt->abs->axis == INPUT_AXIS_X) { 141 evt->abs->axis = INPUT_AXIS_Y; 142 evt->abs->value = INPUT_EVENT_ABS_SIZE - 1 - evt->abs->value; 143 } else if (evt->abs->axis == INPUT_AXIS_Y) { 144 evt->abs->axis = INPUT_AXIS_X; 145 } 146 break; 147 } 148 } 149 150 static void qemu_input_event_trace(QemuConsole *src, InputEvent *evt) 151 { 152 const char *name; 153 int qcode, idx = -1; 154 155 if (src) { 156 idx = qemu_console_get_index(src); 157 } 158 switch (evt->kind) { 159 case INPUT_EVENT_KIND_KEY: 160 switch (evt->key->key->kind) { 161 case KEY_VALUE_KIND_NUMBER: 162 qcode = qemu_input_key_number_to_qcode(evt->key->key->number); 163 name = QKeyCode_lookup[qcode]; 164 trace_input_event_key_number(idx, evt->key->key->number, 165 name, evt->key->down); 166 break; 167 case KEY_VALUE_KIND_QCODE: 168 name = QKeyCode_lookup[evt->key->key->qcode]; 169 trace_input_event_key_qcode(idx, name, evt->key->down); 170 break; 171 case KEY_VALUE_KIND_MAX: 172 /* keep gcc happy */ 173 break; 174 } 175 break; 176 case INPUT_EVENT_KIND_BTN: 177 name = InputButton_lookup[evt->btn->button]; 178 trace_input_event_btn(idx, name, evt->btn->down); 179 break; 180 case INPUT_EVENT_KIND_REL: 181 name = InputAxis_lookup[evt->rel->axis]; 182 trace_input_event_rel(idx, name, evt->rel->value); 183 break; 184 case INPUT_EVENT_KIND_ABS: 185 name = InputAxis_lookup[evt->abs->axis]; 186 trace_input_event_abs(idx, name, evt->abs->value); 187 break; 188 case INPUT_EVENT_KIND_MAX: 189 /* keep gcc happy */ 190 break; 191 } 192 } 193 194 static void qemu_input_queue_process(void *opaque) 195 { 196 struct QemuInputEventQueueHead *queue = opaque; 197 QemuInputEventQueue *item; 198 199 g_assert(!QTAILQ_EMPTY(queue)); 200 item = QTAILQ_FIRST(queue); 201 g_assert(item->type == QEMU_INPUT_QUEUE_DELAY); 202 QTAILQ_REMOVE(queue, item, node); 203 g_free(item); 204 205 while (!QTAILQ_EMPTY(queue)) { 206 item = QTAILQ_FIRST(queue); 207 switch (item->type) { 208 case QEMU_INPUT_QUEUE_DELAY: 209 timer_mod(item->timer, qemu_clock_get_ms(QEMU_CLOCK_VIRTUAL) 210 + item->delay_ms); 211 return; 212 case QEMU_INPUT_QUEUE_EVENT: 213 qemu_input_event_send(item->src, item->evt); 214 qapi_free_InputEvent(item->evt); 215 break; 216 case QEMU_INPUT_QUEUE_SYNC: 217 qemu_input_event_sync(); 218 break; 219 } 220 QTAILQ_REMOVE(queue, item, node); 221 g_free(item); 222 } 223 } 224 225 static void qemu_input_queue_delay(struct QemuInputEventQueueHead *queue, 226 QEMUTimer *timer, uint32_t delay_ms) 227 { 228 QemuInputEventQueue *item = g_new0(QemuInputEventQueue, 1); 229 bool start_timer = QTAILQ_EMPTY(queue); 230 231 item->type = QEMU_INPUT_QUEUE_DELAY; 232 item->delay_ms = delay_ms; 233 item->timer = timer; 234 QTAILQ_INSERT_TAIL(queue, item, node); 235 236 if (start_timer) { 237 timer_mod(item->timer, qemu_clock_get_ms(QEMU_CLOCK_VIRTUAL) 238 + item->delay_ms); 239 } 240 } 241 242 static void qemu_input_queue_event(struct QemuInputEventQueueHead *queue, 243 QemuConsole *src, InputEvent *evt) 244 { 245 QemuInputEventQueue *item = g_new0(QemuInputEventQueue, 1); 246 247 item->type = QEMU_INPUT_QUEUE_EVENT; 248 item->src = src; 249 item->evt = evt; 250 QTAILQ_INSERT_TAIL(queue, item, node); 251 } 252 253 static void qemu_input_queue_sync(struct QemuInputEventQueueHead *queue) 254 { 255 QemuInputEventQueue *item = g_new0(QemuInputEventQueue, 1); 256 257 item->type = QEMU_INPUT_QUEUE_SYNC; 258 QTAILQ_INSERT_TAIL(queue, item, node); 259 } 260 261 void qemu_input_event_send(QemuConsole *src, InputEvent *evt) 262 { 263 QemuInputHandlerState *s; 264 265 if (!runstate_is_running() && !runstate_check(RUN_STATE_SUSPENDED)) { 266 return; 267 } 268 269 qemu_input_event_trace(src, evt); 270 271 /* pre processing */ 272 if (graphic_rotate && (evt->kind == INPUT_EVENT_KIND_ABS)) { 273 qemu_input_transform_abs_rotate(evt); 274 } 275 276 /* send event */ 277 s = qemu_input_find_handler(1 << evt->kind, src); 278 if (!s) { 279 return; 280 } 281 s->handler->event(s->dev, src, evt); 282 s->events++; 283 } 284 285 void qemu_input_event_sync(void) 286 { 287 QemuInputHandlerState *s; 288 289 if (!runstate_is_running() && !runstate_check(RUN_STATE_SUSPENDED)) { 290 return; 291 } 292 293 trace_input_event_sync(); 294 295 QTAILQ_FOREACH(s, &handlers, node) { 296 if (!s->events) { 297 continue; 298 } 299 if (s->handler->sync) { 300 s->handler->sync(s->dev); 301 } 302 s->events = 0; 303 } 304 } 305 306 InputEvent *qemu_input_event_new_key(KeyValue *key, bool down) 307 { 308 InputEvent *evt = g_new0(InputEvent, 1); 309 evt->key = g_new0(InputKeyEvent, 1); 310 evt->kind = INPUT_EVENT_KIND_KEY; 311 evt->key->key = key; 312 evt->key->down = down; 313 return evt; 314 } 315 316 void qemu_input_event_send_key(QemuConsole *src, KeyValue *key, bool down) 317 { 318 InputEvent *evt; 319 evt = qemu_input_event_new_key(key, down); 320 if (QTAILQ_EMPTY(&kbd_queue)) { 321 qemu_input_event_send(src, evt); 322 qemu_input_event_sync(); 323 qapi_free_InputEvent(evt); 324 } else { 325 qemu_input_queue_event(&kbd_queue, src, evt); 326 qemu_input_queue_sync(&kbd_queue); 327 } 328 } 329 330 void qemu_input_event_send_key_number(QemuConsole *src, int num, bool down) 331 { 332 KeyValue *key = g_new0(KeyValue, 1); 333 key->kind = KEY_VALUE_KIND_NUMBER; 334 key->number = num; 335 qemu_input_event_send_key(src, key, down); 336 } 337 338 void qemu_input_event_send_key_qcode(QemuConsole *src, QKeyCode q, bool down) 339 { 340 KeyValue *key = g_new0(KeyValue, 1); 341 key->kind = KEY_VALUE_KIND_QCODE; 342 key->qcode = q; 343 qemu_input_event_send_key(src, key, down); 344 } 345 346 void qemu_input_event_send_key_delay(uint32_t delay_ms) 347 { 348 if (!kbd_timer) { 349 kbd_timer = timer_new_ms(QEMU_CLOCK_VIRTUAL, qemu_input_queue_process, 350 &kbd_queue); 351 } 352 qemu_input_queue_delay(&kbd_queue, kbd_timer, 353 delay_ms ? delay_ms : kbd_default_delay_ms); 354 } 355 356 InputEvent *qemu_input_event_new_btn(InputButton btn, bool down) 357 { 358 InputEvent *evt = g_new0(InputEvent, 1); 359 evt->btn = g_new0(InputBtnEvent, 1); 360 evt->kind = INPUT_EVENT_KIND_BTN; 361 evt->btn->button = btn; 362 evt->btn->down = down; 363 return evt; 364 } 365 366 void qemu_input_queue_btn(QemuConsole *src, InputButton btn, bool down) 367 { 368 InputEvent *evt; 369 evt = qemu_input_event_new_btn(btn, down); 370 qemu_input_event_send(src, evt); 371 qapi_free_InputEvent(evt); 372 } 373 374 void qemu_input_update_buttons(QemuConsole *src, uint32_t *button_map, 375 uint32_t button_old, uint32_t button_new) 376 { 377 InputButton btn; 378 uint32_t mask; 379 380 for (btn = 0; btn < INPUT_BUTTON_MAX; btn++) { 381 mask = button_map[btn]; 382 if ((button_old & mask) == (button_new & mask)) { 383 continue; 384 } 385 qemu_input_queue_btn(src, btn, button_new & mask); 386 } 387 } 388 389 bool qemu_input_is_absolute(void) 390 { 391 QemuInputHandlerState *s; 392 393 s = qemu_input_find_handler(INPUT_EVENT_MASK_REL | INPUT_EVENT_MASK_ABS, 394 NULL); 395 return (s != NULL) && (s->handler->mask & INPUT_EVENT_MASK_ABS); 396 } 397 398 int qemu_input_scale_axis(int value, int size_in, int size_out) 399 { 400 if (size_in < 2) { 401 return size_out / 2; 402 } 403 return (int64_t)value * (size_out - 1) / (size_in - 1); 404 } 405 406 InputEvent *qemu_input_event_new_move(InputEventKind kind, 407 InputAxis axis, int value) 408 { 409 InputEvent *evt = g_new0(InputEvent, 1); 410 InputMoveEvent *move = g_new0(InputMoveEvent, 1); 411 412 evt->kind = kind; 413 evt->data = move; 414 move->axis = axis; 415 move->value = value; 416 return evt; 417 } 418 419 void qemu_input_queue_rel(QemuConsole *src, InputAxis axis, int value) 420 { 421 InputEvent *evt; 422 evt = qemu_input_event_new_move(INPUT_EVENT_KIND_REL, axis, value); 423 qemu_input_event_send(src, evt); 424 qapi_free_InputEvent(evt); 425 } 426 427 void qemu_input_queue_abs(QemuConsole *src, InputAxis axis, int value, int size) 428 { 429 InputEvent *evt; 430 int scaled = qemu_input_scale_axis(value, size, INPUT_EVENT_ABS_SIZE); 431 evt = qemu_input_event_new_move(INPUT_EVENT_KIND_ABS, axis, scaled); 432 qemu_input_event_send(src, evt); 433 qapi_free_InputEvent(evt); 434 } 435 436 void qemu_input_check_mode_change(void) 437 { 438 static int current_is_absolute; 439 int is_absolute; 440 441 is_absolute = qemu_input_is_absolute(); 442 443 if (is_absolute != current_is_absolute) { 444 trace_input_mouse_mode(is_absolute); 445 notifier_list_notify(&mouse_mode_notifiers, NULL); 446 } 447 448 current_is_absolute = is_absolute; 449 } 450 451 void qemu_add_mouse_mode_change_notifier(Notifier *notify) 452 { 453 notifier_list_add(&mouse_mode_notifiers, notify); 454 } 455 456 void qemu_remove_mouse_mode_change_notifier(Notifier *notify) 457 { 458 notifier_remove(notify); 459 } 460 461 MouseInfoList *qmp_query_mice(Error **errp) 462 { 463 MouseInfoList *mice_list = NULL; 464 MouseInfoList *info; 465 QemuInputHandlerState *s; 466 bool current = true; 467 468 QTAILQ_FOREACH(s, &handlers, node) { 469 if (!(s->handler->mask & 470 (INPUT_EVENT_MASK_REL | INPUT_EVENT_MASK_ABS))) { 471 continue; 472 } 473 474 info = g_new0(MouseInfoList, 1); 475 info->value = g_new0(MouseInfo, 1); 476 info->value->index = s->id; 477 info->value->name = g_strdup(s->handler->name); 478 info->value->absolute = s->handler->mask & INPUT_EVENT_MASK_ABS; 479 info->value->current = current; 480 481 current = false; 482 info->next = mice_list; 483 mice_list = info; 484 } 485 486 return mice_list; 487 } 488 489 void do_mouse_set(Monitor *mon, const QDict *qdict) 490 { 491 QemuInputHandlerState *s; 492 int index = qdict_get_int(qdict, "index"); 493 int found = 0; 494 495 QTAILQ_FOREACH(s, &handlers, node) { 496 if (s->id != index) { 497 continue; 498 } 499 if (!(s->handler->mask & (INPUT_EVENT_MASK_REL | 500 INPUT_EVENT_MASK_ABS))) { 501 error_report("Input device '%s' is not a mouse", s->handler->name); 502 return; 503 } 504 found = 1; 505 qemu_input_handler_activate(s); 506 break; 507 } 508 509 if (!found) { 510 error_report("Mouse at index '%d' not found", index); 511 } 512 513 qemu_input_check_mode_change(); 514 } 515