Handle nbd CACHE command. Just do read, without sending read data back. Cache mechanism should be done by exported node driver chain. Signed-off-by: Vladimir Sementsov-Ogievskiy <vsementsov@virtuozzo.com> Message-Id: <20180413143156.11409-1-vsementsov@virtuozzo.com> Reviewed-by: Eric Blake <eblake@redhat.com> [eblake: fix two missing case labels in switch statements] Signed-off-by: Eric Blake <eblake@redhat.com>
246 lines
5.5 KiB
C
246 lines
5.5 KiB
C
/*
|
|
* Copyright (C) 2005 Anthony Liguori <anthony@codemonkey.ws>
|
|
*
|
|
* Network Block Device Common Code
|
|
*
|
|
* This program is free software; you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation; under version 2 of the License.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program; if not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#include "qemu/osdep.h"
|
|
#include "trace.h"
|
|
#include "nbd-internal.h"
|
|
|
|
/* Discard length bytes from channel. Return -errno on failure and 0 on
|
|
* success */
|
|
int nbd_drop(QIOChannel *ioc, size_t size, Error **errp)
|
|
{
|
|
ssize_t ret = 0;
|
|
char small[1024];
|
|
char *buffer;
|
|
|
|
buffer = sizeof(small) >= size ? small : g_malloc(MIN(65536, size));
|
|
while (size > 0) {
|
|
ssize_t count = MIN(65536, size);
|
|
ret = nbd_read(ioc, buffer, MIN(65536, size), errp);
|
|
|
|
if (ret < 0) {
|
|
goto cleanup;
|
|
}
|
|
size -= count;
|
|
}
|
|
|
|
cleanup:
|
|
if (buffer != small) {
|
|
g_free(buffer);
|
|
}
|
|
return ret;
|
|
}
|
|
|
|
|
|
void nbd_tls_handshake(QIOTask *task,
|
|
void *opaque)
|
|
{
|
|
struct NBDTLSHandshakeData *data = opaque;
|
|
|
|
qio_task_propagate_error(task, &data->error);
|
|
data->complete = true;
|
|
g_main_loop_quit(data->loop);
|
|
}
|
|
|
|
|
|
const char *nbd_opt_lookup(uint32_t opt)
|
|
{
|
|
switch (opt) {
|
|
case NBD_OPT_EXPORT_NAME:
|
|
return "export name";
|
|
case NBD_OPT_ABORT:
|
|
return "abort";
|
|
case NBD_OPT_LIST:
|
|
return "list";
|
|
case NBD_OPT_STARTTLS:
|
|
return "starttls";
|
|
case NBD_OPT_INFO:
|
|
return "info";
|
|
case NBD_OPT_GO:
|
|
return "go";
|
|
case NBD_OPT_STRUCTURED_REPLY:
|
|
return "structured reply";
|
|
case NBD_OPT_LIST_META_CONTEXT:
|
|
return "list meta context";
|
|
case NBD_OPT_SET_META_CONTEXT:
|
|
return "set meta context";
|
|
default:
|
|
return "<unknown>";
|
|
}
|
|
}
|
|
|
|
|
|
const char *nbd_rep_lookup(uint32_t rep)
|
|
{
|
|
switch (rep) {
|
|
case NBD_REP_ACK:
|
|
return "ack";
|
|
case NBD_REP_SERVER:
|
|
return "server";
|
|
case NBD_REP_INFO:
|
|
return "info";
|
|
case NBD_REP_META_CONTEXT:
|
|
return "meta context";
|
|
case NBD_REP_ERR_UNSUP:
|
|
return "unsupported";
|
|
case NBD_REP_ERR_POLICY:
|
|
return "denied by policy";
|
|
case NBD_REP_ERR_INVALID:
|
|
return "invalid";
|
|
case NBD_REP_ERR_PLATFORM:
|
|
return "platform lacks support";
|
|
case NBD_REP_ERR_TLS_REQD:
|
|
return "TLS required";
|
|
case NBD_REP_ERR_UNKNOWN:
|
|
return "export unknown";
|
|
case NBD_REP_ERR_SHUTDOWN:
|
|
return "server shutting down";
|
|
case NBD_REP_ERR_BLOCK_SIZE_REQD:
|
|
return "block size required";
|
|
default:
|
|
return "<unknown>";
|
|
}
|
|
}
|
|
|
|
|
|
const char *nbd_info_lookup(uint16_t info)
|
|
{
|
|
switch (info) {
|
|
case NBD_INFO_EXPORT:
|
|
return "export";
|
|
case NBD_INFO_NAME:
|
|
return "name";
|
|
case NBD_INFO_DESCRIPTION:
|
|
return "description";
|
|
case NBD_INFO_BLOCK_SIZE:
|
|
return "block size";
|
|
default:
|
|
return "<unknown>";
|
|
}
|
|
}
|
|
|
|
|
|
const char *nbd_cmd_lookup(uint16_t cmd)
|
|
{
|
|
switch (cmd) {
|
|
case NBD_CMD_READ:
|
|
return "read";
|
|
case NBD_CMD_WRITE:
|
|
return "write";
|
|
case NBD_CMD_DISC:
|
|
return "disconnect";
|
|
case NBD_CMD_FLUSH:
|
|
return "flush";
|
|
case NBD_CMD_TRIM:
|
|
return "trim";
|
|
case NBD_CMD_CACHE:
|
|
return "cache";
|
|
case NBD_CMD_WRITE_ZEROES:
|
|
return "write zeroes";
|
|
case NBD_CMD_BLOCK_STATUS:
|
|
return "block status";
|
|
default:
|
|
return "<unknown>";
|
|
}
|
|
}
|
|
|
|
|
|
const char *nbd_reply_type_lookup(uint16_t type)
|
|
{
|
|
switch (type) {
|
|
case NBD_REPLY_TYPE_NONE:
|
|
return "none";
|
|
case NBD_REPLY_TYPE_OFFSET_DATA:
|
|
return "data";
|
|
case NBD_REPLY_TYPE_OFFSET_HOLE:
|
|
return "hole";
|
|
case NBD_REPLY_TYPE_BLOCK_STATUS:
|
|
return "block status";
|
|
case NBD_REPLY_TYPE_ERROR:
|
|
return "generic error";
|
|
case NBD_REPLY_TYPE_ERROR_OFFSET:
|
|
return "error at offset";
|
|
default:
|
|
if (type & (1 << 15)) {
|
|
return "<unknown error>";
|
|
}
|
|
return "<unknown>";
|
|
}
|
|
}
|
|
|
|
|
|
const char *nbd_err_lookup(int err)
|
|
{
|
|
switch (err) {
|
|
case NBD_SUCCESS:
|
|
return "success";
|
|
case NBD_EPERM:
|
|
return "EPERM";
|
|
case NBD_EIO:
|
|
return "EIO";
|
|
case NBD_ENOMEM:
|
|
return "ENOMEM";
|
|
case NBD_EINVAL:
|
|
return "EINVAL";
|
|
case NBD_ENOSPC:
|
|
return "ENOSPC";
|
|
case NBD_EOVERFLOW:
|
|
return "EOVERFLOW";
|
|
case NBD_ESHUTDOWN:
|
|
return "ESHUTDOWN";
|
|
default:
|
|
return "<unknown>";
|
|
}
|
|
}
|
|
|
|
|
|
int nbd_errno_to_system_errno(int err)
|
|
{
|
|
int ret;
|
|
switch (err) {
|
|
case NBD_SUCCESS:
|
|
ret = 0;
|
|
break;
|
|
case NBD_EPERM:
|
|
ret = EPERM;
|
|
break;
|
|
case NBD_EIO:
|
|
ret = EIO;
|
|
break;
|
|
case NBD_ENOMEM:
|
|
ret = ENOMEM;
|
|
break;
|
|
case NBD_ENOSPC:
|
|
ret = ENOSPC;
|
|
break;
|
|
case NBD_EOVERFLOW:
|
|
ret = EOVERFLOW;
|
|
break;
|
|
case NBD_ESHUTDOWN:
|
|
ret = ESHUTDOWN;
|
|
break;
|
|
default:
|
|
trace_nbd_unknown_error(err);
|
|
/* fallthrough */
|
|
case NBD_EINVAL:
|
|
ret = EINVAL;
|
|
break;
|
|
}
|
|
return ret;
|
|
}
|