summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorRichard W.M. Jones <rjones@redhat.com>2009-05-01 12:16:08 +0100
committerRichard W.M. Jones <rjones@redhat.com>2009-05-01 12:16:08 +0100
commitf47dafd23186938a22d41739d9bc695c7760b912 (patch)
treea6e5bf03a63cae2eeca269505724ae5c5ba11020 /src
parentd9ea3e8d979c3ade1b21f27083788fd33fa3b1fa (diff)
downloadlibguestfs-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.c93
-rw-r--r--src/guestfs-actions.h1
-rw-r--r--src/guestfs_protocol.c22
-rw-r--r--src/guestfs_protocol.h18
-rw-r--r--src/guestfs_protocol.x10
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
};