-}
-
-/* The function is called whenever we can read something on the
- * guestfsd (daemon inside the guest) communication socket.
- */
-static void
-sock_read_event (struct guestfs_main_loop *ml, guestfs_h *g, void *data,
- int watch, int fd, int events)
-{
- XDR xdr;
- unsigned len;
- int n;
-
- if (g->verbose)
- fprintf (stderr,
- "sock_read_event: %p g->state = %d, fd = %d, events = 0x%x\n",
- g, g->state, fd, events);
-
- if (g->sock != fd) {
- error (g, "sock_read_event: internal error: %d != %d", g->sock, fd);
- return;
- }
-
- if (g->msg_in_size <= g->msg_in_allocated) {
- g->msg_in_allocated += 4096;
- g->msg_in = safe_realloc (g, g->msg_in, g->msg_in_allocated);
- }
- n = read (g->sock, g->msg_in + g->msg_in_size,
- g->msg_in_allocated - g->msg_in_size);
- if (n == 0)
- /* Disconnected? Ignore it because stdout_watch will get called
- * and will do the cleanup.
- */
- return;
-
- if (n == -1) {
- if (errno != EAGAIN)
- perrorf (g, "read");
- return;
- }
-
- g->msg_in_size += n;
-
- /* Have we got enough of a message to be able to process it yet? */
- if (g->msg_in_size < 4) return;
-
- xdrmem_create (&xdr, g->msg_in, g->msg_in_size, XDR_DECODE);
- if (!xdr_uint32_t (&xdr, &len)) {
- error (g, "can't decode length word");
- goto cleanup;
- }
-
- /* Length is normally the length of the message, but when guestfsd
- * starts up it sends a "magic" value (longer than any possible
- * message). Check for this.
- */
- if (len == 0xf5f55ff5) {
- if (g->state != LAUNCHING)
- error (g, "received magic signature from guestfsd, but in state %d",
- g->state);
- else if (g->msg_in_size != 4)
- error (g, "received magic signature from guestfsd, but msg size is %d",
- g->msg_in_size);
- else {
- g->state = READY;
- if (g->launch_done_cb)
- g->launch_done_cb (g, g->launch_done_cb_data);
- }
-
- goto cleanup;
- }
-
- /* If this happens, it's pretty bad and we've probably lost synchronization.*/
- if (len > GUESTFS_MESSAGE_MAX) {
- error (g, "message length (%u) > maximum possible size (%d)",
- len, GUESTFS_MESSAGE_MAX);
- goto cleanup;
- }
-
- if (g->msg_in_size-4 < len) return; /* Need more of this message. */
-
- /* This should not happen, and if it does it probably means we've
- * lost all hope of synchronization.
- */
- if (g->msg_in_size-4 > len) {
- error (g, "len = %d, but msg_in_size-4 = %d", len, g->msg_in_size-4);
- goto cleanup;
- }
-
- /* Got the full message, begin processing it. */
- if (g->verbose) {
- int i, j;
-
- for (i = 0; i < g->msg_in_size; i += 16) {
- printf ("%04x: ", i);
- for (j = i; j < MIN (i+16, g->msg_in_size); ++j)
- printf ("%02x ", (unsigned char) g->msg_in[j]);
- for (; j < i+16; ++j)
- printf (" ");
- printf ("|");
- for (j = i; j < MIN (i+16, g->msg_in_size); ++j)
- if (isprint (g->msg_in[j]))
- printf ("%c", g->msg_in[j]);
- else
- printf (".");
- for (; j < i+16; ++j)
- printf (" ");
- printf ("|\n");
- }
- }
-
- /* Not in the expected state. */
- if (g->state != BUSY)
- error (g, "state %d != BUSY", g->state);
-
- /* Push the message up to the higher layer. */
- g->state = READY;
- if (g->reply_cb)
- g->reply_cb (g, g->reply_cb_data, &xdr);