• Home
  • Raw
  • Download

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
507 dom = peer->domain; in tipc_mon_rcv()
508 if (dom) in tipc_mon_rcv()
509 memcpy(&dom_bef, dom, dom->len); in tipc_mon_rcv()
512 if (!dom || (dom->len < new_dlen)) { in tipc_mon_rcv()
513 kfree(dom); in tipc_mon_rcv()
514 dom = kmalloc(new_dlen, GFP_ATOMIC); in tipc_mon_rcv()
515 peer->domain = dom; in tipc_mon_rcv()
516 if (!dom) in tipc_mon_rcv()
519 dom->len = new_dlen; in tipc_mon_rcv()
520 dom->gen = new_gen; in tipc_mon_rcv()
521 dom->member_cnt = new_member_cnt; in tipc_mon_rcv()
522 dom->up_map = be64_to_cpu(arrv_dom->up_map); in tipc_mon_rcv()
524 dom->members[i] = ntohl(arrv_dom->members[i]); in tipc_mon_rcv()
539 struct tipc_mon_domain *dom = data; in tipc_mon_prep() local
545 dom->len = 0; in tipc_mon_prep()
551 len = dom_rec_len(dom, 0); in tipc_mon_prep()
553 dom->len = htons(len); in tipc_mon_prep()
554 dom->gen = htons(gen); in tipc_mon_prep()
555 dom->ack_gen = htons(state->peer_gen); in tipc_mon_prep()
556 dom->member_cnt = 0; in tipc_mon_prep()
565 dom->ack_gen = htons(state->peer_gen); in tipc_mon_prep()
621 struct tipc_mon_domain *dom; in tipc_mon_create() local
628 dom = kzalloc(sizeof(*dom), GFP_ATOMIC); in tipc_mon_create()
629 if (!mon || !self || !dom) { in tipc_mon_create()
632 kfree(dom); in tipc_mon_create()
640 self->domain = dom; in tipc_mon_create()
715 struct tipc_mon_domain *dom = peer->domain; in __tipc_nl_add_monitor_peer() local
743 if (dom) { in __tipc_nl_add_monitor_peer()
744 if (nla_put_u32(msg->skb, TIPC_NLA_MON_PEER_DOMGEN, dom->gen)) in __tipc_nl_add_monitor_peer()
747 dom->up_map, TIPC_NLA_MON_PEER_PAD)) in __tipc_nl_add_monitor_peer()
750 dom->member_cnt * sizeof(u32), &dom->members)) in __tipc_nl_add_monitor_peer()