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