fs/dlm/midcomms.c

155 	int nodeid;
275 static struct midcomms_node *__find_node(int nodeid, int r)
280 		if (node->nodeid == nodeid)
307 	pr_debug("flush midcomms send queue of node %d\n", node->nodeid);
320 	pr_debug("reset node %d\n", node->nodeid);
333 static struct midcomms_node *nodeid2node(int nodeid)
335 	return __find_node(nodeid, nodeid_hash(nodeid));
338 int dlm_midcomms_addr(int nodeid, struct sockaddr_storage *addr, int len)
340 	int ret, idx, r = nodeid_hash(nodeid);
343 	ret = dlm_lowcomms_addr(nodeid, addr, len);
348 	node = __find_node(nodeid, r);
359 	node->nodeid = nodeid;
372 	node->debugfs = dlm_create_debug_comms_file(nodeid, node);
376 static int dlm_send_ack(int nodeid, uint32_t seq)
383 	msg = dlm_lowcomms_new_msg(nodeid, mb_len, GFP_ATOMIC, &ppc,
421 		dlm_send_ack(node->nodeid, atomic_read(&node->seq_next));
432 	mh = dlm_midcomms_get_mhandle(node->nodeid, mb_len, GFP_ATOMIC, &ppc);
446 	pr_debug("sending fin msg to node %d\n", node->nodeid);
484 		 node->nodeid, dlm_state_str(node->state));
541 				 node->nodeid, dlm_state_str(node->state));
545 				dlm_send_ack(node->nodeid, nval);
554 						 node->nodeid, dlm_state_str(node->state));
560 						 node->nodeid, dlm_state_str(node->state));
564 				dlm_send_ack(node->nodeid, nval);
568 					 node->nodeid, dlm_state_str(node->state));
571 				dlm_send_ack(node->nodeid, nval);
574 					 node->nodeid, dlm_state_str(node->state));
591 			dlm_receive_buffer(p, node->nodeid);
602 			dlm_send_ack(node->nodeid, oval);
604 		log_print_ratelimited("ignore dlm msg because seq mismatch, seq: %u, expected: %u, nodeid: %d",
605 				      seq, oval, node->nodeid);
610 				 int nodeid)
629 				  len, nodeid);
637 				  msglen, nodeid);
645 				  len, nodeid);
652 			  p->opts.o_nextcmd, nodeid);
659 static void dlm_midcomms_receive_buffer_3_2(const union dlm_packet *p, int nodeid)
667 	node = nodeid2node(nodeid);
676 			  node->nodeid);
683 				 node->nodeid, dlm_state_str(node->state));
695 				      DLM_VERSION_3_2, node->nodeid, node->version);
718 				  le32_to_cpu(p->rcom.rc_type), nodeid);
723 		dlm_receive_buffer(p, nodeid);
728 		ret = dlm_opts_check_msglen(p, msglen, nodeid);
731 				  msglen, nodeid);
744 					  msglen, nodeid);
752 					  msglen, nodeid);
760 					  msglen, nodeid);
767 				  msglen, nodeid);
779 			  p->header.h_cmd, nodeid);
787 static void dlm_midcomms_receive_buffer_3_1(const union dlm_packet *p, int nodeid)
794 	node = nodeid2node(nodeid);
805 			  node->nodeid);
811 				      DLM_VERSION_3_1, node->nodeid, node->version);
824 				  msglen, nodeid);
831 			  p->header.h_cmd, nodeid);
835 	dlm_receive_buffer(p, nodeid);
838 int dlm_validate_incoming_buffer(int nodeid, unsigned char *buf, int len)
863 				  msglen, nodeid);
885 int dlm_process_incoming_buffer(int nodeid, unsigned char *buf, int len)
901 			dlm_midcomms_receive_buffer_3_1((const union dlm_packet *)ptr, nodeid);
904 			dlm_midcomms_receive_buffer_3_2((const union dlm_packet *)ptr, nodeid);
908 				  le32_to_cpu(hd->h_version), nodeid);
920 void dlm_midcomms_unack_msg_resend(int nodeid)
927 	node = nodeid2node(nodeid);
949 			log_print_ratelimited("retransmit dlm msg, seq %u, nodeid %d",
950 					      mh->seq, node->nodeid);
979 static struct dlm_msg *dlm_midcomms_get_msg_3_2(struct dlm_mhandle *mh, int nodeid,
985 	msg = dlm_lowcomms_new_msg(nodeid, len + DLM_MIDCOMMS_OPT_LEN,
1005 struct dlm_mhandle *dlm_midcomms_get_mhandle(int nodeid, int len,
1014 	node = nodeid2node(nodeid);
1032 		msg = dlm_lowcomms_new_msg(nodeid, len, allocation, ppc,
1044 		msg = dlm_midcomms_get_msg_3_2(mh, nodeid, len, allocation,
1077 		trace_dlm_send_message(mh->node->nodeid, mh->seq,
1082 		trace_dlm_send_rcom(mh->node->nodeid, mh->seq,
1192 		 node->nodeid, dlm_state_str(node->state));
1198 			 node->nodeid, dlm_state_str(node->state));
1203 			 node->nodeid, dlm_state_str(node->state));
1219 void dlm_midcomms_add_member(int nodeid)
1225 	node = nodeid2node(nodeid);
1234 			 node->nodeid, dlm_state_str(node->state));
1241 				 node->nodeid, dlm_state_str(node->state));
1249 				  node->nodeid);
1258 	pr_debug("node %d users inc count %d\n", nodeid, node->users);
1264 void dlm_midcomms_remove_member(int nodeid)
1270 	node = nodeid2node(nodeid);
1289 	pr_debug("node %d users dec count %d\n", nodeid, node->users);
1297 			 node->nodeid, dlm_state_str(node->state));
1305 				 node->nodeid, dlm_state_str(node->state));
1341 					 node->nodeid, dlm_state_str(node->state));
1361 		 node->nodeid, dlm_state_str(node->state));
1366 			 node->nodeid, dlm_state_str(node->state));
1390 			 node->nodeid, dlm_state_str(node->state));
1393 			 node->nodeid, dlm_state_str(node->state));
1420 int dlm_midcomms_close(int nodeid)
1427 	node = nodeid2node(nodeid);
1439 	node = nodeid2node(nodeid);
1443 		return dlm_lowcomms_close(nodeid);
1446 	ret = dlm_lowcomms_close(nodeid);
1505 	msg = dlm_lowcomms_new_msg(node->nodeid, buflen, GFP_NOFS,