Include less of the generated modular QAPI headers

[qemu.git] / block / nbd.c

diff --git a/block/nbd.c b/block/nbd.c
index bbe0f99d6c50c788f7b9fef737b90d3d58a86f8f..d4e4172c08c6a0bd10acd429975af8540082d585 100644 (file)
--- a/block/nbd.c
+++ b/block/nbd.c
@@ -32,12 +32,11 @@
 #include "qemu/uri.h"
 #include "block/block_int.h"
 #include "qemu/module.h"
 #include "qemu/uri.h"
 #include "block/block_int.h"
 #include "qemu/module.h"

-#include "qapi-visit.h"
+#include "qemu/option.h"
+#include "qapi/qapi-visit-sockets.h"

 #include "qapi/qobject-input-visitor.h"
 #include "qapi/qobject-output-visitor.h"
 #include "qapi/qmp/qdict.h"
 #include "qapi/qobject-input-visitor.h"
 #include "qapi/qobject-output-visitor.h"
 #include "qapi/qmp/qdict.h"

-#include "qapi/qmp/qjson.h"
-#include "qapi/qmp/qint.h"

 #include "qapi/qmp/qstring.h"
 #include "qemu/cutils.h"
 
 #include "qapi/qmp/qstring.h"
 #include "qemu/cutils.h"
 


@@ -65,11 +64,11 @@ static int nbd_parse_uri(const char *filename, QDict *options)
     }
 
     /* transport */
     }
 
     /* transport */

-    if (!strcmp(uri->scheme, "nbd")) {
+    if (!g_strcmp0(uri->scheme, "nbd")) {

         is_unix = false;
         is_unix = false;

-    } else if (!strcmp(uri->scheme, "nbd+tcp")) {
+    } else if (!g_strcmp0(uri->scheme, "nbd+tcp")) {

         is_unix = false;
         is_unix = false;

-    } else if (!strcmp(uri->scheme, "nbd+unix")) {
+    } else if (!g_strcmp0(uri->scheme, "nbd+unix")) {

         is_unix = true;
     } else {
         ret = -EINVAL;
         is_unix = true;
     } else {
         ret = -EINVAL;


@@ -306,10 +305,9 @@ NBDClientSession *nbd_get_client_session(BlockDriverState *bs)
     return &s->client;
 }
 
     return &s->client;
 }
 

-static QIOChannelSocket *nbd_establish_connection(SocketAddress *saddr_flat,
+static QIOChannelSocket *nbd_establish_connection(SocketAddress *saddr,

                                                   Error **errp)
 {
                                                   Error **errp)
 {

-    SocketAddressLegacy *saddr = socket_address_crumple(saddr_flat);

     QIOChannelSocket *sioc;
     Error *local_err = NULL;
 
     QIOChannelSocket *sioc;
     Error *local_err = NULL;
 


@@ -319,7 +317,6 @@ static QIOChannelSocket *nbd_establish_connection(SocketAddress *saddr_flat,
     qio_channel_socket_connect_sync(sioc,
                                     saddr,
                                     &local_err);
     qio_channel_socket_connect_sync(sioc,
                                     saddr,
                                     &local_err);

-    qapi_free_SocketAddressLegacy(saddr);

     if (local_err) {
         object_unref(OBJECT(sioc));
         error_propagate(errp, local_err);
     if (local_err) {
         object_unref(OBJECT(sioc));
         error_propagate(errp, local_err);


@@ -391,6 +388,7 @@ static QemuOptsList nbd_runtime_opts = {
             .type = QEMU_OPT_STRING,
             .help = "ID of the TLS credentials to use",
         },
             .type = QEMU_OPT_STRING,
             .help = "ID of the TLS credentials to use",
         },

+        { /* end of list */ }

     },
 };
 
     },
 };
 


@@ -475,9 +473,19 @@ static int nbd_co_flush(BlockDriverState *bs)
 
 static void nbd_refresh_limits(BlockDriverState *bs, Error **errp)
 {
 
 static void nbd_refresh_limits(BlockDriverState *bs, Error **errp)
 {

-    bs->bl.max_pdiscard = NBD_MAX_BUFFER_SIZE;
-    bs->bl.max_pwrite_zeroes = NBD_MAX_BUFFER_SIZE;
-    bs->bl.max_transfer = NBD_MAX_BUFFER_SIZE;
+    NBDClientSession *s = nbd_get_client_session(bs);
+    uint32_t min = s->info.min_block;
+    uint32_t max = MIN_NON_ZERO(NBD_MAX_BUFFER_SIZE, s->info.max_block);
+
+    bs->bl.request_alignment = min ? min : BDRV_SECTOR_SIZE;
+    bs->bl.max_pdiscard = max;
+    bs->bl.max_pwrite_zeroes = max;
+    bs->bl.max_transfer = max;
+
+    if (s->info.opt_block &&
+        s->info.opt_block > bs->bl.opt_transfer) {
+        bs->bl.opt_transfer = s->info.opt_block;
+    }

 }
 
 static void nbd_close(BlockDriverState *bs)
 }
 
 static void nbd_close(BlockDriverState *bs)


@@ -495,7 +503,7 @@ static int64_t nbd_getlength(BlockDriverState *bs)
 {
     BDRVNBDState *s = bs->opaque;
 
 {
     BDRVNBDState *s = bs->opaque;
 

-    return s->client.size;
+    return s->client.info.size;

 }
 
 static void nbd_detach_aio_context(BlockDriverState *bs)
 }
 
 static void nbd_detach_aio_context(BlockDriverState *bs)