diff options
author | Richard W.M. Jones <rjones@redhat.com> | 2009-05-01 12:16:08 +0100 |
---|---|---|
committer | Richard W.M. Jones <rjones@redhat.com> | 2009-05-01 12:16:08 +0100 |
commit | f47dafd23186938a22d41739d9bc695c7760b912 (patch) | |
tree | a6e5bf03a63cae2eeca269505724ae5c5ba11020 /src | |
parent | d9ea3e8d979c3ade1b21f27083788fd33fa3b1fa (diff) | |
download | libguestfs-f47dafd23186938a22d41739d9bc695c7760b912.tar.gz libguestfs-f47dafd23186938a22d41739d9bc695c7760b912.tar.xz libguestfs-f47dafd23186938a22d41739d9bc695c7760b912.zip |
Generated code for 'equal' command.
Diffstat (limited to 'src')
-rw-r--r-- | src/guestfs-actions.c | 93 | ||||
-rw-r--r-- | src/guestfs-actions.h | 1 | ||||
-rw-r--r-- | src/guestfs_protocol.c | 22 | ||||
-rw-r--r-- | src/guestfs_protocol.h | 18 | ||||
-rw-r--r-- | src/guestfs_protocol.x | 10 |
5 files changed, 143 insertions, 1 deletions
diff --git a/src/guestfs-actions.c b/src/guestfs-actions.c index c0762dfa..3da1b42b 100644 --- a/src/guestfs-actions.c +++ b/src/guestfs-actions.c @@ -8335,3 +8335,96 @@ int guestfs_ping_daemon (guestfs_h *g) return 0; } +struct equal_ctx { + /* This flag is set by the callbacks, so we know we've done + * the callbacks as expected, and in the right sequence. + * 0 = not called, 1 = reply_cb called. + */ + int cb_sequence; + struct guestfs_message_header hdr; + struct guestfs_message_error err; + struct guestfs_equal_ret ret; +}; + +static void equal_reply_cb (guestfs_h *g, void *data, XDR *xdr) +{ + guestfs_main_loop *ml = guestfs_get_main_loop (g); + struct equal_ctx *ctx = (struct equal_ctx *) data; + + /* This should definitely not happen. */ + if (ctx->cb_sequence != 0) { + ctx->cb_sequence = 9999; + error (g, "%s: internal error: reply callback called twice", "guestfs_equal"); + return; + } + + ml->main_loop_quit (ml, g); + + if (!xdr_guestfs_message_header (xdr, &ctx->hdr)) { + error (g, "%s: failed to parse reply header", "guestfs_equal"); + return; + } + if (ctx->hdr.status == GUESTFS_STATUS_ERROR) { + if (!xdr_guestfs_message_error (xdr, &ctx->err)) { + error (g, "%s: failed to parse reply error", "guestfs_equal"); + return; + } + goto done; + } + if (!xdr_guestfs_equal_ret (xdr, &ctx->ret)) { + error (g, "%s: failed to parse reply", "guestfs_equal"); + return; + } + done: + ctx->cb_sequence = 1; +} + +int guestfs_equal (guestfs_h *g, + const char *file1, + const char *file2) +{ + struct guestfs_equal_args args; + struct equal_ctx ctx; + guestfs_main_loop *ml = guestfs_get_main_loop (g); + int serial; + + if (check_state (g, "guestfs_equal") == -1) return -1; + guestfs_set_busy (g); + + memset (&ctx, 0, sizeof ctx); + + args.file1 = (char *) file1; + args.file2 = (char *) file2; + serial = guestfs__send_sync (g, GUESTFS_PROC_EQUAL, + (xdrproc_t) xdr_guestfs_equal_args, (char *) &args); + if (serial == -1) { + guestfs_set_ready (g); + return -1; + } + + guestfs__switch_to_receiving (g); + ctx.cb_sequence = 0; + guestfs_set_reply_callback (g, equal_reply_cb, &ctx); + (void) ml->main_loop_run (ml, g); + guestfs_set_reply_callback (g, NULL, NULL); + if (ctx.cb_sequence != 1) { + error (g, "%s reply failed, see earlier error messages", "guestfs_equal"); + guestfs_set_ready (g); + return -1; + } + + if (check_reply_header (g, &ctx.hdr, GUESTFS_PROC_EQUAL, serial) == -1) { + guestfs_set_ready (g); + return -1; + } + + if (ctx.hdr.status == GUESTFS_STATUS_ERROR) { + error (g, "%s", ctx.err.error_message); + guestfs_set_ready (g); + return -1; + } + + guestfs_set_ready (g); + return ctx.ret.equality; +} + diff --git a/src/guestfs-actions.h b/src/guestfs-actions.h index f2218f4e..05399818 100644 --- a/src/guestfs-actions.h +++ b/src/guestfs-actions.h @@ -132,3 +132,4 @@ extern int guestfs_mv (guestfs_h *handle, const char *src, const char *dest); extern int guestfs_drop_caches (guestfs_h *handle, int whattodrop); extern char *guestfs_dmesg (guestfs_h *handle); extern int guestfs_ping_daemon (guestfs_h *handle); +extern int guestfs_equal (guestfs_h *handle, const char *file1, const char *file2); diff --git a/src/guestfs_protocol.c b/src/guestfs_protocol.c index 7a40e14e..66889cc4 100644 --- a/src/guestfs_protocol.c +++ b/src/guestfs_protocol.c @@ -1528,6 +1528,28 @@ xdr_guestfs_dmesg_ret (XDR *xdrs, guestfs_dmesg_ret *objp) } bool_t +xdr_guestfs_equal_args (XDR *xdrs, guestfs_equal_args *objp) +{ + register int32_t *buf; + + if (!xdr_string (xdrs, &objp->file1, ~0)) + return FALSE; + if (!xdr_string (xdrs, &objp->file2, ~0)) + return FALSE; + return TRUE; +} + +bool_t +xdr_guestfs_equal_ret (XDR *xdrs, guestfs_equal_ret *objp) +{ + register int32_t *buf; + + if (!xdr_bool (xdrs, &objp->equality)) + return FALSE; + return TRUE; +} + +bool_t xdr_guestfs_procedure (XDR *xdrs, guestfs_procedure *objp) { register int32_t *buf; diff --git a/src/guestfs_protocol.h b/src/guestfs_protocol.h index e4725247..06287c9e 100644 --- a/src/guestfs_protocol.h +++ b/src/guestfs_protocol.h @@ -789,6 +789,17 @@ struct guestfs_dmesg_ret { }; typedef struct guestfs_dmesg_ret guestfs_dmesg_ret; +struct guestfs_equal_args { + char *file1; + char *file2; +}; +typedef struct guestfs_equal_args guestfs_equal_args; + +struct guestfs_equal_ret { + bool_t equality; +}; +typedef struct guestfs_equal_ret guestfs_equal_ret; + enum guestfs_procedure { GUESTFS_PROC_MOUNT = 1, GUESTFS_PROC_SYNC = 2, @@ -882,7 +893,8 @@ enum guestfs_procedure { GUESTFS_PROC_DROP_CACHES = 90, GUESTFS_PROC_DMESG = 91, GUESTFS_PROC_PING_DAEMON = 92, - GUESTFS_PROC_NR_PROCS = 92 + 1, + GUESTFS_PROC_EQUAL = 93, + GUESTFS_PROC_NR_PROCS = 93 + 1, }; typedef enum guestfs_procedure guestfs_procedure; #define GUESTFS_MESSAGE_MAX 4194304 @@ -1056,6 +1068,8 @@ extern bool_t xdr_guestfs_cp_a_args (XDR *, guestfs_cp_a_args*); extern bool_t xdr_guestfs_mv_args (XDR *, guestfs_mv_args*); extern bool_t xdr_guestfs_drop_caches_args (XDR *, guestfs_drop_caches_args*); extern bool_t xdr_guestfs_dmesg_ret (XDR *, guestfs_dmesg_ret*); +extern bool_t xdr_guestfs_equal_args (XDR *, guestfs_equal_args*); +extern bool_t xdr_guestfs_equal_ret (XDR *, guestfs_equal_ret*); extern bool_t xdr_guestfs_procedure (XDR *, guestfs_procedure*); extern bool_t xdr_guestfs_message_direction (XDR *, guestfs_message_direction*); extern bool_t xdr_guestfs_message_status (XDR *, guestfs_message_status*); @@ -1188,6 +1202,8 @@ extern bool_t xdr_guestfs_cp_a_args (); extern bool_t xdr_guestfs_mv_args (); extern bool_t xdr_guestfs_drop_caches_args (); extern bool_t xdr_guestfs_dmesg_ret (); +extern bool_t xdr_guestfs_equal_args (); +extern bool_t xdr_guestfs_equal_ret (); extern bool_t xdr_guestfs_procedure (); extern bool_t xdr_guestfs_message_direction (); extern bool_t xdr_guestfs_message_status (); diff --git a/src/guestfs_protocol.x b/src/guestfs_protocol.x index e61d3fb8..f6cab670 100644 --- a/src/guestfs_protocol.x +++ b/src/guestfs_protocol.x @@ -614,6 +614,15 @@ struct guestfs_dmesg_ret { string kmsgs<>; }; +struct guestfs_equal_args { + string file1<>; + string file2<>; +}; + +struct guestfs_equal_ret { + bool equality; +}; + enum guestfs_procedure { GUESTFS_PROC_MOUNT = 1, GUESTFS_PROC_SYNC = 2, @@ -707,6 +716,7 @@ enum guestfs_procedure { GUESTFS_PROC_DROP_CACHES = 90, GUESTFS_PROC_DMESG = 91, GUESTFS_PROC_PING_DAEMON = 92, + GUESTFS_PROC_EQUAL = 93, GUESTFS_PROC_NR_PROCS }; |