]> Git Repo - qemu.git/blame - include/block/nbd.h
nbd/client: prepare nbd_receive_reply for structured reply
[qemu.git] / include / block / nbd.h
CommitLineData
75818250 1/*
3736cc5b 2 * Copyright (C) 2016-2017 Red Hat, Inc.
7a5ca864
FB
3 * Copyright (C) 2005 Anthony Liguori <[email protected]>
4 *
5 * Network Block Device
6 *
7 * This program is free software; you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License as published by
9 * the Free Software Foundation; under version 2 of the License.
10 *
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
15 *
16 * You should have received a copy of the GNU General Public License
8167ee88 17 * along with this program; if not, see <http://www.gnu.org/licenses/>.
75818250 18 */
7a5ca864
FB
19
20#ifndef NBD_H
21#define NBD_H
22
7a5ca864 23
5a61cb60 24#include "qemu-common.h"
f17c90be 25#include "qemu/option.h"
1c778ef7 26#include "io/channel-socket.h"
f95910fe 27#include "crypto/tlscreds.h"
c12504ce 28
c8a3a1b6
EB
29/* Handshake phase structs - this struct is passed on the wire */
30
31struct nbd_option {
32 uint64_t magic; /* NBD_OPTS_MAGIC */
33 uint32_t option; /* NBD_OPT_* */
34 uint32_t length;
35} QEMU_PACKED;
36typedef struct nbd_option nbd_option;
37
38struct nbd_opt_reply {
39 uint64_t magic; /* NBD_REP_MAGIC */
40 uint32_t option; /* NBD_OPT_* */
41 uint32_t type; /* NBD_REP_* */
42 uint32_t length;
43} QEMU_PACKED;
44typedef struct nbd_opt_reply nbd_opt_reply;
45
46/* Transmission phase structs
47 *
48 * Note: these are _NOT_ the same as the network representation of an NBD
56af2dda
PB
49 * request and reply!
50 */
ed2dd912 51struct NBDRequest {
75818250
TS
52 uint64_t handle;
53 uint64_t from;
54 uint32_t len;
c8a3a1b6
EB
55 uint16_t flags; /* NBD_CMD_FLAG_* */
56 uint16_t type; /* NBD_CMD_* */
56af2dda 57};
ed2dd912 58typedef struct NBDRequest NBDRequest;
75818250 59
caad5384
VSO
60typedef struct NBDSimpleReply {
61 uint32_t magic; /* NBD_SIMPLE_REPLY_MAGIC */
62 uint32_t error;
63 uint64_t handle;
64} QEMU_PACKED NBDSimpleReply;
65
bae245d1
EB
66/* Header of all structured replies */
67typedef struct NBDStructuredReplyChunk {
68 uint32_t magic; /* NBD_STRUCTURED_REPLY_MAGIC */
69 uint16_t flags; /* combination of NBD_REPLY_FLAG_* */
70 uint16_t type; /* NBD_REPLY_TYPE_* */
71 uint64_t handle; /* request handle */
72 uint32_t length; /* length of payload */
73} QEMU_PACKED NBDStructuredReplyChunk;
74
d2febedb
VSO
75typedef union NBDReply {
76 NBDSimpleReply simple;
77 NBDStructuredReplyChunk structured;
78 struct {
79 /* @magic and @handle fields have the same offset and size both in
80 * simple reply and structured reply chunk, so let them be accessible
81 * without ".simple." or ".structured." specification
82 */
83 uint32_t magic;
84 uint32_t _skip;
85 uint64_t handle;
86 } QEMU_PACKED;
87} NBDReply;
88
bae245d1
EB
89/* Header of NBD_REPLY_TYPE_OFFSET_DATA, complete NBD_REPLY_TYPE_OFFSET_HOLE */
90typedef struct NBDStructuredRead {
91 NBDStructuredReplyChunk h;
92 uint64_t offset;
93} QEMU_PACKED NBDStructuredRead;
94
95/* Header of all NBD_REPLY_TYPE_ERROR* errors */
96typedef struct NBDStructuredError {
97 NBDStructuredReplyChunk h;
98 uint32_t error;
99 uint16_t message_length;
100} QEMU_PACKED NBDStructuredError;
101
b626b51a
EB
102/* Transmission (export) flags: sent from server to client during handshake,
103 but describe what will happen during transmission */
92652b12
VSO
104#define NBD_FLAG_HAS_FLAGS (1 << 0) /* Flags are there */
105#define NBD_FLAG_READ_ONLY (1 << 1) /* Device is read-only */
106#define NBD_FLAG_SEND_FLUSH (1 << 2) /* Send FLUSH */
107#define NBD_FLAG_SEND_FUA (1 << 3) /* Send FUA (Force Unit Access) */
108#define NBD_FLAG_ROTATIONAL (1 << 4) /* Use elevator algorithm -
109 rotational media */
110#define NBD_FLAG_SEND_TRIM (1 << 5) /* Send TRIM (discard) */
111#define NBD_FLAG_SEND_WRITE_ZEROES (1 << 6) /* Send WRITE_ZEROES */
bae245d1 112#define NBD_FLAG_SEND_DF (1 << 7) /* Send DF (Do not Fragment) */
bbb74edd 113
b626b51a
EB
114/* New-style handshake (global) flags, sent from server to client, and
115 control what will happen during handshake phase. */
c203c59a
EB
116#define NBD_FLAG_FIXED_NEWSTYLE (1 << 0) /* Fixed newstyle protocol. */
117#define NBD_FLAG_NO_ZEROES (1 << 1) /* End handshake without zeroes. */
f5076b5a 118
b626b51a
EB
119/* New-style client flags, sent from client to server to control what happens
120 during handshake phase. */
c203c59a
EB
121#define NBD_FLAG_C_FIXED_NEWSTYLE (1 << 0) /* Fixed newstyle protocol. */
122#define NBD_FLAG_C_NO_ZEROES (1 << 1) /* End handshake without zeroes. */
f5076b5a 123
3736cc5b
EB
124/* Option requests. */
125#define NBD_OPT_EXPORT_NAME (1)
126#define NBD_OPT_ABORT (2)
127#define NBD_OPT_LIST (3)
128/* #define NBD_OPT_PEEK_EXPORT (4) not in use */
129#define NBD_OPT_STARTTLS (5)
130#define NBD_OPT_INFO (6)
131#define NBD_OPT_GO (7)
132#define NBD_OPT_STRUCTURED_REPLY (8)
133
134/* Option reply types. */
b6f5d3b5
EB
135#define NBD_REP_ERR(value) ((UINT32_C(1) << 31) | (value))
136
32d7d2e0
HB
137#define NBD_REP_ACK (1) /* Data sending finished. */
138#define NBD_REP_SERVER (2) /* Export description. */
3736cc5b
EB
139#define NBD_REP_INFO (3) /* NBD_OPT_INFO/GO. */
140
141#define NBD_REP_ERR_UNSUP NBD_REP_ERR(1) /* Unknown option */
142#define NBD_REP_ERR_POLICY NBD_REP_ERR(2) /* Server denied */
143#define NBD_REP_ERR_INVALID NBD_REP_ERR(3) /* Invalid length */
144#define NBD_REP_ERR_PLATFORM NBD_REP_ERR(4) /* Not compiled in */
145#define NBD_REP_ERR_TLS_REQD NBD_REP_ERR(5) /* TLS required */
146#define NBD_REP_ERR_UNKNOWN NBD_REP_ERR(6) /* Export unknown */
147#define NBD_REP_ERR_SHUTDOWN NBD_REP_ERR(7) /* Server shutting down */
148#define NBD_REP_ERR_BLOCK_SIZE_REQD NBD_REP_ERR(8) /* Need INFO_BLOCK_SIZE */
149
150/* Info types, used during NBD_REP_INFO */
151#define NBD_INFO_EXPORT 0
152#define NBD_INFO_NAME 1
153#define NBD_INFO_DESCRIPTION 2
154#define NBD_INFO_BLOCK_SIZE 3
f95910fe 155
b626b51a 156/* Request flags, sent from client to server during transmission phase */
1f4d6d18
EB
157#define NBD_CMD_FLAG_FUA (1 << 0) /* 'force unit access' during write */
158#define NBD_CMD_FLAG_NO_HOLE (1 << 1) /* don't punch hole on zero run */
bae245d1 159#define NBD_CMD_FLAG_DF (1 << 2) /* don't fragment structured read */
f5076b5a 160
b626b51a 161/* Supported request types */
75818250
TS
162enum {
163 NBD_CMD_READ = 0,
164 NBD_CMD_WRITE = 1,
bbb74edd
PB
165 NBD_CMD_DISC = 2,
166 NBD_CMD_FLUSH = 3,
1f4d6d18
EB
167 NBD_CMD_TRIM = 4,
168 /* 5 reserved for failed experiment NBD_CMD_CACHE */
169 NBD_CMD_WRITE_ZEROES = 6,
75818250
TS
170};
171
1d45f8b5
LV
172#define NBD_DEFAULT_PORT 10809
173
2d821488
SH
174/* Maximum size of a single READ/WRITE data buffer */
175#define NBD_MAX_BUFFER_SIZE (32 * 1024 * 1024)
476b923c 176
943cec86
EB
177/* Maximum size of an export name. The NBD spec requires 256 and
178 * suggests that servers support up to 4096, but we stick to only the
179 * required size so that we can stack-allocate the names, and because
180 * going larger would require an audit of more code to make sure we
181 * aren't overflowing some other buffer. */
182#define NBD_MAX_NAME_SIZE 256
3777b09f 183
bae245d1
EB
184/* Two types of reply structures */
185#define NBD_SIMPLE_REPLY_MAGIC 0x67446698
186#define NBD_STRUCTURED_REPLY_MAGIC 0x668e33ef
187
188/* Structured reply flags */
189#define NBD_REPLY_FLAG_DONE (1 << 0) /* This reply-chunk is last */
190
191/* Structured reply types */
192#define NBD_REPLY_ERR(value) ((1 << 15) | (value))
193
194#define NBD_REPLY_TYPE_NONE 0
195#define NBD_REPLY_TYPE_OFFSET_DATA 1
196#define NBD_REPLY_TYPE_OFFSET_HOLE 2
197#define NBD_REPLY_TYPE_ERROR NBD_REPLY_ERR(1)
198#define NBD_REPLY_TYPE_ERROR_OFFSET NBD_REPLY_ERR(2)
199
dd689440
EB
200/* NBD errors are based on errno numbers, so there is a 1:1 mapping,
201 * but only a limited set of errno values is specified in the protocol.
202 * Everything else is squashed to EINVAL.
203 */
204#define NBD_SUCCESS 0
205#define NBD_EPERM 1
206#define NBD_EIO 5
207#define NBD_ENOMEM 12
208#define NBD_EINVAL 22
209#define NBD_ENOSPC 28
bae245d1 210#define NBD_EOVERFLOW 75
dd689440
EB
211#define NBD_ESHUTDOWN 108
212
004a89fc
EB
213/* Details collected by NBD_OPT_EXPORT_NAME and NBD_OPT_GO */
214struct NBDExportInfo {
081dd1fe
EB
215 /* Set by client before nbd_receive_negotiate() */
216 bool request_sizes;
217 /* Set by server results during nbd_receive_negotiate() */
004a89fc
EB
218 uint64_t size;
219 uint16_t flags;
081dd1fe
EB
220 uint32_t min_block;
221 uint32_t opt_block;
222 uint32_t max_block;
004a89fc
EB
223};
224typedef struct NBDExportInfo NBDExportInfo;
225
004a89fc 226int nbd_receive_negotiate(QIOChannel *ioc, const char *name,
f95910fe 227 QCryptoTLSCreds *tlscreds, const char *hostname,
004a89fc
EB
228 QIOChannel **outioc, NBDExportInfo *info,
229 Error **errp);
230int nbd_init(int fd, QIOChannelSocket *sioc, NBDExportInfo *info,
be41c100 231 Error **errp);
490dc5ed 232int nbd_send_request(QIOChannel *ioc, NBDRequest *request);
ba845644 233int nbd_receive_reply(QIOChannel *ioc, NBDReply *reply, Error **errp);
0a4eb864 234int nbd_client(int fd);
7a5ca864 235int nbd_disconnect(int fd);
dd689440 236int nbd_errno_to_system_errno(int err);
7a5ca864 237
af49bbbe 238typedef struct NBDExport NBDExport;
1743b515 239typedef struct NBDClient NBDClient;
af49bbbe 240
cd7fca95 241NBDExport *nbd_export_new(BlockDriverState *bs, off_t dev_offset, off_t size,
7423f417 242 uint16_t nbdflags, void (*close)(NBDExport *),
cd7fca95 243 bool writethrough, BlockBackend *on_eject_blk,
98f44bbe 244 Error **errp);
af49bbbe 245void nbd_export_close(NBDExport *exp);
2c8d9f06
PB
246void nbd_export_get(NBDExport *exp);
247void nbd_export_put(NBDExport *exp);
ce33967a 248
e140177d 249BlockBackend *nbd_export_get_blockdev(NBDExport *exp);
125afda8 250
ee0a19ec
PB
251NBDExport *nbd_export_find(const char *name);
252void nbd_export_set_name(NBDExport *exp, const char *name);
b1a75b33 253void nbd_export_set_description(NBDExport *exp, const char *description);
ee0a19ec
PB
254void nbd_export_close_all(void);
255
1c778ef7
DB
256void nbd_client_new(NBDExport *exp,
257 QIOChannelSocket *sioc,
f95910fe
DB
258 QCryptoTLSCreds *tlscreds,
259 const char *tlsaclname,
0c9390d9 260 void (*close_fn)(NBDClient *, bool));
ce33967a
PB
261void nbd_client_get(NBDClient *client);
262void nbd_client_put(NBDClient *client);
af49bbbe 263
bd269ebc
MA
264void nbd_server_start(SocketAddress *addr, const char *tls_creds,
265 Error **errp);
266
d2febedb
VSO
267static inline bool nbd_reply_is_simple(NBDReply *reply)
268{
269 return reply->magic == NBD_SIMPLE_REPLY_MAGIC;
270}
271
272static inline bool nbd_reply_is_structured(NBDReply *reply)
273{
274 return reply->magic == NBD_STRUCTURED_REPLY_MAGIC;
275}
276
7a5ca864 277#endif
This page took 0.670716 seconds and 4 git commands to generate.