136 static struct tipc_peer *peer_prev(struct tipc_peer *peer)  in peer_prev()  argument
138 	return list_last_entry(&peer->list, struct tipc_peer, list);  in peer_prev()
141 static struct tipc_peer *peer_nxt(struct tipc_peer *peer)  in peer_nxt()  argument
143 	return list_first_entry(&peer->list, struct tipc_peer, list);  in peer_nxt()
146 static struct tipc_peer *peer_head(struct tipc_peer *peer)  in peer_head()  argument
148 	while (!peer->is_head)  in peer_head()
149 		peer = peer_prev(peer);  in peer_head()
150 	return peer;  in peer_head()
155 	struct tipc_peer *peer;  in get_peer()  local
158 	hlist_for_each_entry(peer, &mon->peers[thash], hash) {  in get_peer()
159 		if (peer->addr == addr)  in get_peer()
160 			return peer;  in get_peer()
181 static void mon_identify_lost_members(struct tipc_peer *peer,  in mon_identify_lost_members()  argument
185 	struct tipc_peer *member = peer;  in mon_identify_lost_members()
186 	struct tipc_mon_domain *dom_aft = peer->domain;  in mon_identify_lost_members()
187 	int applied_aft = peer->applied;  in mon_identify_lost_members()
216 			     struct tipc_peer *peer)  in mon_apply_domain()  argument
218 	struct tipc_mon_domain *dom = peer->domain;  in mon_apply_domain()
223 	if (!dom || !peer->is_up)  in mon_apply_domain()
227 	peer->applied = 0;  in mon_apply_domain()
228 	member = peer_nxt(peer);  in mon_apply_domain()
233 		peer->applied++;  in mon_apply_domain()
245 	struct tipc_peer *peer = self;  in mon_update_local_domain()  local
259 		peer = peer_nxt(peer);  in mon_update_local_domain()
260 		diff |= dom->members[i] != peer->addr;  in mon_update_local_domain()
261 		dom->members[i] = peer->addr;  in mon_update_local_domain()
262 		map_set(&dom->up_map, i, peer->is_up);  in mon_update_local_domain()
263 		cache->members[i] = htonl(peer->addr);  in mon_update_local_domain()
279 				 struct tipc_peer *peer)  in mon_update_neighbors()  argument
285 		mon_apply_domain(mon, peer);  in mon_update_neighbors()
286 		peer = peer_prev(peer);  in mon_update_neighbors()
296 	struct tipc_peer *peer = peer_nxt(head);  in mon_assign_roles()  local
300 	for (; peer != self; peer = peer_nxt(peer)) {  in mon_assign_roles()
301 		peer->is_local = false;  in mon_assign_roles()
305 			peer->is_head = false;  in mon_assign_roles()
307 				peer->is_local = true;  in mon_assign_roles()
311 		if (!peer->is_up)  in mon_assign_roles()
313 		if (peer->is_head)  in mon_assign_roles()
315 		head = peer;  in mon_assign_roles()
326 	struct tipc_peer *peer, *prev, *head;  in tipc_mon_remove_peer()  local
329 	peer = get_peer(mon, addr);  in tipc_mon_remove_peer()
330 	if (!peer)  in tipc_mon_remove_peer()
332 	prev = peer_prev(peer);  in tipc_mon_remove_peer()
333 	list_del(&peer->list);  in tipc_mon_remove_peer()
334 	hlist_del(&peer->hash);  in tipc_mon_remove_peer()
335 	kfree(peer->domain);  in tipc_mon_remove_peer()
336 	kfree(peer);  in tipc_mon_remove_peer()
345 		list_for_each_entry(peer, &self->list, list) {  in tipc_mon_remove_peer()
346 			kfree(peer->domain);  in tipc_mon_remove_peer()
347 			peer->domain = NULL;  in tipc_mon_remove_peer()
348 			peer->applied = 0;  in tipc_mon_remove_peer()
357 			      struct tipc_peer **peer)  in tipc_mon_add_peer()  argument
363 	*peer = p;  in tipc_mon_add_peer()
392 	struct tipc_peer *peer, *head;  in tipc_mon_peer_up()  local
395 	peer = get_peer(mon, addr);  in tipc_mon_peer_up()
396 	if (!peer && !tipc_mon_add_peer(mon, addr, &peer))  in tipc_mon_peer_up()
398 	peer->is_up = true;  in tipc_mon_peer_up()
399 	head = peer_head(peer);  in tipc_mon_peer_up()
411 	struct tipc_peer *peer, *head;  in tipc_mon_peer_down()  local
416 	peer = get_peer(mon, addr);  in tipc_mon_peer_down()
417 	if (!peer) {  in tipc_mon_peer_down()
421 	applied = peer->applied;  in tipc_mon_peer_down()
422 	peer->applied = 0;  in tipc_mon_peer_down()
423 	dom = peer->domain;  in tipc_mon_peer_down()
424 	peer->domain = NULL;  in tipc_mon_peer_down()
425 	if (peer->is_head)  in tipc_mon_peer_down()
426 		mon_identify_lost_members(peer, dom, applied);  in tipc_mon_peer_down()
428 	peer->is_up = false;  in tipc_mon_peer_down()
429 	peer->is_head = false;  in tipc_mon_peer_down()
430 	peer->is_local = false;  in tipc_mon_peer_down()
431 	peer->down_cnt = 0;  in tipc_mon_peer_down()
432 	head = peer_head(peer);  in tipc_mon_peer_down()
449 	struct tipc_peer *peer;  in tipc_mon_rcv()  local
482 	peer = get_peer(mon, addr);  in tipc_mon_rcv()
483 	if (!peer || !peer->is_up)  in tipc_mon_rcv()
487 	peer->down_cnt = 0;  in tipc_mon_rcv()
497 	dom = peer->domain;  in tipc_mon_rcv()
505 		peer->domain = dom;  in tipc_mon_rcv()
517 	applied_bef = peer->applied;  in tipc_mon_rcv()
518 	mon_apply_domain(mon, peer);  in tipc_mon_rcv()
519 	mon_identify_lost_members(peer, &dom_bef, applied_bef);  in tipc_mon_rcv()
520 	mon_assign_roles(mon, peer_head(peer));  in tipc_mon_rcv()
560 	struct tipc_peer *peer;  in tipc_mon_get_state()  local
569 	peer = get_peer(mon, addr);  in tipc_mon_get_state()
570 	if (peer) {  in tipc_mon_get_state()
572 		state->probing |= peer->down_cnt;  in tipc_mon_get_state()
573 		state->reset |= peer->down_cnt >= MAX_PEER_DOWN_EVENTS;  in tipc_mon_get_state()
574 		state->monitoring = peer->is_local;  in tipc_mon_get_state()
575 		state->monitoring |= peer->is_head;  in tipc_mon_get_state()
637 	struct tipc_peer *peer, *tmp;  in tipc_mon_delete()  local
645 	list_for_each_entry_safe(peer, tmp, &self->list, list) {  in tipc_mon_delete()
646 		list_del(&peer->list);  in tipc_mon_delete()
647 		hlist_del(&peer->hash);  in tipc_mon_delete()
648 		kfree(peer->domain);  in tipc_mon_delete()
649 		kfree(peer);  in tipc_mon_delete()
678 int __tipc_nl_add_monitor_peer(struct tipc_peer *peer, struct tipc_nl_msg *msg)  in __tipc_nl_add_monitor_peer()  argument
680 	struct tipc_mon_domain *dom = peer->domain;  in __tipc_nl_add_monitor_peer()
693 	if (nla_put_u32(msg->skb, TIPC_NLA_MON_PEER_ADDR, peer->addr))  in __tipc_nl_add_monitor_peer()
695 	if (nla_put_u32(msg->skb, TIPC_NLA_MON_PEER_APPLIED, peer->applied))  in __tipc_nl_add_monitor_peer()
698 	if (peer->is_up)  in __tipc_nl_add_monitor_peer()
701 	if (peer->is_local)  in __tipc_nl_add_monitor_peer()
704 	if (peer->is_head)  in __tipc_nl_add_monitor_peer()
735 	struct tipc_peer *peer;  in tipc_nl_add_monitor_peer()  local
741 	peer = mon->self;  in tipc_nl_add_monitor_peer()
744 			if (peer->addr == *prev_node)  in tipc_nl_add_monitor_peer()
749 		if (__tipc_nl_add_monitor_peer(peer, msg)) {  in tipc_nl_add_monitor_peer()
750 			*prev_node = peer->addr;  in tipc_nl_add_monitor_peer()
754 	} while ((peer = peer_nxt(peer)) != mon->self);  in tipc_nl_add_monitor_peer()