fs/dlm/lowcomms.c

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;
164 	int (*connect)(struct connection *con, struct socket *sock,
216 static void lowcomms_queue_swork(struct connection *con)
226 static void lowcomms_queue_rwork(struct connection *con)
256 static struct writequeue_entry *con_next_wq(struct connection *con)
271 static struct connection *__find_con(int nodeid, int r)
273 	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;
451 static bool dlm_lowcomms_con_has_addr(const struct connection *con,
466 	struct connection *con;
508 	struct connection *con = sock2con(sk);
518 	struct connection *con = sock2con(sk);
534 	/* SCTP layer is not calling sk_data_ready when the connection
550 	struct connection *con;
575 	struct connection *con;
594 	struct connection *con = sock2con(sk);
645 static void add_sock(struct socket *sock, struct connection *con)
727 static void allow_connection_io(struct connection *con)
734 static void stop_connection_io(struct connection *con)
755 /* Close a remote connection and tidy up */
756 static void close_connection(struct connection *con, bool and_other)
799 static void shutdown_connection(struct connection *con, bool and_other)
907 static int receive_from_sock(struct connection *con, int buflen)
987 /* Listening socket is busy, accept a connection */
992 	struct connection *newcon;
1039 	log_print("got connection from %d", nodeid);
1041 	/*  Check to see if we already have a connection to this node. This
1042 	 *  could happen if the two nodes initiate a connection at roughly
1058 		struct connection *othercon = newcon->othercon;
1171 static struct writequeue_entry *new_writequeue_entry(struct connection *con)
1195 static struct writequeue_entry *new_wq_entry(struct connection *con, int len,
1234 static struct dlm_msg *dlm_lowcomms_new_msg_con(struct connection *con, int len,
1269 	struct connection *con;
1305 	struct connection *con = e->con;
1369 static int send_to_sock(struct connection *con)
1428 static void clean_one_writequeue(struct connection *con)
1441 	struct connection *con = container_of(rcu, struct connection, rcu);
1452 	struct connection *con;
1455 	log_print("closing connection to node %d", nodeid);
1484 	log_print("closing connection to node %d done", nodeid);
1492 	struct connection *con = container_of(work, struct connection, rwork);
1571 		log_print("critical error accepting connection: %d", ret);
1574 static int dlm_connect(struct connection *con)
1629 	struct connection *con = container_of(work, struct connection, swork);
1644 				/* avoid spamming resched on connection
1733 	struct connection *con;
1840 static int dlm_tcp_connect(struct connection *con, struct socket *sock,
1895 static int dlm_sctp_connect(struct connection *con, struct socket *sock,
2002 	struct connection *con;