Lines Matching refs:conn

77 static inline bool smc_cdc_rxed_any_close(struct smc_connection *conn)  in smc_cdc_rxed_any_close()  argument
79 return conn->local_rx_ctrl.conn_state_flags.peer_conn_abort || in smc_cdc_rxed_any_close()
80 conn->local_rx_ctrl.conn_state_flags.peer_conn_closed; in smc_cdc_rxed_any_close()
84 struct smc_connection *conn) in smc_cdc_rxed_any_close_or_senddone() argument
86 return smc_cdc_rxed_any_close(conn) || in smc_cdc_rxed_any_close_or_senddone()
87 conn->local_rx_ctrl.conn_state_flags.peer_done_writing; in smc_cdc_rxed_any_close_or_senddone()
103 struct smc_connection *conn) in smc_curs_copy() argument
108 spin_lock_irqsave(&conn->acurs_lock, flags); in smc_curs_copy()
110 spin_unlock_irqrestore(&conn->acurs_lock, flags); in smc_curs_copy()
118 struct smc_connection *conn) in smc_curs_copy_net() argument
123 spin_lock_irqsave(&conn->acurs_lock, flags); in smc_curs_copy_net()
125 spin_unlock_irqrestore(&conn->acurs_lock, flags); in smc_curs_copy_net()
133 struct smc_connection *conn) in smcd_curs_copy() argument
138 spin_lock_irqsave(&conn->acurs_lock, flags); in smcd_curs_copy()
140 spin_unlock_irqrestore(&conn->acurs_lock, flags); in smcd_curs_copy()
198 struct smc_connection *conn) in smc_host_cursor_to_cdc() argument
200 smc_curs_copy(save, local, conn); in smc_host_cursor_to_cdc()
207 struct smc_connection *conn, in smc_host_msg_to_cdc() argument
210 struct smc_host_cdc_msg *local = &conn->local_tx_ctrl; in smc_host_msg_to_cdc()
216 smc_host_cursor_to_cdc(&peer->prod, &local->prod, save, conn); in smc_host_msg_to_cdc()
217 smc_host_cursor_to_cdc(&peer->cons, &local->cons, save, conn); in smc_host_msg_to_cdc()
224 struct smc_connection *conn) in smc_cdc_cursor_to_host() argument
229 smc_curs_copy(&old, local, conn); in smc_cdc_cursor_to_host()
230 smc_curs_copy_net(&net, peer, conn); in smc_cdc_cursor_to_host()
238 smc_curs_copy(local, &temp, conn); in smc_cdc_cursor_to_host()
243 struct smc_connection *conn) in smcr_cdc_msg_to_host() argument
249 smc_cdc_cursor_to_host(&local->prod, &peer->prod, conn); in smcr_cdc_msg_to_host()
250 smc_cdc_cursor_to_host(&local->cons, &peer->cons, conn); in smcr_cdc_msg_to_host()
257 struct smc_connection *conn) in smcd_cdc_msg_to_host() argument
263 smc_curs_copy(&local->prod, &temp, conn); in smcd_cdc_msg_to_host()
267 smc_curs_copy(&local->cons, &temp, conn); in smcd_cdc_msg_to_host()
274 struct smc_connection *conn) in smc_cdc_msg_to_host() argument
276 if (conn->lgr->is_smcd) in smc_cdc_msg_to_host()
277 smcd_cdc_msg_to_host(local, (struct smcd_cdc_msg *)peer, conn); in smc_cdc_msg_to_host()
279 smcr_cdc_msg_to_host(local, peer, conn); in smc_cdc_msg_to_host()
283 struct smc_connection *conn; /* socket connection */ member
289 int smc_cdc_get_free_slot(struct smc_connection *conn,
294 void smc_cdc_wait_pend_tx_wr(struct smc_connection *conn);
295 int smc_cdc_msg_send(struct smc_connection *conn, struct smc_wr_buf *wr_buf,
297 int smc_cdc_get_slot_and_msg_send(struct smc_connection *conn);
298 int smcd_cdc_msg_send(struct smc_connection *conn);
299 int smcr_cdc_msg_send_validation(struct smc_connection *conn,
303 void smcd_cdc_rx_init(struct smc_connection *conn);