motorhead/qemu
1
0
Fork 0
mirror of https://github.com/Motorhead1991/qemu.git synced 2025-08-03 07:43:54 -06:00
Code Issues Projects Releases Packages Wiki Activity Actions

nbd/client: Change signature of nbd_negotiate_simple_meta_context()

Browse source 
Pass 'info' instead of three separate parameters related to info,
when requesting the server to set the meta context.  Update the
NBDExportInfo struct to rename the received id field to match the
fact that we are currently overloading the field to match whatever
context the user supplied through the x-dirty-bitmap hack, as well
as adding a TODO comment to remind future patches about a desire
to request two contexts at once.

Signed-off-by: Eric Blake <eblake@redhat.com>
Reviewed-by: Richard W.M. Jones <rjones@redhat.com>
Reviewed-by: Vladimir Sementsov-Ogievskiy <vsementsov@virtuozzo.com>
Message-Id: <20190117193658.16413-11-eblake@redhat.com>
This commit is contained in:
Eric Blake 2019-01-17 13:36:47 -06:00
parent 6dc1667d68
commit 2df94eb52b
3 changed files with 28 additions and 31 deletions
Download patch file Download diff file Expand all files Collapse all files

4
block/nbd-client.c
View file

@ -249,11 +249,11 @@ static int nbd_parse_blockstatus_payload(NBDClientSession *client,
} }
context_id = payload_advance32(&payload); context_id = payload_advance32(&payload);
if (client->info.meta_base_allocation_id != context_id) { if (client->info.context_id != context_id) {
error_setg(errp, "Protocol error: unexpected context id %d for " error_setg(errp, "Protocol error: unexpected context id %d for "
"NBD_REPLY_TYPE_BLOCK_STATUS, when negotiated context " "NBD_REPLY_TYPE_BLOCK_STATUS, when negotiated context "
"id is %d", context_id, "id is %d", context_id,
client->info.meta_base_allocation_id); client->info.context_id);
return -EINVAL; return -EINVAL;
} }

2
include/block/nbd.h
View file

@ -276,7 +276,7 @@ struct NBDExportInfo {
uint32_t opt_block; uint32_t opt_block;
uint32_t max_block; uint32_t max_block;
uint32_t meta_base_allocation_id; uint32_t context_id;
}; };
typedef struct NBDExportInfo NBDExportInfo; typedef struct NBDExportInfo NBDExportInfo;

53
nbd/client.c
View file

