- /* 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 == GUESTFS_LAUNCH_FLAG) {
- 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;
- }
-
- /* This can happen if a cancellation happens right at the end
- * of us sending a FileIn parameter to the daemon. Discard. The
- * daemon should send us an error message next.
- */
- if (len == GUESTFS_CANCEL_FLAG) {
- g->msg_in_size -= 4;
- memmove (g->msg_in, g->msg_in+4, g->msg_in_size);
- goto again;
- }
-
- /* 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. */
-
- /* Got the full message, begin processing it. */
-#if 0
- 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");
- }
- }
-#endif
-
- /* Not in the expected state. */
- if (g->state != BUSY)
- error (g, _("state %d != BUSY"), g->state);
-
- /* Push the message up to the higher layer. */
- if (g->reply_cb)
- g->reply_cb (g, g->reply_cb_data, &xdr);
- else
- /* This message (probably) should never be printed. */
- fprintf (stderr, "libguesfs: sock_read_event: !!! dropped message !!!\n");
-
- g->msg_in_size -= len + 4;
- memmove (g->msg_in, g->msg_in+len+4, g->msg_in_size);
- if (g->msg_in_size > 0) goto again;
-
- cleanup:
- /* Free the message buffer if it's grown excessively large. */
- if (g->msg_in_allocated > 65536) {
- free (g->msg_in);
- g->msg_in = NULL;
- g->msg_in_size = g->msg_in_allocated = 0;
- } else
- g->msg_in_size = 0;
-
- xdr_destroy (&xdr);