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()
416 struct tipc_mon_domain *dom; in tipc_mon_peer_down() local
431 dom = peer->domain; in tipc_mon_peer_down()
434 mon_identify_lost_members(peer, dom, applied); in tipc_mon_peer_down()
435 kfree(dom); in tipc_mon_peer_down()
456 struct tipc_mon_domain *dom; in tipc_mon_rcv() local
505 dom = peer->domain; in tipc_mon_rcv()
506 if (dom) in tipc_mon_rcv()
507 memcpy(&dom_bef, dom, dom->len); in tipc_mon_rcv()
510 if (!dom || (dom->len < new_dlen)) { in tipc_mon_rcv()
511 kfree(dom); in tipc_mon_rcv()
512 dom = kmalloc(new_dlen, GFP_ATOMIC); in tipc_mon_rcv()
513 peer->domain = dom; in tipc_mon_rcv()
514 if (!dom) in tipc_mon_rcv()
517 dom->len = new_dlen; in tipc_mon_rcv()
518 dom->gen = new_gen; in tipc_mon_rcv()
519 dom->member_cnt = new_member_cnt; in tipc_mon_rcv()
520 dom->up_map = be64_to_cpu(arrv_dom->up_map); in tipc_mon_rcv()
522 dom->members[i] = ntohl(arrv_dom->members[i]); in tipc_mon_rcv()
537 struct tipc_mon_domain *dom = data; in tipc_mon_prep() local
543 dom->len = 0; in tipc_mon_prep()
549 len = dom_rec_len(dom, 0); in tipc_mon_prep()
551 dom->len = htons(len); in tipc_mon_prep()
552 dom->gen = htons(gen); in tipc_mon_prep()
553 dom->ack_gen = htons(state->peer_gen); in tipc_mon_prep()
554 dom->member_cnt = 0; in tipc_mon_prep()
563 dom->ack_gen = htons(state->peer_gen); in tipc_mon_prep()
619 struct tipc_mon_domain *dom; in tipc_mon_create() local
626 dom = kzalloc(sizeof(*dom), GFP_ATOMIC); in tipc_mon_create()
627 if (!mon || !self || !dom) { in tipc_mon_create()
630 kfree(dom); in tipc_mon_create()
638 self->domain = dom; in tipc_mon_create()
713 struct tipc_mon_domain *dom = peer->domain; in __tipc_nl_add_monitor_peer() local
741 if (dom) { in __tipc_nl_add_monitor_peer()
742 if (nla_put_u32(msg->skb, TIPC_NLA_MON_PEER_DOMGEN, dom->gen)) in __tipc_nl_add_monitor_peer()
745 dom->up_map, TIPC_NLA_MON_PEER_PAD)) in __tipc_nl_add_monitor_peer()
748 dom->member_cnt * sizeof(u32), &dom->members)) in __tipc_nl_add_monitor_peer()