Lines Matching refs:dom
139 static int dom_rec_len(struct tipc_mon_domain *dom, u16 mcnt) in dom_rec_len() argument
248 struct tipc_mon_domain *dom = peer->domain; in mon_apply_domain() local
253 if (!dom || !peer->is_up) in mon_apply_domain()
259 for (i = 0; i < dom->member_cnt; i++) { in mon_apply_domain()
260 addr = dom->members[i]; in mon_apply_domain()
274 struct tipc_mon_domain *dom = self->domain; in mon_update_local_domain() local
276 u64 prev_up_map = dom->up_map; in mon_update_local_domain()
285 dom->len = dom_rec_len(dom, member_cnt); in mon_update_local_domain()
286 diff = dom->member_cnt != member_cnt; in mon_update_local_domain()
287 dom->member_cnt = member_cnt; in mon_update_local_domain()
290 diff |= dom->members[i] != peer->addr; in mon_update_local_domain()
291 dom->members[i] = peer->addr; in mon_update_local_domain()
292 map_set(&dom->up_map, i, peer->is_up); in mon_update_local_domain()
295 diff |= dom->up_map != prev_up_map; in mon_update_local_domain()
298 dom->gen = ++mon->dom_gen; in mon_update_local_domain()
299 cache->len = mon_cpu_to_le16(dom->len); in mon_update_local_domain()
300 cache->gen = mon_cpu_to_le16(dom->gen); in mon_update_local_domain()
302 cache->up_map = mon_cpu_to_le64(dom->up_map); in mon_update_local_domain()
446 struct tipc_mon_domain *dom; in tipc_mon_peer_down() local
461 dom = peer->domain; in tipc_mon_peer_down()
464 mon_identify_lost_members(peer, dom, applied); in tipc_mon_peer_down()
465 kfree(dom); in tipc_mon_peer_down()
486 struct tipc_mon_domain *dom; in tipc_mon_rcv() local
538 dom = peer->domain; in tipc_mon_rcv()
539 if (dom) in tipc_mon_rcv()
540 memcpy(&dom_bef, dom, dom->len); in tipc_mon_rcv()
543 if (!dom || (dom->len < new_dlen)) { in tipc_mon_rcv()
544 kfree(dom); in tipc_mon_rcv()
545 dom = kmalloc(new_dlen, GFP_ATOMIC); in tipc_mon_rcv()
546 peer->domain = dom; in tipc_mon_rcv()
547 if (!dom) in tipc_mon_rcv()
550 dom->len = new_dlen; in tipc_mon_rcv()
551 dom->gen = new_gen; in tipc_mon_rcv()
552 dom->member_cnt = new_member_cnt; in tipc_mon_rcv()
553 dom->up_map = mon_le64_to_cpu(arrv_dom->up_map); in tipc_mon_rcv()
555 dom->members[i] = mon_le32_to_cpu(arrv_dom->members[i]); in tipc_mon_rcv()
570 struct tipc_mon_domain *dom = data; in tipc_mon_prep() local
576 dom->len = 0; in tipc_mon_prep()
582 len = dom_rec_len(dom, 0); in tipc_mon_prep()
584 dom->len = mon_cpu_to_le16(len); in tipc_mon_prep()
585 dom->gen = mon_cpu_to_le16(gen); in tipc_mon_prep()
586 dom->ack_gen = mon_cpu_to_le16(state->peer_gen); in tipc_mon_prep()
587 dom->member_cnt = 0; in tipc_mon_prep()
596 dom->ack_gen = mon_cpu_to_le16(state->peer_gen); in tipc_mon_prep()
652 struct tipc_mon_domain *dom; in tipc_mon_create() local
659 dom = kzalloc(sizeof(*dom), GFP_ATOMIC); in tipc_mon_create()
660 if (!mon || !self || !dom) { in tipc_mon_create()
663 kfree(dom); in tipc_mon_create()
671 self->domain = dom; in tipc_mon_create()
746 struct tipc_mon_domain *dom = peer->domain; in __tipc_nl_add_monitor_peer() local
774 if (dom) { in __tipc_nl_add_monitor_peer()
775 if (nla_put_u32(msg->skb, TIPC_NLA_MON_PEER_DOMGEN, dom->gen)) in __tipc_nl_add_monitor_peer()
778 dom->up_map, TIPC_NLA_MON_PEER_PAD)) in __tipc_nl_add_monitor_peer()
781 dom->member_cnt * sizeof(u32), &dom->members)) in __tipc_nl_add_monitor_peer()