Lines Matching refs:conn
58 struct smc_connection *conn = &smc->conn; in smc_rx_update_consumer() local
63 smc_curs_add(conn->rmb_desc->len, &cons, len); in smc_rx_update_consumer()
66 if (conn->urg_state == SMC_URG_VALID || conn->urg_rx_skip_pend) { in smc_rx_update_consumer()
67 diff = smc_curs_comp(conn->rmb_desc->len, &cons, in smc_rx_update_consumer()
68 &conn->urg_curs); in smc_rx_update_consumer()
73 conn->urg_state = SMC_URG_READ; in smc_rx_update_consumer()
79 smc_curs_add(conn->rmb_desc->len, &cons, 1); in smc_rx_update_consumer()
80 conn->urg_rx_skip_pend = false; in smc_rx_update_consumer()
83 conn->urg_state = SMC_URG_READ; in smc_rx_update_consumer()
87 smc_curs_copy(&conn->local_tx_ctrl.cons, &cons, conn); in smc_rx_update_consumer()
91 smc_tx_consumer_update(conn, force); in smc_rx_update_consumer()
98 struct smc_connection *conn = &smc->conn; in smc_rx_update_cons() local
101 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_update_cons()
115 struct smc_connection *conn; in smc_rx_pipe_buf_release() local
122 conn = &smc->conn; in smc_rx_pipe_buf_release()
126 if (atomic_sub_and_test(priv->len, &conn->splice_pending)) in smc_rx_pipe_buf_release()
158 partial.offset = src - (char *)smc->conn.rmb_desc->cpu_addr; in smc_rx_splice()
164 spd.pages = &smc->conn.rmb_desc->pages; in smc_rx_splice()
172 get_page(smc->conn.rmb_desc->pages); in smc_rx_splice()
173 atomic_add(bytes, &smc->conn.splice_pending); in smc_rx_splice()
179 static int smc_rx_data_available_and_no_splice_pend(struct smc_connection *conn) in smc_rx_data_available_and_no_splice_pend() argument
181 return atomic_read(&conn->bytes_to_rcv) && in smc_rx_data_available_and_no_splice_pend()
182 !atomic_read(&conn->splice_pending); in smc_rx_data_available_and_no_splice_pend()
194 int (*fcrit)(struct smc_connection *conn)) in smc_rx_wait() argument
197 struct smc_connection *conn = &smc->conn; in smc_rx_wait() local
199 &conn->local_tx_ctrl.conn_state_flags; in smc_rx_wait()
203 if (fcrit(conn)) in smc_rx_wait()
211 conn->killed || in smc_rx_wait()
212 fcrit(conn), in smc_rx_wait()
222 struct smc_connection *conn = &smc->conn; in smc_rx_recv_urg() local
228 !(conn->urg_state == SMC_URG_VALID) || in smc_rx_recv_urg()
229 conn->urg_state == SMC_URG_READ) in smc_rx_recv_urg()
233 if (conn->urg_state == SMC_URG_VALID) { in smc_rx_recv_urg()
235 smc->conn.urg_state = SMC_URG_READ; in smc_rx_recv_urg()
239 rc = memcpy_to_msg(msg, &conn->urg_rx_byte, 1); in smc_rx_recv_urg()
241 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_recv_urg()
242 if (smc_curs_diff(conn->rmb_desc->len, &cons, in smc_rx_recv_urg()
243 &conn->urg_curs) > 1) in smc_rx_recv_urg()
244 conn->urg_rx_skip_pend = true; in smc_rx_recv_urg()
265 struct smc_connection *conn = &smc->conn; in smc_rx_recvmsg_data_available() local
267 if (smc_rx_data_available(conn)) in smc_rx_recvmsg_data_available()
269 else if (conn->urg_state == SMC_URG_VALID) in smc_rx_recvmsg_data_available()
287 struct smc_connection *conn = &smc->conn; in smc_rx_recvmsg() local
288 int (*func)(struct smc_connection *conn); in smc_rx_recvmsg()
309 readable = atomic_read(&conn->bytes_to_rcv); in smc_rx_recvmsg()
310 if (readable >= conn->rmb_desc->len) in smc_rx_recvmsg()
311 SMC_STAT_RMB_RX_FULL(smc, !conn->lnk); in smc_rx_recvmsg()
314 SMC_STAT_RMB_RX_SIZE_SMALL(smc, !conn->lnk); in smc_rx_recvmsg()
316 rcvbuf_base = conn->rx_off + conn->rmb_desc->cpu_addr; in smc_rx_recvmsg()
322 if (conn->killed) in smc_rx_recvmsg()
366 if (!smc_rx_data_available(conn)) { in smc_rx_recvmsg()
374 readable = atomic_read(&conn->bytes_to_rcv); in smc_rx_recvmsg()
375 splbytes = atomic_read(&conn->splice_pending); in smc_rx_recvmsg()
385 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_recvmsg()
388 smc_curs_add(conn->rmb_desc->len, &cons, splbytes); in smc_rx_recvmsg()
389 if (conn->urg_state == SMC_URG_VALID && in smc_rx_recvmsg()
397 chunk_len = min_t(size_t, copylen, conn->rmb_desc->len - in smc_rx_recvmsg()
401 smc_rmb_sync_sg_for_cpu(conn); in smc_rx_recvmsg()
416 smc_rmb_sync_sg_for_device(conn); in smc_rx_recvmsg()
430 smc_rmb_sync_sg_for_device(conn); in smc_rx_recvmsg()
436 atomic_sub(copylen, &conn->bytes_to_rcv); in smc_rx_recvmsg()
453 atomic_set(&smc->conn.splice_pending, 0); in smc_rx_init()
454 smc->conn.urg_state = SMC_URG_READ; in smc_rx_init()