Lines Matching refs:nodeid
105 uint32_t nodeid; /* So we know who we are in the list */ member
144 int nodeid; member
172 static inline int nodeid_hash(int nodeid) in nodeid_hash() argument
174 return nodeid & (CONN_HASH_SIZE-1); in nodeid_hash()
177 static struct connection *__find_con(int nodeid) in __find_con() argument
182 r = nodeid_hash(nodeid); in __find_con()
185 if (con->nodeid == nodeid) in __find_con()
195 static struct connection *__nodeid2con(int nodeid, gfp_t alloc) in __nodeid2con() argument
200 con = __find_con(nodeid); in __nodeid2con()
208 r = nodeid_hash(nodeid); in __nodeid2con()
211 con->nodeid = nodeid; in __nodeid2con()
219 if (con->nodeid) { in __nodeid2con()
243 static struct connection *nodeid2con(int nodeid, gfp_t allocation) in nodeid2con() argument
248 con = __nodeid2con(nodeid, allocation); in nodeid2con()
254 static struct dlm_node_addr *find_node_addr(int nodeid) in find_node_addr() argument
259 if (na->nodeid == nodeid) in find_node_addr()
292 static int nodeid_to_addr(int nodeid, struct sockaddr_storage *sas_out, in nodeid_to_addr() argument
302 na = find_node_addr(nodeid); in nodeid_to_addr()
340 static int addr_to_nodeid(struct sockaddr_storage *addr, int *nodeid) in addr_to_nodeid() argument
353 *nodeid = na->nodeid; in addr_to_nodeid()
364 int dlm_lowcomms_addr(int nodeid, struct sockaddr_storage *addr, int len) in dlm_lowcomms_addr() argument
382 na = find_node_addr(nodeid); in dlm_lowcomms_addr()
384 new_node->nodeid = nodeid; in dlm_lowcomms_addr()
454 int dlm_lowcomms_connect_node(int nodeid) in dlm_lowcomms_connect_node() argument
458 if (nodeid == dlm_our_nodeid()) in dlm_lowcomms_connect_node()
461 con = nodeid2con(nodeid, GFP_NOFS); in dlm_lowcomms_connect_node()
473 if (nodeid_to_addr(con->nodeid, &saddr, NULL, false)) { in lowcomms_error_report()
477 con->nodeid, dlm_config.ci_tcp_port, in lowcomms_error_report()
486 con->nodeid, &sin4->sin_addr.s_addr, in lowcomms_error_report()
495 con->nodeid, sin6->sin6_addr.s6_addr32[0], in lowcomms_error_report()
546 log_print("canceled swork for node %d", con->nodeid); in close_connection()
548 log_print("canceled rwork for node %d", con->nodeid); in close_connection()
585 if (con->nodeid == 0) { in receive_from_sock()
630 ret = dlm_process_incoming_buffer(con->nodeid, in receive_from_sock()
679 int nodeid; in tcp_accept_from_sock() local
719 if (addr_to_nodeid(&peeraddr, &nodeid)) { in tcp_accept_from_sock()
729 log_print("got connection from %d", nodeid); in tcp_accept_from_sock()
736 newcon = nodeid2con(nodeid, GFP_NOFS); in tcp_accept_from_sock()
753 othercon->nodeid = nodeid; in tcp_accept_from_sock()
768 printk("Extra connection from node %d attempted\n", nodeid); in tcp_accept_from_sock()
807 int nodeid; in sctp_accept_from_sock() local
838 if (addr_to_nodeid(&prim.ssp_addr, &nodeid)) { in sctp_accept_from_sock()
847 newcon = nodeid2con(nodeid, GFP_NOFS); in sctp_accept_from_sock()
866 othercon->nodeid = nodeid; in sctp_accept_from_sock()
880 printk("Extra connection from node %d attempted\n", nodeid); in sctp_accept_from_sock()
892 log_print("connected to %d", nodeid); in sctp_accept_from_sock()
984 if (con->nodeid == 0) { in sctp_connect_to_sock()
996 log_print("node %d already connected.", con->nodeid); in sctp_connect_to_sock()
1001 result = nodeid_to_addr(con->nodeid, &daddr, NULL, true); in sctp_connect_to_sock()
1003 log_print("no address for nodeid %d", con->nodeid); in sctp_connect_to_sock()
1024 log_print("connecting to %d", con->nodeid); in sctp_connect_to_sock()
1052 log_print("connect %d try %d error %d", con->nodeid, in sctp_connect_to_sock()
1075 if (con->nodeid == 0) { in tcp_connect_to_sock()
1095 result = nodeid_to_addr(con->nodeid, &saddr, NULL, false); in tcp_connect_to_sock()
1097 log_print("no address for nodeid %d", con->nodeid); in tcp_connect_to_sock()
1119 log_print("connecting to %d", con->nodeid); in tcp_connect_to_sock()
1148 log_print("connect %d try %d error %d", con->nodeid, in tcp_connect_to_sock()
1356 void *dlm_lowcomms_get_buffer(int nodeid, int len, gfp_t allocation, char **ppc) in dlm_lowcomms_get_buffer() argument
1362 con = nodeid2con(nodeid, allocation); in dlm_lowcomms_get_buffer()
1504 int dlm_lowcomms_close(int nodeid) in dlm_lowcomms_close() argument
1509 log_print("closing connection to node %d", nodeid); in dlm_lowcomms_close()
1510 con = nodeid2con(nodeid, 0); in dlm_lowcomms_close()
1518 na = find_node_addr(nodeid); in dlm_lowcomms_close()