1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
/*
* Multifd device state migration
*
* Copyright (C) 2024,2025 Oracle and/or its affiliates.
*
* This work is licensed under the terms of the GNU GPL, version 2 or later.
* See the COPYING file in the top-level directory.
*
* SPDX-License-Identifier: GPL-2.0-or-later
*/
#include "qemu/osdep.h"
#include "qemu/lockable.h"
#include "migration/misc.h"
#include "multifd.h"
#include "options.h"
static struct {
QemuMutex queue_job_mutex;
MultiFDSendData *send_data;
} *multifd_send_device_state;
void multifd_device_state_send_setup(void)
{
assert(!multifd_send_device_state);
multifd_send_device_state = g_malloc(sizeof(*multifd_send_device_state));
qemu_mutex_init(&multifd_send_device_state->queue_job_mutex);
multifd_send_device_state->send_data = multifd_send_data_alloc();
}
void multifd_device_state_send_cleanup(void)
{
g_clear_pointer(&multifd_send_device_state->send_data,
multifd_send_data_free);
qemu_mutex_destroy(&multifd_send_device_state->queue_job_mutex);
g_clear_pointer(&multifd_send_device_state, g_free);
}
void multifd_send_data_clear_device_state(MultiFDDeviceState_t *device_state)
{
g_clear_pointer(&device_state->idstr, g_free);
g_clear_pointer(&device_state->buf, g_free);
}
static void multifd_device_state_fill_packet(MultiFDSendParams *p)
{
MultiFDDeviceState_t *device_state = &p->data->u.device_state;
MultiFDPacketDeviceState_t *packet = p->packet_device_state;
packet->hdr.flags = cpu_to_be32(p->flags);
strncpy(packet->idstr, device_state->idstr, sizeof(packet->idstr) - 1);
packet->idstr[sizeof(packet->idstr) - 1] = 0;
packet->instance_id = cpu_to_be32(device_state->instance_id);
packet->next_packet_size = cpu_to_be32(p->next_packet_size);
}
static void multifd_prepare_header_device_state(MultiFDSendParams *p)
{
p->iov[0].iov_len = sizeof(*p->packet_device_state);
p->iov[0].iov_base = p->packet_device_state;
p->iovs_num++;
}
void multifd_device_state_send_prepare(MultiFDSendParams *p)
{
MultiFDDeviceState_t *device_state = &p->data->u.device_state;
assert(multifd_payload_device_state(p->data));
multifd_prepare_header_device_state(p);
assert(!(p->flags & MULTIFD_FLAG_SYNC));
p->next_packet_size = device_state->buf_len;
if (p->next_packet_size > 0) {
p->iov[p->iovs_num].iov_base = device_state->buf;
p->iov[p->iovs_num].iov_len = p->next_packet_size;
p->iovs_num++;
}
p->flags |= MULTIFD_FLAG_NOCOMP | MULTIFD_FLAG_DEVICE_STATE;
multifd_device_state_fill_packet(p);
}
bool multifd_queue_device_state(char *idstr, uint32_t instance_id,
char *data, size_t len)
{
/* Device state submissions can come from multiple threads */
QEMU_LOCK_GUARD(&multifd_send_device_state->queue_job_mutex);
MultiFDDeviceState_t *device_state;
assert(multifd_payload_empty(multifd_send_device_state->send_data));
multifd_set_payload_type(multifd_send_device_state->send_data,
MULTIFD_PAYLOAD_DEVICE_STATE);
device_state = &multifd_send_device_state->send_data->u.device_state;
device_state->idstr = g_strdup(idstr);
device_state->instance_id = instance_id;
device_state->buf = g_memdup2(data, len);
device_state->buf_len = len;
if (!multifd_send(&multifd_send_device_state->send_data)) {
multifd_send_data_clear(multifd_send_device_state->send_data);
return false;
}
return true;
}
bool multifd_device_state_supported(void)
{
return migrate_multifd() && !migrate_mapped_ram() &&
migrate_multifd_compression() == MULTIFD_COMPRESSION_NONE;
}
|
