fs/dlm/lowcomms.c

71 	uint32_t nodeid;	/* So we know who we are in the list */
153 	int nodeid;
270 static struct connection *__find_con(int nodeid, int r)
275 		if (con->nodeid == nodeid)
282 static void dlm_con_init(struct connection *con, int nodeid)
284 	con->nodeid = nodeid;
298 static struct connection *nodeid2con(int nodeid, gfp_t alloc)
303 	r = nodeid_hash(nodeid);
304 	con = __find_con(nodeid, r);
312 	dlm_con_init(con, nodeid);
321 	tmp = __find_con(nodeid, r);
362 static int nodeid_to_addr(int nodeid, struct sockaddr_storage *sas_out,
374 	con = nodeid2con(nodeid, 0);
421 static int addr_to_nodeid(struct sockaddr_storage *addr, int *nodeid,
435 					*nodeid = con->nodeid;
463 int dlm_lowcomms_addr(int nodeid, struct sockaddr_storage *addr, int len)
469 	con = nodeid2con(nodeid, GFP_NOFS);
547 int dlm_lowcomms_connect_node(int nodeid)
553 	con = nodeid2con(nodeid, 0);
572 int dlm_lowcomms_nodes_set_mark(int nodeid, unsigned int mark)
578 	con = nodeid2con(nodeid, 0);
602 				   con->nodeid, &inet->inet_daddr,
611 				   con->nodeid, &sk->sk_v6_daddr,
625 	dlm_midcomms_unack_msg_resend(con->nodeid);
835 static struct processqueue_entry *new_processqueue_entry(int nodeid,
850 	pentry->nodeid = nodeid;
861 	int nodeid;
884 		dlm_process_incoming_buffer(pentry->nodeid, pentry->buf,
911 	pentry = new_processqueue_entry(con->nodeid, buflen);
929 	trace_dlm_recv(con->nodeid, ret);
952 	ret = dlm_validate_incoming_buffer(con->nodeid, pentry->buf,
988 	int len, idx, result, nodeid;
1009 	if (addr_to_nodeid(&peeraddr, &nodeid, &mark)) {
1036 	log_print("got connection from %d", nodeid);
1044 	newcon = nodeid2con(nodeid, 0);
1067 			dlm_con_init(othercon, nodeid);
1264 struct dlm_msg *dlm_lowcomms_new_msg(int nodeid, int len, gfp_t allocation,
1281 	con = nodeid2con(nodeid, 0);
1393 	trace_dlm_send(con->nodeid, ret);
1449 int dlm_lowcomms_close(int nodeid)
1454 	log_print("closing connection to node %d", nodeid);
1457 	con = nodeid2con(nodeid, 0);
1464 	log_print("io handling for node: %d stopped", nodeid);
1483 	log_print("closing connection to node %d done", nodeid);
1568 	result = nodeid_to_addr(con->nodeid, &addr, NULL,
1571 		log_print("no address for nodeid %d", con->nodeid);
1592 	log_print_ratelimited("connecting to %d", con->nodeid);
1640 					  con->nodeid, con->retries++, ret);