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
536 dom = peer->domain; in tipc_mon_rcv()
537 if (dom) in tipc_mon_rcv()
538 memcpy(&dom_bef, dom, dom->len); in tipc_mon_rcv()
541 if (!dom || (dom->len < new_dlen)) { in tipc_mon_rcv()
542 kfree(dom); in tipc_mon_rcv()
543 dom = kmalloc(new_dlen, GFP_ATOMIC); in tipc_mon_rcv()
544 peer->domain = dom; in tipc_mon_rcv()
545 if (!dom) in tipc_mon_rcv()
548 dom->len = new_dlen; in tipc_mon_rcv()
549 dom->gen = new_gen; in tipc_mon_rcv()
550 dom->member_cnt = new_member_cnt; in tipc_mon_rcv()
551 dom->up_map = mon_le64_to_cpu(arrv_dom->up_map); in tipc_mon_rcv()
553 dom->members[i] = mon_le32_to_cpu(arrv_dom->members[i]); in tipc_mon_rcv()
568 struct tipc_mon_domain *dom = data; in tipc_mon_prep() local
574 dom->len = 0; in tipc_mon_prep()
580 len = dom_rec_len(dom, 0); in tipc_mon_prep()
582 dom->len = mon_cpu_to_le16(len); in tipc_mon_prep()
583 dom->gen = mon_cpu_to_le16(gen); in tipc_mon_prep()
584 dom->ack_gen = mon_cpu_to_le16(state->peer_gen); in tipc_mon_prep()
585 dom->member_cnt = 0; in tipc_mon_prep()
594 dom->ack_gen = mon_cpu_to_le16(state->peer_gen); in tipc_mon_prep()
650 struct tipc_mon_domain *dom; in tipc_mon_create() local
657 dom = kzalloc(sizeof(*dom), GFP_ATOMIC); in tipc_mon_create()
658 if (!mon || !self || !dom) { in tipc_mon_create()
661 kfree(dom); in tipc_mon_create()
669 self->domain = dom; in tipc_mon_create()
744 struct tipc_mon_domain *dom = peer->domain; in __tipc_nl_add_monitor_peer() local
772 if (dom) { in __tipc_nl_add_monitor_peer()
773 if (nla_put_u32(msg->skb, TIPC_NLA_MON_PEER_DOMGEN, dom->gen)) in __tipc_nl_add_monitor_peer()
776 dom->up_map, TIPC_NLA_MON_PEER_PAD)) in __tipc_nl_add_monitor_peer()
779 dom->member_cnt * sizeof(u32), &dom->members)) in __tipc_nl_add_monitor_peer()