Lines Matching refs:dom
109 static int dom_rec_len(struct tipc_mon_domain *dom, u16 mcnt) in dom_rec_len() argument
111 return ((void *)&dom->members - (void *)dom) + (mcnt * sizeof(u32)); in dom_rec_len()
218 struct tipc_mon_domain *dom = peer->domain; in mon_apply_domain() local
223 if (!dom || !peer->is_up) in mon_apply_domain()
229 for (i = 0; i < dom->member_cnt; i++) { in mon_apply_domain()
230 addr = dom->members[i]; in mon_apply_domain()
244 struct tipc_mon_domain *dom = self->domain; in mon_update_local_domain() local
246 u64 prev_up_map = dom->up_map; in mon_update_local_domain()
255 dom->len = dom_rec_len(dom, member_cnt); in mon_update_local_domain()
256 diff = dom->member_cnt != member_cnt; in mon_update_local_domain()
257 dom->member_cnt = member_cnt; 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()
265 diff |= dom->up_map != prev_up_map; in mon_update_local_domain()
268 dom->gen = ++mon->dom_gen; in mon_update_local_domain()
269 cache->len = htons(dom->len); in mon_update_local_domain()
270 cache->gen = htons(dom->gen); in mon_update_local_domain()
272 cache->up_map = cpu_to_be64(dom->up_map); in mon_update_local_domain()
412 struct tipc_mon_domain *dom; in tipc_mon_peer_down() local
423 dom = peer->domain; in tipc_mon_peer_down()
426 mon_identify_lost_members(peer, dom, applied); in tipc_mon_peer_down()
427 kfree(dom); in tipc_mon_peer_down()
448 struct tipc_mon_domain *dom; in tipc_mon_rcv() local
497 dom = peer->domain; in tipc_mon_rcv()
498 if (dom) in tipc_mon_rcv()
499 memcpy(&dom_bef, dom, dom->len); in tipc_mon_rcv()
502 if (!dom || (dom->len < new_dlen)) { in tipc_mon_rcv()
503 kfree(dom); in tipc_mon_rcv()
504 dom = kmalloc(new_dlen, GFP_ATOMIC); in tipc_mon_rcv()
505 peer->domain = dom; in tipc_mon_rcv()
506 if (!dom) in tipc_mon_rcv()
509 dom->len = new_dlen; in tipc_mon_rcv()
510 dom->gen = new_gen; in tipc_mon_rcv()
511 dom->member_cnt = new_member_cnt; in tipc_mon_rcv()
512 dom->up_map = be64_to_cpu(arrv_dom->up_map); in tipc_mon_rcv()
514 dom->members[i] = ntohl(arrv_dom->members[i]); in tipc_mon_rcv()
529 struct tipc_mon_domain *dom = data; in tipc_mon_prep() local
535 dom->len = 0; in tipc_mon_prep()
541 len = dom_rec_len(dom, 0); in tipc_mon_prep()
543 dom->len = htons(len); in tipc_mon_prep()
544 dom->gen = htons(gen); in tipc_mon_prep()
545 dom->ack_gen = htons(state->peer_gen); in tipc_mon_prep()
546 dom->member_cnt = 0; in tipc_mon_prep()
555 dom->ack_gen = htons(state->peer_gen); in tipc_mon_prep()
611 struct tipc_mon_domain *dom; in tipc_mon_create() local
618 dom = kzalloc(sizeof(*dom), GFP_ATOMIC); in tipc_mon_create()
619 if (!mon || !self || !dom) { in tipc_mon_create()
622 kfree(dom); in tipc_mon_create()
630 self->domain = dom; in tipc_mon_create()
690 struct tipc_mon_domain *dom = peer->domain; in __tipc_nl_add_monitor_peer() local
718 if (dom) { in __tipc_nl_add_monitor_peer()
719 if (nla_put_u32(msg->skb, TIPC_NLA_MON_PEER_DOMGEN, dom->gen)) in __tipc_nl_add_monitor_peer()
722 dom->up_map, TIPC_NLA_MON_PEER_PAD)) in __tipc_nl_add_monitor_peer()
725 dom->member_cnt * sizeof(u32), &dom->members)) in __tipc_nl_add_monitor_peer()