Lines Matching refs:nodeid
155 int nodeid; member
275 static struct midcomms_node *__find_node(int nodeid, int r) in __find_node() argument
280 if (node->nodeid == nodeid) in __find_node()
307 pr_debug("flush midcomms send queue of node %d\n", node->nodeid); in dlm_send_queue_flush()
320 pr_debug("reset node %d\n", node->nodeid); in midcomms_node_reset()
333 static struct midcomms_node *nodeid2node(int nodeid) in nodeid2node() argument
335 return __find_node(nodeid, nodeid_hash(nodeid)); in nodeid2node()
338 int dlm_midcomms_addr(int nodeid, struct sockaddr_storage *addr, int len) in dlm_midcomms_addr() argument
340 int ret, r = nodeid_hash(nodeid); in dlm_midcomms_addr()
343 ret = dlm_lowcomms_addr(nodeid, addr, len); in dlm_midcomms_addr()
351 node->nodeid = nodeid; in dlm_midcomms_addr()
364 node->debugfs = dlm_create_debug_comms_file(nodeid, node); in dlm_midcomms_addr()
368 static int dlm_send_ack(int nodeid, uint32_t seq) in dlm_send_ack() argument
375 msg = dlm_lowcomms_new_msg(nodeid, mb_len, GFP_ATOMIC, &ppc, in dlm_send_ack()
413 dlm_send_ack(node->nodeid, atomic_read(&node->seq_next)); in dlm_send_ack_threshold()
424 mh = dlm_midcomms_get_mhandle(node->nodeid, mb_len, GFP_ATOMIC, &ppc); in dlm_send_fin()
438 pr_debug("sending fin msg to node %d\n", node->nodeid); in dlm_send_fin()
476 node->nodeid, dlm_state_str(node->state)); in dlm_pas_fin_ack_rcv()
533 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_receive_buffer()
537 dlm_send_ack(node->nodeid, nval); in dlm_midcomms_receive_buffer()
546 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_receive_buffer()
552 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_receive_buffer()
556 dlm_send_ack(node->nodeid, nval); in dlm_midcomms_receive_buffer()
560 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_receive_buffer()
563 dlm_send_ack(node->nodeid, nval); in dlm_midcomms_receive_buffer()
566 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_receive_buffer()
583 dlm_receive_buffer(p, node->nodeid); in dlm_midcomms_receive_buffer()
594 dlm_send_ack(node->nodeid, oval); in dlm_midcomms_receive_buffer()
597 seq, oval, node->nodeid); in dlm_midcomms_receive_buffer()
602 int nodeid) in dlm_opts_check_msglen() argument
621 len, nodeid); in dlm_opts_check_msglen()
629 msglen, nodeid); in dlm_opts_check_msglen()
637 len, nodeid); in dlm_opts_check_msglen()
644 p->opts.o_nextcmd, nodeid); in dlm_opts_check_msglen()
651 static void dlm_midcomms_receive_buffer_3_2(const union dlm_packet *p, int nodeid) in dlm_midcomms_receive_buffer_3_2() argument
659 node = nodeid2node(nodeid); in dlm_midcomms_receive_buffer_3_2()
668 node->nodeid); in dlm_midcomms_receive_buffer_3_2()
675 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_receive_buffer_3_2()
687 DLM_VERSION_3_2, node->nodeid, node->version); in dlm_midcomms_receive_buffer_3_2()
710 le32_to_cpu(p->rcom.rc_type), nodeid); in dlm_midcomms_receive_buffer_3_2()
715 dlm_receive_buffer(p, nodeid); in dlm_midcomms_receive_buffer_3_2()
720 ret = dlm_opts_check_msglen(p, msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
723 msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
736 msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
744 msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
752 msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
759 msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
771 p->header.h_cmd, nodeid); in dlm_midcomms_receive_buffer_3_2()
779 static void dlm_midcomms_receive_buffer_3_1(const union dlm_packet *p, int nodeid) in dlm_midcomms_receive_buffer_3_1() argument
786 node = nodeid2node(nodeid); in dlm_midcomms_receive_buffer_3_1()
797 node->nodeid); in dlm_midcomms_receive_buffer_3_1()
803 DLM_VERSION_3_1, node->nodeid, node->version); in dlm_midcomms_receive_buffer_3_1()
816 msglen, nodeid); in dlm_midcomms_receive_buffer_3_1()
823 p->header.h_cmd, nodeid); in dlm_midcomms_receive_buffer_3_1()
827 dlm_receive_buffer(p, nodeid); in dlm_midcomms_receive_buffer_3_1()
830 int dlm_validate_incoming_buffer(int nodeid, unsigned char *buf, int len) in dlm_validate_incoming_buffer() argument
855 msglen, nodeid); in dlm_validate_incoming_buffer()
877 int dlm_process_incoming_buffer(int nodeid, unsigned char *buf, int len) in dlm_process_incoming_buffer() argument
893 dlm_midcomms_receive_buffer_3_1((const union dlm_packet *)ptr, nodeid); in dlm_process_incoming_buffer()
896 dlm_midcomms_receive_buffer_3_2((const union dlm_packet *)ptr, nodeid); in dlm_process_incoming_buffer()
900 le32_to_cpu(hd->h_version), nodeid); in dlm_process_incoming_buffer()
912 void dlm_midcomms_unack_msg_resend(int nodeid) in dlm_midcomms_unack_msg_resend() argument
919 node = nodeid2node(nodeid); in dlm_midcomms_unack_msg_resend()
942 mh->seq, node->nodeid); in dlm_midcomms_unack_msg_resend()
971 static struct dlm_msg *dlm_midcomms_get_msg_3_2(struct dlm_mhandle *mh, int nodeid, in dlm_midcomms_get_msg_3_2() argument
977 msg = dlm_lowcomms_new_msg(nodeid, len + DLM_MIDCOMMS_OPT_LEN, in dlm_midcomms_get_msg_3_2()
997 struct dlm_mhandle *dlm_midcomms_get_mhandle(int nodeid, int len, in dlm_midcomms_get_mhandle() argument
1006 node = nodeid2node(nodeid); in dlm_midcomms_get_mhandle()
1024 msg = dlm_lowcomms_new_msg(nodeid, len, allocation, ppc, in dlm_midcomms_get_mhandle()
1033 msg = dlm_midcomms_get_msg_3_2(mh, nodeid, len, allocation, in dlm_midcomms_get_mhandle()
1069 trace_dlm_send_message(mh->node->nodeid, mh->seq, in dlm_midcomms_commit_msg_3_2_trace()
1074 trace_dlm_send_rcom(mh->node->nodeid, mh->seq, in dlm_midcomms_commit_msg_3_2_trace()
1184 node->nodeid, dlm_state_str(node->state)); in dlm_act_fin_ack_rcv()
1190 node->nodeid, dlm_state_str(node->state)); in dlm_act_fin_ack_rcv()
1195 node->nodeid, dlm_state_str(node->state)); in dlm_act_fin_ack_rcv()
1211 void dlm_midcomms_add_member(int nodeid) in dlm_midcomms_add_member() argument
1217 node = nodeid2node(nodeid); in dlm_midcomms_add_member()
1226 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_add_member()
1233 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_add_member()
1241 node->nodeid); in dlm_midcomms_add_member()
1250 pr_debug("node %d users inc count %d\n", nodeid, node->users); in dlm_midcomms_add_member()
1256 void dlm_midcomms_remove_member(int nodeid) in dlm_midcomms_remove_member() argument
1262 node = nodeid2node(nodeid); in dlm_midcomms_remove_member()
1270 pr_debug("node %d users dec count %d\n", nodeid, node->users); in dlm_midcomms_remove_member()
1278 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_remove_member()
1286 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_remove_member()
1322 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_version_wait()
1342 node->nodeid, dlm_state_str(node->state)); in midcomms_shutdown()
1347 node->nodeid, dlm_state_str(node->state)); in midcomms_shutdown()
1371 node->nodeid, dlm_state_str(node->state)); in midcomms_shutdown()
1374 node->nodeid, dlm_state_str(node->state)); in midcomms_shutdown()
1395 int dlm_midcomms_close(int nodeid) in dlm_midcomms_close() argument
1402 node = nodeid2node(nodeid); in dlm_midcomms_close()
1414 node = nodeid2node(nodeid); in dlm_midcomms_close()
1418 return dlm_lowcomms_close(nodeid); in dlm_midcomms_close()
1421 ret = dlm_lowcomms_close(nodeid); in dlm_midcomms_close()
1480 msg = dlm_lowcomms_new_msg(node->nodeid, buflen, GFP_NOFS, in dlm_midcomms_rawmsg_send()