Pārlūkot izejas kodu

migration: cpr_is_incoming

Define the cpr_is_incoming helper, to be used in several cpr fix patches.

Signed-off-by: Steve Sistare <steven.sistare@oracle.com>
Reviewed-by: Peter Xu <peterx@redhat.com>
Reviewed-by: Fabiano Rosas <farosas@suse.de>
Message-ID: <1741380954-341079-2-git-send-email-steven.sistare@oracle.com>
Signed-off-by: Fabiano Rosas <farosas@suse.de>
Steve Sistare 5 mēneši atpakaļ
vecāks
revīzija
1632a2017f
2 mainītis faili ar 6 papildinājumiem un 0 dzēšanām
  1. 1 0
      include/migration/cpr.h
  2. 5 0
      migration/cpr.c

+ 1 - 0
include/migration/cpr.h

@@ -21,6 +21,7 @@ int cpr_find_fd(const char *name, int id);
 
 
 MigMode cpr_get_incoming_mode(void);
 MigMode cpr_get_incoming_mode(void);
 void cpr_set_incoming_mode(MigMode mode);
 void cpr_set_incoming_mode(MigMode mode);
+bool cpr_is_incoming(void);
 
 
 int cpr_state_save(MigrationChannel *channel, Error **errp);
 int cpr_state_save(MigrationChannel *channel, Error **errp);
 int cpr_state_load(MigrationChannel *channel, Error **errp);
 int cpr_state_load(MigrationChannel *channel, Error **errp);

+ 5 - 0
migration/cpr.c

@@ -128,6 +128,11 @@ void cpr_set_incoming_mode(MigMode mode)
     incoming_mode = mode;
     incoming_mode = mode;
 }
 }
 
 
+bool cpr_is_incoming(void)
+{
+    return incoming_mode != MIG_MODE_NONE;
+}
+
 int cpr_state_save(MigrationChannel *channel, Error **errp)
 int cpr_state_save(MigrationChannel *channel, Error **errp)
 {
 {
     int ret;
     int ret;