int nbd_receive_negotiate(QIOChannel *ioc, const char *name,

                          QCryptoTLSCreds *tlscreds, const char *hostname,

                          QIOChannel **outioc, NBDExportInfo *info,

                          Error **errp)

{

    char buf[256];

    uint64_t magic;

    int rc;

    bool zeroes = true;




    trace_nbd_receive_negotiate(tlscreds, hostname ? hostname : "<null>");




    rc = -EINVAL;



    if (outioc) {

        *outioc = NULL;

    }

    if (tlscreds && !outioc) {

        error_setg(errp, "Output I/O channel required for TLS");

        goto fail;

    }



    if (nbd_read(ioc, buf, 8, errp) < 0) {

        error_prepend(errp, "Failed to read data");

        goto fail;

    }



    buf[8] = '\0';

    if (strlen(buf) == 0) {

        error_setg(errp, "Server connection closed unexpectedly");

        goto fail;

    }



    magic = ldq_be_p(buf);

    trace_nbd_receive_negotiate_magic(magic);



    if (memcmp(buf, "NBDMAGIC", 8) != 0) {

        error_setg(errp, "Invalid magic received");

        goto fail;

    }



    if (nbd_read(ioc, &magic, sizeof(magic), errp) < 0) {

        error_prepend(errp, "Failed to read magic");

        goto fail;

    }

    magic = be64_to_cpu(magic);

    trace_nbd_receive_negotiate_magic(magic);



    if (magic == NBD_OPTS_MAGIC) {

        uint32_t clientflags = 0;

        uint16_t globalflags;

        bool fixedNewStyle = false;



        if (nbd_read(ioc, &globalflags, sizeof(globalflags), errp) < 0) {

            error_prepend(errp, "Failed to read server flags");

            goto fail;

        }

        globalflags = be16_to_cpu(globalflags);

        trace_nbd_receive_negotiate_server_flags(globalflags);

        if (globalflags & NBD_FLAG_FIXED_NEWSTYLE) {

            fixedNewStyle = true;

            clientflags |= NBD_FLAG_C_FIXED_NEWSTYLE;

        }

        if (globalflags & NBD_FLAG_NO_ZEROES) {

            zeroes = false;

            clientflags |= NBD_FLAG_C_NO_ZEROES;

        }

        /* client requested flags */

        clientflags = cpu_to_be32(clientflags);

        if (nbd_write(ioc, &clientflags, sizeof(clientflags), errp) < 0) {

            error_prepend(errp, "Failed to send clientflags field");

            goto fail;

        }

        if (tlscreds) {

            if (fixedNewStyle) {

                *outioc = nbd_receive_starttls(ioc, tlscreds, hostname, errp);

                if (!*outioc) {

                    goto fail;

                }

                ioc = *outioc;

            } else {

                error_setg(errp, "Server does not support STARTTLS");

                goto fail;

            }

        }

        if (!name) {

            trace_nbd_receive_negotiate_default_name();

            name = "";

        }

        if (fixedNewStyle) {

            int result;



            if (structured_reply) {

                result = nbd_request_simple_option(ioc,

                                                   NBD_OPT_STRUCTURED_REPLY,

                                                   errp);

                if (result < 0) {

                    goto fail;

                }

                info->structured_reply = result == 1;

            }



            /* Try NBD_OPT_GO first - if it works, we are done (it

             * also gives us a good message if the server requires

             * TLS).  If it is not available, fall back to

             * NBD_OPT_LIST for nicer error messages about a missing

             * export, then use NBD_OPT_EXPORT_NAME.  */

            result = nbd_opt_go(ioc, name, info, errp);

            if (result < 0) {

                goto fail;

            }

            if (result > 0) {

                return 0;

            }

            /* Check our desired export is present in the

             * server export list. Since NBD_OPT_EXPORT_NAME

             * cannot return an error message, running this

             * query gives us better error reporting if the

             * export name is not available.

             */

            if (nbd_receive_query_exports(ioc, name, errp) < 0) {

                goto fail;

            }

        }

        /* write the export name request */

        if (nbd_send_option_request(ioc, NBD_OPT_EXPORT_NAME, -1, name,

                                    errp) < 0) {

            goto fail;

        }



        /* Read the response */

        if (nbd_read(ioc, &info->size, sizeof(info->size), errp) < 0) {

            error_prepend(errp, "Failed to read export length");

            goto fail;

        }

        be64_to_cpus(&info->size);



        if (nbd_read(ioc, &info->flags, sizeof(info->flags), errp) < 0) {

            error_prepend(errp, "Failed to read export flags");

            goto fail;

        }

        be16_to_cpus(&info->flags);

    } else if (magic == NBD_CLIENT_MAGIC) {

        uint32_t oldflags;



        if (name) {

            error_setg(errp, "Server does not support export names");

            goto fail;

        }

        if (tlscreds) {

            error_setg(errp, "Server does not support STARTTLS");

            goto fail;

        }



        if (nbd_read(ioc, &info->size, sizeof(info->size), errp) < 0) {

            error_prepend(errp, "Failed to read export length");

            goto fail;

        }

        be64_to_cpus(&info->size);



        if (nbd_read(ioc, &oldflags, sizeof(oldflags), errp) < 0) {

            error_prepend(errp, "Failed to read export flags");

            goto fail;

        }

        be32_to_cpus(&oldflags);

        if (oldflags & ~0xffff) {

            error_setg(errp, "Unexpected export flags %0x" PRIx32, oldflags);

            goto fail;

        }

        info->flags = oldflags;

    } else {

        error_setg(errp, "Bad magic received");

        goto fail;

    }



    trace_nbd_receive_negotiate_size_flags(info->size, info->flags);

    if (zeroes && nbd_drop(ioc, 124, errp) < 0) {

        error_prepend(errp, "Failed to read reserved block");

        goto fail;

    }

    rc = 0;



fail:

    return rc;

}
int nbd_receive_negotiate(QIOChannel *ioc, const char *name,

                          QCryptoTLSCreds *tlscreds, const char *hostname,

                          QIOChannel **outioc, NBDExportInfo *info,

                          Error **errp)

