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
125 struct connection *othercon; argument
130 #define sock2con(x) ((struct connection *)(x)->sk_user_data) argument
140 struct connection *con;
178 static struct connection *__find_con(int nodeid) in __find_con()
181 struct connection *con; in __find_con()
196 static struct connection *__nodeid2con(int nodeid, gfp_t alloc) in __nodeid2con()
198 struct connection *con = NULL; in __nodeid2con()
221 struct connection *zerocon = __find_con(0); in __nodeid2con()
232 static void foreach_conn(void (*conn_func)(struct connection *c)) in foreach_conn()
236 struct connection *con; in foreach_conn()
244 static struct connection *nodeid2con(int nodeid, gfp_t allocation) in nodeid2con()
246 struct connection *con; in nodeid2con()
256 static struct connection *assoc2con(int assoc_id) in assoc2con()
259 struct connection *con; in assoc2con()
429 struct connection *con = sock2con(sk); in lowcomms_data_ready()
436 struct connection *con = sock2con(sk); in lowcomms_write_space()
452 static inline void lowcomms_connect_sock(struct connection *con) in lowcomms_connect_sock()
468 struct connection *con; in dlm_lowcomms_connect_node()
485 static void add_sock(struct socket *sock, struct connection *con) in add_sock()
517 static void close_connection(struct connection *con, bool and_other) in close_connection()
546 struct connection *con; in sctp_send_shutdown()
574 static void sctp_init_failed_foreach(struct connection *con) in sctp_init_failed_foreach()
609 static void retry_failed_sctp_send(struct connection *recv_con, in retry_failed_sctp_send()
615 struct connection *con; in retry_failed_sctp_send()
653 static void process_sctp_notification(struct connection *con, in process_sctp_notification()
673 struct connection *new_con; in process_sctp_notification()
787 static int receive_from_sock(struct connection *con) in receive_from_sock()
906 static int tcp_accept_from_sock(struct connection *con) in tcp_accept_from_sock()
913 struct connection *newcon; in tcp_accept_from_sock()
914 struct connection *addcon; in tcp_accept_from_sock()
976 struct connection *othercon = newcon->othercon; in tcp_accept_from_sock()
1065 static void sctp_init_assoc(struct connection *con) in sctp_init_assoc()
1072 struct connection *base_con; in sctp_init_assoc()
1154 static void tcp_connect_to_sock(struct connection *con) in tcp_connect_to_sock()
1247 static struct socket *tcp_create_listen_sock(struct connection *con, in tcp_create_listen_sock()
1330 static int add_sctp_bind_addr(struct connection *sctp_con, in add_sctp_bind_addr()
1359 struct connection *con = nodeid2con(0, GFP_NOFS); in sctp_listen_for_all()
1437 struct connection *con = nodeid2con(0, GFP_NOFS); in tcp_listen_for_all()
1466 static struct writequeue_entry *new_writequeue_entry(struct connection *con, in new_writequeue_entry()
1492 struct connection *con; in dlm_lowcomms_get_buffer()
1534 struct connection *con = e->con; in dlm_lowcomms_commit_buffer()
1555 static void send_to_sock(struct connection *con) in send_to_sock()
1625 static void clean_one_writequeue(struct connection *con) in clean_one_writequeue()
1641 struct connection *con; in dlm_lowcomms_close()
1674 struct connection *con = container_of(work, struct connection, rwork); in process_recv_sockets()
1686 struct connection *con = container_of(work, struct connection, swork); in process_send_sockets()
1729 static void stop_conn(struct connection *con) in stop_conn()
1736 static void free_conn(struct connection *con) in free_conn()
1769 struct connection *con; in dlm_lowcomms_start()
1783 con_cache = kmem_cache_create("dlm_conn", sizeof(struct connection), in dlm_lowcomms_start()
1784 __alignof__(struct connection), 0, in dlm_lowcomms_start()