Changeset 84239b1 in mainline for uspace/lib/hound/src/protocol.c
- Timestamp:
- 2018-03-11T19:39:11Z (7 years ago)
- Branches:
- lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
- Children:
- f3d47c97
- Parents:
- 850fd32
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/lib/hound/src/protocol.c
r850fd32 r84239b1 73 73 uint8_t channels; 74 74 uint8_t format; 75 } f __attribute__((packed));75 } __attribute__((packed)) f; 76 76 sysarg_t arg; 77 77 } format_convert_t; … … 385 385 void hound_connection_handler(ipc_callid_t iid, ipc_call_t *icall, void *arg) 386 386 { 387 hound_context_id_t id; 388 errno_t ret; 389 int flags; 390 void *source; 391 void *sink; 392 387 393 /* Accept connection if there is a valid iface*/ 388 394 if (server_iface) { … … 397 403 ipc_callid_t callid = async_get_call(&call); 398 404 switch (IPC_GET_IMETHOD(call)) { 399 case IPC_M_HOUND_CONTEXT_REGISTER: {405 case IPC_M_HOUND_CONTEXT_REGISTER: 400 406 /* check interface functions */ 401 407 if (!server_iface || !server_iface->add_context) { … … 407 413 408 414 /* Get context name */ 409 errno_t ret = 410 async_data_write_accept(&name, true, 0, 0, 0, 0); 415 ret = async_data_write_accept(&name, true, 0, 0, 0, 0); 411 416 if (ret != EOK) { 412 417 async_answer_0(callid, ret); 413 418 break; 414 419 } 415 hound_context_id_t id = 0; 420 421 id = 0; 416 422 ret = server_iface->add_context(server_iface->server, 417 423 &id, name, record); … … 424 430 } 425 431 break; 426 } 427 case IPC_M_HOUND_CONTEXT_UNREGISTER: { 432 case IPC_M_HOUND_CONTEXT_UNREGISTER: 428 433 /* check interface functions */ 429 434 if (!server_iface || !server_iface->rem_context) { … … 433 438 434 439 /* get id, 1st param */ 435 hound_context_id_tid = IPC_GET_ARG1(call);436 const errno_t ret =437 server_iface->rem_context(server_iface->server,id);440 id = IPC_GET_ARG1(call); 441 ret = server_iface->rem_context(server_iface->server, 442 id); 438 443 async_answer_0(callid, ret); 439 444 break; 440 } 441 case IPC_M_HOUND_GET_LIST: { 445 case IPC_M_HOUND_GET_LIST: 442 446 /* check interface functions */ 443 447 if (!server_iface || !server_iface->get_list) { … … 447 451 448 452 char **list = NULL; 449 const intflags = IPC_GET_ARG1(call);453 flags = IPC_GET_ARG1(call); 450 454 size_t count = IPC_GET_ARG2(call); 451 455 const bool conn = IPC_GET_ARG3(call); 452 456 char *conn_name = NULL; 453 errno_tret = EOK;457 ret = EOK; 454 458 455 459 /* get connected actor name if provided */ … … 501 505 free(list); 502 506 break; 503 } 504 case IPC_M_HOUND_CONNECT: { 507 case IPC_M_HOUND_CONNECT: 505 508 /* check interface functions */ 506 509 if (!server_iface || !server_iface->connect) { … … 509 512 } 510 513 511 void *source = NULL;512 void *sink = NULL;514 source = NULL; 515 sink = NULL; 513 516 514 517 /* read source name */ 515 errno_t ret =516 async_data_write_accept(&source, true, 0, 0, 0,0);518 ret = async_data_write_accept(&source, true, 0, 0, 0, 519 0); 517 520 /* read sink name */ 518 521 if (ret == EOK) … … 527 530 async_answer_0(callid, ret); 528 531 break; 529 } 530 case IPC_M_HOUND_DISCONNECT: { 532 case IPC_M_HOUND_DISCONNECT: 531 533 /* check interface functions */ 532 534 if (!server_iface || !server_iface->disconnect) { … … 535 537 } 536 538 537 void *source = NULL;538 void *sink = NULL;539 source = NULL; 540 sink = NULL; 539 541 540 542 /* read source name */ 541 errno_t ret =542 async_data_write_accept(&source, true, 0, 0, 0,0);543 ret = async_data_write_accept(&source, true, 0, 0, 0, 544 0); 543 545 /*read sink name */ 544 546 if (ret == EOK) … … 552 554 async_answer_0(callid, ret); 553 555 break; 554 } 555 case IPC_M_HOUND_STREAM_ENTER: { 556 case IPC_M_HOUND_STREAM_ENTER: 556 557 /* check interface functions */ 557 558 if (!server_iface || !server_iface->is_record_context … … 563 564 564 565 /* get parameters */ 565 hound_context_id_tid = IPC_GET_ARG1(call);566 const intflags = IPC_GET_ARG2(call);566 id = IPC_GET_ARG1(call); 567 flags = IPC_GET_ARG2(call); 567 568 const format_convert_t c = {.arg = IPC_GET_ARG3(call)}; 568 569 const pcm_format_t f = { … … 574 575 575 576 void *stream; 576 errno_tret = server_iface->add_stream(server_iface->server,577 ret = server_iface->add_stream(server_iface->server, 577 578 id, flags, f, bsize, &stream); 578 579 if (ret != EOK) { … … 604 605 } 605 606 break; 606 }607 607 case IPC_M_HOUND_STREAM_EXIT: 608 608 case IPC_M_HOUND_STREAM_DRAIN:
Note:
See TracChangeset
for help on using the changeset viewer.