70 	uint32_t nodeid;	/* So we know who we are in the list */  member
113 	int nodeid;  member
148 static inline int nodeid_hash(int nodeid)  in nodeid_hash()  argument
150 	return nodeid & (CONN_HASH_SIZE-1);  in nodeid_hash()
153 static struct connection *__find_con(int nodeid)  in __find_con()  argument
158 	r = nodeid_hash(nodeid);  in __find_con()
162 		if (con->nodeid == nodeid) {  in __find_con()
176 static struct connection *nodeid2con(int nodeid, gfp_t alloc)  in nodeid2con()  argument
181 	con = __find_con(nodeid);  in nodeid2con()
196 	con->nodeid = nodeid;  in nodeid2con()
205 	if (con->nodeid) {  in nodeid2con()
213 	r = nodeid_hash(nodeid);  in nodeid2con()
222 	tmp = __find_con(nodeid);  in nodeid2con()
250 static struct dlm_node_addr *find_node_addr(int nodeid)  in find_node_addr()  argument
255 		if (na->nodeid == nodeid)  in find_node_addr()
288 static int nodeid_to_addr(int nodeid, struct sockaddr_storage *sas_out,  in nodeid_to_addr()  argument
298 	na = find_node_addr(nodeid);  in nodeid_to_addr()
336 static int addr_to_nodeid(struct sockaddr_storage *addr, int *nodeid)  in addr_to_nodeid()  argument
349 				*nodeid = na->nodeid;  in addr_to_nodeid()
360 int dlm_lowcomms_addr(int nodeid, struct sockaddr_storage *addr, int len)  in dlm_lowcomms_addr()  argument
378 	na = find_node_addr(nodeid);  in dlm_lowcomms_addr()
380 		new_node->nodeid = nodeid;  in dlm_lowcomms_addr()
457 int dlm_lowcomms_connect_node(int nodeid)  in dlm_lowcomms_connect_node()  argument
461 	if (nodeid == dlm_our_nodeid())  in dlm_lowcomms_connect_node()
464 	con = nodeid2con(nodeid, GFP_NOFS);  in dlm_lowcomms_connect_node()
490 				   con->nodeid, &inet->inet_daddr,  in lowcomms_error_report()
499 				   con->nodeid, &sk->sk_v6_daddr,  in lowcomms_error_report()
585 		log_print("canceled swork for node %d", con->nodeid);  in close_connection()
589 		log_print("canceled rwork for node %d", con->nodeid);  in close_connection()
690 	if (con->nodeid == 0) {  in receive_from_sock()
720 	ret = dlm_process_incoming_buffer(con->nodeid, con->rx_buf, buflen);  in receive_from_sock()
754 				  con, con->nodeid);  in receive_from_sock()
772 	int nodeid;  in accept_from_sock()  local
802 	if (addr_to_nodeid(&peeraddr, &nodeid)) {  in accept_from_sock()
812 	dlm_comm_mark(nodeid, &mark);  in accept_from_sock()
815 	log_print("got connection from %d", nodeid);  in accept_from_sock()
822 	newcon = nodeid2con(nodeid, GFP_NOFS);  in accept_from_sock()
850 			othercon->nodeid = nodeid;  in accept_from_sock()
966 	if (con->nodeid == 0) {  in sctp_connect_to_sock()
971 	dlm_comm_mark(con->nodeid, &mark);  in sctp_connect_to_sock()
980 		log_print("node %d already connected.", con->nodeid);  in sctp_connect_to_sock()
985 	result = nodeid_to_addr(con->nodeid, &daddr, NULL, true);  in sctp_connect_to_sock()
987 		log_print("no address for nodeid %d", con->nodeid);  in sctp_connect_to_sock()
1009 	log_print("connecting to %d", con->nodeid);  in sctp_connect_to_sock()
1043 		log_print("connect %d try %d error %d", con->nodeid,  in sctp_connect_to_sock()
1064 	if (con->nodeid == 0) {  in tcp_connect_to_sock()
1069 	dlm_comm_mark(con->nodeid, &mark);  in tcp_connect_to_sock()
1088 	result = nodeid_to_addr(con->nodeid, &saddr, NULL, false);  in tcp_connect_to_sock()
1090 		log_print("no address for nodeid %d", con->nodeid);  in tcp_connect_to_sock()
1112 	log_print("connecting to %d", con->nodeid);  in tcp_connect_to_sock()
1140 		log_print("connect %d try %d error %d", con->nodeid,  in tcp_connect_to_sock()
1345 void *dlm_lowcomms_get_buffer(int nodeid, int len, gfp_t allocation, char **ppc)  in dlm_lowcomms_get_buffer()  argument
1351 	con = nodeid2con(nodeid, allocation);  in dlm_lowcomms_get_buffer()
1494 int dlm_lowcomms_close(int nodeid)  in dlm_lowcomms_close()  argument
1499 	log_print("closing connection to node %d", nodeid);  in dlm_lowcomms_close()
1500 	con = nodeid2con(nodeid, 0);  in dlm_lowcomms_close()
1508 	na = find_node_addr(nodeid);  in dlm_lowcomms_close()