diff options
Diffstat (limited to 'net/tipc/bcast.c')
-rw-r--r-- | net/tipc/bcast.c | 21 |
1 files changed, 10 insertions, 11 deletions
diff --git a/net/tipc/bcast.c b/net/tipc/bcast.c index 06a639c375f0..e0feb7ef1469 100644 --- a/net/tipc/bcast.c +++ b/net/tipc/bcast.c | |||
@@ -356,9 +356,9 @@ static void bclink_peek_nack(struct tipc_msg *msg) | |||
356 | } | 356 | } |
357 | 357 | ||
358 | /* | 358 | /* |
359 | * tipc_bclink_send_msg - broadcast a packet to all nodes in cluster | 359 | * tipc_bclink_xmit - broadcast a packet to all nodes in cluster |
360 | */ | 360 | */ |
361 | int tipc_bclink_send_msg(struct sk_buff *buf) | 361 | int tipc_bclink_xmit(struct sk_buff *buf) |
362 | { | 362 | { |
363 | int res; | 363 | int res; |
364 | 364 | ||
@@ -370,7 +370,7 @@ int tipc_bclink_send_msg(struct sk_buff *buf) | |||
370 | goto exit; | 370 | goto exit; |
371 | } | 371 | } |
372 | 372 | ||
373 | res = tipc_link_send_buf(bcl, buf); | 373 | res = __tipc_link_xmit(bcl, buf); |
374 | if (likely(res >= 0)) { | 374 | if (likely(res >= 0)) { |
375 | bclink_set_last_sent(); | 375 | bclink_set_last_sent(); |
376 | bcl->stats.queue_sz_counts++; | 376 | bcl->stats.queue_sz_counts++; |
@@ -399,19 +399,18 @@ static void bclink_accept_pkt(struct tipc_node *node, u32 seqno) | |||
399 | */ | 399 | */ |
400 | 400 | ||
401 | if (((seqno - tipc_own_addr) % TIPC_MIN_LINK_WIN) == 0) { | 401 | if (((seqno - tipc_own_addr) % TIPC_MIN_LINK_WIN) == 0) { |
402 | tipc_link_send_proto_msg( | 402 | tipc_link_proto_xmit(node->active_links[node->addr & 1], |
403 | node->active_links[node->addr & 1], | 403 | STATE_MSG, 0, 0, 0, 0, 0); |
404 | STATE_MSG, 0, 0, 0, 0, 0); | ||
405 | bcl->stats.sent_acks++; | 404 | bcl->stats.sent_acks++; |
406 | } | 405 | } |
407 | } | 406 | } |
408 | 407 | ||
409 | /** | 408 | /** |
410 | * tipc_bclink_recv_pkt - receive a broadcast packet, and deliver upwards | 409 | * tipc_bclink_rcv - receive a broadcast packet, and deliver upwards |
411 | * | 410 | * |
412 | * tipc_net_lock is read_locked, no other locks set | 411 | * tipc_net_lock is read_locked, no other locks set |
413 | */ | 412 | */ |
414 | void tipc_bclink_recv_pkt(struct sk_buff *buf) | 413 | void tipc_bclink_rcv(struct sk_buff *buf) |
415 | { | 414 | { |
416 | struct tipc_msg *msg = buf_msg(buf); | 415 | struct tipc_msg *msg = buf_msg(buf); |
417 | struct tipc_node *node; | 416 | struct tipc_node *node; |
@@ -468,7 +467,7 @@ receive: | |||
468 | spin_unlock_bh(&bc_lock); | 467 | spin_unlock_bh(&bc_lock); |
469 | tipc_node_unlock(node); | 468 | tipc_node_unlock(node); |
470 | if (likely(msg_mcast(msg))) | 469 | if (likely(msg_mcast(msg))) |
471 | tipc_port_recv_mcast(buf, NULL); | 470 | tipc_port_mcast_rcv(buf, NULL); |
472 | else | 471 | else |
473 | kfree_skb(buf); | 472 | kfree_skb(buf); |
474 | } else if (msg_user(msg) == MSG_BUNDLER) { | 473 | } else if (msg_user(msg) == MSG_BUNDLER) { |
@@ -478,7 +477,7 @@ receive: | |||
478 | bcl->stats.recv_bundled += msg_msgcnt(msg); | 477 | bcl->stats.recv_bundled += msg_msgcnt(msg); |
479 | spin_unlock_bh(&bc_lock); | 478 | spin_unlock_bh(&bc_lock); |
480 | tipc_node_unlock(node); | 479 | tipc_node_unlock(node); |
481 | tipc_link_recv_bundle(buf); | 480 | tipc_link_bundle_rcv(buf); |
482 | } else if (msg_user(msg) == MSG_FRAGMENTER) { | 481 | } else if (msg_user(msg) == MSG_FRAGMENTER) { |
483 | int ret; | 482 | int ret; |
484 | ret = tipc_link_frag_rcv(&node->bclink.reasm_head, | 483 | ret = tipc_link_frag_rcv(&node->bclink.reasm_head, |
@@ -503,7 +502,7 @@ receive: | |||
503 | bclink_accept_pkt(node, seqno); | 502 | bclink_accept_pkt(node, seqno); |
504 | spin_unlock_bh(&bc_lock); | 503 | spin_unlock_bh(&bc_lock); |
505 | tipc_node_unlock(node); | 504 | tipc_node_unlock(node); |
506 | tipc_named_recv(buf); | 505 | tipc_named_rcv(buf); |
507 | } else { | 506 | } else { |
508 | spin_lock_bh(&bc_lock); | 507 | spin_lock_bh(&bc_lock); |
509 | bclink_accept_pkt(node, seqno); | 508 | bclink_accept_pkt(node, seqno); |