Lines Matching refs:nodeid
71 uint32_t nodeid; /* So we know who we are in the list */ member
153 int nodeid; member
270 static struct connection *__find_con(int nodeid, int r) in __find_con() argument
275 if (con->nodeid == nodeid) in __find_con()
282 static void dlm_con_init(struct connection *con, int nodeid) in dlm_con_init() argument
284 con->nodeid = nodeid; in dlm_con_init()
298 static struct connection *nodeid2con(int nodeid, gfp_t alloc) in nodeid2con() argument
303 r = nodeid_hash(nodeid); in nodeid2con()
304 con = __find_con(nodeid, r); in nodeid2con()
312 dlm_con_init(con, nodeid); in nodeid2con()
321 tmp = __find_con(nodeid, r); in nodeid2con()
362 static int nodeid_to_addr(int nodeid, struct sockaddr_storage *sas_out, in nodeid_to_addr() argument
374 con = nodeid2con(nodeid, 0); in nodeid_to_addr()
421 static int addr_to_nodeid(struct sockaddr_storage *addr, int *nodeid, in addr_to_nodeid() argument
435 *nodeid = con->nodeid; in addr_to_nodeid()
463 int dlm_lowcomms_addr(int nodeid, struct sockaddr_storage *addr) in dlm_lowcomms_addr() argument
470 con = nodeid2con(nodeid, GFP_NOFS); in dlm_lowcomms_addr()
548 int dlm_lowcomms_connect_node(int nodeid) in dlm_lowcomms_connect_node() argument
554 con = nodeid2con(nodeid, 0); in dlm_lowcomms_connect_node()
573 int dlm_lowcomms_nodes_set_mark(int nodeid, unsigned int mark) in dlm_lowcomms_nodes_set_mark() argument
579 con = nodeid2con(nodeid, 0); in dlm_lowcomms_nodes_set_mark()
603 con->nodeid, &inet->inet_daddr, in lowcomms_error_report()
612 con->nodeid, &sk->sk_v6_daddr, in lowcomms_error_report()
626 dlm_midcomms_unack_msg_resend(con->nodeid); in lowcomms_error_report()
836 static struct processqueue_entry *new_processqueue_entry(int nodeid, in new_processqueue_entry() argument
851 pentry->nodeid = nodeid; in new_processqueue_entry()
880 dlm_process_incoming_buffer(pentry->nodeid, pentry->buf, in process_dlm_messages()
908 pentry = new_processqueue_entry(con->nodeid, buflen); in receive_from_sock()
926 trace_dlm_recv(con->nodeid, ret); in receive_from_sock()
949 ret = dlm_validate_incoming_buffer(con->nodeid, pentry->buf, in receive_from_sock()
985 int len, idx, result, nodeid; in accept_from_sock() local
1006 if (addr_to_nodeid(&peeraddr, &nodeid, &mark)) { in accept_from_sock()
1033 log_print("got connection from %d", nodeid); in accept_from_sock()
1041 newcon = nodeid2con(nodeid, 0); in accept_from_sock()
1064 dlm_con_init(othercon, nodeid); in accept_from_sock()
1260 struct dlm_msg *dlm_lowcomms_new_msg(int nodeid, int len, char **ppc, in dlm_lowcomms_new_msg() argument
1276 con = nodeid2con(nodeid, 0); in dlm_lowcomms_new_msg()
1388 trace_dlm_send(con->nodeid, ret); in send_to_sock()
1444 int dlm_lowcomms_close(int nodeid) in dlm_lowcomms_close() argument
1449 log_print("closing connection to node %d", nodeid); in dlm_lowcomms_close()
1452 con = nodeid2con(nodeid, 0); in dlm_lowcomms_close()
1459 log_print("io handling for node: %d stopped", nodeid); in dlm_lowcomms_close()
1478 log_print("closing connection to node %d done", nodeid); in dlm_lowcomms_close()
1576 result = nodeid_to_addr(con->nodeid, &addr, NULL, in dlm_connect()
1579 log_print("no address for nodeid %d", con->nodeid); in dlm_connect()
1600 log_print_ratelimited("connecting to %d", con->nodeid); in dlm_connect()
1640 con->nodeid, con->retries++, ret); in process_send_sockets()