| 171,8 → 171,10 |
|---|
| * |
| * @param phone Destination kernel phone structure. |
| * @param request Call structure with request. |
| * |
| * @return EOK on success or EINTR if the sleep was interrupted. |
| */ |
| void ipc_call_sync(phone_t *phone, call_t *request) |
| int ipc_call_sync(phone_t *phone, call_t *request) |
| { |
| answerbox_t sync_box; |
| |
| 182,7 → 184,10 |
|---|
| request->callerbox = &sync_box; |
| |
| ipc_call(phone, request); |
| ipc_wait_for_call(&sync_box, SYNCH_NO_TIMEOUT, SYNCH_FLAGS_NONE); |
| if (!ipc_wait_for_call(&sync_box, SYNCH_NO_TIMEOUT, |
| SYNCH_FLAGS_INTERRUPTIBLE)) |
| return EINTR; |
| return EOK; |
| } |
| |
| /** Answer a message which was not dispatched and is not listed in any queue. |
| 195,6 → 200,13 |
|---|
| |
| call->flags |= IPC_CALL_ANSWERED; |
| |
| if (call->flags & IPC_CALL_FORWARDED) { |
| if (call->caller_phone) { |
| /* Demasquerade the caller phone. */ |
| call->data.phone = call->caller_phone; |
| } |
| } |
| |
| spinlock_lock(&callerbox->lock); |
| list_append(&call->link, &callerbox->answers); |
| spinlock_unlock(&callerbox->lock); |
| 347,8 → 359,11 |
|---|
| list_remove(&call->link); |
| spinlock_unlock(&oldbox->lock); |
| |
| if (mode & IPC_FF_ROUTE_FROM_ME) |
| if (mode & IPC_FF_ROUTE_FROM_ME) { |
| if (!call->caller_phone) |
| call->caller_phone = call->data.phone; |
| call->data.phone = newphone; |
| } |
| |
| return ipc_call(newphone, call); |
| } |
| 577,8 → 592,9 |
|---|
| tmp = tmp->next) { |
| call = list_get_instance(tmp, call_t, link); |
| printf("Callid: %p Srctask:%" PRIu64 " M:%" PRIun |
| " A1:%" PRIun " A2:%" PRIun " A3:%" PRIun |
| " A4:%" PRIun " A5:%" PRIun " Flags:%x\n", call, call->sender->taskid, |
| " A1:%" PRIun " A2:%" PRIun " A3:%" PRIun |
| " A4:%" PRIun " A5:%" PRIun " Flags:%x\n", call, |
| call->sender->taskid, |
| IPC_GET_METHOD(call->data), IPC_GET_ARG1(call->data), |
| IPC_GET_ARG2(call->data), IPC_GET_ARG3(call->data), |
| IPC_GET_ARG4(call->data), IPC_GET_ARG5(call->data), |
| 591,8 → 607,9 |
|---|
| tmp = tmp->next) { |
| call = list_get_instance(tmp, call_t, link); |
| printf("Callid: %p Srctask:%" PRIu64 " M:%" PRIun |
| " A1:%" PRIun " A2:%" PRIun " A3:%" PRIun |
| " A4:%" PRIun " A5:%" PRIun " Flags:%x\n", call, call->sender->taskid, |
| " A1:%" PRIun " A2:%" PRIun " A3:%" PRIun |
| " A4:%" PRIun " A5:%" PRIun " Flags:%x\n", call, |
| call->sender->taskid, |
| IPC_GET_METHOD(call->data), IPC_GET_ARG1(call->data), |
| IPC_GET_ARG2(call->data), IPC_GET_ARG3(call->data), |
| IPC_GET_ARG4(call->data), IPC_GET_ARG5(call->data), |
| 600,11 → 617,12 |
|---|
| } |
| /* Print answerbox - calls */ |
| printf("ABOX - ANSWERS:\n"); |
| for (tmp = task->answerbox.answers.next; tmp != &task->answerbox.answers; |
| for (tmp = task->answerbox.answers.next; |
| tmp != &task->answerbox.answers; |
| tmp = tmp->next) { |
| call = list_get_instance(tmp, call_t, link); |
| printf("Callid:%p M:%" PRIun " A1:%" PRIun " A2:%" PRIun |
| " A3:%" PRIun " A4:%" PRIun " A5:%" PRIun " Flags:%x\n", |
| " A3:%" PRIun " A4:%" PRIun " A5:%" PRIun " Flags:%x\n", |
| call, IPC_GET_METHOD(call->data), IPC_GET_ARG1(call->data), |
| IPC_GET_ARG2(call->data), IPC_GET_ARG3(call->data), |
| IPC_GET_ARG4(call->data), IPC_GET_ARG5(call->data), |