153 static struct tipc_peer *get_peer(struct tipc_monitor *mon, u32 addr)  in get_peer()  argument
158 	hlist_for_each_entry(peer, &mon->peers[thash], hash) {  in get_peer()
167 	struct tipc_monitor *mon = tipc_monitor(net, bearer_id);  in get_self()  local
169 	return mon->self;  in get_self()
172 static inline bool tipc_mon_is_active(struct net *net, struct tipc_monitor *mon)  in tipc_mon_is_active()  argument
176 	return mon->peer_cnt > tn->mon_threshold;  in tipc_mon_is_active()
215 static void mon_apply_domain(struct tipc_monitor *mon,  in mon_apply_domain()  argument
240 static void mon_update_local_domain(struct tipc_monitor *mon)  in mon_update_local_domain()  argument
242 	struct tipc_peer *self = mon->self;  in mon_update_local_domain()
243 	struct tipc_mon_domain *cache = &mon->cache;  in mon_update_local_domain()
251 	member_cnt = dom_size(mon->peer_cnt) - 1;  in mon_update_local_domain()
268 	dom->gen = ++mon->dom_gen;  in mon_update_local_domain()
273 	mon_apply_domain(mon, self);  in mon_update_local_domain()
278 static void mon_update_neighbors(struct tipc_monitor *mon,  in mon_update_neighbors()  argument
283 	dz = dom_size(mon->peer_cnt);  in mon_update_neighbors()
285 		mon_apply_domain(mon, peer);  in mon_update_neighbors()
294 static void mon_assign_roles(struct tipc_monitor *mon, struct tipc_peer *head)  in mon_assign_roles()  argument
297 	struct tipc_peer *self = mon->self;  in mon_assign_roles()
319 	mon->list_gen++;  in mon_assign_roles()
324 	struct tipc_monitor *mon = tipc_monitor(net, bearer_id);  in tipc_mon_remove_peer()  local
328 	if (!mon)  in tipc_mon_remove_peer()
332 	write_lock_bh(&mon->lock);  in tipc_mon_remove_peer()
333 	peer = get_peer(mon, addr);  in tipc_mon_remove_peer()
341 	mon->peer_cnt--;  in tipc_mon_remove_peer()
344 		mon_update_local_domain(mon);  in tipc_mon_remove_peer()
345 	mon_update_neighbors(mon, prev);  in tipc_mon_remove_peer()
348 	if (!tipc_mon_is_active(net, mon)) {  in tipc_mon_remove_peer()
355 	mon_assign_roles(mon, head);  in tipc_mon_remove_peer()
357 	write_unlock_bh(&mon->lock);  in tipc_mon_remove_peer()
360 static bool tipc_mon_add_peer(struct tipc_monitor *mon, u32 addr,  in tipc_mon_add_peer()  argument
363 	struct tipc_peer *self = mon->self;  in tipc_mon_add_peer()
374 	hlist_add_head(&p->hash, &mon->peers[tipc_hashfn(addr)]);  in tipc_mon_add_peer()
387 	mon->peer_cnt++;  in tipc_mon_add_peer()
388 	mon_update_neighbors(mon, p);  in tipc_mon_add_peer()
394 	struct tipc_monitor *mon = tipc_monitor(net, bearer_id);  in tipc_mon_peer_up()  local
398 	write_lock_bh(&mon->lock);  in tipc_mon_peer_up()
399 	peer = get_peer(mon, addr);  in tipc_mon_peer_up()
400 	if (!peer && !tipc_mon_add_peer(mon, addr, &peer))  in tipc_mon_peer_up()
405 		mon_update_local_domain(mon);  in tipc_mon_peer_up()
406 	mon_assign_roles(mon, head);  in tipc_mon_peer_up()
408 	write_unlock_bh(&mon->lock);  in tipc_mon_peer_up()
413 	struct tipc_monitor *mon = tipc_monitor(net, bearer_id);  in tipc_mon_peer_down()  local
419 	if (!mon)  in tipc_mon_peer_down()
423 	write_lock_bh(&mon->lock);  in tipc_mon_peer_down()
424 	peer = get_peer(mon, addr);  in tipc_mon_peer_down()
442 		mon_update_local_domain(mon);  in tipc_mon_peer_down()
443 	mon_assign_roles(mon, head);  in tipc_mon_peer_down()
445 	write_unlock_bh(&mon->lock);  in tipc_mon_peer_down()
453 	struct tipc_monitor *mon = tipc_monitor(net, bearer_id);  in tipc_mon_rcv()  local
491 	write_lock_bh(&mon->lock);  in tipc_mon_rcv()
492 	peer = get_peer(mon, addr);  in tipc_mon_rcv()
528 	mon_apply_domain(mon, peer);  in tipc_mon_rcv()
530 	mon_assign_roles(mon, peer_head(peer));  in tipc_mon_rcv()
532 	write_unlock_bh(&mon->lock);  in tipc_mon_rcv()
538 	struct tipc_monitor *mon = tipc_monitor(net, bearer_id);  in tipc_mon_prep()  local
540 	u16 gen = mon->dom_gen;  in tipc_mon_prep()
544 	if (!tipc_mon_is_active(net, mon)) {  in tipc_mon_prep()
560 	read_lock_bh(&mon->lock);  in tipc_mon_prep()
561 	len = ntohs(mon->cache.len);  in tipc_mon_prep()
563 	memcpy(data, &mon->cache, len);  in tipc_mon_prep()
564 	read_unlock_bh(&mon->lock);  in tipc_mon_prep()
572 	struct tipc_monitor *mon = tipc_monitor(net, bearer_id);  in tipc_mon_get_state()  local
575 	if (!tipc_mon_is_active(net, mon)) {  in tipc_mon_get_state()
583 	    (state->list_gen == mon->list_gen) &&  in tipc_mon_get_state()
584 	    (state->acked_gen == mon->dom_gen))  in tipc_mon_get_state()
587 	read_lock_bh(&mon->lock);  in tipc_mon_get_state()
588 	peer = get_peer(mon, addr);  in tipc_mon_get_state()
590 		state->probing = state->acked_gen != mon->dom_gen;  in tipc_mon_get_state()
595 		state->list_gen = mon->list_gen;  in tipc_mon_get_state()
597 	read_unlock_bh(&mon->lock);  in tipc_mon_get_state()
602 	struct tipc_monitor *mon = from_timer(mon, t, timer);  in mon_timeout()  local
604 	int best_member_cnt = dom_size(mon->peer_cnt) - 1;  in mon_timeout()
606 	write_lock_bh(&mon->lock);  in mon_timeout()
607 	self = mon->self;  in mon_timeout()
609 		mon_update_local_domain(mon);  in mon_timeout()
610 		mon_assign_roles(mon, self);  in mon_timeout()
612 	write_unlock_bh(&mon->lock);  in mon_timeout()
613 	mod_timer(&mon->timer, jiffies + mon->timer_intv);  in mon_timeout()
619 	struct tipc_monitor *mon;  in tipc_mon_create()  local
626 	mon = kzalloc(sizeof(*mon), GFP_ATOMIC);  in tipc_mon_create()
629 	if (!mon || !self || !dom) {  in tipc_mon_create()
630 		kfree(mon);  in tipc_mon_create()
635 	tn->monitors[bearer_id] = mon;  in tipc_mon_create()
636 	rwlock_init(&mon->lock);  in tipc_mon_create()
637 	mon->net = net;  in tipc_mon_create()
638 	mon->peer_cnt = 1;  in tipc_mon_create()
639 	mon->self = self;  in tipc_mon_create()
645 	timer_setup(&mon->timer, mon_timeout, 0);  in tipc_mon_create()
646 	mon->timer_intv = msecs_to_jiffies(MON_TIMEOUT + (tn->random & 0xffff));  in tipc_mon_create()
647 	mod_timer(&mon->timer, jiffies + mon->timer_intv);  in tipc_mon_create()
654 	struct tipc_monitor *mon = tipc_monitor(net, bearer_id);  in tipc_mon_delete()  local
658 	if (!mon)  in tipc_mon_delete()
662 	write_lock_bh(&mon->lock);  in tipc_mon_delete()
670 	mon->self = NULL;  in tipc_mon_delete()
671 	write_unlock_bh(&mon->lock);  in tipc_mon_delete()
672 	del_timer_sync(&mon->timer);  in tipc_mon_delete()
675 	kfree(mon);  in tipc_mon_delete()
680 	struct tipc_monitor *mon;  in tipc_mon_reinit_self()  local
684 		mon = tipc_monitor(net, bearer_id);  in tipc_mon_reinit_self()
685 		if (!mon)  in tipc_mon_reinit_self()
687 		write_lock_bh(&mon->lock);  in tipc_mon_reinit_self()
688 		mon->self->addr = tipc_own_addr(net);  in tipc_mon_reinit_self()
689 		write_unlock_bh(&mon->lock);  in tipc_mon_reinit_self()
769 	struct tipc_monitor *mon = tipc_monitor(net, bearer_id);  in tipc_nl_add_monitor_peer()  local
772 	if (!mon)  in tipc_nl_add_monitor_peer()
775 	read_lock_bh(&mon->lock);  in tipc_nl_add_monitor_peer()
776 	peer = mon->self;  in tipc_nl_add_monitor_peer()
786 			read_unlock_bh(&mon->lock);  in tipc_nl_add_monitor_peer()
789 	} while ((peer = peer_nxt(peer)) != mon->self);  in tipc_nl_add_monitor_peer()
790 	read_unlock_bh(&mon->lock);  in tipc_nl_add_monitor_peer()
798 	struct tipc_monitor *mon = tipc_monitor(net, bearer_id);  in __tipc_nl_add_monitor()  local
805 	if (ret || !mon)  in __tipc_nl_add_monitor()
817 	read_lock_bh(&mon->lock);  in __tipc_nl_add_monitor()
820 	if (tipc_mon_is_active(net, mon))  in __tipc_nl_add_monitor()
825 	if (nla_put_u32(msg->skb, TIPC_NLA_MON_PEERCNT, mon->peer_cnt))  in __tipc_nl_add_monitor()
827 	if (nla_put_u32(msg->skb, TIPC_NLA_MON_LISTGEN, mon->list_gen))  in __tipc_nl_add_monitor()
830 	read_unlock_bh(&mon->lock);  in __tipc_nl_add_monitor()
837 	read_unlock_bh(&mon->lock);  in __tipc_nl_add_monitor()