source: mainline/kernel/generic/src/ipc/ipc.c@ a000878c

lfn serial ticket/834-toolchain-update topic/msim-upgrade topic/simplify-dev-export
Last change on this file since a000878c was c713aa56, checked in by Jakub Jermar <jakub@…>, 15 years ago

Do not deadlock when the task cleans up messages it sent itself.

  • Property mode set to 100644
File size: 20.2 KB
Line 
1/*
2 * Copyright (c) 2006 Ondrej Palkovsky
3 * All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
7 * are met:
8 *
9 * - Redistributions of source code must retain the above copyright
10 * notice, this list of conditions and the following disclaimer.
11 * - Redistributions in binary form must reproduce the above copyright
12 * notice, this list of conditions and the following disclaimer in the
13 * documentation and/or other materials provided with the distribution.
14 * - The name of the author may not be used to endorse or promote products
15 * derived from this software without specific prior written permission.
16 *
17 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
18 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
19 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
20 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
21 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
22 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
23 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
24 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
25 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
26 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
27 */
28
29/** @addtogroup genericipc
30 * @{
31 */
32/** @file
33 */
34
35/* Lock ordering
36 *
37 * First the answerbox, then the phone.
38 */
39
40#include <synch/synch.h>
41#include <synch/spinlock.h>
42#include <synch/mutex.h>
43#include <synch/waitq.h>
44#include <synch/synch.h>
45#include <ipc/ipc.h>
46#include <ipc/kbox.h>
47#include <ipc/event.h>
48#include <errno.h>
49#include <mm/slab.h>
50#include <arch.h>
51#include <proc/task.h>
52#include <memstr.h>
53#include <debug.h>
54#include <print.h>
55#include <console/console.h>
56#include <proc/thread.h>
57#include <arch/interrupt.h>
58#include <ipc/irq.h>
59
60/** Open channel that is assigned automatically to new tasks */
61answerbox_t *ipc_phone_0 = NULL;
62
63static slab_cache_t *ipc_call_slab;
64static slab_cache_t *ipc_answerbox_slab;
65
66/** Initialize a call structure.
67 *
68 * @param call Call structure to be initialized.
69 */
70static void _ipc_call_init(call_t *call)
71{
72 memsetb(call, sizeof(*call), 0);
73 call->callerbox = &TASK->answerbox;
74 call->sender = TASK;
75 call->buffer = NULL;
76}
77
78/** Allocate and initialize a call structure.
79 *
80 * The call is initialized, so that the reply will be directed to
81 * TASK->answerbox.
82 *
83 * @param flags Parameters for slab_alloc (e.g FRAME_ATOMIC).
84 *
85 * @return If flags permit it, return NULL, or initialized kernel
86 * call structure.
87 */
88call_t *ipc_call_alloc(int flags)
89{
90 call_t *call;
91
92 call = slab_alloc(ipc_call_slab, flags);
93 if (call)
94 _ipc_call_init(call);
95
96 return call;
97}
98
99/** Deallocate a call structure.
100 *
101 * @param call Call structure to be freed.
102 */
103void ipc_call_free(call_t *call)
104{
105 /* Check to see if we have data in the IPC_M_DATA_SEND buffer. */
106 if (call->buffer)
107 free(call->buffer);
108 slab_free(ipc_call_slab, call);
109}
110
111/** Initialize an answerbox structure.
112 *
113 * @param box Answerbox structure to be initialized.
114 * @param task Task to which the answerbox belongs.
115 */
116void ipc_answerbox_init(answerbox_t *box, task_t *task)
117{
118 spinlock_initialize(&box->lock, "ipc_box_lock");
119 spinlock_initialize(&box->irq_lock, "ipc_box_irqlock");
120 waitq_initialize(&box->wq);
121 link_initialize(&box->sync_box_link);
122 list_initialize(&box->connected_phones);
123 list_initialize(&box->calls);
124 list_initialize(&box->dispatched_calls);
125 list_initialize(&box->answers);
126 list_initialize(&box->irq_notifs);
127 list_initialize(&box->irq_head);
128 box->task = task;
129}
130
131/** Connect a phone to an answerbox.
132 *
133 * @param phone Initialized phone structure.
134 * @param box Initialized answerbox structure.
135 */
136void ipc_phone_connect(phone_t *phone, answerbox_t *box)
137{
138 mutex_lock(&phone->lock);
139
140 phone->state = IPC_PHONE_CONNECTED;
141 phone->callee = box;
142
143 spinlock_lock(&box->lock);
144 list_append(&phone->link, &box->connected_phones);
145 spinlock_unlock(&box->lock);
146
147 mutex_unlock(&phone->lock);
148}
149
150/** Initialize a phone structure.
151 *
152 * @param phone Phone structure to be initialized.
153 */
154void ipc_phone_init(phone_t *phone)
155{
156 mutex_initialize(&phone->lock, MUTEX_PASSIVE);
157 phone->callee = NULL;
158 phone->state = IPC_PHONE_FREE;
159 atomic_set(&phone->active_calls, 0);
160}
161
162/** Helper function to facilitate synchronous calls.
163 *
164 * @param phone Destination kernel phone structure.
165 * @param request Call structure with request.
166 *
167 * @return EOK on success or EINTR if the sleep was interrupted.
168 */
169int ipc_call_sync(phone_t *phone, call_t *request)
170{
171 answerbox_t *sync_box;
172 ipl_t ipl;
173
174 sync_box = slab_alloc(ipc_answerbox_slab, 0);
175 ipc_answerbox_init(sync_box, TASK);
176
177 /*
178 * Put the answerbox on the TASK's list of synchronous answerboxes so
179 * that it can be cleaned up if the call is interrupted.
180 */
181 ipl = interrupts_disable();
182 spinlock_lock(&TASK->lock);
183 list_append(&sync_box->sync_box_link, &TASK->sync_box_head);
184 spinlock_unlock(&TASK->lock);
185 interrupts_restore(ipl);
186
187 /* We will receive data in a special box. */
188 request->callerbox = sync_box;
189
190 ipc_call(phone, request);
191 if (!ipc_wait_for_call(sync_box, SYNCH_NO_TIMEOUT,
192 SYNCH_FLAGS_INTERRUPTIBLE)) {
193 /* The answerbox and the call will be freed by ipc_cleanup(). */
194 return EINTR;
195 }
196
197 /*
198 * The answer arrived without interruption so we can remove the
199 * answerbox from the TASK's list of synchronous answerboxes.
200 */
201 (void) interrupts_disable();
202 spinlock_lock(&TASK->lock);
203 list_remove(&sync_box->sync_box_link);
204 spinlock_unlock(&TASK->lock);
205 interrupts_restore(ipl);
206
207 slab_free(ipc_answerbox_slab, sync_box);
208 return EOK;
209}
210
211/** Answer a message which was not dispatched and is not listed in any queue.
212 *
213 * @param call Call structure to be answered.
214 * @param selflocked If true, then TASK->answebox is locked.
215 */
216static void _ipc_answer_free_call(call_t *call, bool selflocked)
217{
218 answerbox_t *callerbox = call->callerbox;
219 bool do_lock = ((!selflocked) || callerbox != (&TASK->answerbox));
220
221 call->flags |= IPC_CALL_ANSWERED;
222
223 if (call->flags & IPC_CALL_FORWARDED) {
224 if (call->caller_phone) {
225 /* Demasquerade the caller phone. */
226 call->data.phone = call->caller_phone;
227 }
228 }
229
230 if (do_lock)
231 spinlock_lock(&callerbox->lock);
232 list_append(&call->link, &callerbox->answers);
233 if (do_lock)
234 spinlock_unlock(&callerbox->lock);
235 waitq_wakeup(&callerbox->wq, WAKEUP_FIRST);
236}
237
238/** Answer a message which is in a callee queue.
239 *
240 * @param box Answerbox that is answering the message.
241 * @param call Modified request that is being sent back.
242 */
243void ipc_answer(answerbox_t *box, call_t *call)
244{
245 /* Remove from active box */
246 spinlock_lock(&box->lock);
247 list_remove(&call->link);
248 spinlock_unlock(&box->lock);
249 /* Send back answer */
250 _ipc_answer_free_call(call, false);
251}
252
253/** Simulate sending back a message.
254 *
255 * Most errors are better handled by forming a normal backward
256 * message and sending it as a normal answer.
257 *
258 * @param phone Phone structure the call should appear to come from.
259 * @param call Call structure to be answered.
260 * @param err Return value to be used for the answer.
261 */
262void ipc_backsend_err(phone_t *phone, call_t *call, unative_t err)
263{
264 call->data.phone = phone;
265 atomic_inc(&phone->active_calls);
266 IPC_SET_RETVAL(call->data, err);
267 _ipc_answer_free_call(call, false);
268}
269
270/** Unsafe unchecking version of ipc_call.
271 *
272 * @param phone Phone structure the call comes from.
273 * @param box Destination answerbox structure.
274 * @param call Call structure with request.
275 */
276static void _ipc_call(phone_t *phone, answerbox_t *box, call_t *call)
277{
278 if (!(call->flags & IPC_CALL_FORWARDED)) {
279 atomic_inc(&phone->active_calls);
280 call->data.phone = phone;
281 }
282
283 spinlock_lock(&box->lock);
284 list_append(&call->link, &box->calls);
285 spinlock_unlock(&box->lock);
286 waitq_wakeup(&box->wq, WAKEUP_FIRST);
287}
288
289/** Send an asynchronous request using a phone to an answerbox.
290 *
291 * @param phone Phone structure the call comes from and which is
292 * connected to the destination answerbox.
293 * @param call Call structure with request.
294 *
295 * @return Return 0 on success, ENOENT on error.
296 */
297int ipc_call(phone_t *phone, call_t *call)
298{
299 answerbox_t *box;
300
301 mutex_lock(&phone->lock);
302 if (phone->state != IPC_PHONE_CONNECTED) {
303 mutex_unlock(&phone->lock);
304 if (call->flags & IPC_CALL_FORWARDED) {
305 IPC_SET_RETVAL(call->data, EFORWARD);
306 _ipc_answer_free_call(call, false);
307 } else {
308 if (phone->state == IPC_PHONE_HUNGUP)
309 ipc_backsend_err(phone, call, EHANGUP);
310 else
311 ipc_backsend_err(phone, call, ENOENT);
312 }
313 return ENOENT;
314 }
315 box = phone->callee;
316 _ipc_call(phone, box, call);
317
318 mutex_unlock(&phone->lock);
319 return 0;
320}
321
322/** Disconnect phone from answerbox.
323 *
324 * This call leaves the phone in the HUNGUP state. The change to 'free' is done
325 * lazily later.
326 *
327 * @param phone Phone structure to be hung up.
328 *
329 * @return Return 0 if the phone is disconnected.
330 * Return -1 if the phone was already disconnected.
331 */
332int ipc_phone_hangup(phone_t *phone)
333{
334 answerbox_t *box;
335 call_t *call;
336
337 mutex_lock(&phone->lock);
338 if (phone->state == IPC_PHONE_FREE ||
339 phone->state == IPC_PHONE_HUNGUP ||
340 phone->state == IPC_PHONE_CONNECTING) {
341 mutex_unlock(&phone->lock);
342 return -1;
343 }
344 box = phone->callee;
345 if (phone->state != IPC_PHONE_SLAMMED) {
346 /* Remove myself from answerbox */
347 spinlock_lock(&box->lock);
348 list_remove(&phone->link);
349 spinlock_unlock(&box->lock);
350
351 call = ipc_call_alloc(0);
352 IPC_SET_METHOD(call->data, IPC_M_PHONE_HUNGUP);
353 call->flags |= IPC_CALL_DISCARD_ANSWER;
354 _ipc_call(phone, box, call);
355 }
356
357 phone->state = IPC_PHONE_HUNGUP;
358 mutex_unlock(&phone->lock);
359
360 return 0;
361}
362
363/** Forwards call from one answerbox to another one.
364 *
365 * @param call Call structure to be redirected.
366 * @param newphone Phone structure to target answerbox.
367 * @param oldbox Old answerbox structure.
368 * @param mode Flags that specify mode of the forward operation.
369 *
370 * @return Return 0 if forwarding succeeded or an error code if
371 * there was error.
372 *
373 * The return value serves only as an information for the forwarder,
374 * the original caller is notified automatically with EFORWARD.
375 */
376int ipc_forward(call_t *call, phone_t *newphone, answerbox_t *oldbox, int mode)
377{
378 spinlock_lock(&oldbox->lock);
379 list_remove(&call->link);
380 spinlock_unlock(&oldbox->lock);
381
382 if (mode & IPC_FF_ROUTE_FROM_ME) {
383 if (!call->caller_phone)
384 call->caller_phone = call->data.phone;
385 call->data.phone = newphone;
386 }
387
388 return ipc_call(newphone, call);
389}
390
391
392/** Wait for a phone call.
393 *
394 * @param box Answerbox expecting the call.
395 * @param usec Timeout in microseconds. See documentation for
396 * waitq_sleep_timeout() for decription of its special
397 * meaning.
398 * @param flags Select mode of sleep operation. See documentation for
399 * waitq_sleep_timeout() for description of its special
400 * meaning.
401 * @return Recived call structure or NULL.
402 *
403 * To distinguish between a call and an answer, have a look at call->flags.
404 */
405call_t *ipc_wait_for_call(answerbox_t *box, uint32_t usec, int flags)
406{
407 call_t *request;
408 ipl_t ipl;
409 int rc;
410
411restart:
412 rc = waitq_sleep_timeout(&box->wq, usec, flags);
413 if (SYNCH_FAILED(rc))
414 return NULL;
415
416 spinlock_lock(&box->lock);
417 if (!list_empty(&box->irq_notifs)) {
418 ipl = interrupts_disable();
419 spinlock_lock(&box->irq_lock);
420
421 request = list_get_instance(box->irq_notifs.next, call_t, link);
422 list_remove(&request->link);
423
424 spinlock_unlock(&box->irq_lock);
425 interrupts_restore(ipl);
426 } else if (!list_empty(&box->answers)) {
427 /* Handle asynchronous answers */
428 request = list_get_instance(box->answers.next, call_t, link);
429 list_remove(&request->link);
430 atomic_dec(&request->data.phone->active_calls);
431 } else if (!list_empty(&box->calls)) {
432 /* Handle requests */
433 request = list_get_instance(box->calls.next, call_t, link);
434 list_remove(&request->link);
435 /* Append request to dispatch queue */
436 list_append(&request->link, &box->dispatched_calls);
437 } else {
438 /* This can happen regularly after ipc_cleanup */
439 spinlock_unlock(&box->lock);
440 goto restart;
441 }
442 spinlock_unlock(&box->lock);
443 return request;
444}
445
446/** Answer all calls from list with EHANGUP answer.
447 *
448 * @param lst Head of the list to be cleaned up.
449 */
450void ipc_cleanup_call_list(link_t *lst)
451{
452 call_t *call;
453
454 while (!list_empty(lst)) {
455 call = list_get_instance(lst->next, call_t, link);
456 if (call->buffer)
457 free(call->buffer);
458 list_remove(&call->link);
459
460 IPC_SET_RETVAL(call->data, EHANGUP);
461 _ipc_answer_free_call(call, true);
462 }
463}
464
465/** Disconnects all phones connected to an answerbox.
466 *
467 * @param box Answerbox to disconnect phones from.
468 * @param notify_box If true, the answerbox will get a hangup message for
469 * each disconnected phone.
470 */
471void ipc_answerbox_slam_phones(answerbox_t *box, bool notify_box)
472{
473 phone_t *phone;
474 DEADLOCK_PROBE_INIT(p_phonelck);
475 ipl_t ipl;
476 call_t *call;
477
478 call = notify_box ? ipc_call_alloc(0) : NULL;
479
480 /* Disconnect all phones connected to our answerbox */
481restart_phones:
482 ipl = interrupts_disable();
483 spinlock_lock(&box->lock);
484 while (!list_empty(&box->connected_phones)) {
485 phone = list_get_instance(box->connected_phones.next,
486 phone_t, link);
487 if (SYNCH_FAILED(mutex_trylock(&phone->lock))) {
488 spinlock_unlock(&box->lock);
489 interrupts_restore(ipl);
490 DEADLOCK_PROBE(p_phonelck, DEADLOCK_THRESHOLD);
491 goto restart_phones;
492 }
493
494 /* Disconnect phone */
495 ASSERT(phone->state == IPC_PHONE_CONNECTED);
496
497 list_remove(&phone->link);
498 phone->state = IPC_PHONE_SLAMMED;
499
500 if (notify_box) {
501 mutex_unlock(&phone->lock);
502 spinlock_unlock(&box->lock);
503 interrupts_restore(ipl);
504
505 /*
506 * Send one message to the answerbox for each
507 * phone. Used to make sure the kbox thread
508 * wakes up after the last phone has been
509 * disconnected.
510 */
511 IPC_SET_METHOD(call->data, IPC_M_PHONE_HUNGUP);
512 call->flags |= IPC_CALL_DISCARD_ANSWER;
513 _ipc_call(phone, box, call);
514
515 /* Allocate another call in advance */
516 call = ipc_call_alloc(0);
517
518 /* Must start again */
519 goto restart_phones;
520 }
521
522 mutex_unlock(&phone->lock);
523 }
524
525 spinlock_unlock(&box->lock);
526 interrupts_restore(ipl);
527
528 /* Free unused call */
529 if (call)
530 ipc_call_free(call);
531}
532
533/** Cleans up all IPC communication of the current task.
534 *
535 * Note: ipc_hangup sets returning answerbox to TASK->answerbox, you
536 * have to change it as well if you want to cleanup other tasks than TASK.
537 */
538void ipc_cleanup(void)
539{
540 int i;
541 call_t *call;
542 ipl_t ipl;
543
544 /* Disconnect all our phones ('ipc_phone_hangup') */
545 for (i = 0; i < IPC_MAX_PHONES; i++)
546 ipc_phone_hangup(&TASK->phones[i]);
547
548 /* Unsubscribe from any event notifications. */
549 event_cleanup_answerbox(&TASK->answerbox);
550
551 /* Disconnect all connected irqs */
552 ipc_irq_cleanup(&TASK->answerbox);
553
554 /* Disconnect all phones connected to our regular answerbox */
555 ipc_answerbox_slam_phones(&TASK->answerbox, false);
556
557#ifdef CONFIG_UDEBUG
558 /* Clean up kbox thread and communications */
559 ipc_kbox_cleanup();
560#endif
561
562 /* Answer all messages in 'calls' and 'dispatched_calls' queues */
563 spinlock_lock(&TASK->answerbox.lock);
564 ipc_cleanup_call_list(&TASK->answerbox.dispatched_calls);
565 ipc_cleanup_call_list(&TASK->answerbox.calls);
566 spinlock_unlock(&TASK->answerbox.lock);
567
568 /* Wait for all answers to interrupted synchronous calls to arrive */
569 ipl = interrupts_disable();
570 while (!list_empty(&TASK->sync_box_head)) {
571 answerbox_t *box = list_get_instance(TASK->sync_box_head.next,
572 answerbox_t, sync_box_link);
573
574 list_remove(&box->sync_box_link);
575 call = ipc_wait_for_call(box, SYNCH_NO_TIMEOUT,
576 SYNCH_FLAGS_NONE);
577 ipc_call_free(call);
578 slab_free(ipc_answerbox_slab, box);
579 }
580 interrupts_restore(ipl);
581
582 /* Wait for all answers to asynchronous calls to arrive */
583 while (1) {
584 /* Go through all phones, until all are FREE... */
585 /* Locking not needed, no one else should modify
586 * it, when we are in cleanup */
587 for (i = 0; i < IPC_MAX_PHONES; i++) {
588 if (TASK->phones[i].state == IPC_PHONE_HUNGUP &&
589 atomic_get(&TASK->phones[i].active_calls) == 0) {
590 TASK->phones[i].state = IPC_PHONE_FREE;
591 TASK->phones[i].callee = NULL;
592 }
593
594 /* Just for sure, we might have had some
595 * IPC_PHONE_CONNECTING phones */
596 if (TASK->phones[i].state == IPC_PHONE_CONNECTED)
597 ipc_phone_hangup(&TASK->phones[i]);
598 /* If the hangup succeeded, it has sent a HANGUP
599 * message, the IPC is now in HUNGUP state, we
600 * wait for the reply to come */
601
602 if (TASK->phones[i].state != IPC_PHONE_FREE)
603 break;
604 }
605 /* Voila, got into cleanup */
606 if (i == IPC_MAX_PHONES)
607 break;
608
609 call = ipc_wait_for_call(&TASK->answerbox, SYNCH_NO_TIMEOUT,
610 SYNCH_FLAGS_NONE);
611 ASSERT((call->flags & IPC_CALL_ANSWERED) ||
612 (call->flags & IPC_CALL_NOTIF));
613
614 /*
615 * Record the receipt of this call in the current task's counter
616 * of active calls. IPC_M_PHONE_HUNGUP calls do not contribute
617 * to this counter so do not record answers to them either.
618 */
619 if (!(call->flags & IPC_CALL_DISCARD_ANSWER))
620 atomic_dec(&TASK->active_calls);
621 ipc_call_free(call);
622 }
623}
624
625
626/** Initilize IPC subsystem */
627void ipc_init(void)
628{
629 ipc_call_slab = slab_cache_create("ipc_call", sizeof(call_t), 0, NULL,
630 NULL, 0);
631 ipc_answerbox_slab = slab_cache_create("ipc_answerbox",
632 sizeof(answerbox_t), 0, NULL, NULL, 0);
633}
634
635
636/** List answerbox contents.
637 *
638 * @param taskid Task ID.
639 */
640void ipc_print_task(task_id_t taskid)
641{
642 task_t *task;
643 int i;
644 call_t *call;
645 link_t *tmp;
646
647 spinlock_lock(&tasks_lock);
648 task = task_find_by_id(taskid);
649 if (task)
650 spinlock_lock(&task->lock);
651 spinlock_unlock(&tasks_lock);
652 if (!task)
653 return;
654
655 /* Print opened phones & details */
656 printf("PHONE:\n");
657 for (i = 0; i < IPC_MAX_PHONES; i++) {
658 if (SYNCH_FAILED(mutex_trylock(&task->phones[i].lock))) {
659 printf("%d: mutex busy\n", i);
660 continue;
661 }
662 if (task->phones[i].state != IPC_PHONE_FREE) {
663 printf("%d: ", i);
664 switch (task->phones[i].state) {
665 case IPC_PHONE_CONNECTING:
666 printf("connecting ");
667 break;
668 case IPC_PHONE_CONNECTED:
669 printf("connected to: %p ",
670 task->phones[i].callee);
671 break;
672 case IPC_PHONE_SLAMMED:
673 printf("slammed by: %p ",
674 task->phones[i].callee);
675 break;
676 case IPC_PHONE_HUNGUP:
677 printf("hung up - was: %p ",
678 task->phones[i].callee);
679 break;
680 default:
681 break;
682 }
683 printf("active: %ld\n",
684 atomic_get(&task->phones[i].active_calls));
685 }
686 mutex_unlock(&task->phones[i].lock);
687 }
688
689
690 /* Print answerbox - calls */
691 spinlock_lock(&task->answerbox.lock);
692 printf("ABOX - CALLS:\n");
693 for (tmp = task->answerbox.calls.next; tmp != &task->answerbox.calls;
694 tmp = tmp->next) {
695 call = list_get_instance(tmp, call_t, link);
696 printf("Callid: %p Srctask:%" PRIu64 " M:%" PRIun
697 " A1:%" PRIun " A2:%" PRIun " A3:%" PRIun
698 " A4:%" PRIun " A5:%" PRIun " Flags:%x\n", call,
699 call->sender->taskid,
700 IPC_GET_METHOD(call->data), IPC_GET_ARG1(call->data),
701 IPC_GET_ARG2(call->data), IPC_GET_ARG3(call->data),
702 IPC_GET_ARG4(call->data), IPC_GET_ARG5(call->data),
703 call->flags);
704 }
705 /* Print answerbox - calls */
706 printf("ABOX - DISPATCHED CALLS:\n");
707 for (tmp = task->answerbox.dispatched_calls.next;
708 tmp != &task->answerbox.dispatched_calls;
709 tmp = tmp->next) {
710 call = list_get_instance(tmp, call_t, link);
711 printf("Callid: %p Srctask:%" PRIu64 " M:%" PRIun
712 " A1:%" PRIun " A2:%" PRIun " A3:%" PRIun
713 " A4:%" PRIun " A5:%" PRIun " Flags:%x\n", call,
714 call->sender->taskid,
715 IPC_GET_METHOD(call->data), IPC_GET_ARG1(call->data),
716 IPC_GET_ARG2(call->data), IPC_GET_ARG3(call->data),
717 IPC_GET_ARG4(call->data), IPC_GET_ARG5(call->data),
718 call->flags);
719 }
720 /* Print answerbox - calls */
721 printf("ABOX - ANSWERS:\n");
722 for (tmp = task->answerbox.answers.next;
723 tmp != &task->answerbox.answers;
724 tmp = tmp->next) {
725 call = list_get_instance(tmp, call_t, link);
726 printf("Callid:%p M:%" PRIun " A1:%" PRIun " A2:%" PRIun
727 " A3:%" PRIun " A4:%" PRIun " A5:%" PRIun " Flags:%x\n",
728 call, IPC_GET_METHOD(call->data), IPC_GET_ARG1(call->data),
729 IPC_GET_ARG2(call->data), IPC_GET_ARG3(call->data),
730 IPC_GET_ARG4(call->data), IPC_GET_ARG5(call->data),
731 call->flags);
732 }
733
734 spinlock_unlock(&task->answerbox.lock);
735 spinlock_unlock(&task->lock);
736}
737
738/** @}
739 */
Note: See TracBrowser for help on using the repository browser.