@ -630,26 +630,30 @@ static QIOChannel *nbd_receive_starttls(QIOChannel *ioc,
} }
/* nbd_negotiate_simple_meta_context: /* nbd_negotiate_simple_meta_context:
* Set one meta context. Simple means that reply must contain zero (not * Request the server to set the meta context for export @info->name
* negotiated) or one (negotiated) contexts. More contexts would be considered * using @info->x_dirty_bitmap with a fallback to "base:allocation",
* as a protocol error. It's also implied that meta-data query equals queried * setting @info->context_id to the resulting id. Fail if the server
* context name, so, if server replies with something different than @context, * responds with more than one context or with a context different
* it is considered an error too. * than the query.
* return 1 for successful negotiation, context_id is set * return 1 for successful negotiation,
* 0 if operation is unsupported, * 0 if operation is unsupported,
* -1 with errp set for any other error * -1 with errp set for any other error
*/ */
static int nbd_negotiate_simple_meta_context(QIOChannel *ioc, static int nbd_negotiate_simple_meta_context(QIOChannel *ioc,
const char *export, NBDExportInfo *info,
const char *context,
uint32_t *context_id,
Error **errp) Error **errp)
{ {
/*
* TODO: Removing the x_dirty_bitmap hack will mean refactoring
* this function to request and store ids for multiple contexts
* (both base:allocation and a dirty bitmap), at which point this
* function should lose the term _simple.
*/
int ret; int ret;
NBDOptionReply reply; NBDOptionReply reply;
uint32_t received_id = 0; const char *context = info->x_dirty_bitmap ?: "base:allocation";
bool received = false; bool received = false;
uint32_t export_len = strlen(export); uint32_t export_len = strlen(info->name);
uint32_t context_len = strlen(context); uint32_t context_len = strlen(context);
uint32_t data_len = sizeof(export_len) + export_len + uint32_t data_len = sizeof(export_len) + export_len +
sizeof(uint32_t) + /* number of queries */ sizeof(uint32_t) + /* number of queries */
@ -657,9 +661,9 @@ static int nbd_negotiate_simple_meta_context(QIOChannel *ioc,
char *data = g_malloc(data_len); char *data = g_malloc(data_len);
char *p = data; char *p = data;
trace_nbd_opt_meta_request(context, export); trace_nbd_opt_meta_request(context, info->name);
stl_be_p(p, export_len); stl_be_p(p, export_len);
memcpy(p += sizeof(export_len), export, export_len); memcpy(p += sizeof(export_len), info->name, export_len);
stl_be_p(p += export_len, 1); stl_be_p(p += export_len, 1);
stl_be_p(p += sizeof(uint32_t), context_len); stl_be_p(p += sizeof(uint32_t), context_len);
memcpy(p += sizeof(context_len), context, context_len); memcpy(p += sizeof(context_len), context, context_len);
@ -685,7 +689,7 @@ static int nbd_negotiate_simple_meta_context(QIOChannel *ioc,
if (reply.type == NBD_REP_META_CONTEXT) { if (reply.type == NBD_REP_META_CONTEXT) {
char *name; char *name;
if (reply.length != sizeof(received_id) + context_len) { if (reply.length != sizeof(info->context_id) + context_len) {
error_setg(errp, "Failed to negotiate meta context '%s', server " error_setg(errp, "Failed to negotiate meta context '%s', server "
"answered with unexpected length %" PRIu32, context, "answered with unexpected length %" PRIu32, context,
reply.length); reply.length);
@ -693,12 +697,13 @@ static int nbd_negotiate_simple_meta_context(QIOChannel *ioc,
return -1; return -1;
} }
if (nbd_read(ioc, &received_id, sizeof(received_id), errp) < 0) { if (nbd_read(ioc, &info->context_id, sizeof(info->context_id),
errp) < 0) {
return -1; return -1;
} }
received_id = be32_to_cpu(received_id); info->context_id = be32_to_cpu(info->context_id);
reply.length -= sizeof(received_id); reply.length -= sizeof(info->context_id);
name = g_malloc(reply.length + 1); name = g_malloc(reply.length + 1);
if (nbd_read(ioc, name, reply.length, errp) < 0) { if (nbd_read(ioc, name, reply.length, errp) < 0) {
g_free(name); g_free(name);
@ -715,7 +720,7 @@ static int nbd_negotiate_simple_meta_context(QIOChannel *ioc,
} }
g_free(name); g_free(name);
trace_nbd_opt_meta_reply(context, received_id); trace_nbd_opt_meta_reply(context, info->context_id);
received = true; received = true;
/* receive NBD_REP_ACK */ /* receive NBD_REP_ACK */
@ -744,12 +749,7 @@ static int nbd_negotiate_simple_meta_context(QIOChannel *ioc,
return -1; return -1;
} }
if (received) { return received;
*context_id = received_id;
return 1;
}
return 0;
} }
int nbd_receive_negotiate(QIOChannel *ioc, QCryptoTLSCreds *tlscreds, int nbd_receive_negotiate(QIOChannel *ioc, QCryptoTLSCreds *tlscreds,
@ -848,10 +848,7 @@ int nbd_receive_negotiate(QIOChannel *ioc, QCryptoTLSCreds *tlscreds,
} }
if (info->structured_reply && base_allocation) { if (info->structured_reply && base_allocation) {
result = nbd_negotiate_simple_meta_context( result = nbd_negotiate_simple_meta_context(ioc, info, errp);
ioc, info->name,
info->x_dirty_bitmap ?: "base:allocation",
&info->meta_base_allocation_id, errp);
if (result < 0) { if (result < 0) {
goto fail; goto fail;
} }