]>
Commit | Line | Data |
---|---|---|
2302c1ca MAL |
1 | #ifndef NBD_CLIENT_H |
2 | #define NBD_CLIENT_H | |
3 | ||
4 | #include "qemu-common.h" | |
5 | #include "block/nbd.h" | |
6 | #include "block/block_int.h" | |
064097d9 | 7 | #include "io/channel-socket.h" |
2302c1ca MAL |
8 | |
9 | /* #define DEBUG_NBD */ | |
10 | ||
11 | #if defined(DEBUG_NBD) | |
12 | #define logout(fmt, ...) \ | |
13 | fprintf(stderr, "nbd\t%-24s" fmt, __func__, ##__VA_ARGS__) | |
14 | #else | |
15 | #define logout(fmt, ...) ((void)0) | |
16 | #endif | |
17 | ||
18 | #define MAX_NBD_REQUESTS 16 | |
19 | ||
20 | typedef struct NbdClientSession { | |
064097d9 DB |
21 | QIOChannelSocket *sioc; /* The master data channel */ |
22 | QIOChannel *ioc; /* The current I/O channel which may differ (eg TLS) */ | |
7423f417 | 23 | uint16_t nbdflags; |
2302c1ca | 24 | off_t size; |
2302c1ca MAL |
25 | |
26 | CoMutex send_mutex; | |
27 | CoMutex free_sema; | |
28 | Coroutine *send_coroutine; | |
29 | int in_flight; | |
30 | ||
31 | Coroutine *recv_coroutine[MAX_NBD_REQUESTS]; | |
32 | struct nbd_reply reply; | |
33 | ||
2302c1ca | 34 | bool is_unix; |
2302c1ca MAL |
35 | } NbdClientSession; |
36 | ||
f53a829b HR |
37 | NbdClientSession *nbd_get_client_session(BlockDriverState *bs); |
38 | ||
064097d9 DB |
39 | int nbd_client_init(BlockDriverState *bs, |
40 | QIOChannelSocket *sock, | |
41 | const char *export_name, | |
75822a12 DB |
42 | QCryptoTLSCreds *tlscreds, |
43 | const char *hostname, | |
f53a829b HR |
44 | Error **errp); |
45 | void nbd_client_close(BlockDriverState *bs); | |
46 | ||
447e57c3 | 47 | int nbd_client_co_pdiscard(BlockDriverState *bs, int64_t offset, int count); |
f53a829b | 48 | int nbd_client_co_flush(BlockDriverState *bs); |
70c4fb26 EB |
49 | int nbd_client_co_pwritev(BlockDriverState *bs, uint64_t offset, |
50 | uint64_t bytes, QEMUIOVector *qiov, int flags); | |
51 | int nbd_client_co_preadv(BlockDriverState *bs, uint64_t offset, | |
52 | uint64_t bytes, QEMUIOVector *qiov, int flags); | |
f53a829b HR |
53 | |
54 | void nbd_client_detach_aio_context(BlockDriverState *bs); | |
55 | void nbd_client_attach_aio_context(BlockDriverState *bs, | |
56 | AioContext *new_context); | |
69447cd8 | 57 | |
2302c1ca | 58 | #endif /* NBD_CLIENT_H */ |