Lines Matching refs:nodeid
71 uint32_t nodeid; /* So we know who we are in the list */ member
153 int nodeid; member
269 static struct connection *__find_con(int nodeid, int r) in __find_con() argument
274 if (con->nodeid == nodeid) in __find_con()
281 static void dlm_con_init(struct connection *con, int nodeid) in dlm_con_init() argument
283 con->nodeid = nodeid; in dlm_con_init()
297 static struct connection *nodeid2con(int nodeid, gfp_t alloc) in nodeid2con() argument
302 r = nodeid_hash(nodeid); in nodeid2con()
303 con = __find_con(nodeid, r); in nodeid2con()
311 dlm_con_init(con, nodeid); in nodeid2con()
320 tmp = __find_con(nodeid, r); in nodeid2con()
361 static int nodeid_to_addr(int nodeid, struct sockaddr_storage *sas_out, in nodeid_to_addr() argument
373 con = nodeid2con(nodeid, 0); in nodeid_to_addr()
420 static int addr_to_nodeid(struct sockaddr_storage *addr, int *nodeid, in addr_to_nodeid() argument
434 *nodeid = con->nodeid; in addr_to_nodeid()
462 int dlm_lowcomms_addr(int nodeid, struct sockaddr_storage *addr) in dlm_lowcomms_addr() argument
469 con = nodeid2con(nodeid, GFP_NOFS); in dlm_lowcomms_addr()
547 int dlm_lowcomms_connect_node(int nodeid) in dlm_lowcomms_connect_node() argument
553 con = nodeid2con(nodeid, 0); in dlm_lowcomms_connect_node()
572 int dlm_lowcomms_nodes_set_mark(int nodeid, unsigned int mark) in dlm_lowcomms_nodes_set_mark() argument
578 con = nodeid2con(nodeid, 0); in dlm_lowcomms_nodes_set_mark()
602 con->nodeid, &inet->inet_daddr, in lowcomms_error_report()
611 con->nodeid, &sk->sk_v6_daddr, in lowcomms_error_report()
625 dlm_midcomms_unack_msg_resend(con->nodeid); in lowcomms_error_report()
835 static struct processqueue_entry *new_processqueue_entry(int nodeid, in new_processqueue_entry() argument
850 pentry->nodeid = nodeid; in new_processqueue_entry()
879 dlm_process_incoming_buffer(pentry->nodeid, pentry->buf, in process_dlm_messages()
907 pentry = new_processqueue_entry(con->nodeid, buflen); in receive_from_sock()
925 trace_dlm_recv(con->nodeid, ret); in receive_from_sock()
948 ret = dlm_validate_incoming_buffer(con->nodeid, pentry->buf, in receive_from_sock()
984 int len, idx, result, nodeid; in accept_from_sock() local
1005 if (addr_to_nodeid(&peeraddr, &nodeid, &mark)) { in accept_from_sock()
1032 log_print("got connection from %d", nodeid); in accept_from_sock()
1040 newcon = nodeid2con(nodeid, 0); in accept_from_sock()
1063 dlm_con_init(othercon, nodeid); in accept_from_sock()
1259 struct dlm_msg *dlm_lowcomms_new_msg(int nodeid, int len, char **ppc, in dlm_lowcomms_new_msg() argument
1275 con = nodeid2con(nodeid, 0); in dlm_lowcomms_new_msg()
1387 trace_dlm_send(con->nodeid, ret); in send_to_sock()
1443 int dlm_lowcomms_close(int nodeid) in dlm_lowcomms_close() argument
1448 log_print("closing connection to node %d", nodeid); in dlm_lowcomms_close()
1451 con = nodeid2con(nodeid, 0); in dlm_lowcomms_close()
1458 log_print("io handling for node: %d stopped", nodeid); in dlm_lowcomms_close()
1477 log_print("closing connection to node %d done", nodeid); in dlm_lowcomms_close()
1575 result = nodeid_to_addr(con->nodeid, &addr, NULL, in dlm_connect()
1578 log_print("no address for nodeid %d", con->nodeid); in dlm_connect()
1599 log_print_ratelimited("connecting to %d", con->nodeid); in dlm_connect()
1639 con->nodeid, con->retries++, ret); in process_send_sockets()