Lines Matching refs:nodeid

70 	uint32_t nodeid;	/* So we know who we are in the list */  member
152 int nodeid; member
267 static struct connection *__find_con(int nodeid, int r) in __find_con() argument
272 if (con->nodeid == nodeid) in __find_con()
279 static void dlm_con_init(struct connection *con, int nodeid) in dlm_con_init() argument
281 con->nodeid = nodeid; in dlm_con_init()
295 static struct connection *nodeid2con(int nodeid, gfp_t alloc) in nodeid2con() argument
300 r = nodeid_hash(nodeid); in nodeid2con()
301 con = __find_con(nodeid, r); in nodeid2con()
309 dlm_con_init(con, nodeid); in nodeid2con()
318 tmp = __find_con(nodeid, r); in nodeid2con()
359 static int nodeid_to_addr(int nodeid, struct sockaddr_storage *sas_out, in nodeid_to_addr() argument
371 con = nodeid2con(nodeid, 0); in nodeid_to_addr()
418 static int addr_to_nodeid(struct sockaddr_storage *addr, int *nodeid, in addr_to_nodeid() argument
432 *nodeid = con->nodeid; in addr_to_nodeid()
460 int dlm_lowcomms_addr(int nodeid, struct sockaddr_storage *addr, int len) in dlm_lowcomms_addr() argument
466 con = nodeid2con(nodeid, GFP_NOFS); in dlm_lowcomms_addr()
544 int dlm_lowcomms_connect_node(int nodeid) in dlm_lowcomms_connect_node() argument
550 con = nodeid2con(nodeid, 0); in dlm_lowcomms_connect_node()
569 int dlm_lowcomms_nodes_set_mark(int nodeid, unsigned int mark) in dlm_lowcomms_nodes_set_mark() argument
575 con = nodeid2con(nodeid, 0); in dlm_lowcomms_nodes_set_mark()
599 con->nodeid, &inet->inet_daddr, in lowcomms_error_report()
608 con->nodeid, &sk->sk_v6_daddr, in lowcomms_error_report()
622 dlm_midcomms_unack_msg_resend(con->nodeid); in lowcomms_error_report()
832 static struct processqueue_entry *new_processqueue_entry(int nodeid, in new_processqueue_entry() argument
847 pentry->nodeid = nodeid; in new_processqueue_entry()
858 int nodeid; member
880 dlm_process_incoming_buffer(pentry->nodeid, pentry->buf, in process_dlm_messages()
906 pentry = new_processqueue_entry(con->nodeid, buflen); in receive_from_sock()
924 trace_dlm_recv(con->nodeid, ret); in receive_from_sock()
947 ret = dlm_validate_incoming_buffer(con->nodeid, pentry->buf, in receive_from_sock()
979 int len, idx, result, nodeid; in accept_from_sock() local
1000 if (addr_to_nodeid(&peeraddr, &nodeid, &mark)) { in accept_from_sock()
1027 log_print("got connection from %d", nodeid); in accept_from_sock()
1035 newcon = nodeid2con(nodeid, 0); in accept_from_sock()
1058 dlm_con_init(othercon, nodeid); in accept_from_sock()
1255 struct dlm_msg *dlm_lowcomms_new_msg(int nodeid, int len, gfp_t allocation, in dlm_lowcomms_new_msg() argument
1272 con = nodeid2con(nodeid, 0); in dlm_lowcomms_new_msg()
1384 trace_dlm_send(con->nodeid, ret); in send_to_sock()
1440 int dlm_lowcomms_close(int nodeid) in dlm_lowcomms_close() argument
1445 log_print("closing connection to node %d", nodeid); in dlm_lowcomms_close()
1448 con = nodeid2con(nodeid, 0); in dlm_lowcomms_close()
1455 log_print("io handling for node: %d stopped", nodeid); in dlm_lowcomms_close()
1474 log_print("closing connection to node %d done", nodeid); in dlm_lowcomms_close()
1556 result = nodeid_to_addr(con->nodeid, &addr, NULL, in dlm_connect()
1559 log_print("no address for nodeid %d", con->nodeid); in dlm_connect()
1580 log_print_ratelimited("connecting to %d", con->nodeid); in dlm_connect()
1628 con->nodeid, con->retries++, ret); in process_send_sockets()