/* * 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 "qapi/error.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"; 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_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_WRITE_ZEROES: return "write zeroes"; default: return "<unknown>"; } }