Lines Matching refs:conn
139 struct net *rds_conn_net(struct rds_connection *conn) in rds_conn_net() argument
141 return read_pnet(&conn->c_net); in rds_conn_net()
145 void rds_conn_net_set(struct rds_connection *conn, struct net *net) in rds_conn_net_set() argument
147 write_pnet(&conn->c_net, net); in rds_conn_net_set()
438 int (*conn_alloc)(struct rds_connection *conn, gfp_t gfp);
440 int (*conn_connect)(struct rds_connection *conn);
441 void (*conn_shutdown)(struct rds_connection *conn);
442 void (*xmit_prepare)(struct rds_connection *conn);
443 void (*xmit_complete)(struct rds_connection *conn);
444 int (*xmit)(struct rds_connection *conn, struct rds_message *rm,
446 int (*xmit_rdma)(struct rds_connection *conn, struct rm_rdma_op *op);
447 int (*xmit_atomic)(struct rds_connection *conn, struct rm_atomic_op *op);
448 int (*recv)(struct rds_connection *conn);
455 void (*cm_connect_complete)(struct rds_connection *conn,
614 int rds_cong_get_maps(struct rds_connection *conn);
615 void rds_cong_add_conn(struct rds_connection *conn);
616 void rds_cong_remove_conn(struct rds_connection *conn);
626 struct rds_message *rds_cong_update_alloc(struct rds_connection *conn);
637 void rds_conn_shutdown(struct rds_connection *conn);
638 void rds_conn_destroy(struct rds_connection *conn);
639 void rds_conn_drop(struct rds_connection *conn);
640 void rds_conn_connect_if_down(struct rds_connection *conn);
647 void __rds_conn_error(struct rds_connection *conn, const char *, ...);
648 #define rds_conn_error(conn, fmt...) \ argument
649 __rds_conn_error(conn, KERN_WARNING "RDS: " fmt)
652 rds_conn_transition(struct rds_connection *conn, int old, int new) in rds_conn_transition() argument
654 return atomic_cmpxchg(&conn->c_state, old, new) == old; in rds_conn_transition()
658 rds_conn_state(struct rds_connection *conn) in rds_conn_state() argument
660 return atomic_read(&conn->c_state); in rds_conn_state()
664 rds_conn_up(struct rds_connection *conn) in rds_conn_up() argument
666 return atomic_read(&conn->c_state) == RDS_CONN_UP; in rds_conn_up()
670 rds_conn_connecting(struct rds_connection *conn) in rds_conn_connecting() argument
672 return atomic_read(&conn->c_state) == RDS_CONN_CONNECTING; in rds_conn_connecting()
719 void rds_inc_init(struct rds_incoming *inc, struct rds_connection *conn,
722 void rds_recv_incoming(struct rds_connection *conn, __be32 saddr, __be32 daddr,
734 void rds_send_reset(struct rds_connection *conn);
735 int rds_send_xmit(struct rds_connection *conn);
739 void rds_send_drop_acked(struct rds_connection *conn, u64 ack,
741 int rds_send_pong(struct rds_connection *conn, __be16 dport);
810 void rds_queue_reconnect(struct rds_connection *conn);
815 void rds_connect_complete(struct rds_connection *conn);