void stream_start(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(&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(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(&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);

}

    s = block_job_create(&stream_job_driver, bs, speed, cb, opaque, errp);
void FUNC_0(BlockDriverState *VAR_0, BlockDriverState *VAR_1,

                  const char *VAR_2, int64_t VAR_3,

                  BlockdevOnError VAR_4,

                  BlockCompletionFunc *VAR_5,

                  void *VAR_6, Error **VAR_7)

{

    StreamBlockJob *s;



    s = block_job_create(&stream_job_driver, VAR_0, VAR_3, VAR_5, VAR_6, VAR_7);

    if (!s) {

        return;

    }



    s->VAR_1 = VAR_1;

    s->VAR_2 = g_strdup(VAR_2);



    s->VAR_4 = VAR_4;

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

    trace_stream_start(VAR_0, VAR_1, s, s->common.co, VAR_6);

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

}

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