105 	uint32_t nodeid;	/* So we know who we are in the list */  member
145 	int nodeid;  member
173 static inline int nodeid_hash(int nodeid)  in nodeid_hash()  argument
175 	return nodeid & (CONN_HASH_SIZE-1);  in nodeid_hash()
178 static struct connection *__find_con(int nodeid)  in __find_con()  argument
183 	r = nodeid_hash(nodeid);  in __find_con()
186 		if (con->nodeid == nodeid)  in __find_con()
196 static struct connection *__nodeid2con(int nodeid, gfp_t alloc)  in __nodeid2con()  argument
201 	con = __find_con(nodeid);  in __nodeid2con()
209 	r = nodeid_hash(nodeid);  in __nodeid2con()
212 	con->nodeid = nodeid;  in __nodeid2con()
220 	if (con->nodeid) {  in __nodeid2con()
244 static struct connection *nodeid2con(int nodeid, gfp_t allocation)  in nodeid2con()  argument
249 	con = __nodeid2con(nodeid, allocation);  in nodeid2con()
275 static struct dlm_node_addr *find_node_addr(int nodeid)  in find_node_addr()  argument
280 		if (na->nodeid == nodeid)  in find_node_addr()
313 static int nodeid_to_addr(int nodeid, struct sockaddr_storage *sas_out,  in nodeid_to_addr()  argument
323 	na = find_node_addr(nodeid);  in nodeid_to_addr()
361 static int addr_to_nodeid(struct sockaddr_storage *addr, int *nodeid)  in addr_to_nodeid()  argument
374 				*nodeid = na->nodeid;  in addr_to_nodeid()
385 int dlm_lowcomms_addr(int nodeid, struct sockaddr_storage *addr, int len)  in dlm_lowcomms_addr()  argument
403 	na = find_node_addr(nodeid);  in dlm_lowcomms_addr()
405 		new_node->nodeid = nodeid;  in dlm_lowcomms_addr()
466 int dlm_lowcomms_connect_node(int nodeid)  in dlm_lowcomms_connect_node()  argument
474 	if (nodeid == dlm_our_nodeid())  in dlm_lowcomms_connect_node()
477 	con = nodeid2con(nodeid, GFP_NOFS);  in dlm_lowcomms_connect_node()
585 	if (!con->nodeid || con->sctp_assoc)  in sctp_init_failed_foreach()
588 	log_print("Retrying SCTP association init for node %d\n", con->nodeid);  in sctp_init_failed_foreach()
617 	int nodeid = sn_send_failed->ssf_info.sinfo_ppid;  in retry_failed_sctp_send()  local
619 	log_print("Retry sending %d bytes to node id %d", len, nodeid);  in retry_failed_sctp_send()
621 	if (!nodeid) {  in retry_failed_sctp_send()
626 	con = nodeid2con(nodeid, 0);  in retry_failed_sctp_send()
629 			  nodeid);  in retry_failed_sctp_send()
633 	mh = dlm_lowcomms_get_buffer(nodeid, len, GFP_NOFS, &retry_buf);  in retry_failed_sctp_send()
670 			int nodeid;  in process_sctp_notification()  local
708 			if (addr_to_nodeid(&prim.ssp_addr, &nodeid)) {  in process_sctp_notification()
717 			new_con = nodeid2con(nodeid, GFP_NOFS);  in process_sctp_notification()
731 					  nodeid, ret);  in process_sctp_notification()
744 				 nodeid, (int)sn->sn_assoc_change.sac_assoc_id);  in process_sctp_notification()
857 	BUG_ON(con->nodeid == 0);  in receive_from_sock()
862 	ret = dlm_process_incoming_buffer(con->nodeid,  in receive_from_sock()
912 	int nodeid;  in tcp_accept_from_sock()  local
952 	if (addr_to_nodeid(&peeraddr, &nodeid)) {  in tcp_accept_from_sock()
962 	log_print("got connection from %d", nodeid);  in tcp_accept_from_sock()
969 	newcon = nodeid2con(nodeid, GFP_NOFS);  in tcp_accept_from_sock()
986 			othercon->nodeid = nodeid;  in tcp_accept_from_sock()
1001 			printk("Extra connection from node %d attempted\n", nodeid);  in tcp_accept_from_sock()
1083 	if (nodeid_to_addr(con->nodeid, NULL, (struct sockaddr *)&rem_addr,  in sctp_init_assoc()
1085 		log_print("no address for nodeid %d", con->nodeid);  in sctp_init_assoc()
1103 		log_print("writequeue empty for nodeid %d", con->nodeid);  in sctp_init_assoc()
1130 	sinfo->sinfo_ppid = cpu_to_le32(con->nodeid);  in sctp_init_assoc()
1137 			  con->nodeid, ret);  in sctp_init_assoc()
1162 	if (con->nodeid == 0) {  in tcp_connect_to_sock()
1182 	result = nodeid_to_addr(con->nodeid, &saddr, NULL, false);  in tcp_connect_to_sock()
1184 		log_print("no address for nodeid %d", con->nodeid);  in tcp_connect_to_sock()
1206 	log_print("connecting to %d", con->nodeid);  in tcp_connect_to_sock()
1235 		log_print("connect %d try %d error %d", con->nodeid,  in tcp_connect_to_sock()
1490 void *dlm_lowcomms_get_buffer(int nodeid, int len, gfp_t allocation, char **ppc)  in dlm_lowcomms_get_buffer()  argument
1496 	con = nodeid2con(nodeid, allocation);  in dlm_lowcomms_get_buffer()
1639 int dlm_lowcomms_close(int nodeid)  in dlm_lowcomms_close()  argument
1644 	log_print("closing connection to node %d", nodeid);  in dlm_lowcomms_close()
1645 	con = nodeid2con(nodeid, 0);  in dlm_lowcomms_close()
1651 			log_print("canceled swork for node %d", nodeid);  in dlm_lowcomms_close()
1653 			log_print("canceled rwork for node %d", nodeid);  in dlm_lowcomms_close()
1659 	na = find_node_addr(nodeid);  in dlm_lowcomms_close()