Searched refs:nodeid (Results 1 - 48 of 48) sorted by relevance

/linux-4.1.27/fs/dlm/
H A Dlowcomms.h20 int dlm_lowcomms_close(int nodeid);
21 void *dlm_lowcomms_get_buffer(int nodeid, int len, gfp_t allocation, char **ppc);
23 int dlm_lowcomms_connect_node(int nodeid);
24 int dlm_lowcomms_addr(int nodeid, struct sockaddr_storage *addr, int len);
H A Drcom.h17 int dlm_rcom_status(struct dlm_ls *ls, int nodeid, uint32_t status_flags);
18 int dlm_rcom_names(struct dlm_ls *ls, int nodeid, char *last_name,int last_len);
22 void dlm_receive_rcom(struct dlm_ls *ls, struct dlm_rcom *rc, int nodeid);
23 int dlm_send_ls_not_ready(int nodeid, struct dlm_rcom *rc_in);
H A Ddir.c32 * offset into the sorted list of nodeid's to give the particular nodeid.
67 int error = -ENOMEM, last_len, nodeid, result; dlm_recover_directory() local
81 if (memb->nodeid == dlm_our_nodeid()) dlm_recover_directory()
93 error = dlm_rcom_names(ls, memb->nodeid, dlm_recover_directory()
135 error = dlm_master_lookup(ls, memb->nodeid, dlm_recover_directory()
138 &nodeid, &result); dlm_recover_directory()
146 * master nodeid is different from dlm_recover_directory()
147 * memb->nodeid which says it is the master. dlm_recover_directory()
151 nodeid != memb->nodeid) { dlm_recover_directory()
154 "nodeid %d memb %d bad %u", dlm_recover_directory()
155 result, nodeid, memb->nodeid, dlm_recover_directory()
163 * master nodeid matches memb->nodeid. */ dlm_recover_directory()
166 nodeid == memb->nodeid) { dlm_recover_directory()
171 * added with memb->nodeid as the master. */ dlm_recover_directory()
237 char *outbuf, int outlen, int nodeid) dlm_copy_master_names()
251 nodeid, inlen, inbuf); dlm_copy_master_names()
265 if (dir_nodeid != nodeid) dlm_copy_master_names()
236 dlm_copy_master_names(struct dlm_ls *ls, char *inbuf, int inlen, char *outbuf, int outlen, int nodeid) dlm_copy_master_names() argument
H A Dmember.c53 if (!slot->nodeid) dlm_slots_copy_out()
55 ro->ro_nodeid = cpu_to_le32(slot->nodeid); dlm_slots_copy_out()
76 if (!array[i].nodeid) log_slots()
80 array[i].slot, array[i].nodeid); log_slots()
133 if (ro->ro_nodeid != memb->nodeid) dlm_slots_copy_in()
140 if (memb->nodeid == our_nodeid) { dlm_slots_copy_in()
153 log_error(ls, "dlm_slots_copy_in nodeid %d no slot", dlm_slots_copy_in()
154 memb->nodeid); dlm_slots_copy_in()
181 if (memb->nodeid == our_nodeid) { dlm_slots_assign()
212 log_error(ls, "nodeid %d slot changed %d %d", dlm_slots_assign()
213 memb->nodeid, memb->slot_prev, memb->slot); dlm_slots_assign()
239 array[memb->slot - 1].nodeid = memb->nodeid; dlm_slots_assign()
251 if (array[i].nodeid) dlm_slots_assign()
256 array[i].nodeid = memb->nodeid; dlm_slots_assign()
260 if (!ls->ls_slot && memb->nodeid == our_nodeid) dlm_slots_assign()
302 if (new->nodeid < memb->nodeid) list_for_each()
326 error = dlm_lowcomms_connect_node(node->nodeid); dlm_add_member()
332 memb->nodeid = node->nodeid; dlm_add_member()
340 static struct dlm_member *find_memb(struct list_head *head, int nodeid) find_memb() argument
345 if (memb->nodeid == nodeid) list_for_each_entry()
351 int dlm_is_member(struct dlm_ls *ls, int nodeid) dlm_is_member() argument
353 if (find_memb(&ls->ls_nodes, nodeid)) dlm_is_member()
358 int dlm_is_removed(struct dlm_ls *ls, int nodeid) dlm_is_removed() argument
360 if (find_memb(&ls->ls_nodes_gone, nodeid)) dlm_is_removed()
425 array[x++] = memb->nodeid; make_member_array()
442 error = dlm_rcom_status(ls, memb->nodeid, 0); ping_members()
447 log_rinfo(ls, "ping_members aborted %d last nodeid %d", ping_members()
474 error = dlm_comm_seq(memb->nodeid, &seq); dlm_lsop_recover_slot()
479 slot.nodeid = memb->nodeid; dlm_lsop_recover_slot()
506 slots[i].nodeid = memb->nodeid; dlm_lsop_recover_done()
518 int nodeid) find_config_node()
523 if (rv->nodes[i].nodeid == nodeid) find_config_node()
539 log_rinfo(ls, "prev removed member %d", memb->nodeid); dlm_recover_members()
546 node = find_config_node(rv, memb->nodeid); dlm_recover_members()
551 log_rinfo(ls, "remove member %d", memb->nodeid); dlm_recover_members()
555 memb->nodeid, memb->comm_seq, node->comm_seq); dlm_recover_members()
568 if (dlm_is_member(ls, node->nodeid)) dlm_recover_members()
571 log_rinfo(ls, "add member %d", node->nodeid); dlm_recover_members()
575 if (low == -1 || memb->nodeid < low) dlm_recover_members()
576 low = memb->nodeid; dlm_recover_members()
517 find_config_node(struct dlm_recover *rv, int nodeid) find_config_node() argument
H A Drcom.c95 static int check_rcom_config(struct dlm_ls *ls, struct dlm_rcom *rc, int nodeid) check_rcom_config() argument
100 log_error(ls, "version mismatch: %x nodeid %d: %x", check_rcom_config()
101 DLM_HEADER_MAJOR | DLM_HEADER_MINOR, nodeid, check_rcom_config()
108 log_error(ls, "config mismatch: %d,%x nodeid %d: %d,%x", check_rcom_config()
109 ls->ls_lvblen, ls->ls_exflags, nodeid, check_rcom_config()
134 * low nodeid gathers one slot value at a time from each node.
138 * other nodes gather all slot values at once from the low nodeid.
144 int dlm_rcom_status(struct dlm_ls *ls, int nodeid, uint32_t status_flags) dlm_rcom_status() argument
150 ls->ls_recover_nodeid = nodeid; dlm_rcom_status()
152 if (nodeid == dlm_our_nodeid()) { dlm_rcom_status()
158 error = create_rcom(ls, nodeid, DLM_RCOM_STATUS, dlm_rcom_status()
179 log_debug(ls, "remote node %d not ready", nodeid); dlm_rcom_status()
183 error = check_rcom_config(ls, rc, nodeid); dlm_rcom_status()
197 int nodeid = rc_in->rc_header.h_nodeid; receive_rcom_status() local
221 error = create_rcom(ls, nodeid, DLM_RCOM_STATUS_REPLY, receive_rcom_status()
271 int dlm_rcom_names(struct dlm_ls *ls, int nodeid, char *last_name, int last_len) dlm_rcom_names() argument
277 ls->ls_recover_nodeid = nodeid; dlm_rcom_names()
279 error = create_rcom(ls, nodeid, DLM_RCOM_NAMES, last_len, &rc, &mh); dlm_rcom_names()
299 int error, inlen, outlen, nodeid; receive_rcom_names() local
301 nodeid = rc_in->rc_header.h_nodeid; receive_rcom_names()
305 error = create_rcom(ls, nodeid, DLM_RCOM_NAMES_REPLY, outlen, &rc, &mh); receive_rcom_names()
312 nodeid); receive_rcom_names()
358 int error, ret_nodeid, nodeid = rc_in->rc_header.h_nodeid; receive_rcom_lookup() local
361 error = create_rcom(ls, nodeid, DLM_RCOM_LOOKUP_REPLY, 0, &rc, &mh); receive_rcom_lookup()
366 log_error(ls, "receive_rcom_lookup dump from %d", nodeid); receive_rcom_lookup()
371 error = dlm_master_lookup(ls, nodeid, rc_in->rc_buf, len, receive_rcom_lookup()
446 int error, nodeid = rc_in->rc_header.h_nodeid; receive_rcom_lock() local
450 error = create_rcom(ls, nodeid, DLM_RCOM_LOCK_REPLY, receive_rcom_lock()
468 int dlm_send_ls_not_ready(int nodeid, struct dlm_rcom *rc_in) dlm_send_ls_not_ready() argument
476 mh = dlm_lowcomms_get_buffer(nodeid, mb_len, GFP_NOFS, &mb); dlm_send_ls_not_ready()
548 void dlm_receive_rcom(struct dlm_ls *ls, struct dlm_rcom *rc, int nodeid) dlm_receive_rcom() argument
646 nodeid, dlm_receive_rcom()
654 rc->rc_type, nodeid); dlm_receive_rcom()
H A Dmidcomms.h17 int dlm_process_incoming_buffer(int nodeid, const void *base, unsigned offset,
H A Dlowcomms.c105 uint32_t nodeid; /* So we know who we are in the list */ member in struct:connection
145 int nodeid; member in struct:dlm_node_addr
173 static inline int nodeid_hash(int nodeid) nodeid_hash() argument
175 return nodeid & (CONN_HASH_SIZE-1); nodeid_hash()
178 static struct connection *__find_con(int nodeid) __find_con() argument
183 r = nodeid_hash(nodeid); __find_con()
186 if (con->nodeid == nodeid) __find_con()
196 static struct connection *__nodeid2con(int nodeid, gfp_t alloc) __nodeid2con() argument
201 con = __find_con(nodeid); __nodeid2con()
209 r = nodeid_hash(nodeid); __nodeid2con()
212 con->nodeid = nodeid; __nodeid2con()
220 if (con->nodeid) { __nodeid2con()
244 static struct connection *nodeid2con(int nodeid, gfp_t allocation) nodeid2con() argument
249 con = __nodeid2con(nodeid, allocation); nodeid2con()
275 static struct dlm_node_addr *find_node_addr(int nodeid) find_node_addr() argument
280 if (na->nodeid == nodeid) find_node_addr()
313 static int nodeid_to_addr(int nodeid, struct sockaddr_storage *sas_out, nodeid_to_addr() argument
323 na = find_node_addr(nodeid); nodeid_to_addr()
361 static int addr_to_nodeid(struct sockaddr_storage *addr, int *nodeid) addr_to_nodeid() argument
374 *nodeid = na->nodeid; addr_to_nodeid()
385 int dlm_lowcomms_addr(int nodeid, struct sockaddr_storage *addr, int len) dlm_lowcomms_addr() argument
403 na = find_node_addr(nodeid); dlm_lowcomms_addr()
405 new_node->nodeid = nodeid; dlm_lowcomms_addr()
466 int dlm_lowcomms_connect_node(int nodeid) dlm_lowcomms_connect_node() argument
474 if (nodeid == dlm_our_nodeid()) dlm_lowcomms_connect_node()
477 con = nodeid2con(nodeid, GFP_NOFS); dlm_lowcomms_connect_node()
585 if (!con->nodeid || con->sctp_assoc) sctp_init_failed_foreach()
588 log_print("Retrying SCTP association init for node %d\n", con->nodeid); sctp_init_failed_foreach()
617 int nodeid = sn_send_failed->ssf_info.sinfo_ppid; retry_failed_sctp_send() local
619 log_print("Retry sending %d bytes to node id %d", len, nodeid); retry_failed_sctp_send()
621 if (!nodeid) { retry_failed_sctp_send()
626 con = nodeid2con(nodeid, 0); retry_failed_sctp_send()
628 log_print("Could not look up con for nodeid %d\n", retry_failed_sctp_send()
629 nodeid); retry_failed_sctp_send()
633 mh = dlm_lowcomms_get_buffer(nodeid, len, GFP_NOFS, &retry_buf); retry_failed_sctp_send()
670 int nodeid; process_sctp_notification() local
708 if (addr_to_nodeid(&prim.ssp_addr, &nodeid)) { process_sctp_notification()
717 new_con = nodeid2con(nodeid, GFP_NOFS); process_sctp_notification()
731 nodeid, ret); process_sctp_notification()
744 nodeid, (int)sn->sn_assoc_change.sac_assoc_id); process_sctp_notification()
857 BUG_ON(con->nodeid == 0); receive_from_sock()
862 ret = dlm_process_incoming_buffer(con->nodeid, receive_from_sock()
912 int nodeid; tcp_accept_from_sock() local
952 if (addr_to_nodeid(&peeraddr, &nodeid)) { tcp_accept_from_sock()
962 log_print("got connection from %d", nodeid); tcp_accept_from_sock()
969 newcon = nodeid2con(nodeid, GFP_NOFS); tcp_accept_from_sock()
986 othercon->nodeid = nodeid; tcp_accept_from_sock()
1001 printk("Extra connection from node %d attempted\n", nodeid); tcp_accept_from_sock()
1083 if (nodeid_to_addr(con->nodeid, NULL, (struct sockaddr *)&rem_addr, sctp_init_assoc()
1085 log_print("no address for nodeid %d", con->nodeid); sctp_init_assoc()
1103 log_print("writequeue empty for nodeid %d", con->nodeid); sctp_init_assoc()
1130 sinfo->sinfo_ppid = cpu_to_le32(con->nodeid); sctp_init_assoc()
1137 con->nodeid, ret); sctp_init_assoc()
1162 if (con->nodeid == 0) { tcp_connect_to_sock()
1182 result = nodeid_to_addr(con->nodeid, &saddr, NULL, false); tcp_connect_to_sock()
1184 log_print("no address for nodeid %d", con->nodeid); tcp_connect_to_sock()
1206 log_print("connecting to %d", con->nodeid); tcp_connect_to_sock()
1235 log_print("connect %d try %d error %d", con->nodeid, tcp_connect_to_sock()
1490 void *dlm_lowcomms_get_buffer(int nodeid, int len, gfp_t allocation, char **ppc) dlm_lowcomms_get_buffer() argument
1496 con = nodeid2con(nodeid, allocation); dlm_lowcomms_get_buffer()
1639 int dlm_lowcomms_close(int nodeid) dlm_lowcomms_close() argument
1644 log_print("closing connection to node %d", nodeid); dlm_lowcomms_close()
1645 con = nodeid2con(nodeid, 0); dlm_lowcomms_close()
1651 log_print("canceled swork for node %d", nodeid); dlm_lowcomms_close()
1653 log_print("canceled rwork for node %d", nodeid); dlm_lowcomms_close()
1659 na = find_node_addr(nodeid); dlm_lowcomms_close()
H A Dconfig.h18 int nodeid; member in struct:dlm_config_node
48 int dlm_comm_seq(int nodeid, uint32_t *seq);
H A Dmember.h21 int dlm_is_removed(struct dlm_ls *ls, int nodeid);
22 int dlm_is_member(struct dlm_ls *ls, int nodeid);
H A Drequestqueue.h16 void dlm_add_requestqueue(struct dlm_ls *ls, int nodeid, struct dlm_message *ms);
H A Drequestqueue.c23 int nodeid; member in struct:rq_entry
34 void dlm_add_requestqueue(struct dlm_ls *ls, int nodeid, struct dlm_message *ms) dlm_add_requestqueue() argument
46 e->nodeid = nodeid; dlm_add_requestqueue()
130 static int purge_request(struct dlm_ls *ls, struct dlm_message *ms, int nodeid) purge_request() argument
138 if (dlm_is_removed(ls, nodeid)) purge_request()
164 if (purge_request(ls, ms, e->nodeid)) { dlm_purge_requestqueue()
H A Dconfig.c28 * /config/dlm/<cluster>/spaces/<space>/nodes/<node>/nodeid
30 * /config/dlm/<cluster>/comms/<comm>/nodeid
235 .ca_name = "nodeid",
284 .ca_name = "nodeid",
326 int nodeid; member in struct:dlm_comm
339 int nodeid; member in struct:dlm_node
342 int comm_seq; /* copy of cm->seq when nd->nodeid is set */
599 cm->nodeid = -1; make_comm()
610 dlm_lowcomms_close(cm->nodeid); drop_comm()
632 nd->nodeid = -1; make_node()
729 return sprintf(buf, "%d\n", cm->nodeid); comm_nodeid_read()
735 int rc = kstrtoint(buf, 0, &cm->nodeid); comm_nodeid_write()
776 rv = dlm_lowcomms_addr(cm->nodeid, addr, len); comm_addr_write()
850 return sprintf(buf, "%d\n", nd->nodeid); node_nodeid_read()
857 int rc = kstrtoint(buf, 0, &nd->nodeid); node_nodeid_write()
861 dlm_comm_seq(nd->nodeid, &seq); node_nodeid_write()
904 static struct dlm_comm *get_comm(int nodeid) get_comm() argument
918 if (cm->nodeid != nodeid) get_comm()
966 node->nodeid = nd->nodeid; dlm_config_nodes()
984 int dlm_comm_seq(int nodeid, uint32_t *seq) dlm_comm_seq() argument
986 struct dlm_comm *cm = get_comm(nodeid); dlm_comm_seq()
996 return local_comm ? local_comm->nodeid : 0; dlm_our_nodeid()
H A Dlock.h21 void dlm_receive_buffer(union dlm_packet *p, int nodeid);
32 int dlm_master_lookup(struct dlm_ls *ls, int nodeid, char *name, int len,
60 int nodeid, int pid);
H A Ddir.h22 char *outbuf, int outlen, int nodeid);
H A Dmidcomms.c58 int dlm_process_incoming_buffer(int nodeid, const void *base, dlm_process_incoming_buffer() argument
97 msglen, nodeid, len); dlm_process_incoming_buffer()
129 dlm_receive_buffer(p, nodeid); dlm_process_incoming_buffer()
H A Drecover.c66 * status. The node with the lowest nodeid polls all the others for their
69 * status flag X, then status flag X_ALL will be set on the low nodeid.
108 error = dlm_rcom_status(ls, memb->nodeid, 0); wait_status_all()
130 int error = 0, delay = 0, nodeid = ls->ls_low_nodeid; wait_status_low() local
138 error = dlm_rcom_status(ls, nodeid, status_flags); wait_status_low()
227 * master nodeid. As replies are returned from the resource directories the
396 * when setting the new nodeid.
399 static void set_lock_master(struct list_head *queue, int nodeid) set_lock_master() argument
405 lkb->lkb_nodeid = nodeid; list_for_each_entry()
419 * Propagate the new master nodeid to locks
483 * causing the master nodeid to briefly change during the aborted recovery, and
513 * has departed, get the new master nodeid from the directory. The dir will
H A Ddlm_internal.h117 int nodeid; member in struct:dlm_member
186 * lkb_nodeid: when the lkb is a local copy, nodeid is 0; when the lkb
187 * is a master copy, nodeid specifies the remote lock holder, when the
188 * lkb is a process copy, the nodeid specifies the lock master.
279 * nodeid, even when nodeid is our_nodeid.
282 * greater than zero when another nodeid.
377 uint32_t h_nodeid; /* nodeid of sender */
H A Dnetlink.c96 data->nodeid = lkb->lkb_nodeid; fill_data()
H A Dlock.c91 static void do_purge(struct dlm_ls *ls, int nodeid, int pid);
164 printk(KERN_ERR "lkb: nodeid %d id %x remid %x exflags %x flags %x " dlm_print_lkb()
174 printk(KERN_ERR "rsb: nodeid %d master %d dir %d flags %lx first %x " dlm_print_rsb()
701 /* When we are the dir nodeid, we can set the master find_rsb_dir()
867 /* our rsb is not master, but the dir nodeid has sent us a validate_master_nodeid()
885 * master nodeid. During normal operation (non recovery) this is only
1380 static int nodeid_warned(int nodeid, int num_nodes, int *warned) nodeid_warned() argument
1386 warned[i] = nodeid; nodeid_warned()
1389 if (warned[i] == nodeid) nodeid_warned()
2617 log_print("grant_pending_locks r nodeid %d", r->res_nodeid); grant_pending_locks()
2687 /* set_master(r, lkb) -- set the master nodeid of a resource
2689 The purpose of this function is to set the nodeid field in the given
2690 lkb using the nodeid field in the given rsb. If the rsb's nodeid is
2692 0. If the rsb's nodeid is _not_ known, it needs to be looked up
2695 When the rsb nodeid is being looked up remotely, the initial lkb
2701 0: nodeid is set in rsb/lkb and the caller should go ahead and use it
2734 have set res_master_nodeid when dir nodeid is local, but set_master()
2766 /* confirm_master -- confirm (or deny) an rsb's master nodeid */
3228 /* set_master: sets lkb nodeid from r */ _request_lock()
3844 int error, nodeid = ms_in->m_header.h_nodeid; send_lookup_reply() local
3846 error = create_message(r, NULL, nodeid, DLM_MSG_LOOKUP_REPLY, &ms, &mh); send_lookup_reply()
4143 node would continue returning our nodeid until our send_remove receive_request()
4402 log_error(ls, "receive_remove from %d bad nodeid %d", receive_remove()
4985 int nodeid) dlm_receive_message()
4993 ms->m_type, nodeid); dlm_receive_message()
4997 dlm_add_requestqueue(ls, nodeid, ms); dlm_receive_message()
5018 void dlm_receive_buffer(union dlm_packet *p, int nodeid) dlm_receive_buffer() argument
5034 log_print("invalid h_cmd %d from %u", hd->h_cmd, nodeid); dlm_receive_buffer()
5038 if (hd->h_nodeid != nodeid) { dlm_receive_buffer()
5040 hd->h_nodeid, nodeid, hd->h_lockspace); dlm_receive_buffer()
5049 hd->h_lockspace, nodeid, hd->h_cmd, type); dlm_receive_buffer()
5053 dlm_send_ls_not_ready(nodeid, &p->rcom); dlm_receive_buffer()
5062 dlm_receive_message(ls, &p->message, nodeid); dlm_receive_buffer()
5064 dlm_receive_rcom(ls, &p->rcom, nodeid); dlm_receive_buffer()
5436 /* cache one removed nodeid to optimize the common dlm_recover_purge()
5441 nodeid_gone = memb->nodeid; dlm_recover_purge()
5544 static struct dlm_lkb *search_remid_list(struct list_head *head, int nodeid, search_remid_list() argument
5550 if (lkb->lkb_nodeid == nodeid && lkb->lkb_remid == remid) list_for_each_entry()
5556 static struct dlm_lkb *search_remid(struct dlm_rsb *r, int nodeid, search_remid() argument
5561 lkb = search_remid_list(&r->res_grantqueue, nodeid, remid); search_remid()
5564 lkb = search_remid_list(&r->res_convertqueue, nodeid, remid); search_remid()
5567 lkb = search_remid_list(&r->res_waitqueue, nodeid, remid); search_remid()
5619 to check if the rsb already has an lkb with the given remote nodeid/lkid.
6256 static void do_purge(struct dlm_ls *ls, int nodeid, int pid) do_purge() argument
6271 static int send_purge(struct dlm_ls *ls, int nodeid, int pid) send_purge() argument
6277 error = _create_message(ls, sizeof(struct dlm_message), nodeid, send_purge()
6281 ms->m_nodeid = nodeid; send_purge()
6288 int nodeid, int pid) dlm_user_purge()
6292 if (nodeid && (nodeid != dlm_our_nodeid())) { dlm_user_purge()
6293 error = send_purge(ls, nodeid, pid); dlm_user_purge()
6299 do_purge(ls, nodeid, pid); dlm_user_purge()
4984 dlm_receive_message(struct dlm_ls *ls, struct dlm_message *ms, int nodeid) dlm_receive_message() argument
6287 dlm_user_purge(struct dlm_ls *ls, struct dlm_user_proc *proc, int nodeid, int pid) dlm_user_purge() argument
H A Ddebug_fs.c181 /* id nodeid remid pid xid exflags flags sts grmode rqmode time_us print_format2_lock()
393 seq_puts(seq, "id nodeid remid pid xid exflags flags sts grmode rqmode time_ms r_nodeid r_len r_name\n"); table_seq_show()
H A Drecoverd.c141 * Get new master nodeid's for rsb's that were mastered on ls_recover()
H A Duser.c103 kb->i.purge.nodeid = kb32->i.purge.nodeid; compat_input()
389 error = dlm_user_purge(ls, proc, params->nodeid, params->pid); device_user_purge()
/linux-4.1.27/arch/x86/mm/
H A Damdtopology.c78 u32 nodeid, reg; amd_numa_init() local
104 nodeids[i] = nodeid = limit & 7; amd_numa_init()
110 if (nodeid >= numnodes) { amd_numa_init()
111 pr_info("Ignoring excess node %d (%Lx:%Lx)\n", nodeid, amd_numa_init()
123 nodeid, (base >> 8) & 3, (limit >> 8) & 3); amd_numa_init()
126 if (node_isset(nodeid, numa_nodes_parsed)) { amd_numa_init()
128 nodeid); amd_numa_init()
149 pr_err("Empty node %d\n", nodeid); amd_numa_init()
154 nodeid, base, limit); amd_numa_init()
166 nodeid, base, limit); amd_numa_init()
169 numa_add_memblk(nodeid, base, limit); amd_numa_init()
170 node_set(nodeid, numa_nodes_parsed); amd_numa_init()
/linux-4.1.27/drivers/char/
H A Dmmtimer.c262 int nodeid = n->timer->it.mmtimer.node; mmtimer_add_list() local
264 struct rb_node **link = &timers[nodeid].timer_head.rb_node; mmtimer_add_list()
286 rb_insert_color(&n->list, &timers[nodeid].timer_head); mmtimer_add_list()
288 if (!timers[nodeid].next || expires < rb_entry(timers[nodeid].next, mmtimer_add_list()
290 timers[nodeid].next = &n->list; mmtimer_add_list()
297 static void mmtimer_set_next_timer(int nodeid) mmtimer_set_next_timer() argument
299 struct mmtimer_node *n = &timers[nodeid]; mmtimer_set_next_timer()
556 int nodeid = data; mmtimer_tasklet() local
557 struct mmtimer_node *mn = &timers[nodeid]; mmtimer_tasklet()
591 mmtimer_set_next_timer(nodeid); mmtimer_tasklet()
612 cnodeid_t nodeid = timr->it.mmtimer.node; sgi_timer_del() local
615 spin_lock_irqsave(&timers[nodeid].lock, irqflags); sgi_timer_del()
618 struct rb_node *n = timers[nodeid].timer_head.rb_node; sgi_timer_del()
637 spin_unlock_irqrestore(&timers[nodeid].lock, irqflags); sgi_timer_del()
641 if (timers[nodeid].next == n) { sgi_timer_del()
642 timers[nodeid].next = rb_next(n); sgi_timer_del()
646 rb_erase(n, &timers[nodeid].timer_head); sgi_timer_del()
650 mmtimer_disable_int(cnodeid_to_nasid(nodeid), sgi_timer_del()
652 mmtimer_set_next_timer(nodeid); sgi_timer_del()
655 spin_unlock_irqrestore(&timers[nodeid].lock, irqflags); sgi_timer_del()
682 cnodeid_t nodeid; sgi_timer_set() local
729 nodeid = cpu_to_node(smp_processor_id()); sgi_timer_set()
732 spin_lock_irqsave(&timers[nodeid].lock, irqflags); sgi_timer_set()
738 timr->it.mmtimer.node = nodeid; sgi_timer_set()
742 n = timers[nodeid].next; sgi_timer_set()
747 if (timers[nodeid].next == n) { sgi_timer_set()
749 spin_unlock_irqrestore(&timers[nodeid].lock, irqflags); sgi_timer_set()
756 mmtimer_disable_int(cnodeid_to_nasid(nodeid), COMPARATOR); sgi_timer_set()
758 mmtimer_set_next_timer(nodeid); sgi_timer_set()
761 spin_unlock_irqrestore(&timers[nodeid].lock, irqflags); sgi_timer_set()
/linux-4.1.27/include/uapi/linux/
H A Ddlm_netlink.h25 int nodeid; member in struct:dlm_lock_data
H A Ddlm_plock.h35 __s32 nodeid; member in struct:dlm_plock_info
H A Ddlm_device.h57 __u32 nodeid; member in struct:dlm_purge_params
H A Dfuse.h382 uint64_t nodeid; /* Inode ID */ member in struct:fuse_entry_out
383 uint64_t generation; /* Inode generation: nodeid:gen must
397 uint64_t nodeid; member in struct:fuse_forget_one
677 uint64_t nodeid; member in struct:fuse_in_header
734 uint64_t nodeid; member in struct:fuse_notify_store_out
742 uint64_t nodeid; member in struct:fuse_notify_retrieve_out
/linux-4.1.27/fs/fuse/
H A Dinode.c90 fi->nodeid = 0; fuse_alloc_inode()
131 fuse_queue_forget(fc, fi->forget, fi->nodeid, fi->nlookup); fuse_evict_inode()
279 u64 nodeid = *(u64 *) _nodeidp; fuse_inode_eq() local
280 if (get_node_id(inode) == nodeid) fuse_inode_eq()
288 u64 nodeid = *(u64 *) _nodeidp; fuse_inode_set() local
289 get_fuse_inode(inode)->nodeid = nodeid; fuse_inode_set()
293 struct inode *fuse_iget(struct super_block *sb, u64 nodeid, fuse_iget() argument
302 inode = iget5_locked(sb, nodeid, fuse_inode_eq, fuse_inode_set, &nodeid); fuse_iget()
329 int fuse_reverse_inval_inode(struct super_block *sb, u64 nodeid, fuse_reverse_inval_inode() argument
336 inode = ilookup5(sb, nodeid, fuse_inode_eq, &nodeid); fuse_reverse_inval_inode()
424 args.in.h.nodeid = get_node_id(d_inode(dentry)); fuse_statfs()
628 u64 nodeid; member in struct:fuse_inode_handle
640 if (handle->nodeid == 0) fuse_get_dentry()
643 inode = ilookup5(sb, handle->nodeid, fuse_inode_eq, &handle->nodeid); fuse_get_dentry()
653 err = fuse_lookup_name(sb, handle->nodeid, &name, &outarg, fuse_get_dentry()
662 if (get_node_id(inode) != handle->nodeid) fuse_get_dentry()
685 u64 nodeid; fuse_encode_fh() local
693 nodeid = get_fuse_inode(inode)->nodeid; fuse_encode_fh()
696 fh[0] = (u32)(nodeid >> 32); fuse_encode_fh()
697 fh[1] = (u32)(nodeid & 0xffffffff); fuse_encode_fh()
701 nodeid = get_fuse_inode(parent)->nodeid; fuse_encode_fh()
704 fh[3] = (u32)(nodeid >> 32); fuse_encode_fh()
705 fh[4] = (u32)(nodeid & 0xffffffff); fuse_encode_fh()
721 handle.nodeid = (u64) fid->raw[0] << 32; fuse_fh_to_dentry()
722 handle.nodeid |= (u64) fid->raw[1]; fuse_fh_to_dentry()
735 parent.nodeid = (u64) fid->raw[3] << 32; fuse_fh_to_parent()
736 parent.nodeid |= (u64) fid->raw[4]; fuse_fh_to_parent()
H A Ddir.c149 u64 nodeid, struct qstr *name, fuse_lookup_init()
154 args->in.h.nodeid = nodeid; fuse_lookup_init()
227 /* Zero nodeid is same as -ENOENT */ fuse_dentry_revalidate()
228 if (!ret && !outarg.nodeid) fuse_dentry_revalidate()
232 if (outarg.nodeid != get_node_id(inode)) { fuse_dentry_revalidate()
233 fuse_queue_forget(fc, forget, outarg.nodeid, 1); fuse_dentry_revalidate()
270 static int invalid_nodeid(u64 nodeid) invalid_nodeid() argument
272 return !nodeid || nodeid == FUSE_ROOT_ID; invalid_nodeid()
285 int fuse_lookup_name(struct super_block *sb, u64 nodeid, struct qstr *name, fuse_lookup_name() argument
307 fuse_lookup_init(fc, &args, nodeid, name, outarg); fuse_lookup_name()
309 /* Zero nodeid is same as -ENOENT, but with valid timeout */ fuse_lookup_name()
310 if (err || !outarg->nodeid) fuse_lookup_name()
314 if (!outarg->nodeid) fuse_lookup_name()
319 *inode = fuse_iget(sb, outarg->nodeid, outarg->generation, fuse_lookup_name()
324 fuse_queue_forget(fc, forget, outarg->nodeid, 1); fuse_lookup_name()
420 args.in.h.nodeid = get_node_id(dir); fuse_create_open()
436 if (!S_ISREG(outentry.attr.mode) || invalid_nodeid(outentry.nodeid)) fuse_create_open()
440 ff->nodeid = outentry.nodeid; fuse_create_open()
442 inode = fuse_iget(dir->i_sb, outentry.nodeid, outentry.generation, fuse_create_open()
447 fuse_queue_forget(fc, forget, outentry.nodeid, 1); fuse_create_open()
533 args->in.h.nodeid = get_node_id(dir); create_new_entry()
542 if (invalid_nodeid(outarg.nodeid)) create_new_entry()
548 inode = fuse_iget(dir->i_sb, outarg.nodeid, outarg.generation, create_new_entry()
551 fuse_queue_forget(fc, forget, outarg.nodeid, 1); create_new_entry()
650 args.in.h.nodeid = get_node_id(dir); fuse_unlink()
686 args.in.h.nodeid = get_node_id(dir); fuse_rmdir()
713 args.in.h.nodeid = get_node_id(olddir); fuse_rename_common()
886 args.in.h.nodeid = get_node_id(inode); fuse_do_getattr()
1047 args.in.h.nodeid = get_node_id(inode); fuse_access()
1176 if (!o->nodeid) { fuse_direntplus_link()
1178 * Unlike in the case of fuse_lookup, zero nodeid does not mean fuse_direntplus_link()
1198 if (invalid_nodeid(o->nodeid)) fuse_direntplus_link()
1211 } else if (get_node_id(inode) != o->nodeid || fuse_direntplus_link()
1242 inode = fuse_iget(dir->i_sb, o->nodeid, o->generation, fuse_direntplus_link()
1306 fuse_force_forget(file, direntplus->entry_out.nodeid); parse_dirplusfile()
1381 args.in.h.nodeid = get_node_id(inode); read_link()
1558 args->in.h.nodeid = get_node_id(inode); fuse_setattr_fill()
1754 args.in.h.nodeid = get_node_id(inode); fuse_setxattr()
1790 args.in.h.nodeid = get_node_id(inode); fuse_getxattr()
1834 args.in.h.nodeid = get_node_id(inode); fuse_listxattr()
1869 args.in.h.nodeid = get_node_id(inode); fuse_removexattr()
148 fuse_lookup_init(struct fuse_conn *fc, struct fuse_args *args, u64 nodeid, struct qstr *name, struct fuse_entry_out *outarg) fuse_lookup_init() argument
H A Dfuse_i.h74 u64 nodeid; member in struct:fuse_inode
142 u64 nodeid; member in struct:fuse_file
230 uint64_t nodeid; member in struct:fuse_args::__anon10945::__anon10946
645 return get_fuse_inode(inode)->nodeid; get_node_id()
654 * Inode to nodeid comparison.
661 struct inode *fuse_iget(struct super_block *sb, u64 nodeid,
665 int fuse_lookup_name(struct super_block *sb, u64 nodeid, struct qstr *name,
672 u64 nodeid, u64 nlookup);
677 void fuse_force_forget(struct file *file, u64 nodeid);
873 int fuse_reverse_inval_inode(struct super_block *sb, u64 nodeid,
889 int fuse_do_open(struct fuse_conn *fc, u64 nodeid, struct file *file,
H A Ddev.c337 u64 nodeid, u64 nlookup) fuse_queue_forget()
339 forget->forget_one.nodeid = nodeid; fuse_queue_forget()
570 req->in.h.nodeid = args->in.h.nodeid; fuse_simple_request()
653 void fuse_force_forget(struct file *file, u64 nodeid) fuse_force_forget() argument
664 req->in.h.nodeid = nodeid; fuse_force_forget()
1172 .nodeid = forget->forget_one.nodeid,
1610 u64 nodeid; fuse_notify_store() local
1630 nodeid = outarg.nodeid; fuse_notify_store()
1638 inode = ilookup5(fc->sb, nodeid, fuse_inode_eq, &nodeid); fuse_notify_store()
1725 req->in.h.nodeid = outarg->nodeid; fuse_retrieve()
1784 u64 nodeid = outarg.nodeid; fuse_notify_retrieve() local
1786 inode = ilookup5(fc->sb, nodeid, fuse_inode_eq, &nodeid); fuse_notify_retrieve()
336 fuse_queue_forget(struct fuse_conn *fc, struct fuse_forget_link *forget, u64 nodeid, u64 nlookup) fuse_queue_forget() argument
H A Dfile.c23 static int fuse_send_open(struct fuse_conn *fc, u64 nodeid, struct file *file, fuse_send_open() argument
34 args.in.h.nodeid = nodeid; fuse_send_open()
116 int fuse_do_open(struct fuse_conn *fc, u64 nodeid, struct file *file, fuse_do_open() argument
132 err = fuse_send_open(fc, nodeid, file, opcode, &outarg); fuse_do_open()
148 ff->nodeid = nodeid; fuse_do_open()
240 req->in.h.nodeid = ff->nodeid; fuse_prepare_release()
425 req->in.h.nodeid = get_node_id(inode); fuse_flush()
476 args.in.h.nodeid = get_node_id(inode); fuse_fsync_common()
510 req->in.h.nodeid = ff->nodeid; fuse_read_fill()
935 req->in.h.nodeid = ff->nodeid; fuse_write_fill()
2114 args->in.h.nodeid = get_node_id(inode); fuse_lk_fill()
2227 args.in.h.nodeid = get_node_id(inode); fuse_bmap()
2527 req->in.h.nodeid = ff->nodeid; fuse_do_ioctl()
2721 args.in.h.nodeid = ff->nodeid; fuse_file_poll()
2921 args.in.h.nodeid = ff->nodeid; fuse_file_fallocate()
/linux-4.1.27/drivers/net/appletalk/
H A Dcops.c173 int nodeid; /* Set to 1 once have nodeid. */ member in struct:cops_local
187 static int cops_nodeid (struct net_device *dev, int nodeid);
455 * the nodeid, if it is reset it will lose it all. cops_jumpstart()
461 * If atalkd already gave us a nodeid we will use that cops_jumpstart()
462 * one again, else we wait for atalkd to give us a nodeid cops_jumpstart()
464 * our nodeid while we are resetting. cops_jumpstart()
466 if(lp->nodeid == 1) cops_jumpstart()
599 * any nodeid 1-254. The card will try and get that exact
600 * address else we can specify 0 as the nodeid and the card
601 * will autoprobe for a nodeid.
603 static int cops_nodeid (struct net_device *dev, int nodeid) cops_nodeid() argument
622 outb(nodeid, ioaddr); /* Suggest node address. */ cops_nodeid()
635 /* Not sure what Tangent does if nodeid picked is used. */ cops_nodeid()
636 if(nodeid == 0) /* Seed. */ cops_nodeid()
637 nodeid = jiffies&0xFF; /* Get a random try */ cops_nodeid()
641 outb(nodeid, ioaddr); /* LAP address hint. */ cops_nodeid()
645 lp->node_acquire=0; /* Set nodeid holder to 0. */ cops_nodeid()
646 while(lp->node_acquire==0) /* Get *True* nodeid finally. */ cops_nodeid()
653 cops_rx(dev); /* Grab the nodeid put in lp->node_acquire. */ cops_nodeid()
658 cops_rx(dev); /* Grab the nodeid put in lp->node_acquire. */ cops_nodeid()
667 lp->nodeid=1; /* Set got nodeid to 1. */ cops_nodeid()
822 /* Set nodeid and then get out. */ cops_rx()
944 /* Get and set the nodeid and network # atalkd wants. */ cops_ioctl()
/linux-4.1.27/mm/
H A Dsparse.c348 unsigned long usemap_count, int nodeid) sparse_early_usemaps_alloc_node()
355 usemap = sparse_early_usemaps_alloc_pgdat_section(NODE_DATA(nodeid), sparse_early_usemaps_alloc_node()
367 check_usemap_section_nr(nodeid, usemap_map[pnum]); sparse_early_usemaps_alloc_node()
390 unsigned long map_count, int nodeid) sparse_mem_maps_populate_node()
396 map = alloc_remap(nodeid, size * map_count); sparse_mem_maps_populate_node()
410 BOOTMEM_ALLOC_ACCESSIBLE, nodeid); sparse_mem_maps_populate_node()
427 map_map[pnum] = sparse_mem_map_populate(pnum, nodeid); sparse_mem_maps_populate_node()
442 unsigned long map_count, int nodeid) sparse_early_mem_maps_alloc_node()
446 map_count, nodeid); sparse_early_mem_maps_alloc_node()
496 int nodeid; alloc_usemap_and_memmap() local
501 nodeid = sparse_early_nid(ms); alloc_usemap_and_memmap()
502 if (nodeid == nodeid_begin) { alloc_usemap_and_memmap()
510 nodeid_begin = nodeid; alloc_usemap_and_memmap()
345 sparse_early_usemaps_alloc_node(void *data, unsigned long pnum_begin, unsigned long pnum_end, unsigned long usemap_count, int nodeid) sparse_early_usemaps_alloc_node() argument
387 sparse_mem_maps_populate_node(struct page **map_map, unsigned long pnum_begin, unsigned long pnum_end, unsigned long map_count, int nodeid) sparse_mem_maps_populate_node() argument
439 sparse_early_mem_maps_alloc_node(void *data, unsigned long pnum_begin, unsigned long pnum_end, unsigned long map_count, int nodeid) sparse_early_mem_maps_alloc_node() argument
H A Dslab.c270 #define MAKE_LIST(cachep, listp, slab, nodeid) \
273 list_splice(&get_node(cachep, nodeid)->slab, listp); \
276 #define MAKE_ALL_LISTS(cachep, ptr, nodeid) \
278 MAKE_LIST((cachep), (&(ptr)->slabs_full), slabs_full, nodeid); \
279 MAKE_LIST((cachep), (&(ptr)->slabs_partial), slabs_partial, nodeid); \
280 MAKE_LIST((cachep), (&(ptr)->slabs_free), slabs_free, nodeid); \
855 gfp_t flags, int nodeid) ____cache_alloc_node()
1359 int nodeid) init_list()
1363 ptr = kmalloc_node(sizeof(struct kmem_cache_node), GFP_NOWAIT, nodeid); init_list()
1372 MAKE_ALL_LISTS(cachep, ptr, nodeid); init_list()
1373 cachep->node[nodeid] = ptr; init_list()
1528 slab_out_of_memory(struct kmem_cache *cachep, gfp_t gfpflags, int nodeid) slab_out_of_memory() argument
1543 nodeid, gfpflags); slab_out_of_memory()
1585 int nodeid) kmem_getpages()
1597 page = alloc_pages_exact_node(nodeid, flags | __GFP_NOTRACK, cachep->gfporder); kmem_getpages()
1600 slab_out_of_memory(cachep, flags, nodeid); kmem_getpages()
1620 kmemcheck_alloc_shadow(page, cachep->gfporder, flags, nodeid); kmem_getpages()
2461 gfp_t local_flags, int nodeid) alloc_slabmgmt()
2469 local_flags, nodeid); alloc_slabmgmt()
2550 int nodeid) slab_get_obj()
2557 WARN_ON(page_to_nid(virt_to_page(objp)) != nodeid); slab_get_obj()
2564 void *objp, int nodeid) slab_put_obj()
2571 WARN_ON(page_to_nid(virt_to_page(objp)) != nodeid); slab_put_obj()
2603 gfp_t flags, int nodeid, struct page *page) cache_grow()
2622 n = get_node(cachep, nodeid); cache_grow()
2647 * 'nodeid'. cache_grow()
2650 page = kmem_getpages(cachep, local_flags, nodeid); cache_grow()
2656 local_flags & ~GFP_CONSTRAINT_MASK, nodeid); cache_grow()
3092 * A interface to enable slab creation on nodeid
3095 int nodeid) ____cache_alloc_node()
3103 VM_BUG_ON(nodeid < 0 || nodeid >= MAX_NUMNODES); ____cache_alloc_node()
3104 n = get_node(cachep, nodeid); ____cache_alloc_node()
3119 check_spinlock_acquired_node(cachep, nodeid); ____cache_alloc_node()
3127 obj = slab_get_obj(cachep, page, nodeid); ____cache_alloc_node()
3142 x = cache_grow(cachep, gfp_exact_node(flags), nodeid, NULL); ____cache_alloc_node()
3153 slab_alloc_node(struct kmem_cache *cachep, gfp_t flags, int nodeid, slab_alloc_node() argument
3172 if (nodeid == NUMA_NO_NODE) slab_alloc_node()
3173 nodeid = slab_node; slab_alloc_node()
3175 if (unlikely(!get_node(cachep, nodeid))) { slab_alloc_node()
3181 if (nodeid == slab_node) { slab_alloc_node()
3193 ptr = ____cache_alloc_node(cachep, flags, nodeid); slab_alloc_node()
3389 * is per page memory reference) to get nodeid. Instead use a global __cache_free()
3445 * @nodeid: node number of the target node.
3452 void *kmem_cache_alloc_node(struct kmem_cache *cachep, gfp_t flags, int nodeid) kmem_cache_alloc_node() argument
3454 void *ret = slab_alloc_node(cachep, flags, nodeid, _RET_IP_); kmem_cache_alloc_node()
3458 flags, nodeid); kmem_cache_alloc_node()
3467 int nodeid, kmem_cache_alloc_node_trace()
3472 ret = slab_alloc_node(cachep, flags, nodeid, _RET_IP_); kmem_cache_alloc_node_trace()
3476 flags, nodeid); kmem_cache_alloc_node_trace()
854 ____cache_alloc_node(struct kmem_cache *cachep, gfp_t flags, int nodeid) ____cache_alloc_node() argument
1358 init_list(struct kmem_cache *cachep, struct kmem_cache_node *list, int nodeid) init_list() argument
1584 kmem_getpages(struct kmem_cache *cachep, gfp_t flags, int nodeid) kmem_getpages() argument
2459 alloc_slabmgmt(struct kmem_cache *cachep, struct page *page, int colour_off, gfp_t local_flags, int nodeid) alloc_slabmgmt() argument
2549 slab_get_obj(struct kmem_cache *cachep, struct page *page, int nodeid) slab_get_obj() argument
2563 slab_put_obj(struct kmem_cache *cachep, struct page *page, void *objp, int nodeid) slab_put_obj() argument
2602 cache_grow(struct kmem_cache *cachep, gfp_t flags, int nodeid, struct page *page) cache_grow() argument
3094 ____cache_alloc_node(struct kmem_cache *cachep, gfp_t flags, int nodeid) ____cache_alloc_node() argument
3465 kmem_cache_alloc_node_trace(struct kmem_cache *cachep, gfp_t flags, int nodeid, size_t size) kmem_cache_alloc_node_trace() argument
H A Dsparse-vmemmap.c198 unsigned long map_count, int nodeid) sparse_mem_maps_populate_node()
205 vmemmap_buf_start = __earlyonly_bootmem_alloc(nodeid, size * map_count, sparse_mem_maps_populate_node()
219 map_map[pnum] = sparse_mem_map_populate(pnum, nodeid); sparse_mem_maps_populate_node()
195 sparse_mem_maps_populate_node(struct page **map_map, unsigned long pnum_begin, unsigned long pnum_end, unsigned long map_count, int nodeid) sparse_mem_maps_populate_node() argument
/linux-4.1.27/arch/x86/include/asm/
H A Dnuma.h33 extern int __init numa_add_memblk(int nodeid, u64 start, u64 end);
/linux-4.1.27/arch/x86/include/asm/numachip/
H A Dnumachip_csr.h37 * Local CSR space starts in global CSR space with "nodeid" = 0xfff0, however
/linux-4.1.27/arch/ia64/sn/kernel/
H A Dhuberror.c181 * Parameters : cnode, the compact nodeid.
203 * Parameters : cnode, the compact nodeid.
/linux-4.1.27/arch/mips/sgi-ip27/
H A Dip27-smp.c103 * Initialize the arrays to invalid nodeid (-1) cpu_node_probe()
/linux-4.1.27/include/linux/
H A Ddlm.h20 int nodeid; /* 1 to MAX_INT */ member in struct:dlm_slot
H A Dmm.h2149 int nodeid);
/linux-4.1.27/arch/powerpc/platforms/cell/
H A Dspider-pic.c316 /* Hook up the cascade interrupt to the iic and nodeid */ spider_init_one()
/linux-4.1.27/fs/ocfs2/
H A Dstack_user.c959 slot->nodeid, slot->slot); user_recover_slot()
960 conn->cc_recovery_handler(slot->nodeid, conn->cc_recovery_data); user_recover_slot()
974 atomic_set(&lc->oc_this_node, slots[i].nodeid); user_recover_done()
/linux-4.1.27/arch/x86/kernel/cpu/
H A Dperf_event_intel_uncore_snbep.c1090 int i, bus, nodeid; snbep_pci2phy_map_init() local
1104 nodeid = config; snbep_pci2phy_map_init()
1114 if (nodeid == ((config >> (3 * i)) & 0x7)) { snbep_pci2phy_map_init()
/linux-4.1.27/drivers/misc/mic/host/
H A Dmic_smpt.c404 "nodeid %d SMPT ref count %lld map %lld unmap %lld\n", mic_smpt_uninit()
/linux-4.1.27/drivers/md/
H A Dmd-cluster.c287 slot->nodeid, slot->slot, recover_slot()

Completed in 983 milliseconds