Lines Matching refs:chan_state
332 struct monitor_multihop_chan_state *chan_state)
335 assert(chan_state != NULL);
348 collections_hash_insert(forwarding_table, vci, chan_state);
365 struct monitor_multihop_chan_state *chan_state = collections_hash_find(forwarding_table,
368 if (chan_state == NULL) {
371 return chan_state;
411 struct monitor_multihop_chan_state *chan_state, uint8_t direction)
414 return &chan_state->dir1;
416 return &chan_state->dir2;
425 struct monitor_multihop_chan_state *chan_state, uint8_t direction,
429 *dir = &chan_state->dir1;
432 *dir = &chan_state->dir2;
452 struct monitor_multihop_chan_state *chan_state, iref_t iref,
457 struct monitor_multihop_chan_state *chan_state);
468 multihop_monitor_request_error(struct monitor_multihop_chan_state *chan_state,
484 struct monitor_multihop_chan_state *chan_state = NULL;
498 chan_state = malloc(sizeof(struct monitor_multihop_chan_state));
499 assert(chan_state != NULL);
500 chan_state->connstate = MONITOR_MULTIHOP_BIND_WAIT;
501 chan_state->dir2.type = MULTIHOP_ENDPOINT;
502 chan_state->dir2.vci = vci;
503 chan_state->dir2.binding.monitor_binding = b;
507 chan_state->tmp_vci = forwarding_table_insert(chan_state);
511 multihop_monitor_request_error(chan_state,
513 forwarding_table_delete(chan_state->tmp_vci);
522 &chan_state->dir1.binding.intermon_binding);
526 multihop_monitor_request_error(chan_state, err);
527 forwarding_table_delete(chan_state->tmp_vci);
532 multihop_monitor_bind_request_cont(chan_state, iref, core_id);
537 struct monitor_multihop_chan_state *chan_state;
548 multihop_monitor_bind_request_cont(st->chan_state, st->iref, st->core);
555 * \param chan_state pointer to the channel state
560 struct monitor_multihop_chan_state *chan_state, iref_t iref,
566 chan_state->dir1.binding.intermon_binding;
570 NOP_CONT, iref, chan_state->tmp_vci, core);
577 me->chan_state = chan_state;
587 multihop_monitor_request_error(chan_state, err);
588 forwarding_table_delete(chan_state->tmp_vci);
609 struct monitor_multihop_chan_state *chan_state = malloc(
611 chan_state->connstate = MONITOR_MULTIHOP_BIND_WAIT;
612 chan_state->dir2.vci = vci;
613 chan_state->dir2.binding.intermon_binding = b;
614 chan_state->dir2.type = MULTIHOP_NODE;
615 chan_state->tmp_vci = forwarding_table_insert(chan_state);
621 err = iref_get_binding(iref, &chan_state->dir1.binding.monitor_binding);
636 multihop_bind_service_request(service_id, chan_state);
645 &chan_state->dir1.binding.intermon_binding);
649 multihop_monitor_request_error(chan_state, err);
650 forwarding_table_delete(chan_state->tmp_vci);
655 multihop_monitor_bind_request_cont(chan_state, iref, core);
663 struct monitor_multihop_chan_state *chan_state;
672 multihop_bind_service_request(st->service_id, st->chan_state);
684 struct monitor_multihop_chan_state *chan_state)
690 chan_state->dir1.binding.monitor_binding->tx_vtbl.multihop_bind_service_request(
691 chan_state->dir1.binding.monitor_binding, NOP_CONT,
692 service_id, chan_state->tmp_vci);
696 chan_state->dir1.binding.monitor_binding;
701 me->chan_state = chan_state;
711 multihop_monitor_request_error(chan_state, err);
712 forwarding_table_delete(chan_state->tmp_vci);
731 struct monitor_multihop_chan_state *chan_state = forwarding_table_lookup(
734 assert(chan_state->connstate == MONITOR_MULTIHOP_BIND_WAIT);
736 multihop_vci_t next_receiver_vci = chan_state->dir2.vci;
738 chan_state->dir2.binding.intermon_binding;
740 chan_state->dir1.type = MULTIHOP_ENDPOINT;
741 chan_state->dir1.vci = sender_vci;
742 chan_state->dir1.binding.monitor_binding = mon_binding;
743 chan_state->connstate = MONITOR_MULTIHOP_CONNECTED;
816 struct monitor_multihop_chan_state *chan_state = forwarding_table_lookup(
819 assert(chan_state->connstate == MONITOR_MULTIHOP_BIND_WAIT);
822 chan_state->dir1.type = MULTIHOP_NODE;
823 chan_state->dir1.binding.intermon_binding = binding;
824 chan_state->dir1.vci = sender_vci;
825 chan_state->connstate = MONITOR_MULTIHOP_CONNECTED;
827 if (chan_state->dir2.type == MULTIHOP_NODE) {
829 chan_state->dir2.binding.intermon_binding,
830 chan_state->dir2.vci, receiver_vci, msgerr);
833 chan_state->dir2.binding.monitor_binding,
834 chan_state->dir2.vci, receiver_vci, msgerr);
840 if (chan_state->dir2.type == MULTIHOP_NODE) {
842 chan_state->dir2.binding.intermon_binding,
843 chan_state->dir2.vci, 0, msgerr);
846 chan_state->dir2.binding.monitor_binding,
847 chan_state->dir2.vci, 0, msgerr);
917 struct monitor_multihop_chan_state *chan_state, errval_t msgerr)
919 assert(chan_state != NULL);
920 if (chan_state->dir2.type == MULTIHOP_NODE) {
922 chan_state->dir2.binding.intermon_binding, chan_state->dir2.vci,
926 chan_state->dir2.binding.monitor_binding, chan_state->dir2.vci,
986 struct monitor_multihop_chan_state *chan_state = forwarding_table_lookup(
988 struct direction *dir = multihop_get_direction(chan_state, direction);
1105 struct monitor_multihop_chan_state *chan_state = forwarding_table_lookup(
1107 struct direction *dir = multihop_get_direction(chan_state, direction);
1292 struct monitor_multihop_chan_state *chan_state = forwarding_table_lookup(
1294 struct direction *dir = multihop_get_direction(chan_state, direction);
1427 struct monitor_multihop_chan_state *chan_state = forwarding_table_lookup(
1429 struct direction *dir = multihop_get_direction(chan_state, direction);