105 	uint32_t nodeid;	/* So we know who we are in the list */  member
143 	int nodeid;  member
178 static inline int nodeid_hash(int nodeid)  in nodeid_hash()  argument
180 	return nodeid & (CONN_HASH_SIZE-1);  in nodeid_hash()
183 static struct connection *__find_con(int nodeid)  in __find_con()  argument
188 	r = nodeid_hash(nodeid);  in __find_con()
191 		if (con->nodeid == nodeid)  in __find_con()
201 static struct connection *__nodeid2con(int nodeid, gfp_t alloc)  in __nodeid2con()  argument
206 	con = __find_con(nodeid);  in __nodeid2con()
214 	r = nodeid_hash(nodeid);  in __nodeid2con()
217 	con->nodeid = nodeid;  in __nodeid2con()
225 	if (con->nodeid) {  in __nodeid2con()
249 static struct connection *nodeid2con(int nodeid, gfp_t allocation)  in nodeid2con()  argument
254 	con = __nodeid2con(nodeid, allocation);  in nodeid2con()
260 static struct dlm_node_addr *find_node_addr(int nodeid)  in find_node_addr()  argument
265 		if (na->nodeid == nodeid)  in find_node_addr()
298 static int nodeid_to_addr(int nodeid, struct sockaddr_storage *sas_out,  in nodeid_to_addr()  argument
308 	na = find_node_addr(nodeid);  in nodeid_to_addr()
346 static int addr_to_nodeid(struct sockaddr_storage *addr, int *nodeid)  in addr_to_nodeid()  argument
359 				*nodeid = na->nodeid;  in addr_to_nodeid()
370 int dlm_lowcomms_addr(int nodeid, struct sockaddr_storage *addr, int len)  in dlm_lowcomms_addr()  argument
388 	na = find_node_addr(nodeid);  in dlm_lowcomms_addr()
390 		new_node->nodeid = nodeid;  in dlm_lowcomms_addr()
467 int dlm_lowcomms_connect_node(int nodeid)  in dlm_lowcomms_connect_node()  argument
471 	if (nodeid == dlm_our_nodeid())  in dlm_lowcomms_connect_node()
474 	con = nodeid2con(nodeid, GFP_NOFS);  in dlm_lowcomms_connect_node()
498 				   con->nodeid, dlm_config.ci_tcp_port,  in lowcomms_error_report()
506 				   con->nodeid, &sin4->sin_addr.s_addr,  in lowcomms_error_report()
515 				   con->nodeid, sin6->sin6_addr.s6_addr32[0],  in lowcomms_error_report()
596 		log_print("canceled swork for node %d", con->nodeid);  in close_connection()
600 		log_print("canceled rwork for node %d", con->nodeid);  in close_connection()
641 	if (con->nodeid == 0) {  in receive_from_sock()
686 	ret = dlm_process_incoming_buffer(con->nodeid,  in receive_from_sock()
735 	int nodeid;  in tcp_accept_from_sock()  local
767 	if (addr_to_nodeid(&peeraddr, &nodeid)) {  in tcp_accept_from_sock()
777 	log_print("got connection from %d", nodeid);  in tcp_accept_from_sock()
784 	newcon = nodeid2con(nodeid, GFP_NOFS);  in tcp_accept_from_sock()
801 			othercon->nodeid = nodeid;  in tcp_accept_from_sock()
818 			printk("Extra connection from node %d attempted\n", nodeid);  in tcp_accept_from_sock()
861 	int nodeid;  in sctp_accept_from_sock()  local
892 	ret = addr_to_nodeid(&prim.ssp_addr, &nodeid);  in sctp_accept_from_sock()
902 	newcon = nodeid2con(nodeid, GFP_NOFS);  in sctp_accept_from_sock()
921 			othercon->nodeid = nodeid;  in sctp_accept_from_sock()
937 			printk("Extra connection from node %d attempted\n", nodeid);  in sctp_accept_from_sock()
949 	log_print("connected to %d", nodeid);  in sctp_accept_from_sock()
1042 	if (con->nodeid == 0) {  in sctp_connect_to_sock()
1054 		log_print("node %d already connected.", con->nodeid);  in sctp_connect_to_sock()
1059 	result = nodeid_to_addr(con->nodeid, &daddr, NULL, true);  in sctp_connect_to_sock()
1061 		log_print("no address for nodeid %d", con->nodeid);  in sctp_connect_to_sock()
1081 	log_print("connecting to %d", con->nodeid);  in sctp_connect_to_sock()
1119 		log_print("connect %d try %d error %d", con->nodeid,  in sctp_connect_to_sock()
1140 	if (con->nodeid == 0) {  in tcp_connect_to_sock()
1160 	result = nodeid_to_addr(con->nodeid, &saddr, NULL, false);  in tcp_connect_to_sock()
1162 		log_print("no address for nodeid %d", con->nodeid);  in tcp_connect_to_sock()
1183 	log_print("connecting to %d", con->nodeid);  in tcp_connect_to_sock()
1212 		log_print("connect %d try %d error %d", con->nodeid,  in tcp_connect_to_sock()
1425 void *dlm_lowcomms_get_buffer(int nodeid, int len, gfp_t allocation, char **ppc)  in dlm_lowcomms_get_buffer()  argument
1431 	con = nodeid2con(nodeid, allocation);  in dlm_lowcomms_get_buffer()
1574 int dlm_lowcomms_close(int nodeid)  in dlm_lowcomms_close()  argument
1579 	log_print("closing connection to node %d", nodeid);  in dlm_lowcomms_close()
1580 	con = nodeid2con(nodeid, 0);  in dlm_lowcomms_close()
1588 	na = find_node_addr(nodeid);  in dlm_lowcomms_close()