Message ID | fe14c841e40e294c05f8dae966e94cc12b3e5473.1724701542.git.maciej.szmigiero@oracle.com |
---|---|
State | New |
Headers | show |
Series | Multifd 🔀 device state transfer support with VFIO consumer | expand |
"Maciej S. Szmigiero" <mail@maciej.szmigiero.name> writes: > From: "Maciej S. Szmigiero" <maciej.szmigiero@oracle.com> > > qemu_loadvm_load_state_buffer() and its load_state_buffer > SaveVMHandler allow providing device state buffer to explicitly > specified device via its idstr and instance id. > > Signed-off-by: Maciej S. Szmigiero <maciej.szmigiero@oracle.com> Reviewed-by: Fabiano Rosas <farosas@suse.de>
On 27/08/2024 20:54, Maciej S. Szmigiero wrote: > External email: Use caution opening links or attachments > > > From: "Maciej S. Szmigiero" <maciej.szmigiero@oracle.com> > > qemu_loadvm_load_state_buffer() and its load_state_buffer > SaveVMHandler allow providing device state buffer to explicitly > specified device via its idstr and instance id. > > Signed-off-by: Maciej S. Szmigiero <maciej.szmigiero@oracle.com> > --- > include/migration/register.h | 15 +++++++++++++++ > migration/savevm.c | 25 +++++++++++++++++++++++++ > migration/savevm.h | 3 +++ > 3 files changed, 43 insertions(+) > > diff --git a/include/migration/register.h b/include/migration/register.h > index 9de123252edf..4a578f140713 100644 > --- a/include/migration/register.h > +++ b/include/migration/register.h > @@ -263,6 +263,21 @@ typedef struct SaveVMHandlers { > */ > int (*load_state)(QEMUFile *f, void *opaque, int version_id); > > + /** > + * @load_state_buffer > + * > + * Load device state buffer provided to qemu_loadvm_load_state_buffer(). > + * > + * @opaque: data pointer passed to register_savevm_live() > + * @data: the data buffer to load > + * @data_size: the data length in buffer > + * @errp: pointer to Error*, to store an error if it happens. > + * > + * Returns zero to indicate success and negative for error > + */ > + int (*load_state_buffer)(void *opaque, char *data, size_t data_size, > + Error **errp); Nit: Maybe rename data to buf and data_size to len to be consistent with qemu_loadvm_load_state_buffer()? > + > /** > * @load_setup > * > diff --git a/migration/savevm.c b/migration/savevm.c > index d43acbbf20cf..3fde5ca8c26b 100644 > --- a/migration/savevm.c > +++ b/migration/savevm.c > @@ -3101,6 +3101,31 @@ int qemu_loadvm_approve_switchover(void) > return migrate_send_rp_switchover_ack(mis); > } > > +int qemu_loadvm_load_state_buffer(const char *idstr, uint32_t instance_id, > + char *buf, size_t len, Error **errp) > +{ > + SaveStateEntry *se; > + > + se = find_se(idstr, instance_id); > + if (!se) { > + error_setg(errp, "Unknown idstr %s or instance id %u for load state buffer", > + idstr, instance_id); > + return -1; > + } > + > + if (!se->ops || !se->ops->load_state_buffer) { > + error_setg(errp, "idstr %s / instance %u has no load state buffer operation", > + idstr, instance_id); > + return -1; > + } > + > + if (se->ops->load_state_buffer(se->opaque, buf, len, errp) != 0) { > + return -1; > + } > + > + return 0; Nit: this can be simplified to: return se->ops->load_state_buffer(se->opaque, buf, len, errp); Thanks. > +} > + > bool save_snapshot(const char *name, bool overwrite, const char *vmstate, > bool has_devices, strList *devices, Error **errp) > { > diff --git a/migration/savevm.h b/migration/savevm.h > index 9ec96a995c93..d388f1bfca98 100644 > --- a/migration/savevm.h > +++ b/migration/savevm.h > @@ -70,4 +70,7 @@ int qemu_loadvm_approve_switchover(void); > int qemu_savevm_state_complete_precopy_non_iterable(QEMUFile *f, > bool in_postcopy, bool inactivate_disks); > > +int qemu_loadvm_load_state_buffer(const char *idstr, uint32_t instance_id, > + char *buf, size_t len, Error **errp); > + > #endif
On 5.09.2024 16:15, Avihai Horon wrote: > > On 27/08/2024 20:54, Maciej S. Szmigiero wrote: >> External email: Use caution opening links or attachments >> >> >> From: "Maciej S. Szmigiero" <maciej.szmigiero@oracle.com> >> >> qemu_loadvm_load_state_buffer() and its load_state_buffer >> SaveVMHandler allow providing device state buffer to explicitly >> specified device via its idstr and instance id. >> >> Signed-off-by: Maciej S. Szmigiero <maciej.szmigiero@oracle.com> >> --- >>  include/migration/register.h | 15 +++++++++++++++ >>  migration/savevm.c          | 25 +++++++++++++++++++++++++ >>  migration/savevm.h          | 3 +++ >>  3 files changed, 43 insertions(+) >> >> diff --git a/include/migration/register.h b/include/migration/register.h >> index 9de123252edf..4a578f140713 100644 >> --- a/include/migration/register.h >> +++ b/include/migration/register.h >> @@ -263,6 +263,21 @@ typedef struct SaveVMHandlers { >>       */ >>      int (*load_state)(QEMUFile *f, void *opaque, int version_id); >> >> +   /** >> +    * @load_state_buffer >> +    * >> +    * Load device state buffer provided to qemu_loadvm_load_state_buffer(). >> +    * >> +    * @opaque: data pointer passed to register_savevm_live() >> +    * @data: the data buffer to load >> +    * @data_size: the data length in buffer >> +    * @errp: pointer to Error*, to store an error if it happens. >> +    * >> +    * Returns zero to indicate success and negative for error >> +    */ >> +   int (*load_state_buffer)(void *opaque, char *data, size_t data_size, >> +                            Error **errp); > > Nit: Maybe rename data to buf and data_size to len to be consistent with qemu_loadvm_load_state_buffer()? Will do. >> + >>      /** >>       * @load_setup >>       * >> diff --git a/migration/savevm.c b/migration/savevm.c >> index d43acbbf20cf..3fde5ca8c26b 100644 >> --- a/migration/savevm.c >> +++ b/migration/savevm.c >> @@ -3101,6 +3101,31 @@ int qemu_loadvm_approve_switchover(void) >>      return migrate_send_rp_switchover_ack(mis); >>  } >> >> +int qemu_loadvm_load_state_buffer(const char *idstr, uint32_t instance_id, >> +                                 char *buf, size_t len, Error **errp) >> +{ >> +   SaveStateEntry *se; >> + >> +   se = find_se(idstr, instance_id); >> +   if (!se) { >> +       error_setg(errp, "Unknown idstr %s or instance id %u for load state buffer", >> +                  idstr, instance_id); >> +       return -1; >> +   } >> + >> +   if (!se->ops || !se->ops->load_state_buffer) { >> +       error_setg(errp, "idstr %s / instance %u has no load state buffer operation", >> +                  idstr, instance_id); >> +       return -1; >> +   } >> + >> +   if (se->ops->load_state_buffer(se->opaque, buf, len, errp) != 0) { >> +       return -1; >> +   } >> + >> +   return 0; > > Nit: this can be simplified to: > return se->ops->load_state_buffer(se->opaque, buf, len, errp); You're right - will change it so. > Thanks. Thanks, Maciej
diff --git a/include/migration/register.h b/include/migration/register.h index 9de123252edf..4a578f140713 100644 --- a/include/migration/register.h +++ b/include/migration/register.h @@ -263,6 +263,21 @@ typedef struct SaveVMHandlers { */ int (*load_state)(QEMUFile *f, void *opaque, int version_id); + /** + * @load_state_buffer + * + * Load device state buffer provided to qemu_loadvm_load_state_buffer(). + * + * @opaque: data pointer passed to register_savevm_live() + * @data: the data buffer to load + * @data_size: the data length in buffer + * @errp: pointer to Error*, to store an error if it happens. + * + * Returns zero to indicate success and negative for error + */ + int (*load_state_buffer)(void *opaque, char *data, size_t data_size, + Error **errp); + /** * @load_setup * diff --git a/migration/savevm.c b/migration/savevm.c index d43acbbf20cf..3fde5ca8c26b 100644 --- a/migration/savevm.c +++ b/migration/savevm.c @@ -3101,6 +3101,31 @@ int qemu_loadvm_approve_switchover(void) return migrate_send_rp_switchover_ack(mis); } +int qemu_loadvm_load_state_buffer(const char *idstr, uint32_t instance_id, + char *buf, size_t len, Error **errp) +{ + SaveStateEntry *se; + + se = find_se(idstr, instance_id); + if (!se) { + error_setg(errp, "Unknown idstr %s or instance id %u for load state buffer", + idstr, instance_id); + return -1; + } + + if (!se->ops || !se->ops->load_state_buffer) { + error_setg(errp, "idstr %s / instance %u has no load state buffer operation", + idstr, instance_id); + return -1; + } + + if (se->ops->load_state_buffer(se->opaque, buf, len, errp) != 0) { + return -1; + } + + return 0; +} + bool save_snapshot(const char *name, bool overwrite, const char *vmstate, bool has_devices, strList *devices, Error **errp) { diff --git a/migration/savevm.h b/migration/savevm.h index 9ec96a995c93..d388f1bfca98 100644 --- a/migration/savevm.h +++ b/migration/savevm.h @@ -70,4 +70,7 @@ int qemu_loadvm_approve_switchover(void); int qemu_savevm_state_complete_precopy_non_iterable(QEMUFile *f, bool in_postcopy, bool inactivate_disks); +int qemu_loadvm_load_state_buffer(const char *idstr, uint32_t instance_id, + char *buf, size_t len, Error **errp); + #endif