103 	uint32_t nodeid;	/* So we know who we are in the list */  member
141 	int nodeid;  member
176 static inline int nodeid_hash(int nodeid)  in nodeid_hash()  argument
178 	return nodeid & (CONN_HASH_SIZE-1);  in nodeid_hash()
181 static struct connection *__find_con(int nodeid)  in __find_con()  argument
186 	r = nodeid_hash(nodeid);  in __find_con()
189 		if (con->nodeid == nodeid)  in __find_con()
199 static struct connection *__nodeid2con(int nodeid, gfp_t alloc)  in __nodeid2con()  argument
204 	con = __find_con(nodeid);  in __nodeid2con()
212 	r = nodeid_hash(nodeid);  in __nodeid2con()
215 	con->nodeid = nodeid;  in __nodeid2con()
223 	if (con->nodeid) {  in __nodeid2con()
247 static struct connection *nodeid2con(int nodeid, gfp_t allocation)  in nodeid2con()  argument
252 	con = __nodeid2con(nodeid, allocation);  in nodeid2con()
258 static struct dlm_node_addr *find_node_addr(int nodeid)  in find_node_addr()  argument
263 		if (na->nodeid == nodeid)  in find_node_addr()
296 static int nodeid_to_addr(int nodeid, struct sockaddr_storage *sas_out,  in nodeid_to_addr()  argument
306 	na = find_node_addr(nodeid);  in nodeid_to_addr()
344 static int addr_to_nodeid(struct sockaddr_storage *addr, int *nodeid)  in addr_to_nodeid()  argument
357 				*nodeid = na->nodeid;  in addr_to_nodeid()
368 int dlm_lowcomms_addr(int nodeid, struct sockaddr_storage *addr, int len)  in dlm_lowcomms_addr()  argument
386 	na = find_node_addr(nodeid);  in dlm_lowcomms_addr()
388 		new_node->nodeid = nodeid;  in dlm_lowcomms_addr()
465 int dlm_lowcomms_connect_node(int nodeid)  in dlm_lowcomms_connect_node()  argument
469 	if (nodeid == dlm_our_nodeid())  in dlm_lowcomms_connect_node()
472 	con = nodeid2con(nodeid, GFP_NOFS);  in dlm_lowcomms_connect_node()
496 				   con->nodeid, dlm_config.ci_tcp_port,  in lowcomms_error_report()
504 				   con->nodeid, &sin4->sin_addr.s_addr,  in lowcomms_error_report()
513 				   con->nodeid, sin6->sin6_addr.s6_addr32[0],  in lowcomms_error_report()
594 		log_print("canceled swork for node %d", con->nodeid);  in close_connection()
598 		log_print("canceled rwork for node %d", con->nodeid);  in close_connection()
639 	if (con->nodeid == 0) {  in receive_from_sock()
684 	ret = dlm_process_incoming_buffer(con->nodeid,  in receive_from_sock()
733 	int nodeid;  in tcp_accept_from_sock()  local
765 	if (addr_to_nodeid(&peeraddr, &nodeid)) {  in tcp_accept_from_sock()
775 	log_print("got connection from %d", nodeid);  in tcp_accept_from_sock()
782 	newcon = nodeid2con(nodeid, GFP_NOFS);  in tcp_accept_from_sock()
799 			othercon->nodeid = nodeid;  in tcp_accept_from_sock()
816 			printk("Extra connection from node %d attempted\n", nodeid);  in tcp_accept_from_sock()
859 	int nodeid;  in sctp_accept_from_sock()  local
890 	ret = addr_to_nodeid(&prim.ssp_addr, &nodeid);  in sctp_accept_from_sock()
900 	newcon = nodeid2con(nodeid, GFP_NOFS);  in sctp_accept_from_sock()
919 			othercon->nodeid = nodeid;  in sctp_accept_from_sock()
935 			printk("Extra connection from node %d attempted\n", nodeid);  in sctp_accept_from_sock()
947 	log_print("connected to %d", nodeid);  in sctp_accept_from_sock()
1040 	if (con->nodeid == 0) {  in sctp_connect_to_sock()
1052 		log_print("node %d already connected.", con->nodeid);  in sctp_connect_to_sock()
1057 	result = nodeid_to_addr(con->nodeid, &daddr, NULL, true);  in sctp_connect_to_sock()
1059 		log_print("no address for nodeid %d", con->nodeid);  in sctp_connect_to_sock()
1079 	log_print("connecting to %d", con->nodeid);  in sctp_connect_to_sock()
1117 		log_print("connect %d try %d error %d", con->nodeid,  in sctp_connect_to_sock()
1138 	if (con->nodeid == 0) {  in tcp_connect_to_sock()
1158 	result = nodeid_to_addr(con->nodeid, &saddr, NULL, false);  in tcp_connect_to_sock()
1160 		log_print("no address for nodeid %d", con->nodeid);  in tcp_connect_to_sock()
1181 	log_print("connecting to %d", con->nodeid);  in tcp_connect_to_sock()
1210 		log_print("connect %d try %d error %d", con->nodeid,  in tcp_connect_to_sock()
1423 void *dlm_lowcomms_get_buffer(int nodeid, int len, gfp_t allocation, char **ppc)  in dlm_lowcomms_get_buffer()  argument
1429 	con = nodeid2con(nodeid, allocation);  in dlm_lowcomms_get_buffer()
1572 int dlm_lowcomms_close(int nodeid)  in dlm_lowcomms_close()  argument
1577 	log_print("closing connection to node %d", nodeid);  in dlm_lowcomms_close()
1578 	con = nodeid2con(nodeid, 0);  in dlm_lowcomms_close()
1586 	na = find_node_addr(nodeid);  in dlm_lowcomms_close()