fridtjof/qemu-cr16
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

migration: add cpr_walk_fd

Browse source 
Add a helper to walk all CPR fd's and run a callback for each.

Signed-off-by: Steve Sistare <steven.sistare@oracle.com>
Reviewed-by: Peter Xu <peterx@redhat.com>
Link: https://lore.kernel.org/r/1759332851-370353-3-git-send-email-steven.sistare@oracle.com
Signed-off-by: Peter Xu <peterx@redhat.com>
This commit is contained in:
Steve Sistare 2025-10-01 08:33:54 -07:00 • committed by Peter Xu
parent dc79c7d5e1
commit a9f9eee58b
2 changed files with 16 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

3
include/migration/cpr.h
View file

@ -34,6 +34,9 @@ void cpr_resave_fd(const char *name, int id, int fd);
int cpr_open_fd(const char *path, int flags, const char *name, int id,
Error **errp);
typedef bool (*cpr_walk_fd_cb)(int fd);
bool cpr_walk_fd(cpr_walk_fd_cb cb);
MigMode cpr_get_incoming_mode(void);
void cpr_set_incoming_mode(MigMode mode);
bool cpr_is_incoming(void);

13
migration/cpr.c
View file

@ -122,6 +122,19 @@ int cpr_open_fd(const char *path, int flags, const char *name, int id,
return fd;
}
bool cpr_walk_fd(cpr_walk_fd_cb cb)
{
CprFd *elem;
QLIST_FOREACH(elem, &cpr_state.fds, next) {
g_assert(elem->fd >= 0);
if (!cb(elem->fd)) {
return false;
}
}
return true;
}
/*************************************************************************/
static const VMStateDescription vmstate_cpr_state = {
.name = CPR_STATE,