2 * Copyright (C) 2009-2011 Red Hat Inc.
4 * This library is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU Lesser General Public
6 * License as published by the Free Software Foundation; either
7 * version 2 of the License, or (at your option) any later version.
9 * This library is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 * Lesser General Public License for more details.
14 * You should have received a copy of the GNU Lesser General Public
15 * License along with this library; if not, write to the Free Software
16 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
21 #define _BSD_SOURCE /* for mkdtemp, usleep */
34 #include <sys/select.h>
38 #include <rpc/types.h>
45 #ifdef HAVE_SYS_TYPES_H
46 #include <sys/types.h>
49 #ifdef HAVE_SYS_WAIT_H
53 #ifdef HAVE_SYS_SOCKET_H
54 #include <sys/socket.h>
61 #include <arpa/inet.h>
62 #include <netinet/in.h>
65 #include "glthread/lock.h"
66 #include "ignore-value.h"
69 #include "guestfs-internal.h"
70 #include "guestfs-internal-actions.h"
71 #include "guestfs_protocol.h"
73 /* Size of guestfs_progress message on the wire. */
74 #define PROGRESS_MESSAGE_SIZE 24
76 /* This is the code used to send and receive RPC messages and (for
77 * certain types of message) to perform file transfers. This code is
78 * driven from the generated actions (src/actions.c). There
79 * are five different cases to consider:
81 * (1) A non-daemon function. There is no RPC involved at all, it's
82 * all handled inside the library.
84 * (2) A simple RPC (eg. "mount"). We write the request, then read
85 * the reply. The sequence of calls is:
92 * (3) An RPC with FileOut parameters (eg. "upload"). We write the
93 * request, then write the file(s), then read the reply. The sequence
98 * guestfs___send_file (possibly multiple times)
102 * (4) An RPC with FileIn parameters (eg. "download"). We write the
103 * request, then read the reply, then read the file(s). The sequence
109 * guestfs___recv_file (possibly multiple times)
112 * (5) Both FileOut and FileIn parameters. There are no calls like
113 * this in the current API, but they would be implemented as a
114 * combination of cases (3) and (4).
116 * During all writes and reads, we also select(2) on qemu stdout
117 * looking for messages (guestfsd stderr and guest kernel dmesg), and
118 * anything received is passed up through the log_message_cb. This is
119 * also the reason why all the sockets are non-blocking. We also have
120 * to check for EOF (qemu died). All of this is handled by the
121 * functions send_to_daemon and recv_from_daemon.
124 /* This is only used on the debug path, to generate a one-line
125 * printable summary of a protocol message. 'workspace' is scratch
126 * space used to format the message, and it must be at least
127 * MAX_MESSAGE_SUMMARY bytes in size.
129 #define MAX_MESSAGE_SUMMARY 200 /* >= 5 * (4 * 3 + 2) + a few bytes overhead */
132 xwrite (int fd, const void *v_buf, size_t len)
134 const char *buf = v_buf;
138 r = write (fd, buf, len);
150 message_summary (const void *buf, size_t n, char *workspace)
152 const unsigned char *cbuf = buf;
157 /* Print only up to 5 x 32 bits of the message. That is enough to
158 * cover the message length, and the first four fields of the
159 * message header (prog, vers, proc, direction).
167 sprintf (p, "%02x ", cbuf[i]);
185 guestfs___set_busy (guestfs_h *g)
187 if (g->state != READY) {
188 error (g, _("guestfs_set_busy: called when in state %d != READY"),
197 guestfs___end_busy (guestfs_h *g)
211 error (g, _("guestfs_end_busy: called when in state %d"), g->state);
217 /* This is called if we detect EOF, ie. qemu died. */
219 child_cleanup (guestfs_h *g)
221 debug (g, "child_cleanup: %p: child process died", g);
223 /*if (g->pid > 0) kill (g->pid, SIGTERM);*/
224 if (g->recoverypid > 0) kill (g->recoverypid, 9);
225 waitpid (g->pid, NULL, 0);
226 if (g->recoverypid > 0) waitpid (g->recoverypid, NULL, 0);
227 if (g->fd[0] >= 0) close (g->fd[0]);
228 if (g->fd[1] >= 0) close (g->fd[1]);
235 memset (&g->launch_t, 0, sizeof g->launch_t);
237 guestfs___call_callbacks_void (g, GUESTFS_EVENT_SUBPROCESS_QUIT);
241 read_log_message_or_eof (guestfs_h *g, int fd, int error_if_eof)
247 debug (g, "read_log_message_or_eof: %p g->state = %d, fd = %d",
251 /* QEMU's console emulates a 16550A serial port. The real 16550A
252 * device has a small FIFO buffer (16 bytes) which means here we see
253 * lots of small reads of 1-16 bytes in length, usually single
254 * bytes. Sleeping here for a very brief period groups reads
255 * together (so we usually get a few lines of output at once) and
256 * improves overall throughput, as well as making the event
257 * interface a bit more sane for callers. With a virtio-serial
258 * based console (not yet implemented) we may be able to remove
263 n = read (fd, buf, sizeof buf);
265 /* Hopefully this indicates the qemu child process has died. */
269 /* We weren't expecting eof here (called from launch) so place
270 * something in the error buffer. RHBZ#588851.
272 error (g, "child process died unexpectedly");
278 if (errno == EINTR || errno == EAGAIN)
285 /* It's an actual log message, send it upwards if anyone is listening. */
286 guestfs___call_callbacks_message (g, GUESTFS_EVENT_APPLIANCE, buf, n);
291 /* Read 'n' bytes, setting the socket to blocking temporarily so
292 * that we really read the number of bytes requested.
293 * Returns: 0 == EOF while reading
294 * -1 == error, error() function has been called
295 * n == read 'n' bytes in full
298 really_read_from_socket (guestfs_h *g, int sock, char *buf, size_t n)
304 /* Set socket to blocking. */
305 flags = fcntl (sock, F_GETFL);
307 perrorf (g, "fcntl");
310 if (fcntl (sock, F_SETFL, flags & ~O_NONBLOCK) == -1) {
311 perrorf (g, "fcntl");
317 r = read (sock, &buf[got], n-got);
327 /* Restore original socket flags. */
328 if (fcntl (sock, F_SETFL, flags) == -1) {
329 perrorf (g, "fcntl");
333 return (ssize_t) got;
336 /* Convenient wrapper to generate a progress message callback. */
338 guestfs___progress_message_callback (guestfs_h *g,
339 const guestfs_progress *message)
343 array[0] = message->proc;
344 array[1] = message->serial;
345 array[2] = message->position;
346 array[3] = message->total;
348 guestfs___call_callbacks_array (g, GUESTFS_EVENT_PROGRESS,
349 array, sizeof array / sizeof array[0]);
353 check_for_daemon_cancellation_or_eof (guestfs_h *g, int fd)
355 char summary[MAX_MESSAGE_SUMMARY];
361 n = really_read_from_socket (g, fd, buf, 4);
365 /* Hopefully this indicates the qemu child process has died. */
370 debug (g, "check_for_daemon_cancellation_or_eof: %s",
371 message_summary (buf, 4, summary));
373 xdrmem_create (&xdr, buf, 4, XDR_DECODE);
374 xdr_uint32_t (&xdr, &flag);
377 /* Read and process progress messages that happen during FileIn. */
378 if (flag == GUESTFS_PROGRESS_FLAG) {
379 char buf[PROGRESS_MESSAGE_SIZE];
381 n = really_read_from_socket (g, fd, buf, PROGRESS_MESSAGE_SIZE);
389 if (g->state == BUSY) {
390 guestfs_progress message;
392 xdrmem_create (&xdr, buf, PROGRESS_MESSAGE_SIZE, XDR_DECODE);
393 xdr_guestfs_progress (&xdr, &message);
396 guestfs___progress_message_callback (g, &message);
402 if (flag != GUESTFS_CANCEL_FLAG) {
403 error (g, _("check_for_daemon_cancellation_or_eof: read 0x%x from daemon, expected 0x%x\n"),
404 flag, GUESTFS_CANCEL_FLAG);
411 /* This writes the whole N bytes of BUF to the daemon socket.
413 * If the whole write is successful, it returns 0.
414 * If there was an error, it returns -1.
415 * If the daemon sent a cancellation message, it returns -2.
417 * It also checks qemu stdout for log messages and passes those up
418 * through log_message_cb.
420 * It also checks for EOF (qemu died) and passes that up through the
421 * child_cleanup function above.
424 guestfs___send_to_daemon (guestfs_h *g, const void *v_buf, size_t n)
426 const char *buf = v_buf;
429 char summary[MAX_MESSAGE_SUMMARY];
431 debug (g, "send_to_daemon: %zu bytes: %s", n,
432 message_summary (v_buf, n, summary));
437 if (g->fd[1] >= 0) /* Read qemu stdout for log messages & EOF. */
438 FD_SET (g->fd[1], &rset);
439 FD_SET (g->sock, &rset); /* Read socket for cancellation & EOF. */
440 FD_SET (g->sock, &wset); /* Write to socket to send the data. */
442 int max_fd = MAX (g->sock, g->fd[1]);
447 int r = select (max_fd+1, &rset2, &wset2, NULL, NULL);
449 if (errno == EINTR || errno == EAGAIN)
451 perrorf (g, "select");
455 if (g->fd[1] >= 0 && FD_ISSET (g->fd[1], &rset2)) {
456 if (read_log_message_or_eof (g, g->fd[1], 0) == -1)
459 if (FD_ISSET (g->sock, &rset2)) {
460 r = check_for_daemon_cancellation_or_eof (g, g->sock);
464 /* Daemon sent cancel message. But to maintain
465 * synchronization we must write out the remainder of the
466 * write buffer before we return (RHBZ#576879).
468 if (xwrite (g->sock, buf, n) == -1) {
469 perrorf (g, "write");
472 return -2; /* cancelled */
475 if (FD_ISSET (g->sock, &wset2)) {
476 r = write (g->sock, buf, n);
478 if (errno == EINTR || errno == EAGAIN)
480 perrorf (g, "write");
481 if (errno == EPIPE) /* Disconnected from guest (RHBZ#508713). */
493 /* This reads a single message, file chunk, launch flag or
494 * cancellation flag from the daemon. If something was read, it
495 * returns 0, otherwise -1.
497 * Both size_rtn and buf_rtn must be passed by the caller as non-NULL.
499 * *size_rtn returns the size of the returned message or it may be
500 * GUESTFS_LAUNCH_FLAG or GUESTFS_CANCEL_FLAG.
502 * *buf_rtn is returned containing the message (if any) or will be set
503 * to NULL. *buf_rtn must be freed by the caller.
505 * It also checks qemu stdout for log messages and passes those up
506 * through log_message_cb.
508 * It also checks for EOF (qemu died) and passes that up through the
509 * child_cleanup function above.
511 * Progress notifications are handled transparently by this function.
512 * If the callback exists, it is called. The caller of this function
513 * will not see GUESTFS_PROGRESS_FLAG.
517 guestfs___recv_from_daemon (guestfs_h *g, uint32_t *size_rtn, void **buf_rtn)
519 char summary[MAX_MESSAGE_SUMMARY];
524 if (g->fd[1] >= 0) /* Read qemu stdout for log messages & EOF. */
525 FD_SET (g->fd[1], &rset);
526 FD_SET (g->sock, &rset); /* Read socket for data & EOF. */
528 int max_fd = MAX (g->sock, g->fd[1]);
534 /* nr is the size of the message, but we prime it as -4 because we
535 * have to read the message length word first.
540 ssize_t message_size =
541 *size_rtn != GUESTFS_PROGRESS_FLAG ?
542 *size_rtn : PROGRESS_MESSAGE_SIZE;
543 if (nr >= message_size)
547 int r = select (max_fd+1, &rset2, NULL, NULL, NULL);
549 if (errno == EINTR || errno == EAGAIN)
551 perrorf (g, "select");
557 if (g->fd[1] >= 0 && FD_ISSET (g->fd[1], &rset2)) {
558 if (read_log_message_or_eof (g, g->fd[1], 0) == -1) {
564 if (FD_ISSET (g->sock, &rset2)) {
565 if (nr < 0) { /* Have we read the message length word yet? */
566 r = read (g->sock, lenbuf+nr+4, -nr);
568 if (errno == EINTR || errno == EAGAIN)
572 /* Under some circumstances we see "Connection reset by peer"
573 * here when the child dies suddenly. Catch this and call
574 * the cleanup function, same as for EOF.
576 if (err == ECONNRESET)
581 error (g, _("unexpected end of file when reading from daemon"));
587 if (nr < 0) /* Still not got the whole length word. */
591 xdrmem_create (&xdr, lenbuf, 4, XDR_DECODE);
592 xdr_uint32_t (&xdr, size_rtn);
595 /* *size_rtn changed, recalculate message_size */
597 *size_rtn != GUESTFS_PROGRESS_FLAG ?
598 *size_rtn : PROGRESS_MESSAGE_SIZE;
600 if (*size_rtn == GUESTFS_LAUNCH_FLAG) {
601 if (g->state != LAUNCHING)
602 error (g, _("received magic signature from guestfsd, but in state %d"),
606 guestfs___call_callbacks_void (g, GUESTFS_EVENT_LAUNCH_DONE);
608 debug (g, "recv_from_daemon: received GUESTFS_LAUNCH_FLAG");
611 else if (*size_rtn == GUESTFS_CANCEL_FLAG) {
612 debug (g, "recv_from_daemon: received GUESTFS_CANCEL_FLAG");
615 else if (*size_rtn == GUESTFS_PROGRESS_FLAG)
617 /* If this happens, it's pretty bad and we've probably lost
620 else if (*size_rtn > GUESTFS_MESSAGE_MAX) {
621 error (g, _("message length (%u) > maximum possible size (%d)"),
622 (unsigned) *size_rtn, GUESTFS_MESSAGE_MAX);
626 /* Allocate the complete buffer, size now known. */
627 *buf_rtn = safe_malloc (g, message_size);
631 size_t sizetoread = message_size - nr;
632 if (sizetoread > BUFSIZ) sizetoread = BUFSIZ;
634 r = read (g->sock, (char *) (*buf_rtn) + nr, sizetoread);
636 if (errno == EINTR || errno == EAGAIN)
644 error (g, _("unexpected end of file when reading from daemon"));
654 /* Got the full message, caller can start processing it. */
655 #ifdef ENABLE_PACKET_DUMP
659 for (i = 0; i < nr; i += 16) {
660 printf ("%04zx: ", i);
661 for (j = i; j < MIN (i+16, nr); ++j)
662 printf ("%02x ", (*(unsigned char **)buf_rtn)[j]);
663 for (; j < i+16; ++j)
666 for (j = i; j < MIN (i+16, nr); ++j)
667 if (c_isprint ((*(char **)buf_rtn)[j]))
668 printf ("%c", (*(char **)buf_rtn)[j]);
671 for (; j < i+16; ++j)
678 if (*size_rtn == GUESTFS_PROGRESS_FLAG) {
679 if (g->state == BUSY) {
680 guestfs_progress message;
682 xdrmem_create (&xdr, *buf_rtn, PROGRESS_MESSAGE_SIZE, XDR_DECODE);
683 xdr_guestfs_progress (&xdr, &message);
686 guestfs___progress_message_callback (g, &message);
692 /* Process next message. */
693 return guestfs___recv_from_daemon (g, size_rtn, buf_rtn);
696 debug (g, "recv_from_daemon: %" PRIu32 " bytes: %s", *size_rtn,
697 message_summary (*buf_rtn, *size_rtn, summary));
702 /* This is very much like recv_from_daemon above, but g->sock is
703 * a listening socket and we are accepting a new connection on
704 * that socket instead of reading anything. Returns the newly
708 guestfs___accept_from_daemon (guestfs_h *g)
712 debug (g, "accept_from_daemon: %p g->state = %d", g, g->state);
716 if (g->fd[1] >= 0) /* Read qemu stdout for log messages & EOF. */
717 FD_SET (g->fd[1], &rset);
718 FD_SET (g->sock, &rset); /* Read socket for accept. */
720 int max_fd = MAX (g->sock, g->fd[1]);
724 /* If the qemu process has died, clean up the zombie (RHBZ#579155).
725 * By partially polling in the select below we ensure that this
726 * function will be called eventually.
728 waitpid (g->pid, NULL, WNOHANG);
732 struct timeval tv = { .tv_sec = 1, .tv_usec = 0 };
733 int r = select (max_fd+1, &rset2, NULL, NULL, &tv);
735 if (errno == EINTR || errno == EAGAIN)
737 perrorf (g, "select");
741 if (g->fd[1] >= 0 && FD_ISSET (g->fd[1], &rset2)) {
742 if (read_log_message_or_eof (g, g->fd[1], 1) == -1)
745 if (FD_ISSET (g->sock, &rset2)) {
746 sock = accept (g->sock, NULL, NULL);
748 if (errno == EINTR || errno == EAGAIN)
750 perrorf (g, "accept");
760 guestfs___send (guestfs_h *g, int proc_nr,
761 uint64_t progress_hint, uint64_t optargs_bitmask,
762 xdrproc_t xdrp, char *args)
764 struct guestfs_message_header hdr;
767 int serial = g->msg_next_serial++;
772 if (g->state != BUSY) {
773 error (g, _("guestfs___send: state %d != BUSY"), g->state);
777 /* We have to allocate this message buffer on the heap because
778 * it is quite large (although will be mostly unused). We
779 * can't allocate it on the stack because in some environments
780 * we have quite limited stack space available, notably when
781 * running in the JVM.
783 msg_out = safe_malloc (g, GUESTFS_MESSAGE_MAX + 4);
784 xdrmem_create (&xdr, msg_out + 4, GUESTFS_MESSAGE_MAX, XDR_ENCODE);
786 /* Serialize the header. */
787 hdr.prog = GUESTFS_PROGRAM;
788 hdr.vers = GUESTFS_PROTOCOL_VERSION;
790 hdr.direction = GUESTFS_DIRECTION_CALL;
792 hdr.status = GUESTFS_STATUS_OK;
793 hdr.progress_hint = progress_hint;
794 hdr.optargs_bitmask = optargs_bitmask;
796 if (!xdr_guestfs_message_header (&xdr, &hdr)) {
797 error (g, _("xdr_guestfs_message_header failed"));
801 /* Serialize the args. If any, because some message types
802 * have no parameters.
805 if (!(*xdrp) (&xdr, args)) {
806 error (g, _("dispatch failed to marshal args"));
811 /* Get the actual length of the message, resize the buffer to match
812 * the actual length, and write the length word at the beginning.
814 len = xdr_getpos (&xdr);
817 msg_out = safe_realloc (g, msg_out, len + 4);
818 msg_out_size = len + 4;
820 xdrmem_create (&xdr, msg_out, 4, XDR_ENCODE);
821 xdr_uint32_t (&xdr, &len);
824 r = guestfs___send_to_daemon (g, msg_out, msg_out_size);
825 if (r == -2) /* Ignore stray daemon cancellations. */
838 static int cancel = 0; /* XXX Implement file cancellation. */
839 static int send_file_chunk (guestfs_h *g, int cancel, const char *buf, size_t len);
840 static int send_file_data (guestfs_h *g, const char *buf, size_t len);
841 static int send_file_cancellation (guestfs_h *g);
842 static int send_file_complete (guestfs_h *g);
848 * -2 daemon cancelled (we must read the error message)
851 guestfs___send_file (guestfs_h *g, const char *filename)
853 char buf[GUESTFS_MAX_CHUNK_SIZE];
856 fd = open (filename, O_RDONLY);
858 perrorf (g, "open: %s", filename);
859 send_file_cancellation (g);
863 /* Send file in chunked encoding. */
865 r = read (fd, buf, sizeof buf);
866 if (r == -1 && (errno == EINTR || errno == EAGAIN))
869 err = send_file_data (g, buf, r);
871 if (err == -2) /* daemon sent cancellation */
872 send_file_cancellation (g);
877 if (cancel) { /* cancel from either end */
878 send_file_cancellation (g);
883 perrorf (g, "read: %s", filename);
884 send_file_cancellation (g);
888 /* End of file, but before we send that, we need to close
889 * the file and check for errors.
891 if (close (fd) == -1) {
892 perrorf (g, "close: %s", filename);
893 send_file_cancellation (g);
897 return send_file_complete (g);
900 /* Send a chunk of file data. */
902 send_file_data (guestfs_h *g, const char *buf, size_t len)
904 return send_file_chunk (g, 0, buf, len);
907 /* Send a cancellation message. */
909 send_file_cancellation (guestfs_h *g)
911 return send_file_chunk (g, 1, NULL, 0);
914 /* Send a file complete chunk. */
916 send_file_complete (guestfs_h *g)
919 return send_file_chunk (g, 0, buf, 0);
923 send_file_chunk (guestfs_h *g, int cancel, const char *buf, size_t buflen)
932 if (g->state != BUSY) {
933 error (g, _("send_file_chunk: state %d != READY"), g->state);
937 /* Allocate the chunk buffer. Don't use the stack to avoid
938 * excessive stack usage and unnecessary copies.
940 msg_out = safe_malloc (g, GUESTFS_MAX_CHUNK_SIZE + 4 + 48);
941 xdrmem_create (&xdr, msg_out + 4, GUESTFS_MAX_CHUNK_SIZE + 48, XDR_ENCODE);
943 /* Serialize the chunk. */
944 chunk.cancel = cancel;
945 chunk.data.data_len = buflen;
946 chunk.data.data_val = (char *) buf;
948 if (!xdr_guestfs_chunk (&xdr, &chunk)) {
949 error (g, _("xdr_guestfs_chunk failed (buf = %p, buflen = %zu)"),
955 len = xdr_getpos (&xdr);
958 /* Reduce the size of the outgoing message buffer to the real length. */
959 msg_out = safe_realloc (g, msg_out, len + 4);
960 msg_out_size = len + 4;
962 xdrmem_create (&xdr, msg_out, 4, XDR_ENCODE);
963 xdr_uint32_t (&xdr, &len);
965 r = guestfs___send_to_daemon (g, msg_out, msg_out_size);
967 /* Did the daemon send a cancellation message? */
969 debug (g, "got daemon cancellation");
985 /* Receive a reply. */
987 guestfs___recv (guestfs_h *g, const char *fn,
988 guestfs_message_header *hdr,
989 guestfs_message_error *err,
990 xdrproc_t xdrp, char *ret)
998 r = guestfs___recv_from_daemon (g, &size, &buf);
1002 /* This can happen if a cancellation happens right at the end
1003 * of us sending a FileIn parameter to the daemon. Discard. The
1004 * daemon should send us an error message next.
1006 if (size == GUESTFS_CANCEL_FLAG)
1009 if (size == GUESTFS_LAUNCH_FLAG) {
1010 error (g, "%s: received unexpected launch flag from daemon when expecting reply", fn);
1014 xdrmem_create (&xdr, buf, size, XDR_DECODE);
1016 if (!xdr_guestfs_message_header (&xdr, hdr)) {
1017 error (g, "%s: failed to parse reply header", fn);
1022 if (hdr->status == GUESTFS_STATUS_ERROR) {
1023 if (!xdr_guestfs_message_error (&xdr, err)) {
1024 error (g, "%s: failed to parse reply error", fn);
1030 if (xdrp && ret && !xdrp (&xdr, ret)) {
1031 error (g, "%s: failed to parse reply", fn);
1043 /* Same as guestfs___recv, but it discards the reply message. */
1045 guestfs___recv_discard (guestfs_h *g, const char *fn)
1052 r = guestfs___recv_from_daemon (g, &size, &buf);
1056 /* This can happen if a cancellation happens right at the end
1057 * of us sending a FileIn parameter to the daemon. Discard. The
1058 * daemon should send us an error message next.
1060 if (size == GUESTFS_CANCEL_FLAG)
1063 if (size == GUESTFS_LAUNCH_FLAG) {
1064 error (g, "%s: received unexpected launch flag from daemon when expecting reply", fn);
1071 /* Receive a file. */
1073 /* Returns -1 = error, 0 = EOF, > 0 = more data */
1074 static ssize_t receive_file_data (guestfs_h *g, void **buf);
1077 guestfs___recv_file (guestfs_h *g, const char *filename)
1082 fd = open (filename, O_WRONLY|O_CREAT|O_TRUNC|O_NOCTTY, 0666);
1084 perrorf (g, "open: %s", filename);
1088 /* Receive the file in chunked encoding. */
1089 while ((r = receive_file_data (g, &buf)) > 0) {
1090 if (xwrite (fd, buf, r) == -1) {
1091 perrorf (g, "%s: write", filename);
1099 error (g, _("%s: error in chunked encoding"), filename);
1103 if (close (fd) == -1) {
1104 perrorf (g, "close: %s", filename);
1111 /* Send cancellation message to daemon, then wait until it
1112 * cancels (just throwing away data).
1116 uint32_t flag = GUESTFS_CANCEL_FLAG;
1118 debug (g, "%s: waiting for daemon to acknowledge cancellation",
1121 xdrmem_create (&xdr, fbuf, sizeof fbuf, XDR_ENCODE);
1122 xdr_uint32_t (&xdr, &flag);
1125 if (xwrite (g->sock, fbuf, sizeof fbuf) == -1) {
1126 perrorf (g, _("write to daemon socket"));
1130 while (receive_file_data (g, NULL) > 0)
1131 ; /* just discard it */
1136 /* Receive a chunk of file data. */
1137 /* Returns -1 = error, 0 = EOF, > 0 = more data */
1139 receive_file_data (guestfs_h *g, void **buf_r)
1145 guestfs_chunk chunk;
1147 r = guestfs___recv_from_daemon (g, &len, &buf);
1149 error (g, _("receive_file_data: parse error in reply callback"));
1153 if (len == GUESTFS_LAUNCH_FLAG || len == GUESTFS_CANCEL_FLAG) {
1154 error (g, _("receive_file_data: unexpected flag received when reading file chunks"));
1158 memset (&chunk, 0, sizeof chunk);
1160 xdrmem_create (&xdr, buf, len, XDR_DECODE);
1161 if (!xdr_guestfs_chunk (&xdr, &chunk)) {
1162 error (g, _("failed to parse file chunk"));
1167 /* After decoding, the original buffer is no longer used. */
1171 error (g, _("file receive cancelled by daemon"));
1172 free (chunk.data.data_val);
1176 if (chunk.data.data_len == 0) { /* end of transfer */
1177 free (chunk.data.data_val);
1181 if (buf_r) *buf_r = chunk.data.data_val;
1182 else free (chunk.data.data_val); /* else caller frees */
1184 return chunk.data.data_len;