506,6 → 506,7 |
ipc_answer_0(callid, ENOMEM); |
return NULL; |
} |
|
/* Add connection to the connection hash table */ |
key = conn->in_phone_hash; |
futex_down(&async_futex); |
524,6 → 525,7 |
* |
* @param callid Hash of the incoming call. |
* @param call Data of the incoming call. |
* |
*/ |
static void handle_call(ipc_callid_t callid, ipc_call_t *call) |
{ |
740,12 → 742,6 |
{ |
amsg_t *msg; |
|
if (_in_interrupt_handler) { |
printf("Cannot send asynchronous request in interrupt " |
"handler.\n"); |
_exit(1); |
} |
|
msg = malloc(sizeof(*msg)); |
msg->done = 0; |
msg->dataptr = dataptr; |
754,7 → 750,7 |
msg->wdata.active = 1; |
|
ipc_call_async_4(phoneid, method, arg1, arg2, arg3, arg4, msg, |
reply_received, 1); |
reply_received, !_in_interrupt_handler); |
|
return (aid_t) msg; |
} |
782,12 → 778,6 |
{ |
amsg_t *msg; |
|
if (_in_interrupt_handler) { |
printf("Cannot send asynchronous request in interrupt " |
"handler.\n"); |
_exit(1); |
} |
|
msg = malloc(sizeof(*msg)); |
msg->done = 0; |
msg->dataptr = dataptr; |
796,7 → 786,7 |
msg->wdata.active = 1; |
|
ipc_call_async_5(phoneid, method, arg1, arg2, arg3, arg4, arg5, msg, |
reply_received, 1); |
reply_received, !_in_interrupt_handler); |
|
return (aid_t) msg; |
} |
884,11 → 874,6 |
{ |
amsg_t *msg; |
|
if (_in_interrupt_handler) { |
printf("Cannot call async_usleep in interrupt handler.\n"); |
_exit(1); |
} |
|
msg = malloc(sizeof(*msg)); |
if (!msg) |
return; |