pxcloud/spice
5
0
Fork 0
mirror of https://gitlab.uni-freiburg.de/opensourcevdi/spice synced 2026-01-03 07:02:25 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

spice.h: add entries for tracking vm state

Browse Source 
When vm state changes (started/stopped), we notify all the
attached SpiceCharDeviceStates about the change. This is mainly required
for avoiding writing/reading to/from the device during the non-live
stage of migration.

spice version will be bumped in one of the following patches.
This commit is contained in:
Yonit Halperin 2012-06-28 14:22:43 +03:00
parent 11033ca5dc
commit c302e12c78
2 changed files with 36 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
server/reds.c
View File

@ -252,6 +252,7 @@ typedef struct RedsState {
SpiceTimer *mig_timer; SpiceTimer *mig_timer;
SpiceTimer *mm_timer; SpiceTimer *mm_timer;
int vm_running;
Ring char_devs_states; /* list of SpiceCharDeviceStateItem */ Ring char_devs_states; /* list of SpiceCharDeviceStateItem */
SSL_CTX *ctx; SSL_CTX *ctx;
@ -3260,7 +3261,9 @@ static int spice_server_char_device_add_interface(SpiceServer *s,
spice_assert(char_device->st); spice_assert(char_device->st);
/* setting the char_device state to "started" for backward compatibily with /* setting the char_device state to "started" for backward compatibily with
* qemu releases that don't call spice api for start/stop (not implemented yet) */ * qemu releases that don't call spice api for start/stop (not implemented yet) */
spice_char_device_start(char_device->st); if (reds->vm_running) {
spice_char_device_start(char_device->st);
}
reds_char_device_add_state(char_device->st); reds_char_device_add_state(char_device->st);
} else { } else {
spice_warning("failed to create device state for %s", char_device->subtype); spice_warning("failed to create device state for %s", char_device->subtype);
@ -3476,6 +3479,7 @@ static int do_spice_init(SpiceCoreInterface *core_interface)
ring_init(&reds->channels); ring_init(&reds->channels);
ring_init(&reds->mig_target_clients); ring_init(&reds->mig_target_clients);
ring_init(&reds->char_devs_states); ring_init(&reds->char_devs_states);
reds->vm_running = TRUE; /* for backward compatibility */
if (!(reds->mig_timer = core->timer_add(migrate_timeout, NULL))) { if (!(reds->mig_timer = core->timer_add(migrate_timeout, NULL))) {
spice_error("migration timer create failed"); spice_error("migration timer create failed");
@ -4025,6 +4029,34 @@ SPICE_GNUC_VISIBLE int spice_server_migrate_switch(SpiceServer *s)
return 0; return 0;
} }
SPICE_GNUC_VISIBLE void spice_server_vm_start(SpiceServer *s)
{
RingItem *item;
spice_assert(s == reds);
reds->vm_running = TRUE;
RING_FOREACH(item, &reds->char_devs_states) {
SpiceCharDeviceStateItem *st_item;
st_item = SPICE_CONTAINEROF(item, SpiceCharDeviceStateItem, link);
spice_char_device_start(st_item->st);
}
}
SPICE_GNUC_VISIBLE void spice_server_vm_stop(SpiceServer *s)
{
RingItem *item;
spice_assert(s == reds);
reds->vm_running = FALSE;
RING_FOREACH(item, &reds->char_devs_states) {
SpiceCharDeviceStateItem *st_item;
st_item = SPICE_CONTAINEROF(item, SpiceCharDeviceStateItem, link);
spice_char_device_stop(st_item->st);
}
}
ssize_t reds_stream_read(RedsStream *s, void *buf, size_t nbyte) ssize_t reds_stream_read(RedsStream *s, void *buf, size_t nbyte)
{ {
ssize_t ret; ssize_t ret;

3
server/spice.h
View File

@ -528,4 +528,7 @@ int spice_server_migrate_end(SpiceServer *s, int completed);
void spice_server_set_name(SpiceServer *s, const char *name); void spice_server_set_name(SpiceServer *s, const char *name);
void spice_server_set_uuid(SpiceServer *s, const uint8_t uuid[16]); void spice_server_set_uuid(SpiceServer *s, const uint8_t uuid[16]);
void spice_server_vm_start(SpiceServer *s);
void spice_server_vm_stop(SpiceServer *s);
#endif #endif