Patchwork [29/41] migration: merge qemu_popen_cmd with qemu_popen

login
register
mail settings
Submitter Paolo Bonzini
Date Feb. 15, 2013, 5:47 p.m.
Message ID <1360950433-17106-30-git-send-email-pbonzini@redhat.com>
Download mbox | patch
Permalink /patch/220825/
State New
Headers show

Comments

Paolo Bonzini - Feb. 15, 2013, 5:47 p.m.
There is no reason for outgoing exec migration to do popen manually
anymore (the reason used to be that we needed the FILE* to make it
non-blocking).  Use qemu_popen_cmd.

Signed-off-by: Paolo Bonzini <pbonzini@redhat.com>
---
 include/migration/qemu-file.h |    1 -
 migration-exec.c              |   10 ++++------
 savevm.c                      |   22 ++++++++--------------
 3 files changed, 12 insertions(+), 21 deletions(-)
Orit Wasserman - Feb. 21, 2013, 7:36 a.m.
On 02/15/2013 07:47 PM, Paolo Bonzini wrote:
> There is no reason for outgoing exec migration to do popen manually
> anymore (the reason used to be that we needed the FILE* to make it
> non-blocking).  Use qemu_popen_cmd.
> 
> Signed-off-by: Paolo Bonzini <pbonzini@redhat.com>
> ---
>  include/migration/qemu-file.h |    1 -
>  migration-exec.c              |   10 ++++------
>  savevm.c                      |   22 ++++++++--------------
>  3 files changed, 12 insertions(+), 21 deletions(-)
> 
> diff --git a/include/migration/qemu-file.h b/include/migration/qemu-file.h
> index 46fc11d..987e719 100644
> --- a/include/migration/qemu-file.h
> +++ b/include/migration/qemu-file.h
> @@ -77,7 +77,6 @@ QEMUFile *qemu_fopen_ops(void *opaque, const QEMUFileOps *ops);
>  QEMUFile *qemu_fopen(const char *filename, const char *mode);
>  QEMUFile *qemu_fdopen(int fd, const char *mode);
>  QEMUFile *qemu_fopen_socket(int fd);
> -QEMUFile *qemu_popen(FILE *popen_file, const char *mode);
>  QEMUFile *qemu_popen_cmd(const char *command, const char *mode);
>  int qemu_get_fd(QEMUFile *f);
>  int qemu_fclose(QEMUFile *f);
> diff --git a/migration-exec.c b/migration-exec.c
> index a051a6e..5dc7313 100644
> --- a/migration-exec.c
> +++ b/migration-exec.c
> @@ -59,19 +59,17 @@ static int exec_close(MigrationState *s)
>  
>  void exec_start_outgoing_migration(MigrationState *s, const char *command, Error **errp)
>  {
> -    FILE *f;
> -
> -    f = popen(command, "w");
> +    QEMUFile *f;
> +    f = qemu_popen_cmd(command, "w");
>      if (f == NULL) {
>          error_setg_errno(errp, errno, "failed to popen the migration target");
>          return;
>      }
>  
> -    s->fd = fileno(f);
> +    s->opaque = f;
> +    s->fd = qemu_get_fd(f);
>      assert(s->fd != -1);
>  
> -    s->opaque = qemu_popen(f, "w");
> -
>      s->close = exec_close;
>      s->get_error = file_errno;
>      s->write = file_write;
> diff --git a/savevm.c b/savevm.c
> index fef2ab9..d7c2559 100644
> --- a/savevm.c
> +++ b/savevm.c
> @@ -275,11 +275,17 @@ static const QEMUFileOps stdio_pipe_write_ops = {
>      .close =      stdio_pclose
>  };
>  
> -QEMUFile *qemu_popen(FILE *stdio_file, const char *mode)
> +QEMUFile *qemu_popen_cmd(const char *command, const char *mode)
>  {
> +    FILE *stdio_file;
>      QEMUFileStdio *s;
>  
> -    if (stdio_file == NULL || mode == NULL || (mode[0] != 'r' && mode[0] != 'w') || mode[1] != 0) {
> +    stdio_file = popen(command, mode);
> +    if(stdio_file == NULL) {
> +        return NULL;
> +    }
> +
> +    if (mode == NULL || (mode[0] != 'r' && mode[0] != 'w') || mode[1] != 0) {
>          fprintf(stderr, "qemu_popen: Argument validity check failed\n");
>          return NULL;
>      }
> @@ -296,18 +302,6 @@ QEMUFile *qemu_popen(FILE *stdio_file, const char *mode)
>      return s->file;
>  }
>  
> -QEMUFile *qemu_popen_cmd(const char *command, const char *mode)
> -{
> -    FILE *popen_file;
> -
> -    popen_file = popen(command, mode);
> -    if(popen_file == NULL) {
> -        return NULL;
> -    }
> -
> -    return qemu_popen(popen_file, mode);
> -}
> -
>  static const QEMUFileOps stdio_file_read_ops = {
>      .get_fd =     stdio_get_fd,
>      .get_buffer = stdio_get_buffer,
> 
Reviewed-by: Orit Wasserman <owasserm@redhat.com>
Juan Quintela - Feb. 22, 2013, 11:18 a.m.
Paolo Bonzini <pbonzini@redhat.com> wrote:
> There is no reason for outgoing exec migration to do popen manually
> anymore (the reason used to be that we needed the FILE* to make it
> non-blocking).  Use qemu_popen_cmd.
>
> Signed-off-by: Paolo Bonzini <pbonzini@redhat.com>

Reviewed-by: Juan Quintela <quintela@redhat.com>

Patch

diff --git a/include/migration/qemu-file.h b/include/migration/qemu-file.h
index 46fc11d..987e719 100644
--- a/include/migration/qemu-file.h
+++ b/include/migration/qemu-file.h
@@ -77,7 +77,6 @@  QEMUFile *qemu_fopen_ops(void *opaque, const QEMUFileOps *ops);
 QEMUFile *qemu_fopen(const char *filename, const char *mode);
 QEMUFile *qemu_fdopen(int fd, const char *mode);
 QEMUFile *qemu_fopen_socket(int fd);
-QEMUFile *qemu_popen(FILE *popen_file, const char *mode);
 QEMUFile *qemu_popen_cmd(const char *command, const char *mode);
 int qemu_get_fd(QEMUFile *f);
 int qemu_fclose(QEMUFile *f);
diff --git a/migration-exec.c b/migration-exec.c
index a051a6e..5dc7313 100644
--- a/migration-exec.c
+++ b/migration-exec.c
@@ -59,19 +59,17 @@  static int exec_close(MigrationState *s)
 
 void exec_start_outgoing_migration(MigrationState *s, const char *command, Error **errp)
 {
-    FILE *f;
-
-    f = popen(command, "w");
+    QEMUFile *f;
+    f = qemu_popen_cmd(command, "w");
     if (f == NULL) {
         error_setg_errno(errp, errno, "failed to popen the migration target");
         return;
     }
 
-    s->fd = fileno(f);
+    s->opaque = f;
+    s->fd = qemu_get_fd(f);
     assert(s->fd != -1);
 
-    s->opaque = qemu_popen(f, "w");
-
     s->close = exec_close;
     s->get_error = file_errno;
     s->write = file_write;
diff --git a/savevm.c b/savevm.c
index fef2ab9..d7c2559 100644
--- a/savevm.c
+++ b/savevm.c
@@ -275,11 +275,17 @@  static const QEMUFileOps stdio_pipe_write_ops = {
     .close =      stdio_pclose
 };
 
-QEMUFile *qemu_popen(FILE *stdio_file, const char *mode)
+QEMUFile *qemu_popen_cmd(const char *command, const char *mode)
 {
+    FILE *stdio_file;
     QEMUFileStdio *s;
 
-    if (stdio_file == NULL || mode == NULL || (mode[0] != 'r' && mode[0] != 'w') || mode[1] != 0) {
+    stdio_file = popen(command, mode);
+    if(stdio_file == NULL) {
+        return NULL;
+    }
+
+    if (mode == NULL || (mode[0] != 'r' && mode[0] != 'w') || mode[1] != 0) {
         fprintf(stderr, "qemu_popen: Argument validity check failed\n");
         return NULL;
     }
@@ -296,18 +302,6 @@  QEMUFile *qemu_popen(FILE *stdio_file, const char *mode)
     return s->file;
 }
 
-QEMUFile *qemu_popen_cmd(const char *command, const char *mode)
-{
-    FILE *popen_file;
-
-    popen_file = popen(command, mode);
-    if(popen_file == NULL) {
-        return NULL;
-    }
-
-    return qemu_popen(popen_file, mode);
-}
-
 static const QEMUFileOps stdio_file_read_ops = {
     .get_fd =     stdio_get_fd,
     .get_buffer = stdio_get_buffer,