Lines Matching refs:nodeid
155 int nodeid; member
274 static struct midcomms_node *__find_node(int nodeid, int r) in __find_node() argument
279 if (node->nodeid == nodeid) in __find_node()
306 pr_debug("flush midcomms send queue of node %d\n", node->nodeid); in dlm_send_queue_flush()
319 pr_debug("reset node %d\n", node->nodeid); in midcomms_node_reset()
332 static struct midcomms_node *nodeid2node(int nodeid) in nodeid2node() argument
334 return __find_node(nodeid, nodeid_hash(nodeid)); in nodeid2node()
337 int dlm_midcomms_addr(int nodeid, struct sockaddr_storage *addr) in dlm_midcomms_addr() argument
339 int ret, idx, r = nodeid_hash(nodeid); in dlm_midcomms_addr()
342 ret = dlm_lowcomms_addr(nodeid, addr); in dlm_midcomms_addr()
347 node = __find_node(nodeid, r); in dlm_midcomms_addr()
358 node->nodeid = nodeid; in dlm_midcomms_addr()
371 node->debugfs = dlm_create_debug_comms_file(nodeid, node); in dlm_midcomms_addr()
375 static int dlm_send_ack(int nodeid, uint32_t seq) in dlm_send_ack() argument
382 msg = dlm_lowcomms_new_msg(nodeid, mb_len, &ppc, NULL, NULL); in dlm_send_ack()
419 dlm_send_ack(node->nodeid, atomic_read(&node->seq_next)); in dlm_send_ack_threshold()
430 mh = dlm_midcomms_get_mhandle(node->nodeid, mb_len, &ppc); in dlm_send_fin()
444 pr_debug("sending fin msg to node %d\n", node->nodeid); in dlm_send_fin()
482 node->nodeid, dlm_state_str(node->state)); in dlm_pas_fin_ack_rcv()
539 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_receive_buffer()
543 dlm_send_ack(node->nodeid, nval); in dlm_midcomms_receive_buffer()
552 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_receive_buffer()
558 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_receive_buffer()
562 dlm_send_ack(node->nodeid, nval); in dlm_midcomms_receive_buffer()
566 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_receive_buffer()
569 dlm_send_ack(node->nodeid, nval); in dlm_midcomms_receive_buffer()
572 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_receive_buffer()
589 dlm_receive_buffer(p, node->nodeid); in dlm_midcomms_receive_buffer()
600 dlm_send_ack(node->nodeid, oval); in dlm_midcomms_receive_buffer()
603 seq, oval, node->nodeid); in dlm_midcomms_receive_buffer()
608 int nodeid) in dlm_opts_check_msglen() argument
627 len, nodeid); in dlm_opts_check_msglen()
635 msglen, nodeid); in dlm_opts_check_msglen()
643 len, nodeid); in dlm_opts_check_msglen()
650 p->opts.o_nextcmd, nodeid); in dlm_opts_check_msglen()
657 static void dlm_midcomms_receive_buffer_3_2(const union dlm_packet *p, int nodeid) in dlm_midcomms_receive_buffer_3_2() argument
665 node = nodeid2node(nodeid); in dlm_midcomms_receive_buffer_3_2()
674 node->nodeid); in dlm_midcomms_receive_buffer_3_2()
681 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_receive_buffer_3_2()
693 DLM_VERSION_3_2, node->nodeid, node->version); in dlm_midcomms_receive_buffer_3_2()
716 le32_to_cpu(p->rcom.rc_type), nodeid); in dlm_midcomms_receive_buffer_3_2()
721 dlm_receive_buffer(p, nodeid); in dlm_midcomms_receive_buffer_3_2()
726 ret = dlm_opts_check_msglen(p, msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
729 msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
742 msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
750 msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
758 msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
765 msglen, nodeid); in dlm_midcomms_receive_buffer_3_2()
777 p->header.h_cmd, nodeid); in dlm_midcomms_receive_buffer_3_2()
785 static void dlm_midcomms_receive_buffer_3_1(const union dlm_packet *p, int nodeid) in dlm_midcomms_receive_buffer_3_1() argument
792 node = nodeid2node(nodeid); in dlm_midcomms_receive_buffer_3_1()
803 node->nodeid); in dlm_midcomms_receive_buffer_3_1()
809 DLM_VERSION_3_1, node->nodeid, node->version); in dlm_midcomms_receive_buffer_3_1()
822 msglen, nodeid); in dlm_midcomms_receive_buffer_3_1()
829 p->header.h_cmd, nodeid); in dlm_midcomms_receive_buffer_3_1()
833 dlm_receive_buffer(p, nodeid); in dlm_midcomms_receive_buffer_3_1()
836 int dlm_validate_incoming_buffer(int nodeid, unsigned char *buf, int len) in dlm_validate_incoming_buffer() argument
861 msglen, nodeid); in dlm_validate_incoming_buffer()
883 int dlm_process_incoming_buffer(int nodeid, unsigned char *buf, int len) in dlm_process_incoming_buffer() argument
899 dlm_midcomms_receive_buffer_3_1((const union dlm_packet *)ptr, nodeid); in dlm_process_incoming_buffer()
902 dlm_midcomms_receive_buffer_3_2((const union dlm_packet *)ptr, nodeid); in dlm_process_incoming_buffer()
906 le32_to_cpu(hd->h_version), nodeid); in dlm_process_incoming_buffer()
918 void dlm_midcomms_unack_msg_resend(int nodeid) in dlm_midcomms_unack_msg_resend() argument
925 node = nodeid2node(nodeid); in dlm_midcomms_unack_msg_resend()
948 mh->seq, node->nodeid); in dlm_midcomms_unack_msg_resend()
977 static struct dlm_msg *dlm_midcomms_get_msg_3_2(struct dlm_mhandle *mh, int nodeid, in dlm_midcomms_get_msg_3_2() argument
983 msg = dlm_lowcomms_new_msg(nodeid, len + DLM_MIDCOMMS_OPT_LEN, in dlm_midcomms_get_msg_3_2()
1003 struct dlm_mhandle *dlm_midcomms_get_mhandle(int nodeid, int len, char **ppc) in dlm_midcomms_get_mhandle() argument
1011 node = nodeid2node(nodeid); in dlm_midcomms_get_mhandle()
1029 msg = dlm_lowcomms_new_msg(nodeid, len, ppc, NULL, NULL); in dlm_midcomms_get_mhandle()
1040 msg = dlm_midcomms_get_msg_3_2(mh, nodeid, len, ppc); in dlm_midcomms_get_mhandle()
1072 trace_dlm_send_message(mh->node->nodeid, mh->seq, in dlm_midcomms_commit_msg_3_2_trace()
1077 trace_dlm_send_rcom(mh->node->nodeid, mh->seq, in dlm_midcomms_commit_msg_3_2_trace()
1187 node->nodeid, dlm_state_str(node->state)); in dlm_act_fin_ack_rcv()
1193 node->nodeid, dlm_state_str(node->state)); in dlm_act_fin_ack_rcv()
1198 node->nodeid, dlm_state_str(node->state)); in dlm_act_fin_ack_rcv()
1214 void dlm_midcomms_add_member(int nodeid) in dlm_midcomms_add_member() argument
1220 node = nodeid2node(nodeid); in dlm_midcomms_add_member()
1229 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_add_member()
1236 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_add_member()
1244 node->nodeid); in dlm_midcomms_add_member()
1253 pr_debug("node %d users inc count %d\n", nodeid, node->users); in dlm_midcomms_add_member()
1259 void dlm_midcomms_remove_member(int nodeid) in dlm_midcomms_remove_member() argument
1265 node = nodeid2node(nodeid); in dlm_midcomms_remove_member()
1284 pr_debug("node %d users dec count %d\n", nodeid, node->users); in dlm_midcomms_remove_member()
1292 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_remove_member()
1300 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_remove_member()
1336 node->nodeid, dlm_state_str(node->state)); in dlm_midcomms_version_wait()
1356 node->nodeid, dlm_state_str(node->state)); in midcomms_shutdown()
1361 node->nodeid, dlm_state_str(node->state)); in midcomms_shutdown()
1385 node->nodeid, dlm_state_str(node->state)); in midcomms_shutdown()
1388 node->nodeid, dlm_state_str(node->state)); in midcomms_shutdown()
1415 int dlm_midcomms_close(int nodeid) in dlm_midcomms_close() argument
1422 node = nodeid2node(nodeid); in dlm_midcomms_close()
1434 node = nodeid2node(nodeid); in dlm_midcomms_close()
1438 return dlm_lowcomms_close(nodeid); in dlm_midcomms_close()
1441 ret = dlm_lowcomms_close(nodeid); in dlm_midcomms_close()
1500 msg = dlm_lowcomms_new_msg(node->nodeid, buflen, &msgbuf, in dlm_midcomms_rawmsg_send()