net/smc/smc.h

153 struct smc_connection {  struct
154 	struct rb_node		alert_node;
155 	struct smc_link_group	*lgr;		/* link group of connection */
156 	struct smc_link		*lnk;		/* assigned SMC-R link */
157 	u32			alert_token_local; /* unique conn. id */
158 	u8			peer_rmbe_idx;	/* from tcp handshake */
159 	int			peer_rmbe_size;	/* size of peer rx buffer */
160 	atomic_t		peer_rmbe_space;/* remaining free bytes in peer
163 	int			rtoken_idx;	/* idx to peer RMB rkey/addr */
165 	struct smc_buf_desc	*sndbuf_desc;	/* send buffer descriptor */
166 	struct smc_buf_desc	*rmb_desc;	/* RMBE descriptor */
167 	int                     rmbe_size_comp; /* compressed notation */
168 	int			rmbe_update_limit;
173 	struct smc_host_cdc_msg	local_tx_ctrl;	/* host byte order staging
178 	union smc_host_cursor	local_tx_ctrl_fin;
181 	union smc_host_cursor	tx_curs_prep;	/* tx - prepared data
184 	union smc_host_cursor	tx_curs_sent;	/* tx - sent data
187 	union smc_host_cursor	tx_curs_fin;	/* tx - confirmed by peer
190 	atomic_t		sndbuf_space;	/* remaining space in sndbuf */
191 	u16			tx_cdc_seq;	/* sequence # for CDC send */
192 	u16			tx_cdc_seq_fin;	/* sequence # - tx completed */
193 	spinlock_t		send_lock;	/* protect wr_sends */
194 	atomic_t		cdc_pend_tx_wr; /* number of pending tx CDC wqe
198 	wait_queue_head_t	cdc_pend_tx_wq; /* wakeup on no cdc_pend_tx_wr*/
199 	atomic_t		tx_pushing;     /* nr_threads trying tx push */
200 	struct delayed_work	tx_work;	/* retry of smc_cdc_msg_send */
201 	u32			tx_off;		/* base offset in peer rmb */
203 	struct smc_host_cdc_msg	local_rx_ctrl;	/* filled during event_handl.
207 	union smc_host_cursor	rx_curs_confirmed; /* confirmed to peer
210 	union smc_host_cursor	urg_curs;	/* points at urgent byte */
211 	enum smc_urg_state	urg_state;
212 	bool			urg_tx_pend;	/* urgent data staged */
213 	bool			urg_rx_skip_pend;
218 	char			urg_rx_byte;	/* urgent byte */
219 	bool			tx_in_release_sock;
223 	atomic_t		bytes_to_rcv;	/* arrived data,
226 	atomic_t		splice_pending;	/* number of spliced bytes
230 	spinlock_t		acurs_lock;	/* protect cursors */
255 	struct smc_connection	conn;		/* smc connection */  argument