Lines Matching refs:nodeid
69 uint32_t nodeid; /* So we know who we are in the list */ member
139 int nodeid; member
208 static struct connection *__find_con(int nodeid, int r) in __find_con() argument
213 if (con->nodeid == nodeid) in __find_con()
225 static int dlm_con_init(struct connection *con, int nodeid) in dlm_con_init() argument
232 con->nodeid = nodeid; in dlm_con_init()
248 static struct connection *nodeid2con(int nodeid, gfp_t alloc) in nodeid2con() argument
253 r = nodeid_hash(nodeid); in nodeid2con()
254 con = __find_con(nodeid, r); in nodeid2con()
262 ret = dlm_con_init(con, nodeid); in nodeid2con()
277 tmp = __find_con(nodeid, r); in nodeid2con()
303 static struct dlm_node_addr *find_node_addr(int nodeid) in find_node_addr() argument
308 if (na->nodeid == nodeid) in find_node_addr()
342 static int nodeid_to_addr(int nodeid, struct sockaddr_storage *sas_out, in nodeid_to_addr() argument
353 na = find_node_addr(nodeid); in nodeid_to_addr()
393 static int addr_to_nodeid(struct sockaddr_storage *addr, int *nodeid, in addr_to_nodeid() argument
407 *nodeid = na->nodeid; in addr_to_nodeid()
433 int dlm_lowcomms_addr(int nodeid, struct sockaddr_storage *addr, int len) in dlm_lowcomms_addr() argument
452 na = find_node_addr(nodeid); in dlm_lowcomms_addr()
454 new_node->nodeid = nodeid; in dlm_lowcomms_addr()
514 log_print("successful connected to node %d", con->nodeid); in lowcomms_write_space()
554 int dlm_lowcomms_connect_node(int nodeid) in dlm_lowcomms_connect_node() argument
559 if (nodeid == dlm_our_nodeid()) in dlm_lowcomms_connect_node()
563 con = nodeid2con(nodeid, GFP_NOFS); in dlm_lowcomms_connect_node()
575 int dlm_lowcomms_nodes_set_mark(int nodeid, unsigned int mark) in dlm_lowcomms_nodes_set_mark() argument
580 na = find_node_addr(nodeid); in dlm_lowcomms_nodes_set_mark()
608 con->nodeid, dlm_config.ci_tcp_port, in lowcomms_error_report()
616 con->nodeid, &sin4->sin_addr.s_addr, in lowcomms_error_report()
625 con->nodeid, sin6->sin6_addr.s6_addr32[0], in lowcomms_error_report()
783 log_print("canceled swork for node %d", con->nodeid); in close_connection()
787 log_print("canceled rwork for node %d", con->nodeid); in close_connection()
935 ret = dlm_process_incoming_buffer(con->nodeid, con->rx_buf, buflen); in receive_from_sock()
950 dlm_midcomms_receive_done(con->nodeid); in receive_from_sock()
963 con, con->nodeid); in receive_from_sock()
993 int nodeid; in accept_from_sock() local
1015 if (addr_to_nodeid(&peeraddr, &nodeid, &mark)) { in accept_from_sock()
1024 log_print("got connection from %d", nodeid); in accept_from_sock()
1032 newcon = nodeid2con(nodeid, GFP_NOFS); in accept_from_sock()
1055 result = dlm_con_init(othercon, nodeid); in accept_from_sock()
1293 struct dlm_msg *dlm_lowcomms_new_msg(int nodeid, int len, gfp_t allocation, in dlm_lowcomms_new_msg() argument
1310 con = nodeid2con(nodeid, allocation); in dlm_lowcomms_new_msg()
1477 int dlm_lowcomms_close(int nodeid) in dlm_lowcomms_close() argument
1483 log_print("closing connection to node %d", nodeid); in dlm_lowcomms_close()
1485 con = nodeid2con(nodeid, 0); in dlm_lowcomms_close()
1496 na = find_node_addr(nodeid); in dlm_lowcomms_close()
1534 log_print("node %d already connected.", con->nodeid); in dlm_connect()
1539 result = nodeid_to_addr(con->nodeid, &addr, NULL, in dlm_connect()
1542 log_print("no address for nodeid %d", con->nodeid); in dlm_connect()
1561 log_print_ratelimited("connecting to %d", con->nodeid); in dlm_connect()
1583 log_print("connect %d try %d error %d", con->nodeid, in dlm_connect()
1601 dlm_midcomms_unack_msg_resend(con->nodeid); in process_send_sockets()
1911 log_print("successful connected to node %d", con->nodeid); in dlm_sctp_connect()