Lines Matching refs:connection
103 struct connection { struct
117 int (*rx_action) (struct connection *); /* What to do when active */ argument
118 void (*connect_action) (struct connection *); /* What to do to connect */ argument
124 struct connection *othercon; argument
129 #define sock2con(x) ((struct connection *)(x)->sk_user_data) argument
139 struct connection *con;
177 static struct connection *__find_con(int nodeid) in __find_con()
180 struct connection *con; in __find_con()
195 static struct connection *__nodeid2con(int nodeid, gfp_t alloc) in __nodeid2con()
197 struct connection *con = NULL; in __nodeid2con()
220 struct connection *zerocon = __find_con(0); in __nodeid2con()
231 static void foreach_conn(void (*conn_func)(struct connection *c)) in foreach_conn()
235 struct connection *con; in foreach_conn()
243 static struct connection *nodeid2con(int nodeid, gfp_t allocation) in nodeid2con()
245 struct connection *con; in nodeid2con()
408 struct connection *con = sock2con(sk); in lowcomms_data_ready()
415 struct connection *con = sock2con(sk); in lowcomms_write_space()
431 static inline void lowcomms_connect_sock(struct connection *con) in lowcomms_connect_sock()
456 struct connection *con; in dlm_lowcomms_connect_node()
470 struct connection *con = sock2con(sk); in lowcomms_error_report()
506 static void add_sock(struct socket *sock, struct connection *con) in add_sock()
540 static void close_connection(struct connection *con, bool and_other, in close_connection()
569 static int receive_from_sock(struct connection *con) in receive_from_sock()
673 static int tcp_accept_from_sock(struct connection *con) in tcp_accept_from_sock()
680 struct connection *newcon; in tcp_accept_from_sock()
681 struct connection *addcon; in tcp_accept_from_sock()
743 struct connection *othercon = newcon->othercon; in tcp_accept_from_sock()
803 static int sctp_accept_from_sock(struct connection *con) in sctp_accept_from_sock()
810 struct connection *newcon; in sctp_accept_from_sock()
811 struct connection *addcon; in sctp_accept_from_sock()
856 struct connection *othercon = newcon->othercon; in sctp_accept_from_sock()
944 static int sctp_bind_addrs(struct connection *con, uint16_t port) in sctp_bind_addrs()
976 static void sctp_connect_to_sock(struct connection *con) in sctp_connect_to_sock()
1067 static void tcp_connect_to_sock(struct connection *con) in tcp_connect_to_sock()
1162 static struct socket *tcp_create_listen_sock(struct connection *con, in tcp_create_listen_sock()
1248 struct connection *con = nodeid2con(0, GFP_NOFS); in sctp_listen_for_all()
1303 struct connection *con = nodeid2con(0, GFP_NOFS); in tcp_listen_for_all()
1332 static struct writequeue_entry *new_writequeue_entry(struct connection *con, in new_writequeue_entry()
1358 struct connection *con; in dlm_lowcomms_get_buffer()
1400 struct connection *con = e->con; in dlm_lowcomms_commit_buffer()
1421 static void send_to_sock(struct connection *con) in send_to_sock()
1490 static void clean_one_writequeue(struct connection *con) in clean_one_writequeue()
1506 struct connection *con; in dlm_lowcomms_close()
1533 struct connection *con = container_of(work, struct connection, rwork); in process_recv_sockets()
1545 struct connection *con = container_of(work, struct connection, swork); in process_send_sockets()
1586 static void stop_conn(struct connection *con) in stop_conn()
1593 static void free_conn(struct connection *con) in free_conn()
1626 struct connection *con; in dlm_lowcomms_start()
1640 con_cache = kmem_cache_create("dlm_conn", sizeof(struct connection), in dlm_lowcomms_start()
1641 __alignof__(struct connection), 0, in dlm_lowcomms_start()