Lines Matching refs:nodeid
151 int nodeid; member
265 static struct midcomms_node *__find_node(int nodeid, int r) in __find_node() argument
270 if (node->nodeid == nodeid) in __find_node()
297 pr_debug("flush midcomms send queue of node %d\n", node->nodeid); in dlm_send_queue_flush()
310 pr_debug("reset node %d\n", node->nodeid); in midcomms_node_reset()
322 static struct midcomms_node *nodeid2node(int nodeid, gfp_t alloc) in nodeid2node() argument
325 int r = nodeid_hash(nodeid); in nodeid2node()
327 node = __find_node(nodeid, r); in nodeid2node()
335 node->nodeid = nodeid; in nodeid2node()
348 tmp = __find_node(nodeid, r); in nodeid2node()
358 node->debugfs = dlm_create_debug_comms_file(nodeid, node); in nodeid2node()
362 static int dlm_send_ack(int nodeid, uint32_t seq) in dlm_send_ack() argument
369 msg = dlm_lowcomms_new_msg(nodeid, mb_len, GFP_NOFS, &ppc, in dlm_send_ack()
397 mh = dlm_midcomms_get_mhandle(node->nodeid, mb_len, GFP_NOFS, &ppc); in dlm_send_fin()
412 pr_debug("sending fin msg to node %d\n", node->nodeid); in dlm_send_fin()
451 node->nodeid, dlm_state_str(node->state)); in dlm_pas_fin_ack_rcv()
482 dlm_send_ack(node->nodeid, node->seq_next); in dlm_midcomms_receive_buffer()
486 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_receive_buffer()
492 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_receive_buffer()
500 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_receive_buffer()
508 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_receive_buffer()
513 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_receive_buffer()
532 dlm_receive_buffer(p, node->nodeid); in dlm_midcomms_receive_buffer()
541 dlm_send_ack(node->nodeid, node->seq_next); in dlm_midcomms_receive_buffer()
544 seq, node->seq_next, node->nodeid); in dlm_midcomms_receive_buffer()
555 dlm_midcomms_recv_node_lookup(int nodeid, const union dlm_packet *p, in dlm_midcomms_recv_node_lookup() argument
566 msglen, nodeid); in dlm_midcomms_recv_node_lookup()
578 node = nodeid2node(nodeid, 0); in dlm_midcomms_recv_node_lookup()
583 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_recv_node_lookup()
589 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_recv_node_lookup()
599 node->nodeid); in dlm_midcomms_recv_node_lookup()
619 node = nodeid2node(nodeid, allocation); in dlm_midcomms_recv_node_lookup()
625 msglen, nodeid); in dlm_midcomms_recv_node_lookup()
630 p->opts.o_nextcmd, nodeid); in dlm_midcomms_recv_node_lookup()
634 p->header.h_cmd, nodeid); in dlm_midcomms_recv_node_lookup()
654 node->nodeid); in dlm_midcomms_version_check_3_2()
660 DLM_VERSION_3_2, node->nodeid, node->version); in dlm_midcomms_version_check_3_2()
667 static int dlm_opts_check_msglen(union dlm_packet *p, uint16_t msglen, int nodeid) in dlm_opts_check_msglen() argument
686 len, nodeid); in dlm_opts_check_msglen()
694 msglen, nodeid); in dlm_opts_check_msglen()
702 len, nodeid); in dlm_opts_check_msglen()
709 p->opts.o_nextcmd, nodeid); in dlm_opts_check_msglen()
716 static void dlm_midcomms_receive_buffer_3_2(union dlm_packet *p, int nodeid) in dlm_midcomms_receive_buffer_3_2() argument
724 node = dlm_midcomms_recv_node_lookup(nodeid, p, msglen, in dlm_midcomms_receive_buffer_3_2()
748 le32_to_cpu(p->rcom.rc_type), nodeid); in dlm_midcomms_receive_buffer_3_2()
753 dlm_receive_buffer(p, nodeid); in dlm_midcomms_receive_buffer_3_2()
758 ret = dlm_opts_check_msglen(p, msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
761 msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
774 msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
782 msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
790 msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
797 msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
809 p->header.h_cmd, nodeid); in dlm_midcomms_receive_buffer_3_2()
823 node->nodeid); in dlm_midcomms_version_check_3_1()
829 DLM_VERSION_3_1, node->nodeid, node->version); in dlm_midcomms_version_check_3_1()
836 static void dlm_midcomms_receive_buffer_3_1(union dlm_packet *p, int nodeid) in dlm_midcomms_receive_buffer_3_1() argument
843 node = dlm_midcomms_recv_node_lookup(nodeid, p, msglen, in dlm_midcomms_receive_buffer_3_1()
858 msglen, nodeid); in dlm_midcomms_receive_buffer_3_1()
865 p->header.h_cmd, nodeid); in dlm_midcomms_receive_buffer_3_1()
869 dlm_receive_buffer(p, nodeid); in dlm_midcomms_receive_buffer_3_1()
877 int dlm_process_incoming_buffer(int nodeid, unsigned char *buf, int len) in dlm_process_incoming_buffer() argument
902 msglen, nodeid); in dlm_process_incoming_buffer()
914 dlm_midcomms_receive_buffer_3_1((union dlm_packet *)ptr, nodeid); in dlm_process_incoming_buffer()
917 dlm_midcomms_receive_buffer_3_2((union dlm_packet *)ptr, nodeid); in dlm_process_incoming_buffer()
921 le32_to_cpu(hd->h_version), nodeid); in dlm_process_incoming_buffer()
933 void dlm_midcomms_receive_done(int nodeid) in dlm_midcomms_receive_done() argument
939 node = nodeid2node(nodeid, 0); in dlm_midcomms_receive_done()
966 dlm_send_ack(node->nodeid, node->seq_next); in dlm_midcomms_receive_done()
976 void dlm_midcomms_unack_msg_resend(int nodeid) in dlm_midcomms_unack_msg_resend() argument
983 node = nodeid2node(nodeid, 0); in dlm_midcomms_unack_msg_resend()
1006 mh->seq, node->nodeid); in dlm_midcomms_unack_msg_resend()
1034 static struct dlm_msg *dlm_midcomms_get_msg_3_2(struct dlm_mhandle *mh, int nodeid, in dlm_midcomms_get_msg_3_2() argument
1040 msg = dlm_lowcomms_new_msg(nodeid, len + DLM_MIDCOMMS_OPT_LEN, in dlm_midcomms_get_msg_3_2()
1056 struct dlm_mhandle *dlm_midcomms_get_mhandle(int nodeid, int len, in dlm_midcomms_get_mhandle() argument
1065 node = nodeid2node(nodeid, 0); in dlm_midcomms_get_mhandle()
1083 msg = dlm_lowcomms_new_msg(nodeid, len, allocation, ppc, in dlm_midcomms_get_mhandle()
1092 msg = dlm_midcomms_get_msg_3_2(mh, nodeid, len, allocation, in dlm_midcomms_get_mhandle()
1164 node->nodeid, dlm_state_str(node->state)); in dlm_act_fin_ack_rcv()
1170 node->nodeid, dlm_state_str(node->state)); in dlm_act_fin_ack_rcv()
1175 node->nodeid, dlm_state_str(node->state)); in dlm_act_fin_ack_rcv()
1192 void dlm_midcomms_add_member(int nodeid) in dlm_midcomms_add_member() argument
1197 if (nodeid == dlm_our_nodeid()) in dlm_midcomms_add_member()
1201 node = nodeid2node(nodeid, GFP_NOFS); in dlm_midcomms_add_member()
1210 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_add_member()
1217 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_add_member()
1225 node->nodeid); in dlm_midcomms_add_member()
1240 void dlm_midcomms_remove_member(int nodeid) in dlm_midcomms_remove_member() argument
1245 if (nodeid == dlm_our_nodeid()) in dlm_midcomms_remove_member()
1249 node = nodeid2node(nodeid, 0); in dlm_midcomms_remove_member()
1265 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_remove_member()
1275 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_remove_member()
1322 node->nodeid, dlm_state_str(node->state)); in midcomms_shutdown()
1327 node->nodeid, dlm_state_str(node->state)); in midcomms_shutdown()
1355 node->nodeid, dlm_state_str(node->state)); in midcomms_shutdown()
1361 node->nodeid, dlm_state_str(node->state)); in midcomms_shutdown()
1390 int dlm_midcomms_close(int nodeid) in dlm_midcomms_close() argument
1395 if (nodeid == dlm_our_nodeid()) in dlm_midcomms_close()
1400 node = nodeid2node(nodeid, 0); in dlm_midcomms_close()
1412 node = nodeid2node(nodeid, 0); in dlm_midcomms_close()
1416 return dlm_lowcomms_close(nodeid); in dlm_midcomms_close()
1419 ret = dlm_lowcomms_close(nodeid); in dlm_midcomms_close()