diff options
author | Richard W.M. Jones <rjones@redhat.com> | 2009-05-01 11:00:46 +0100 |
---|---|---|
committer | Richard W.M. Jones <rjones@redhat.com> | 2009-05-01 11:00:46 +0100 |
commit | ac286b26df1aabceca26dac66c325a3676ace4cc (patch) | |
tree | e35289262967573c2ceb56ce67f66d7e678dba41 /src | |
parent | 3cb794463a62239e36d730bc5d2d3eb4c7a66096 (diff) | |
download | libguestfs-ac286b26df1aabceca26dac66c325a3676ace4cc.tar.gz libguestfs-ac286b26df1aabceca26dac66c325a3676ace4cc.tar.xz libguestfs-ac286b26df1aabceca26dac66c325a3676ace4cc.zip |
Generated code for cp, cp-a and mv commands.
Diffstat (limited to 'src')
-rw-r--r-- | src/guestfs-actions.c | 264 | ||||
-rw-r--r-- | src/guestfs-actions.h | 3 | ||||
-rw-r--r-- | src/guestfs_protocol.c | 36 | ||||
-rw-r--r-- | src/guestfs_protocol.h | 29 | ||||
-rw-r--r-- | src/guestfs_protocol.x | 18 |
5 files changed, 349 insertions, 1 deletions
diff --git a/src/guestfs-actions.c b/src/guestfs-actions.c index c20301b8..49923551 100644 --- a/src/guestfs-actions.c +++ b/src/guestfs-actions.c @@ -7816,3 +7816,267 @@ int guestfs_grub_install (guestfs_h *g, return 0; } +struct cp_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; +}; + +static void cp_reply_cb (guestfs_h *g, void *data, XDR *xdr) +{ + guestfs_main_loop *ml = guestfs_get_main_loop (g); + struct cp_ctx *ctx = (struct cp_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_cp"); + return; + } + + ml->main_loop_quit (ml, g); + + if (!xdr_guestfs_message_header (xdr, &ctx->hdr)) { + error (g, "%s: failed to parse reply header", "guestfs_cp"); + 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_cp"); + return; + } + goto done; + } + done: + ctx->cb_sequence = 1; +} + +int guestfs_cp (guestfs_h *g, + const char *src, + const char *dest) +{ + struct guestfs_cp_args args; + struct cp_ctx ctx; + guestfs_main_loop *ml = guestfs_get_main_loop (g); + int serial; + + if (check_state (g, "guestfs_cp") == -1) return -1; + guestfs_set_busy (g); + + memset (&ctx, 0, sizeof ctx); + + args.src = (char *) src; + args.dest = (char *) dest; + serial = guestfs__send_sync (g, GUESTFS_PROC_CP, + (xdrproc_t) xdr_guestfs_cp_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, cp_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_cp"); + guestfs_set_ready (g); + return -1; + } + + if (check_reply_header (g, &ctx.hdr, GUESTFS_PROC_CP, 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 0; +} + +struct cp_a_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; +}; + +static void cp_a_reply_cb (guestfs_h *g, void *data, XDR *xdr) +{ + guestfs_main_loop *ml = guestfs_get_main_loop (g); + struct cp_a_ctx *ctx = (struct cp_a_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_cp_a"); + return; + } + + ml->main_loop_quit (ml, g); + + if (!xdr_guestfs_message_header (xdr, &ctx->hdr)) { + error (g, "%s: failed to parse reply header", "guestfs_cp_a"); + 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_cp_a"); + return; + } + goto done; + } + done: + ctx->cb_sequence = 1; +} + +int guestfs_cp_a (guestfs_h *g, + const char *src, + const char *dest) +{ + struct guestfs_cp_a_args args; + struct cp_a_ctx ctx; + guestfs_main_loop *ml = guestfs_get_main_loop (g); + int serial; + + if (check_state (g, "guestfs_cp_a") == -1) return -1; + guestfs_set_busy (g); + + memset (&ctx, 0, sizeof ctx); + + args.src = (char *) src; + args.dest = (char *) dest; + serial = guestfs__send_sync (g, GUESTFS_PROC_CP_A, + (xdrproc_t) xdr_guestfs_cp_a_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, cp_a_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_cp_a"); + guestfs_set_ready (g); + return -1; + } + + if (check_reply_header (g, &ctx.hdr, GUESTFS_PROC_CP_A, 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 0; +} + +struct mv_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; +}; + +static void mv_reply_cb (guestfs_h *g, void *data, XDR *xdr) +{ + guestfs_main_loop *ml = guestfs_get_main_loop (g); + struct mv_ctx *ctx = (struct mv_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_mv"); + return; + } + + ml->main_loop_quit (ml, g); + + if (!xdr_guestfs_message_header (xdr, &ctx->hdr)) { + error (g, "%s: failed to parse reply header", "guestfs_mv"); + 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_mv"); + return; + } + goto done; + } + done: + ctx->cb_sequence = 1; +} + +int guestfs_mv (guestfs_h *g, + const char *src, + const char *dest) +{ + struct guestfs_mv_args args; + struct mv_ctx ctx; + guestfs_main_loop *ml = guestfs_get_main_loop (g); + int serial; + + if (check_state (g, "guestfs_mv") == -1) return -1; + guestfs_set_busy (g); + + memset (&ctx, 0, sizeof ctx); + + args.src = (char *) src; + args.dest = (char *) dest; + serial = guestfs__send_sync (g, GUESTFS_PROC_MV, + (xdrproc_t) xdr_guestfs_mv_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, mv_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_mv"); + guestfs_set_ready (g); + return -1; + } + + if (check_reply_header (g, &ctx.hdr, GUESTFS_PROC_MV, 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 0; +} + diff --git a/src/guestfs-actions.h b/src/guestfs-actions.h index 843968cc..56088bae 100644 --- a/src/guestfs-actions.h +++ b/src/guestfs-actions.h @@ -126,3 +126,6 @@ extern char *guestfs_get_e2uuid (guestfs_h *handle, const char *device); extern int guestfs_fsck (guestfs_h *handle, const char *fstype, const char *device); extern int guestfs_zero (guestfs_h *handle, const char *device); extern int guestfs_grub_install (guestfs_h *handle, const char *root, const char *device); +extern int guestfs_cp (guestfs_h *handle, const char *src, const char *dest); +extern int guestfs_cp_a (guestfs_h *handle, const char *src, const char *dest); +extern int guestfs_mv (guestfs_h *handle, const char *src, const char *dest); diff --git a/src/guestfs_protocol.c b/src/guestfs_protocol.c index 2f08afdf..6c00afc3 100644 --- a/src/guestfs_protocol.c +++ b/src/guestfs_protocol.c @@ -1472,6 +1472,42 @@ xdr_guestfs_grub_install_args (XDR *xdrs, guestfs_grub_install_args *objp) } bool_t +xdr_guestfs_cp_args (XDR *xdrs, guestfs_cp_args *objp) +{ + register int32_t *buf; + + if (!xdr_string (xdrs, &objp->src, ~0)) + return FALSE; + if (!xdr_string (xdrs, &objp->dest, ~0)) + return FALSE; + return TRUE; +} + +bool_t +xdr_guestfs_cp_a_args (XDR *xdrs, guestfs_cp_a_args *objp) +{ + register int32_t *buf; + + if (!xdr_string (xdrs, &objp->src, ~0)) + return FALSE; + if (!xdr_string (xdrs, &objp->dest, ~0)) + return FALSE; + return TRUE; +} + +bool_t +xdr_guestfs_mv_args (XDR *xdrs, guestfs_mv_args *objp) +{ + register int32_t *buf; + + if (!xdr_string (xdrs, &objp->src, ~0)) + return FALSE; + if (!xdr_string (xdrs, &objp->dest, ~0)) + 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 69ae268f..d2c93b99 100644 --- a/src/guestfs_protocol.h +++ b/src/guestfs_protocol.h @@ -761,6 +761,24 @@ struct guestfs_grub_install_args { }; typedef struct guestfs_grub_install_args guestfs_grub_install_args; +struct guestfs_cp_args { + char *src; + char *dest; +}; +typedef struct guestfs_cp_args guestfs_cp_args; + +struct guestfs_cp_a_args { + char *src; + char *dest; +}; +typedef struct guestfs_cp_a_args guestfs_cp_a_args; + +struct guestfs_mv_args { + char *src; + char *dest; +}; +typedef struct guestfs_mv_args guestfs_mv_args; + enum guestfs_procedure { GUESTFS_PROC_MOUNT = 1, GUESTFS_PROC_SYNC = 2, @@ -848,7 +866,10 @@ enum guestfs_procedure { GUESTFS_PROC_FSCK = 84, GUESTFS_PROC_ZERO = 85, GUESTFS_PROC_GRUB_INSTALL = 86, - GUESTFS_PROC_NR_PROCS = 86 + 1, + GUESTFS_PROC_CP = 87, + GUESTFS_PROC_CP_A = 88, + GUESTFS_PROC_MV = 89, + GUESTFS_PROC_NR_PROCS = 89 + 1, }; typedef enum guestfs_procedure guestfs_procedure; #define GUESTFS_MESSAGE_MAX 4194304 @@ -1017,6 +1038,9 @@ extern bool_t xdr_guestfs_fsck_args (XDR *, guestfs_fsck_args*); extern bool_t xdr_guestfs_fsck_ret (XDR *, guestfs_fsck_ret*); extern bool_t xdr_guestfs_zero_args (XDR *, guestfs_zero_args*); extern bool_t xdr_guestfs_grub_install_args (XDR *, guestfs_grub_install_args*); +extern bool_t xdr_guestfs_cp_args (XDR *, guestfs_cp_args*); +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_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*); @@ -1144,6 +1168,9 @@ extern bool_t xdr_guestfs_fsck_args (); extern bool_t xdr_guestfs_fsck_ret (); extern bool_t xdr_guestfs_zero_args (); extern bool_t xdr_guestfs_grub_install_args (); +extern bool_t xdr_guestfs_cp_args (); +extern bool_t xdr_guestfs_cp_a_args (); +extern bool_t xdr_guestfs_mv_args (); 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 81833300..1a6a2d70 100644 --- a/src/guestfs_protocol.x +++ b/src/guestfs_protocol.x @@ -591,6 +591,21 @@ struct guestfs_grub_install_args { string device<>; }; +struct guestfs_cp_args { + string src<>; + string dest<>; +}; + +struct guestfs_cp_a_args { + string src<>; + string dest<>; +}; + +struct guestfs_mv_args { + string src<>; + string dest<>; +}; + enum guestfs_procedure { GUESTFS_PROC_MOUNT = 1, GUESTFS_PROC_SYNC = 2, @@ -678,6 +693,9 @@ enum guestfs_procedure { GUESTFS_PROC_FSCK = 84, GUESTFS_PROC_ZERO = 85, GUESTFS_PROC_GRUB_INSTALL = 86, + GUESTFS_PROC_CP = 87, + GUESTFS_PROC_CP_A = 88, + GUESTFS_PROC_MV = 89, GUESTFS_PROC_NR_PROCS }; |