blob: 78255964fa4dc1c69f96548e035e74a167999a62 [file] [log] [blame]
Greg Kroah-Hartmanb2441312017-11-01 15:07:57 +01001/* SPDX-License-Identifier: GPL-2.0 */
Ursula Braune6727f32017-01-09 16:55:23 +01002/*
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
21static 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
30void smc_tx_init(struct smc_sock *smc);
31int smc_tx_sendmsg(struct smc_sock *smc, struct msghdr *msg, size_t len);
32int smc_tx_sndbuf_nonempty(struct smc_connection *conn);
33void smc_tx_sndbuf_nonfull(struct smc_sock *smc);
Ursula Braun952310c2017-01-09 16:55:24 +010034void smc_tx_consumer_update(struct smc_connection *conn);
Ursula Braune6727f32017-01-09 16:55:23 +010035
36#endif /* SMC_TX_H */