Lines Matching defs:connection

69 struct connection {
92 	 * connection attempt second connection for one node.
102 	struct connection *othercon;
115 #define sock2con(x) ((struct connection *)(x)->sk_user_data)
134 	struct connection *con;
215 static void lowcomms_queue_swork(struct connection *con)
225 static void lowcomms_queue_rwork(struct connection *con)
255 static struct writequeue_entry *con_next_wq(struct connection *con)
270 static struct connection *__find_con(int nodeid, int r)
272 	struct connection *con;
283 static void dlm_con_init(struct connection *con, int nodeid)
297  * connection structure for this node.
299 static struct connection *nodeid2con(int nodeid, gfp_t alloc)
301 	struct connection *con, *tmp;
320 	 * abort our connection creation and return the existing connection.
368 	struct connection *con;
425 	struct connection *con;
452 static bool dlm_lowcomms_con_has_addr(const struct connection *con,
467 	struct connection *con;
510 	struct connection *con = sock2con(sk);
520 	struct connection *con = sock2con(sk);
536 	/* SCTP layer is not calling sk_data_ready when the connection
552 	struct connection *con;
577 	struct connection *con;
596 	struct connection *con = sock2con(sk);
647 static void add_sock(struct socket *sock, struct connection *con)
729 static void allow_connection_io(struct connection *con)
736 static void stop_connection_io(struct connection *con)
757 /* Close a remote connection and tidy up */
758 static void close_connection(struct connection *con, bool and_other)
801 static void shutdown_connection(struct connection *con, bool and_other)
903 static int receive_from_sock(struct connection *con, int buflen)
983 /* Listening socket is busy, accept a connection */
988 	struct connection *newcon;
1035 	log_print("got connection from %d", nodeid);
1037 	/*  Check to see if we already have a connection to this node. This
1038 	 *  could happen if the two nodes initiate a connection at roughly
1054 		struct connection *othercon = newcon->othercon;
1167 static struct writequeue_entry *new_writequeue_entry(struct connection *con)
1191 static struct writequeue_entry *new_wq_entry(struct connection *con, int len,
1230 static struct dlm_msg *dlm_lowcomms_new_msg_con(struct connection *con, int len,
1265 	struct connection *con;
1301 	struct connection *con = e->con;
1365 static int send_to_sock(struct connection *con)
1424 static void clean_one_writequeue(struct connection *con)
1437 	struct connection *con = container_of(rcu, struct connection, rcu);
1448 	struct connection *con;
1451 	log_print("closing connection to node %d", nodeid);
1480 	log_print("closing connection to node %d done", nodeid);
1488 	struct connection *con = container_of(work, struct connection, rwork);
1567 		log_print("critical error accepting connection: %d", ret);
1570 static int dlm_connect(struct connection *con)
1624 	struct connection *con = container_of(work, struct connection, swork);
1721 	struct connection *con;
1969 	struct connection *con;