Searched refs:ksock_conn_t (Results 1 – 5 of 5) sorted by relevance
| /linux-4.1.27/drivers/staging/lustre/lnet/klnds/socklnd/ |
| D | socklnd.h | 310 } ksock_conn_t; typedef
370 int (*pro_send_hello)(ksock_conn_t *, ksock_hello_msg_t *); /* handshake function */
371 int (*pro_recv_hello)(ksock_conn_t *, ksock_hello_msg_t *, int);/* handshake function */
374 ksock_tx_t *(*pro_queue_tx_msg)(ksock_conn_t *, ksock_tx_t *); /* queue tx on the connection */
375 …int (*pro_queue_tx_zcack)(ksock_conn_t *, ksock_tx_t *, __u64); /* queue ZC ack on the connection…
376 int (*pro_handle_zcreq)(ksock_conn_t *, __u64, int); /* handle ZC request */
377 int (*pro_handle_zcack)(ksock_conn_t *, __u64, __u64); /* handle ZC ACK */
378 int (*pro_match_tx)(ksock_conn_t *, ksock_tx_t *, int); /* msg type matches the connection type:
417 ksocknal_conn_addref(ksock_conn_t *conn) in ksocknal_conn_addref()
423 extern void ksocknal_queue_zombie_conn(ksock_conn_t *conn);
[all …]
|
| D | socklnd_lib-linux.c | 40 ksocknal_lib_get_conn_addrs(ksock_conn_t *conn) in ksocknal_lib_get_conn_addrs()
65 ksocknal_lib_zc_capable(ksock_conn_t *conn) in ksocknal_lib_zc_capable()
78 ksocknal_lib_send_iov(ksock_conn_t *conn, ksock_tx_t *tx) in ksocknal_lib_send_iov()
120 ksocknal_lib_send_kiov(ksock_conn_t *conn, ksock_tx_t *tx) in ksocknal_lib_send_kiov()
188 ksocknal_lib_eager_ack(ksock_conn_t *conn) in ksocknal_lib_eager_ack()
203 ksocknal_lib_recv_iov(ksock_conn_t *conn) in ksocknal_lib_recv_iov()
307 ksocknal_lib_recv_kiov(ksock_conn_t *conn) in ksocknal_lib_recv_kiov()
426 ksocknal_lib_get_conn_tunables(ksock_conn_t *conn, int *txmem, int *rxmem, int *nagle) in ksocknal_lib_get_conn_tunables()
556 ksocknal_lib_push_conn(ksock_conn_t *conn) in ksocknal_lib_push_conn()
587 extern void ksocknal_read_callback(ksock_conn_t *conn);
[all …]
|
| D | socklnd_cb.c | 111 ksocknal_send_iov (ksock_conn_t *conn, ksock_tx_t *tx) in ksocknal_send_iov()
148 ksocknal_send_kiov (ksock_conn_t *conn, ksock_tx_t *tx) in ksocknal_send_kiov()
186 ksocknal_transmit (ksock_conn_t *conn, ksock_tx_t *tx) in ksocknal_transmit()
252 ksocknal_recv_iov (ksock_conn_t *conn) in ksocknal_recv_iov()
297 ksocknal_recv_kiov (ksock_conn_t *conn) in ksocknal_recv_kiov()
341 ksocknal_receive (ksock_conn_t *conn) in ksocknal_receive()
435 ksock_conn_t *conn = tx->tx_conn; in ksocknal_check_zc_req()
503 ksocknal_process_transmit (ksock_conn_t *conn, ksock_tx_t *tx) in ksocknal_process_transmit()
617 ksock_conn_t *
621 ksock_conn_t *conn; in ksocknal_find_conn_locked()
[all …]
|
| D | socklnd_proto.c | 45 ksocknal_queue_tx_msg_v1(ksock_conn_t *conn, ksock_tx_t *tx_msg) in ksocknal_queue_tx_msg_v1()
53 ksocknal_next_tx_carrier(ksock_conn_t *conn) in ksocknal_next_tx_carrier()
73 ksocknal_queue_tx_zcack_v2(ksock_conn_t *conn, in ksocknal_queue_tx_zcack_v2()
120 ksocknal_queue_tx_msg_v2(ksock_conn_t *conn, ksock_tx_t *tx_msg) in ksocknal_queue_tx_msg_v2()
156 ksocknal_queue_tx_zcack_v3(ksock_conn_t *conn, in ksocknal_queue_tx_zcack_v3()
274 ksocknal_match_tx(ksock_conn_t *conn, ksock_tx_t *tx, int nonblk) in ksocknal_match_tx()
318 ksocknal_match_tx_v3(ksock_conn_t *conn, ksock_tx_t *tx, int nonblk) in ksocknal_match_tx_v3()
362 ksocknal_handle_zcreq(ksock_conn_t *c, __u64 cookie, int remote) in ksocknal_handle_zcreq()
365 ksock_conn_t *conn; in ksocknal_handle_zcreq()
406 ksocknal_handle_zcack(ksock_conn_t *conn, __u64 cookie1, __u64 cookie2) in ksocknal_handle_zcack()
[all …]
|
| D | socklnd.c | 323 ksocknal_associate_route_conn_locked(ksock_route_t *route, ksock_conn_t *conn) in ksocknal_associate_route_conn_locked()
370 ksock_conn_t *conn; in ksocknal_add_route_locked()
397 conn = list_entry(tmp, ksock_conn_t, ksnc_list); in ksocknal_add_route_locked()
412 ksock_conn_t *conn; in ksocknal_del_route_locked()
420 conn = list_entry(ctmp, ksock_conn_t, ksnc_list); in ksocknal_del_route_locked()
512 ksock_conn_t *conn; in ksocknal_del_peer_locked()
554 conn = list_entry(tmp, ksock_conn_t, ksnc_list); in ksocknal_del_peer_locked()
623 static ksock_conn_t *
628 ksock_conn_t *conn; in ksocknal_get_conn_by_idx()
647 conn = list_entry(ctmp, ksock_conn_t, in ksocknal_get_conn_by_idx()
[all …]
|