Ignore:
File:
1 edited

Legend:

Unmodified
Added
Removed
  • kernel/generic/src/ipc/ipc.c

    r79ae36dd r55b77d9  
    128128        list_initialize(&box->answers);
    129129        list_initialize(&box->irq_notifs);
    130         list_initialize(&box->irq_head);
     130        list_initialize(&box->irq_list);
    131131        box->task = task;
    132132}
     
    183183         */
    184184        irq_spinlock_lock(&TASK->lock, true);
    185         list_append(&sync_box->sync_box_link, &TASK->sync_box_head);
     185        list_append(&sync_box->sync_box_link, &TASK->sync_boxes);
    186186        irq_spinlock_unlock(&TASK->lock, true);
    187187       
     
    450450                irq_spinlock_lock(&box->irq_lock, false);
    451451               
    452                 request = list_get_instance(box->irq_notifs.next, call_t, link);
     452                request = list_get_instance(list_first(&box->irq_notifs),
     453                    call_t, link);
    453454                list_remove(&request->link);
    454455               
     
    459460               
    460461                /* Handle asynchronous answers */
    461                 request = list_get_instance(box->answers.next, call_t, link);
     462                request = list_get_instance(list_first(&box->answers),
     463                    call_t, link);
    462464                list_remove(&request->link);
    463465                atomic_dec(&request->data.phone->active_calls);
     
    467469               
    468470                /* Handle requests */
    469                 request = list_get_instance(box->calls.next, call_t, link);
     471                request = list_get_instance(list_first(&box->calls),
     472                    call_t, link);
    470473                list_remove(&request->link);
    471474               
     
    494497 *
    495498 */
    496 void ipc_cleanup_call_list(link_t *lst)
     499void ipc_cleanup_call_list(list_t *lst)
    497500{
    498501        while (!list_empty(lst)) {
    499                 call_t *call = list_get_instance(lst->next, call_t, link);
     502                call_t *call = list_get_instance(list_first(lst), call_t, link);
    500503                if (call->buffer)
    501504                        free(call->buffer);
     
    526529        irq_spinlock_lock(&box->lock, true);
    527530        while (!list_empty(&box->connected_phones)) {
    528                 phone = list_get_instance(box->connected_phones.next,
     531                phone = list_get_instance(list_first(&box->connected_phones),
    529532                    phone_t, link);
    530533                if (SYNCH_FAILED(mutex_trylock(&phone->lock))) {
     
    606609        /* Wait for all answers to interrupted synchronous calls to arrive */
    607610        ipl_t ipl = interrupts_disable();
    608         while (!list_empty(&TASK->sync_box_head)) {
    609                 answerbox_t *box = list_get_instance(TASK->sync_box_head.next,
    610                     answerbox_t, sync_box_link);
     611        while (!list_empty(&TASK->sync_boxes)) {
     612                answerbox_t *box = list_get_instance(
     613                    list_first(&TASK->sync_boxes), answerbox_t, sync_box_link);
    611614               
    612615                list_remove(&box->sync_box_link);
     
    743746#endif
    744747       
    745         link_t *cur;
    746        
    747748        printf(" --- incomming calls ---\n");
    748         for (cur = task->answerbox.calls.next; cur != &task->answerbox.calls;
    749             cur = cur->next) {
     749        list_foreach(task->answerbox.calls, cur) {
    750750                call_t *call = list_get_instance(cur, call_t, link);
    751751               
     
    767767       
    768768        printf(" --- dispatched calls ---\n");
    769         for (cur = task->answerbox.dispatched_calls.next;
    770             cur != &task->answerbox.dispatched_calls;
    771             cur = cur->next) {
     769        list_foreach(task->answerbox.dispatched_calls, cur) {
    772770                call_t *call = list_get_instance(cur, call_t, link);
    773771               
     
    789787       
    790788        printf(" --- incoming answers ---\n");
    791         for (cur = task->answerbox.answers.next;
    792             cur != &task->answerbox.answers;
    793             cur = cur->next) {
     789        list_foreach(task->answerbox.answers, cur) {
    794790                call_t *call = list_get_instance(cur, call_t, link);
    795791               
Note: See TracChangeset for help on using the changeset viewer.