Lines Matching refs:owner
134 if (l->owner->active_links[0] != l) in tipc_parallel_link()
135 return l->owner->active_links[0]; in tipc_parallel_link()
136 return l->owner->active_links[1]; in tipc_parallel_link()
151 return (l_ptr->owner->active_links[0] == l_ptr) || in tipc_link_is_active()
152 (l_ptr->owner->active_links[1] == l_ptr); in tipc_link_is_active()
164 tipc_node_lock(l_ptr->owner); in link_timeout()
205 tipc_node_unlock(l_ptr->owner); in link_timeout()
263 l_ptr->owner = n_ptr; in tipc_link_create()
310 tipc_node_detach_link(l->owner, l); in tipc_link_delete()
392 l->owner->inputq = &l->inputq; in link_prepare_wakeup()
393 l->owner->action_flags |= TIPC_MSG_EVT; in link_prepare_wakeup()
433 struct tipc_node *owner = l_ptr->owner; in tipc_link_reset() local
449 tipc_node_link_down(l_ptr->owner, l_ptr); in tipc_link_reset()
450 tipc_bearer_remove_dest(owner->net, l_ptr->bearer_id, l_ptr->addr); in tipc_link_reset()
452 if (was_active_link && tipc_node_is_up(l_ptr->owner) && (pl != l_ptr)) { in tipc_link_reset()
464 if (!owner->inputq) in tipc_link_reset()
465 owner->inputq = &l_ptr->inputq; in tipc_link_reset()
466 skb_queue_splice_init(&l_ptr->wakeupq, owner->inputq); in tipc_link_reset()
467 if (!skb_queue_empty(owner->inputq)) in tipc_link_reset()
468 owner->action_flags |= TIPC_MSG_EVT; in tipc_link_reset()
498 struct tipc_node *node = link->owner; in link_activate()
537 if (tipc_bclink_acks_missing(l_ptr->owner)) { in link_state_event()
590 if (tipc_bclink_acks_missing(l_ptr->owner)) { in link_state_event()
622 other = l_ptr->owner->active_links[0]; in link_state_event()
630 if (l_ptr->owner->working_links == 1) in link_state_event()
660 other = l_ptr->owner->active_links[0]; in link_state_event()
668 if (l_ptr->owner->working_links == 1) in link_state_event()
708 uint bc_last_in = link->owner->bclink.last_in; in __tipc_link_xmit()
765 return __tipc_link_xmit(link->owner->net, link, &head); in __tipc_link_xmit_skb()
847 msg_set_last_bcast(msg, link->owner->bclink.acked); in tipc_link_sync_xmit()
889 msg_set_bcast_ack(msg, link->owner->bclink.last_in); in tipc_link_push_packets()
892 tipc_bearer_send(link->owner->net, link->bearer_id, in tipc_link_push_packets()
921 struct net *net = l_ptr->owner->net; in link_retransmit_failure()
982 msg_set_bcast_ack(msg, l_ptr->owner->bclink.last_in); in tipc_link_retransmit()
983 tipc_bearer_send(l_ptr->owner->net, l_ptr->bearer_id, skb, in tipc_link_retransmit()
1176 struct tipc_node *node = link->owner; in tipc_data_input()
1217 struct tipc_node *node = link->owner; in tipc_link_input()
1353 if ((tipc_node_blocked(l_ptr->owner)) && (msg_typ != RESET_MSG)) in tipc_link_proto_xmit()
1359 msg_set_bcast_ack(msg, l_ptr->owner->bclink.last_in); in tipc_link_proto_xmit()
1360 msg_set_last_bcast(msg, tipc_bclink_get_last_sent(l_ptr->owner->net)); in tipc_link_proto_xmit()
1395 r_flag = (l_ptr->owner->working_links > tipc_link_is_up(l_ptr)); in tipc_link_proto_xmit()
1408 tipc_bearer_send(l_ptr->owner->net, l_ptr->bearer_id, buf, in tipc_link_proto_xmit()
1448 l_ptr->owner->action_flags |= TIPC_WAIT_OWN_LINKS_DOWN; in tipc_link_proto_rcv()
1469 if (!tipc_node_is_up(l_ptr->owner)) { in tipc_link_proto_rcv()
1470 l_ptr->owner->bclink.last_sent = in tipc_link_proto_rcv()
1471 l_ptr->owner->bclink.last_in = in tipc_link_proto_rcv()
1473 l_ptr->owner->bclink.oos_state = 0; in tipc_link_proto_rcv()
1515 if (l_ptr->owner->bclink.recv_permitted) in tipc_link_proto_rcv()
1516 tipc_bclink_update_link_state(l_ptr->owner, in tipc_link_proto_rcv()
1547 tunnel = l_ptr->owner->active_links[selector & 1]; in tipc_link_tunnel_xmit()
1573 struct tipc_link *tunnel = l_ptr->owner->active_links[0]; in tipc_link_failover_send_queue()
1602 split_bundles = (l_ptr->owner->active_links[0] != in tipc_link_failover_send_queue()
1603 l_ptr->owner->active_links[1]); in tipc_link_failover_send_queue()
1657 msg_set_bcast_ack(msg, link->owner->bclink.last_in); in tipc_link_dup_queue_xmit()
1700 pl = link->owner->links[bearer_id]; in tipc_link_failover_rcv()
1812 struct tipc_net *tn = net_generic(l_ptr->owner->net, tipc_net_id); in link_print()