{

    char buf[256];

    uint64_t magic;

    int rc;

    bool zeroes = true;




    trace_nbd_receive_negotiate(tlscreds, hostname ? hostname : "<null>");




    rc = -EINVAL;



    if (outioc) {

        *outioc = NULL;

    }

    if (tlscreds && !outioc) {

        error_setg(errp, "Output I/O channel required for TLS");

        goto fail;

    }



    if (nbd_read(ioc, buf, 8, errp) < 0) {

        error_prepend(errp, "Failed to read data");

        goto fail;

    }



    buf[8] = '\0';

    if (strlen(buf) == 0) {

        error_setg(errp, "Server connection closed unexpectedly");

        goto fail;

    }



    magic = ldq_be_p(buf);

    trace_nbd_receive_negotiate_magic(magic);



    if (memcmp(buf, "NBDMAGIC", 8) != 0) {

        error_setg(errp, "Invalid magic received");

        goto fail;

    }



    if (nbd_read(ioc, &magic, sizeof(magic), errp) < 0) {

        error_prepend(errp, "Failed to read magic");

        goto fail;

    }

    magic = be64_to_cpu(magic);

    trace_nbd_receive_negotiate_magic(magic);



    if (magic == NBD_OPTS_MAGIC) {

        uint32_t clientflags = 0;

        uint16_t globalflags;

        bool fixedNewStyle = false;



        if (nbd_read(ioc, &globalflags, sizeof(globalflags), errp) < 0) {

            error_prepend(errp, "Failed to read server flags");

            goto fail;

        }

        globalflags = be16_to_cpu(globalflags);

        trace_nbd_receive_negotiate_server_flags(globalflags);

        if (globalflags & NBD_FLAG_FIXED_NEWSTYLE) {

            fixedNewStyle = true;

            clientflags |= NBD_FLAG_C_FIXED_NEWSTYLE;

        }

        if (globalflags & NBD_FLAG_NO_ZEROES) {

            zeroes = false;

            clientflags |= NBD_FLAG_C_NO_ZEROES;

        }

        

        clientflags = cpu_to_be32(clientflags);

        if (nbd_write(ioc, &clientflags, sizeof(clientflags), errp) < 0) {

            error_prepend(errp, "Failed to send clientflags field");

            goto fail;

        }

        if (tlscreds) {

            if (fixedNewStyle) {

                *outioc = nbd_receive_starttls(ioc, tlscreds, hostname, errp);

                if (!*outioc) {

                    goto fail;

                }

                ioc = *outioc;

            } else {

                error_setg(errp, "Server does not support STARTTLS");

                goto fail;

            }

        }

        if (!name) {

            trace_nbd_receive_negotiate_default_name();

            name = "";

        }

        if (fixedNewStyle) {

            int result;



            if (structured_reply) {

                result = nbd_request_simple_option(ioc,

                                                   NBD_OPT_STRUCTURED_REPLY,

                                                   errp);

                if (result < 0) {

                    goto fail;

                }

                info->structured_reply = result == 1;

            }



            









            result = nbd_opt_go(ioc, name, info, errp);

            if (result < 0) {

                goto fail;

            }

            if (result > 0) {

                return 0;

            }

            











            if (nbd_receive_query_exports(ioc, name, errp) < 0) {

                goto fail;

            }

        }

        

        if (nbd_send_option_request(ioc, NBD_OPT_EXPORT_NAME, -1, name,

                                    errp) < 0) {

            goto fail;

        }



        

        if (nbd_read(ioc, &info->size, sizeof(info->size), errp) < 0) {

            error_prepend(errp, "Failed to read export length");

            goto fail;

        }

        be64_to_cpus(&info->size);



        if (nbd_read(ioc, &info->flags, sizeof(info->flags), errp) < 0) {

            error_prepend(errp, "Failed to read export flags");

            goto fail;

        }

        be16_to_cpus(&info->flags);

    } else if (magic == NBD_CLIENT_MAGIC) {

        uint32_t oldflags;



        if (name) {

            error_setg(errp, "Server does not support export names");

            goto fail;

        }

        if (tlscreds) {

            error_setg(errp, "Server does not support STARTTLS");

            goto fail;

        }



        if (nbd_read(ioc, &info->size, sizeof(info->size), errp) < 0) {

            error_prepend(errp, "Failed to read export length");

            goto fail;

        }

        be64_to_cpus(&info->size);



        if (nbd_read(ioc, &oldflags, sizeof(oldflags), errp) < 0) {

            error_prepend(errp, "Failed to read export flags");

            goto fail;

        }

        be32_to_cpus(&oldflags);

        if (oldflags & ~0xffff) {

            error_setg(errp, "Unexpected export flags %0x" PRIx32, oldflags);

            goto fail;

        }

        info->flags = oldflags;

    } else {

        error_setg(errp, "Bad magic received");

        goto fail;

    }



    trace_nbd_receive_negotiate_size_flags(info->size, info->flags);

    if (zeroes && nbd_drop(ioc, 124, errp) < 0) {

        error_prepend(errp, "Failed to read reserved block");

        goto fail;

    }

    rc = 0;



fail:

    return rc;

}
    } else {
int FUNC_0(QIOChannel *VAR_0, const char *VAR_1,

                          QCryptoTLSCreds *VAR_2, const char *VAR_3,

                          QIOChannel **VAR_4, NBDExportInfo *VAR_5,

                          Error **VAR_6)

{

    char VAR_7[256];

    uint64_t magic;

    int VAR_8;

    bool zeroes = true;




    trace_nbd_receive_negotiate(VAR_2, VAR_3 ? VAR_3 : "<null>");




    VAR_8 = -EINVAL;



    if (VAR_4) {

        *VAR_4 = NULL;

    }

    if (VAR_2 && !VAR_4) {

        error_setg(VAR_6, "Output I/O channel required for TLS");

        goto fail;

    }



    if (nbd_read(VAR_0, VAR_7, 8, VAR_6) < 0) {

        error_prepend(VAR_6, "Failed to read data");

        goto fail;

    }



    VAR_7[8] = '\0';

    if (strlen(VAR_7) == 0) {

        error_setg(VAR_6, "Server connection closed unexpectedly");

        goto fail;

    }



    magic = ldq_be_p(VAR_7);

    trace_nbd_receive_negotiate_magic(magic);



    if (memcmp(VAR_7, "NBDMAGIC", 8) != 0) {

        error_setg(VAR_6, "Invalid magic received");

        goto fail;

    }



    if (nbd_read(VAR_0, &magic, sizeof(magic), VAR_6) < 0) {

        error_prepend(VAR_6, "Failed to read magic");

        goto fail;

    }

    magic = be64_to_cpu(magic);

    trace_nbd_receive_negotiate_magic(magic);



    if (magic == NBD_OPTS_MAGIC) {

        uint32_t clientflags = 0;

        uint16_t globalflags;

        bool fixedNewStyle = false;



        if (nbd_read(VAR_0, &globalflags, sizeof(globalflags), VAR_6) < 0) {

            error_prepend(VAR_6, "Failed to read server flags");

            goto fail;

        }

        globalflags = be16_to_cpu(globalflags);

        trace_nbd_receive_negotiate_server_flags(globalflags);

        if (globalflags & NBD_FLAG_FIXED_NEWSTYLE) {

            fixedNewStyle = true;

            clientflags |= NBD_FLAG_C_FIXED_NEWSTYLE;

        }

        if (globalflags & NBD_FLAG_NO_ZEROES) {

            zeroes = false;

            clientflags |= NBD_FLAG_C_NO_ZEROES;

        }

        

        clientflags = cpu_to_be32(clientflags);

        if (nbd_write(VAR_0, &clientflags, sizeof(clientflags), VAR_6) < 0) {

            error_prepend(VAR_6, "Failed to send clientflags field");

            goto fail;

        }

        if (VAR_2) {

            if (fixedNewStyle) {

                *VAR_4 = nbd_receive_starttls(VAR_0, VAR_2, VAR_3, VAR_6);

                if (!*VAR_4) {

                    goto fail;

                }

                VAR_0 = *VAR_4;

            } else {

                error_setg(VAR_6, "Server does not support STARTTLS");

                goto fail;

            }

        }

        if (!VAR_1) {

            trace_nbd_receive_negotiate_default_name();

            VAR_1 = "";

        }

        if (fixedNewStyle) {

            int VAR_9;



            if (structured_reply) {

                VAR_9 = nbd_request_simple_option(VAR_0,

                                                   NBD_OPT_STRUCTURED_REPLY,

                                                   VAR_6);

                if (VAR_9 < 0) {

                    goto fail;

                }

                VAR_5->structured_reply = VAR_9 == 1;

            }



            









            VAR_9 = nbd_opt_go(VAR_0, VAR_1, VAR_5, VAR_6);

            if (VAR_9 < 0) {

                goto fail;

            }

            if (VAR_9 > 0) {

                return 0;

            }

            











            if (nbd_receive_query_exports(VAR_0, VAR_1, VAR_6) < 0) {

                goto fail;

            }

        }

        

        if (nbd_send_option_request(VAR_0, NBD_OPT_EXPORT_NAME, -1, VAR_1,

                                    VAR_6) < 0) {

            goto fail;

        }



        

        if (nbd_read(VAR_0, &VAR_5->size, sizeof(VAR_5->size), VAR_6) < 0) {

            error_prepend(VAR_6, "Failed to read export length");

            goto fail;

        }

        be64_to_cpus(&VAR_5->size);



        if (nbd_read(VAR_0, &VAR_5->flags, sizeof(VAR_5->flags), VAR_6) < 0) {

            error_prepend(VAR_6, "Failed to read export flags");

            goto fail;

        }

        be16_to_cpus(&VAR_5->flags);

    } else if (magic == NBD_CLIENT_MAGIC) {

        uint32_t oldflags;



        if (VAR_1) {

            error_setg(VAR_6, "Server does not support export names");

            goto fail;

        }

        if (VAR_2) {

            error_setg(VAR_6, "Server does not support STARTTLS");

            goto fail;

        }



        if (nbd_read(VAR_0, &VAR_5->size, sizeof(VAR_5->size), VAR_6) < 0) {

            error_prepend(VAR_6, "Failed to read export length");

            goto fail;

        }

        be64_to_cpus(&VAR_5->size);



        if (nbd_read(VAR_0, &oldflags, sizeof(oldflags), VAR_6) < 0) {

            error_prepend(VAR_6, "Failed to read export flags");

            goto fail;

        }

        be32_to_cpus(&oldflags);

        if (oldflags & ~0xffff) {

            error_setg(VAR_6, "Unexpected export flags %0x" PRIx32, oldflags);

            goto fail;

        }

        VAR_5->flags = oldflags;

    } else {

        error_setg(VAR_6, "Bad magic received");

        goto fail;

    }



    trace_nbd_receive_negotiate_size_flags(VAR_5->size, VAR_5->flags);

    if (zeroes && nbd_drop(VAR_0, 124, VAR_6) < 0) {

        error_prepend(VAR_6, "Failed to read reserved block");

        goto fail;

    }

    VAR_8 = 0;



fail:

    return VAR_8;

}
int FUNC_0(QIOChannel *VAR_0, const char *VAR_1,
QCryptoTLSCreds *VAR_2, const char *VAR_3,
QIOChannel **VAR_4, NBDExportInfo *VAR_5,
Error **VAR_6)
{ char VAR_7[256]; uint64_t magic; int VAR_8; bool zeroes = true; trace_nbd_receive_negotiate(VAR_2, VAR_3 ? VAR_3 : "<null>"); VAR_8 = -EINVAL; if (VAR_4) { *VAR_4 = NULL; } if (VAR_2 && !VAR_4) { error_setg(VAR_6, "Output I/O channel required for TLS"); goto fail; } if (nbd_read(VAR_0, VAR_7, 8, VAR_6) < 0) { error_prepend(VAR_6, "Failed to read data"); goto fail; } VAR_7[8] = '\0'; if (strlen(VAR_7) == 0) { error_setg(VAR_6, "Server connection closed unexpectedly"); goto fail; } magic = ldq_be_p(VAR_7); trace_nbd_receive_negotiate_magic(magic); if (memcmp(VAR_7, "NBDMAGIC", 8) != 0) { error_setg(VAR_6, "Invalid magic received"); goto fail; } if (nbd_read(VAR_0, &magic, sizeof(magic), VAR_6) < 0) { error_prepend(VAR_6, "Failed to read magic"); goto fail; } magic = be64_to_cpu(magic); trace_nbd_receive_negotiate_magic(magic); if (magic == NBD_OPTS_MAGIC) { uint32_t clientflags = 0; uint16_t globalflags; bool fixedNewStyle = false; if (nbd_read(VAR_0, &globalflags, sizeof(globalflags), VAR_6) < 0) { error_prepend(VAR_6, "Failed to read server flags"); goto fail; } globalflags = be16_to_cpu(globalflags); trace_nbd_receive_negotiate_server_flags(globalflags); if (globalflags & NBD_FLAG_FIXED_NEWSTYLE) { fixedNewStyle = true; clientflags |= NBD_FLAG_C_FIXED_NEWSTYLE; } if (globalflags & NBD_FLAG_NO_ZEROES) { zeroes = false; clientflags |= NBD_FLAG_C_NO_ZEROES; } clientflags = cpu_to_be32(clientflags); if (nbd_write(VAR_0, &clientflags, sizeof(clientflags), VAR_6) < 0) { error_prepend(VAR_6, "Failed to send clientflags field"); goto fail; } if (VAR_2) { if (fixedNewStyle) { *VAR_4 = nbd_receive_starttls(VAR_0, VAR_2, VAR_3, VAR_6); if (!*VAR_4) { goto fail; } VAR_0 = *VAR_4; } else { error_setg(VAR_6, "Server does not support STARTTLS"); goto fail; } } if (!VAR_1) { trace_nbd_receive_negotiate_default_name(); VAR_1 = ""; } if (fixedNewStyle) { int VAR_9; if (structured_reply) { VAR_9 = nbd_request_simple_option(VAR_0,
NBD_OPT_STRUCTURED_REPLY,
VAR_6); if (VAR_9 < 0) { goto fail; } VAR_5->structured_reply = VAR_9 == 1; } VAR_9 = nbd_opt_go(VAR_0, VAR_1, VAR_5, VAR_6); if (VAR_9 < 0) { goto fail; } if (VAR_9 > 0) { return 0; } if (nbd_receive_query_exports(VAR_0, VAR_1, VAR_6) < 0) { goto fail; } } if (nbd_send_option_request(VAR_0, NBD_OPT_EXPORT_NAME, -1, VAR_1,
VAR_6) < 0) { goto fail; } if (nbd_read(VAR_0, &VAR_5->size, sizeof(VAR_5->size), VAR_6) < 0) { error_prepend(VAR_6, "Failed to read export length"); goto fail; } be64_to_cpus(&VAR_5->size); if (nbd_read(VAR_0, &VAR_5->flags, sizeof(VAR_5->flags), VAR_6) < 0) { error_prepend(VAR_6, "Failed to read export flags"); goto fail; } be16_to_cpus(&VAR_5->flags); } else if (magic == NBD_CLIENT_MAGIC) { uint32_t oldflags; if (VAR_1) { error_setg(VAR_6, "Server does not support export names"); goto fail; } if (VAR_2) { error_setg(VAR_6, "Server does not support STARTTLS"); goto fail; } if (nbd_read(VAR_0, &VAR_5->size, sizeof(VAR_5->size), VAR_6) < 0) { error_prepend(VAR_6, "Failed to read export length"); goto fail; } be64_to_cpus(&VAR_5->size); if (nbd_read(VAR_0, &oldflags, sizeof(oldflags), VAR_6) < 0) { error_prepend(VAR_6, "Failed to read export flags"); goto fail; } be32_to_cpus(&oldflags); if (oldflags & ~0xffff) { error_setg(VAR_6, "Unexpected export flags %0x" PRIx32, oldflags); goto fail; } VAR_5->flags = oldflags; } else { error_setg(VAR_6, "Bad magic received"); goto fail; } trace_nbd_receive_negotiate_size_flags(VAR_5->size, VAR_5->flags); if (zeroes && nbd_drop(VAR_0, 124, VAR_6) < 0) { error_prepend(VAR_6, "Failed to read reserved block"); goto fail; } VAR_8 = 0; fail:
return VAR_8; }