void stream_start(const char *job_id, BlockDriverState *bs,

                  BlockDriverState *base, const char *backing_file_str,

                  int64_t speed, BlockdevOnError on_error,

                  BlockCompletionFunc *cb, void *opaque, Error **errp)

{

    StreamBlockJob *s;



    s = block_job_create(job_id, &stream_job_driver, bs, speed,

                         cb, opaque, errp);

    if (!s) {

        return;

    }



    s->base = base;

    s->backing_file_str = g_strdup(backing_file_str);



    s->on_error = on_error;

    s->common.co = qemu_coroutine_create(stream_run);

    trace_stream_start(bs, base, s, s->common.co, opaque);

    qemu_coroutine_enter(s->common.co, s);

}

void stream_start(const char *job_id, BlockDriverState *bs,

                  BlockDriverState *base, const char *backing_file_str,

                  int64_t speed, BlockdevOnError on_error,

                  BlockCompletionFunc *cb, void *opaque, Error **errp)

{

    StreamBlockJob *s;



    s = block_job_create(job_id, &stream_job_driver, bs, speed,

                         cb, opaque, errp);

    if (!s) {

        return;

    }



    s->base = base;

    s->backing_file_str = g_strdup(backing_file_str);



    s->on_error = on_error;

    s->common.co = qemu_coroutine_create(stream_run);

    trace_stream_start(bs, base, s, s->common.co, opaque);

    qemu_coroutine_enter(s->common.co, s);

}

    qemu_coroutine_enter(s->common.co, s);     qemu_coroutine_enter(s->common.co, s);     s->common.co = qemu_coroutine_create(stream_run);     qemu_coroutine_enter(s->common.co, s);     qemu_coroutine_enter(s->common.co, s);
void FUNC_0(const char *VAR_0, BlockDriverState *VAR_1,

                  BlockDriverState *VAR_2, const char *VAR_3,

                  int64_t VAR_4, BlockdevOnError VAR_5,

                  BlockCompletionFunc *VAR_6, void *VAR_7, Error **VAR_8)

{

    StreamBlockJob *s;



    s = block_job_create(VAR_0, &stream_job_driver, VAR_1, VAR_4,

                         VAR_6, VAR_7, VAR_8);

    if (!s) {

        return;

    }



    s->VAR_2 = VAR_2;

    s->VAR_3 = g_strdup(VAR_3);



    s->VAR_5 = VAR_5;

    s->common.co = qemu_coroutine_create(stream_run);

    trace_stream_start(VAR_1, VAR_2, s, s->common.co, VAR_7);

    qemu_coroutine_enter(s->common.co, s);

}

void FUNC_0(const char *VAR_0, BlockDriverState *VAR_1,
BlockDriverState *VAR_2, const char *VAR_3,
int64_t VAR_4, BlockdevOnError VAR_5,
BlockCompletionFunc *VAR_6, void *VAR_7, Error **VAR_8)
{ StreamBlockJob *s; s = block_job_create(VAR_0, &stream_job_driver, VAR_1, VAR_4,
VAR_6, VAR_7, VAR_8); if (!s) { return; } s->VAR_2 = VAR_2; s->VAR_3 = g_strdup(VAR_3); s->VAR_5 = VAR_5; s->common.co = qemu_coroutine_create(stream_run); trace_stream_start(VAR_1, VAR_2, s, s->common.co, VAR_7); qemu_coroutine_enter(s->common.co, s); }