Searched refs:bclink (Results 1 - 5 of 5) sorted by relevance

/linux-4.1.27/net/tipc/
H A Dbcast.c59 spin_lock_bh(&tn->bclink->lock); tipc_bclink_lock()
66 spin_unlock_bh(&tn->bclink->lock); tipc_bclink_unlock()
73 tipc_sk_mcast_rcv(net, &tn->bclink->arrvq, &tn->bclink->inputq); tipc_bclink_input()
101 tipc_nmap_add(&tn->bclink->bcast_nodes, addr); tipc_bclink_add_node()
110 tipc_nmap_remove(&tn->bclink->bcast_nodes, addr); tipc_bclink_remove_node()
135 node->bclink.last_sent = less_eq(node->bclink.last_sent, seqno) ? bclink_update_last_sent()
136 seqno : node->bclink.last_sent; bclink_update_last_sent()
148 return tn->bclink->retransmit_to; tipc_bclink_retransmit_to()
180 tipc_sk_rcv(net, &tn->bclink->link.wakeupq); tipc_bclink_wakeup_users()
197 if (unlikely(!n_ptr->bclink.recv_permitted)) tipc_bclink_acknowledge()
214 if (tn->bclink->bcast_nodes.count) tipc_bclink_acknowledge()
225 less_eq(acked, n_ptr->bclink.acked)) tipc_bclink_acknowledge()
231 if (more(buf_seqno(skb), n_ptr->bclink.acked)) tipc_bclink_acknowledge()
247 n_ptr->bclink.acked = acked; tipc_bclink_acknowledge()
273 if (less_eq(last_sent, n_ptr->bclink.last_in)) tipc_bclink_update_link_state()
279 if (n_ptr->bclink.last_sent == n_ptr->bclink.last_in) tipc_bclink_update_link_state()
283 if ((++n_ptr->bclink.oos_state) == 1) { tipc_bclink_update_link_state()
284 if (n_ptr->bclink.deferred_size < (TIPC_MIN_LINK_WIN / 2)) tipc_bclink_update_link_state()
286 n_ptr->bclink.oos_state++; tipc_bclink_update_link_state()
290 if (n_ptr->bclink.oos_state & 0x1) tipc_bclink_update_link_state()
297 struct sk_buff *skb = skb_peek(&n_ptr->bclink.deferdq); tipc_bclink_update_link_state()
298 u32 to = skb ? buf_seqno(skb) - 1 : n_ptr->bclink.last_sent; tipc_bclink_update_link_state()
304 msg_set_bcast_ack(msg, n_ptr->bclink.last_in); tipc_bclink_update_link_state()
305 msg_set_bcgap_after(msg, n_ptr->bclink.last_in); tipc_bclink_update_link_state()
314 n_ptr->bclink.oos_state++; tipc_bclink_update_link_state()
332 if (n_ptr->bclink.recv_permitted && bclink_peek_nack()
333 (n_ptr->bclink.last_in != n_ptr->bclink.last_sent) && bclink_peek_nack()
334 (n_ptr->bclink.last_in == msg_bcgap_after(msg))) bclink_peek_nack()
335 n_ptr->bclink.oos_state = 2; bclink_peek_nack()
351 struct tipc_bclink *bclink = tn->bclink; tipc_bclink_xmit() local
365 if (likely(bclink)) { tipc_bclink_xmit()
367 if (likely(bclink->bcast_nodes.count)) { tipc_bclink_xmit()
406 node->bclink.last_in = seqno; bclink_accept_pkt()
407 node->bclink.oos_state = 0; bclink_accept_pkt()
448 if (unlikely(!node->bclink.recv_permitted)) tipc_bclink_rcv()
459 tn->bclink->retransmit_to = node; tipc_bclink_rcv()
474 next_in = mod(node->bclink.last_in + 1); tipc_bclink_rcv()
475 arrvq = &tn->bclink->arrvq; tipc_bclink_rcv()
476 inputq = &tn->bclink->inputq; tipc_bclink_rcv()
507 tipc_buf_append(&node->bclink.reasm_buf, &buf); tipc_bclink_rcv()
508 if (unlikely(!buf && !node->bclink.reasm_buf)) { tipc_bclink_rcv()
535 if (node->bclink.last_in == node->bclink.last_sent) tipc_bclink_rcv()
538 if (skb_queue_empty(&node->bclink.deferdq)) { tipc_bclink_rcv()
539 node->bclink.oos_state = 1; tipc_bclink_rcv()
543 msg = buf_msg(skb_peek(&node->bclink.deferdq)); tipc_bclink_rcv()
550 buf = __skb_dequeue(&node->bclink.deferdq); tipc_bclink_rcv()
556 deferred = tipc_link_defer_pkt(&node->bclink.deferdq, tipc_bclink_rcv()
580 return (n_ptr->bclink.recv_permitted && tipc_bclink_acks_missing()
581 (tipc_bclink_get_last_sent(n_ptr->net) != n_ptr->bclink.acked)); tipc_bclink_acks_missing()
602 struct tipc_bclink *bclink = tn->bclink; tipc_bcbearer_send() local
610 bcbuf_set_acks(buf, bclink->bcast_nodes.count); tipc_bcbearer_send()
614 if (WARN_ON(!bclink->bcast_nodes.count)) { tipc_bcbearer_send()
621 bcbearer->remains = bclink->bcast_nodes; tipc_bcbearer_send()
873 struct tipc_bclink *bclink; tipc_bclink_init() local
880 bclink = kzalloc(sizeof(*bclink), GFP_ATOMIC); tipc_bclink_init()
881 if (!bclink) { tipc_bclink_init()
886 bcl = &bclink->link; tipc_bclink_init()
891 spin_lock_init(&bclink->lock); tipc_bclink_init()
897 spin_lock_init(&bclink->node.lock); tipc_bclink_init()
898 __skb_queue_head_init(&bclink->arrvq); tipc_bclink_init()
899 skb_queue_head_init(&bclink->inputq); tipc_bclink_init()
900 bcl->owner = &bclink->node; tipc_bclink_init()
911 tn->bclink = bclink; tipc_bclink_init()
927 kfree(tn->bclink); tipc_bclink_stop()
H A Dnode.c134 __skb_queue_head_init(&n_ptr->bclink.deferdq); tipc_node_create()
364 n_ptr->bclink.oos_state = 0; node_established_contact()
365 n_ptr->bclink.acked = tipc_bclink_get_last_sent(n_ptr->net); node_established_contact()
382 if (n_ptr->bclink.recv_permitted) { node_lost_contact()
383 __skb_queue_purge(&n_ptr->bclink.deferdq); node_lost_contact()
385 if (n_ptr->bclink.reasm_buf) { node_lost_contact()
386 kfree_skb(n_ptr->bclink.reasm_buf); node_lost_contact()
387 n_ptr->bclink.reasm_buf = NULL; node_lost_contact()
393 n_ptr->bclink.recv_permitted = false; node_lost_contact()
H A Dnode.h72 * struct tipc_node_bclink - TIPC node bclink structure
107 * @bclink: broadcast-related info
129 struct tipc_node_bclink bclink; member in struct:tipc_node
H A Dlink.c708 uint bc_last_in = link->owner->bclink.last_in; __tipc_link_xmit()
847 msg_set_last_bcast(msg, link->owner->bclink.acked); tipc_link_sync_xmit()
863 n->bclink.last_sent = n->bclink.last_in = msg_last_bcast(msg); tipc_link_sync_rcv()
864 n->bclink.recv_permitted = true; tipc_link_sync_rcv()
889 msg_set_bcast_ack(msg, link->owner->bclink.last_in); tipc_link_push_packets()
944 n_ptr->bclink.recv_permitted, link_retransmit_failure()
945 n_ptr->bclink.acked); link_retransmit_failure()
947 n_ptr->bclink.last_in, link_retransmit_failure()
948 n_ptr->bclink.oos_state, link_retransmit_failure()
949 n_ptr->bclink.last_sent); link_retransmit_failure()
982 msg_set_bcast_ack(msg, l_ptr->owner->bclink.last_in); tipc_link_retransmit()
1099 if (unlikely(n_ptr->bclink.acked != msg_bcast_ack(msg))) tipc_rcv()
1192 node->bclink.recv_permitted = true; tipc_data_input()
1359 msg_set_bcast_ack(msg, l_ptr->owner->bclink.last_in); tipc_link_proto_xmit()
1470 l_ptr->owner->bclink.last_sent = tipc_link_proto_rcv()
1471 l_ptr->owner->bclink.last_in = tipc_link_proto_rcv()
1473 l_ptr->owner->bclink.oos_state = 0; tipc_link_proto_rcv()
1515 if (l_ptr->owner->bclink.recv_permitted) tipc_link_proto_rcv()
1657 msg_set_bcast_ack(msg, link->owner->bclink.last_in); skb_queue_walk()
H A Dcore.h94 struct tipc_bclink *bclink; member in struct:tipc_net

Completed in 191 milliseconds