Skip to content

Commit

Permalink
qemu-nbd: Restore "qemu-nbd -v --fork" output
Browse files Browse the repository at this point in the history
Closing stderr earlier is good for daemonized qemu-nbd under ssh
earlier, but breaks the case where -v is being used to track what is
happening in the server, as in iotest 233.

When we know we are verbose, we should preserve original stderr and
restore it once the setup stage is done. This commit restores the
original behavior with -v option. In this case original output
inside the test is kept intact.

Reported-by: Kevin Wolf <kwolf@redhat.com>
Signed-off-by: Denis V. Lunev <den@openvz.org>
CC: Eric Blake <eblake@redhat.com>
CC: Vladimir Sementsov-Ogievskiy <vsementsov@yandex-team.ru>
CC: Hanna Reitz <hreitz@redhat.com>
CC: Mike Maslenkin <mike.maslenkin@gmail.com>
Fixes: 5c56dd2 ("qemu-nbd: fix regression with qemu-nbd --fork run over ssh")
Message-ID: <20230906093210.339585-7-den@openvz.org>
Reviewed-by: Eric Blake <eblake@redhat.com>
Tested-by: Eric Blake <eblake@redhat.com>
[eblake: fix build by avoiding stderr as struct member name]
Signed-off-by: Eric Blake <eblake@redhat.com>
  • Loading branch information
Denis V. Lunev authored and ebblake committed Sep 8, 2023
1 parent 2eb7c2a commit f6f4620
Showing 1 changed file with 20 additions and 4 deletions.
24 changes: 20 additions & 4 deletions qemu-nbd.c
Original file line number Diff line number Diff line change
Expand Up @@ -255,18 +255,23 @@ struct NbdClientOpts {
char *device;
char *srcpath;
SocketAddress *saddr;
int old_stderr;
bool fork_process;
bool verbose;
};

static void nbd_client_release_pipe(void)
static void nbd_client_release_pipe(int old_stderr)
{
/* Close stderr so that the qemu-nbd process exits. */
if (dup2(STDOUT_FILENO, STDERR_FILENO) < 0) {
if (dup2(old_stderr, STDERR_FILENO) < 0) {
error_report("Could not release pipe to parent: %s",
strerror(errno));
exit(EXIT_FAILURE);
}
if (old_stderr != STDOUT_FILENO && close(old_stderr) < 0) {
error_report("Could not release qemu-nbd: %s", strerror(errno));
exit(EXIT_FAILURE);
}
}

#if HAVE_NBD_DEVICE
Expand Down Expand Up @@ -332,7 +337,7 @@ static void *nbd_client_thread(void *arg)
fprintf(stderr, "NBD device %s is now connected to %s\n",
opts->device, opts->srcpath);
} else {
nbd_client_release_pipe();
nbd_client_release_pipe(opts->old_stderr);
}

if (nbd_client(fd) < 0) {
Expand Down Expand Up @@ -597,6 +602,7 @@ int main(int argc, char **argv)
.device = NULL,
.srcpath = NULL,
.saddr = NULL,
.old_stderr = STDOUT_FILENO,
};

#ifdef CONFIG_POSIX
Expand Down Expand Up @@ -951,6 +957,16 @@ int main(int argc, char **argv)

close(stderr_fd[0]);

/* Remember parent's stderr if we will be restoring it. */
if (opts.verbose /* fork_process is set */) {
opts.old_stderr = dup(STDERR_FILENO);
if (opts.old_stderr < 0) {
error_report("Could not dup original stderr: %s",
strerror(errno));
exit(EXIT_FAILURE);
}
}

ret = qemu_daemon(1, 0);
saved_errno = errno; /* dup2 will overwrite error below */

Expand Down Expand Up @@ -1181,7 +1197,7 @@ int main(int argc, char **argv)
}

if (opts.fork_process) {
nbd_client_release_pipe();
nbd_client_release_pipe(opts.old_stderr);
}

state = RUNNING;
Expand Down

0 comments on commit f6f4620

Please sign in to comment.