Lines Matching defs:connection
68 struct connection {
91 * connection attempt second connection for one node.
101 struct connection *othercon;
114 #define sock2con(x) ((struct connection *)(x)->sk_user_data)
133 struct connection *con;
163 int (*connect)(struct connection *con, struct socket *sock,
212 static void lowcomms_queue_swork(struct connection *con)
222 static void lowcomms_queue_rwork(struct connection *con)
252 static struct writequeue_entry *con_next_wq(struct connection *con)
267 static struct connection *__find_con(int nodeid, int r)
269 struct connection *con;
279 static void dlm_con_init(struct connection *con, int nodeid)
293 * connection structure for this node.
295 static struct connection *nodeid2con(int nodeid, gfp_t alloc)
297 struct connection *con, *tmp;
316 * abort our connection creation and return the existing connection.
364 struct connection *con;
421 struct connection *con;
447 static bool dlm_lowcomms_con_has_addr(const struct connection *con,
462 struct connection *con;
504 struct connection *con = sock2con(sk);
514 struct connection *con = sock2con(sk);
530 /* SCTP layer is not calling sk_data_ready when the connection
546 struct connection *con;
571 struct connection *con;
590 struct connection *con = sock2con(sk);
641 static void add_sock(struct socket *sock, struct connection *con)
723 static void allow_connection_io(struct connection *con)
730 static void stop_connection_io(struct connection *con)
751 /* Close a remote connection and tidy up */
752 static void close_connection(struct connection *con, bool and_other)
795 static void shutdown_connection(struct connection *con, bool and_other)
899 static int receive_from_sock(struct connection *con, int buflen)
975 /* Listening socket is busy, accept a connection */
980 struct connection *newcon;
1027 log_print("got connection from %d", nodeid);
1029 /* Check to see if we already have a connection to this node. This
1030 * could happen if the two nodes initiate a connection at roughly
1046 struct connection *othercon = newcon->othercon;
1159 static struct writequeue_entry *new_writequeue_entry(struct connection *con)
1183 static struct writequeue_entry *new_wq_entry(struct connection *con, int len,
1222 static struct dlm_msg *dlm_lowcomms_new_msg_con(struct connection *con, int len,
1259 struct connection *con;
1295 struct connection *con = e->con;
1359 static int send_to_sock(struct connection *con)
1418 static void clean_one_writequeue(struct connection *con)
1431 struct connection *con = container_of(rcu, struct connection, rcu);
1442 struct connection *con;
1445 log_print("closing connection to node %d", nodeid);
1474 log_print("closing connection to node %d done", nodeid);
1482 struct connection *con = container_of(work, struct connection, rwork);
1545 log_print("critical error accepting connection: %d", ret);
1548 static int dlm_connect(struct connection *con)
1603 struct connection *con = container_of(work, struct connection, swork);
1618 /* avoid spamming resched on connection
1711 struct connection *con;
1818 static int dlm_tcp_connect(struct connection *con, struct socket *sock,
1873 static int dlm_sctp_connect(struct connection *con, struct socket *sock,
1980 struct connection *con;