Commit | Line | Data |
---|---|---|
b2441318 | 1 | /* SPDX-License-Identifier: GPL-2.0 */ |
e6727f39 UB |
2 | /* |
3 | * Shared Memory Communications over RDMA (SMC-R) and RoCE | |
4 | * | |
5 | * Manage send buffer | |
6 | * | |
7 | * Copyright IBM Corp. 2016 | |
8 | * | |
9 | * Author(s): Ursula Braun <ubraun@linux.vnet.ibm.com> | |
10 | */ | |
11 | ||
12 | #ifndef SMC_TX_H | |
13 | #define SMC_TX_H | |
14 | ||
15 | #include <linux/socket.h> | |
16 | #include <linux/types.h> | |
17 | ||
18 | #include "smc.h" | |
19 | #include "smc_cdc.h" | |
20 | ||
21 | static inline int smc_tx_prepared_sends(struct smc_connection *conn) | |
22 | { | |
23 | union smc_host_cursor sent, prep; | |
24 | ||
25 | smc_curs_write(&sent, smc_curs_read(&conn->tx_curs_sent, conn), conn); | |
26 | smc_curs_write(&prep, smc_curs_read(&conn->tx_curs_prep, conn), conn); | |
27 | return smc_curs_diff(conn->sndbuf_size, &sent, &prep); | |
28 | } | |
29 | ||
30 | void smc_tx_init(struct smc_sock *smc); | |
31 | int smc_tx_sendmsg(struct smc_sock *smc, struct msghdr *msg, size_t len); | |
32 | int smc_tx_sndbuf_nonempty(struct smc_connection *conn); | |
33 | void smc_tx_sndbuf_nonfull(struct smc_sock *smc); | |
952310cc | 34 | void smc_tx_consumer_update(struct smc_connection *conn); |
e6727f39 UB |
35 | |
36 | #endif /* SMC_TX_H */ |