Lines Matching defs:connection
68 struct connection {
83 int (*rx_action) (struct connection *); /* What to do when active */
84 void (*connect_action) (struct connection *); /* What to do to connect */
85 void (*shutdown_action)(struct connection *con); /* What to do to shutdown */
89 struct connection *othercon;
98 #define sock2con(x) ((struct connection *)(x)->sk_user_data)
108 struct connection *con;
146 sequential nodeids, so we should be able to go straight to a connection
153 static struct connection *__find_con(int nodeid)
156 struct connection *con;
174 * connection structure for this node.
176 static struct connection *nodeid2con(int nodeid, gfp_t alloc)
178 struct connection *con, *tmp;
206 struct connection *zerocon = __find_con(0);
220 * abort our connection creation and return the existing connection.
237 static void foreach_conn(void (*conn_func)(struct connection *c))
240 struct connection *con;
404 struct connection *con;
415 struct connection *con;
434 static inline void lowcomms_connect_sock(struct connection *con)
444 /* SCTP layer is not calling sk_data_ready when the connection
459 struct connection *con;
473 struct connection *con;
542 static void add_sock(struct socket *sock, struct connection *con)
578 /* Close a remote connection and tidy up */
579 static void close_connection(struct connection *con, bool and_other,
610 static void shutdown_connection(struct connection *con)
648 static void dlm_tcp_shutdown(struct connection *con)
655 static int con_realloc_receive_buf(struct connection *con, int newlen)
676 static int receive_from_sock(struct connection *con)
753 log_print("connection %p got EOF from %d",
765 /* Listening socket is busy, accept a connection */
766 static int accept_from_sock(struct connection *con)
773 struct connection *newcon;
774 struct connection *addcon;
815 log_print("got connection from %d", nodeid);
817 /* Check to see if we already have a connection to this node. This
818 * could happen if the two nodes initiate a connection at roughly
829 struct connection *othercon = newcon->othercon;
898 log_print("error accepting connection from node: %d", result);
929 static int sctp_bind_addrs(struct connection *con, uint16_t port)
958 static void sctp_connect_to_sock(struct connection *con)
1056 static void tcp_connect_to_sock(struct connection *con)
1152 static struct socket *tcp_create_listen_sock(struct connection *con,
1241 struct connection *con = nodeid2con(0, GFP_NOFS);
1292 struct connection *con = nodeid2con(0, GFP_NOFS);
1321 static struct writequeue_entry *new_writequeue_entry(struct connection *con,
1347 struct connection *con;
1389 struct connection *con = e->con;
1408 static void send_to_sock(struct connection *con)
1470 a new connection, then call this function again. */
1480 static void clean_one_writequeue(struct connection *con)
1496 struct connection *con;
1499 log_print("closing connection to node %d", nodeid);
1523 struct connection *con = container_of(work, struct connection, rwork);
1535 struct connection *con = container_of(work, struct connection, swork);
1572 static void _stop_conn(struct connection *con, bool and_other)
1588 static void stop_conn(struct connection *con)
1593 static void shutdown_conn(struct connection *con)
1601 struct connection *con = container_of(rcu, struct connection, rcu);
1607 static void free_conn(struct connection *con)
1625 struct connection *con;
1674 struct connection *con;