Lines Matching defs:conn
45 ksocknal_queue_tx_msg_v1(ksock_conn_t *conn, ksock_tx_t *tx_msg)
48 list_add_tail(&tx_msg->tx_list, &conn->ksnc_tx_queue);
53 ksocknal_next_tx_carrier(ksock_conn_t *conn)
55 ksock_tx_t *tx = conn->ksnc_tx_carrier;
57 /* Called holding BH lock: conn->ksnc_scheduler->kss_lock */
58 LASSERT (!list_empty(&conn->ksnc_tx_queue));
62 if (tx->tx_list.next == &conn->ksnc_tx_queue) {
64 conn->ksnc_tx_carrier = NULL;
66 conn->ksnc_tx_carrier = list_entry(tx->tx_list.next,
68 LASSERT (conn->ksnc_tx_carrier->tx_msg.ksm_type == tx->tx_msg.ksm_type);
73 ksocknal_queue_tx_zcack_v2(ksock_conn_t *conn,
76 ksock_tx_t *tx = conn->ksnc_tx_carrier;
91 &conn->ksnc_tx_queue);
92 conn->ksnc_tx_carrier = tx_ack;
101 &conn->ksnc_tx_queue);
114 ksocknal_next_tx_carrier(conn);
120 ksocknal_queue_tx_msg_v2(ksock_conn_t *conn, ksock_tx_t *tx_msg)
122 ksock_tx_t *tx = conn->ksnc_tx_carrier;
132 list_add_tail(&tx_msg->tx_list, &conn->ksnc_tx_queue);
133 conn->ksnc_tx_carrier = tx_msg;
138 list_add_tail(&tx_msg->tx_list, &conn->ksnc_tx_queue);
146 ksocknal_next_tx_carrier(conn);
156 ksocknal_queue_tx_zcack_v3(ksock_conn_t *conn,
161 if (conn->ksnc_type != SOCKLND_CONN_ACK)
162 return ksocknal_queue_tx_zcack_v2(conn, tx_ack, cookie);
168 tx = conn->ksnc_tx_carrier;
172 &conn->ksnc_tx_queue);
173 conn->ksnc_tx_carrier = tx_ack;
178 /* conn->ksnc_tx_carrier != NULL */
196 libcfs_id2str(conn->ksnc_peer->ksnp_id), cookie);
211 ksocknal_next_tx_carrier(conn);
248 libcfs_id2str(conn->ksnc_peer->ksnp_id), cookie);
265 list_add_tail(&tx_ack->tx_list, &conn->ksnc_tx_queue);
267 ksocknal_next_tx_carrier(conn);
274 ksocknal_match_tx(ksock_conn_t *conn, ksock_tx_t *tx, int nonblk)
288 ((conn->ksnc_proto == &ksocknal_protocol_v1x) ?
293 switch (conn->ksnc_type) {
295 CERROR("ksnc_type bad: %u\n", conn->ksnc_type);
318 ksocknal_match_tx_v3(ksock_conn_t *conn, ksock_tx_t *tx, int nonblk)
327 switch (conn->ksnc_type) {
329 CERROR("ksnc_type bad: %u\n", conn->ksnc_type);
365 ksock_conn_t *conn;
371 conn = ksocknal_find_conn_locked(peer, NULL, !!remote);
372 if (conn != NULL) {
373 ksock_sched_t *sched = conn->ksnc_scheduler;
375 LASSERT(conn->ksnc_proto->pro_queue_tx_zcack != NULL);
379 rc = conn->ksnc_proto->pro_queue_tx_zcack(conn, NULL, cookie);
406 ksocknal_handle_zcack(ksock_conn_t *conn, __u64 cookie1, __u64 cookie2)
408 ksock_peer_t *peer = conn->ksnc_peer;
420 conn->ksnc_proto == &ksocknal_protocol_v3x) {
453 ksocknal_send_hello_v1 (ksock_conn_t *conn, ksock_hello_msg_t *hello)
455 struct socket *sock = conn->ksnc_sock;
503 rc, &conn->ksnc_ipaddr, conn->ksnc_port);
520 &conn->ksnc_ipaddr, conn->ksnc_port);
529 ksocknal_send_hello_v2 (ksock_conn_t *conn, ksock_hello_msg_t *hello)
531 struct socket *sock = conn->ksnc_sock;
535 hello->kshm_version = conn->ksnc_proto->pro_version;
552 rc, &conn->ksnc_ipaddr, conn->ksnc_port);
565 &conn->ksnc_ipaddr, conn->ksnc_port);
572 ksocknal_recv_hello_v1(ksock_conn_t *conn, ksock_hello_msg_t *hello,
575 struct socket *sock = conn->ksnc_sock;
591 rc, &conn->ksnc_ipaddr);
601 &conn->ksnc_ipaddr);
615 hello->kshm_nips, &conn->ksnc_ipaddr);
627 rc, &conn->ksnc_ipaddr);
637 i, &conn->ksnc_ipaddr);
649 ksocknal_recv_hello_v2 (ksock_conn_t *conn, ksock_hello_msg_t *hello, int timeout)
651 struct socket *sock = conn->ksnc_sock;
656 conn->ksnc_flip = 0;
658 conn->ksnc_flip = 1;
666 rc, &conn->ksnc_ipaddr);
671 if (conn->ksnc_flip) {
684 hello->kshm_nips, &conn->ksnc_ipaddr);
695 rc, &conn->ksnc_ipaddr);
701 if (conn->ksnc_flip)
706 i, &conn->ksnc_ipaddr);