Archipelago » qemu

    size_t buffer_size;

    size_t buffer_capacity;

    QemuThread thread;

} QEMUFileBuffered;

#ifdef DEBUG_BUFFERED_FILE

        ret = ret2;

    }

    ret = migrate_fd_close(s->migration_state);

    return ret;

}

    while (true) {

        int64_t current_time = qemu_get_clock_ms(rt_clock);

            break;

        }

        if (s->freeze_output) {

    .set_rate_limit = buffered_set_rate_limit,

};

{

    QEMUFileBuffered *s;

    s->migration_state = migration_state;

    s->xfer_limit = migration_state->bandwidth_limit / 10;

    s->file = qemu_fopen_ops(s, &buffered_file_ops);

    qemu_thread_create(&s->thread, buffered_file_thread, s,

                       QEMU_THREAD_DETACHED);

}

#include "hw/hw.h"

#include "migration/migration.h"

#endif

    int64_t dirty_pages_rate;

    bool enabled_capabilities[MIGRATION_CAPABILITY_MAX];

    int64_t xbzrle_cache_size;

};

void process_incoming_migration(QEMUFile *f);

    int ret;

    s->state = MIG_STATE_ACTIVE;

    DPRINTF("beginning savevm\n");

    ret = qemu_savevm_state_begin(s->file, &s->params);