summaryrefslogtreecommitdiffstats
path: root/daemon
diff options
context:
space:
mode:
authorRichard Jones <rjones@redhat.com>2010-03-22 18:36:16 +0000
committerRichard Jones <rjones@redhat.com>2010-03-23 21:56:14 +0000
commitb6483061c25e90ae1b9e016812dea8e3756d6c23 (patch)
tree5c9f8dbde945d1f1aeba90e2ffcaca5012475881 /daemon
parent5d90acbe4b670e14084bbe9d11b717bfb6d95603 (diff)
downloadlibguestfs-b6483061c25e90ae1b9e016812dea8e3756d6c23.tar.gz
libguestfs-b6483061c25e90ae1b9e016812dea8e3756d6c23.tar.xz
libguestfs-b6483061c25e90ae1b9e016812dea8e3756d6c23.zip
New API: guestfs_copy_size to copy a fixed number of bytes.
This is similar to 'guestfs_dd', but it copies just a fixed number of bytes from the source to the destination. It's an error if the source is too short or if the destination is too small.
Diffstat (limited to 'daemon')
-rw-r--r--daemon/dd.c81
1 files changed, 81 insertions, 0 deletions
diff --git a/daemon/dd.c b/daemon/dd.c
index d92dac0f..2bbe8551 100644
--- a/daemon/dd.c
+++ b/daemon/dd.c
@@ -21,6 +21,7 @@
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
+#include <fcntl.h>
#include "../src/guestfs_protocol.h"
#include "daemon.h"
@@ -70,3 +71,83 @@ do_dd (const char *src, const char *dest)
return 0;
}
+
+int
+do_copy_size (const char *src, const char *dest, int64_t size)
+{
+ char *buf;
+ int src_fd, dest_fd;
+
+ if (STRPREFIX (src, "/dev/"))
+ src_fd = open (src, O_RDONLY);
+ else {
+ buf = sysroot_path (src);
+ if (!buf) {
+ reply_with_perror ("malloc");
+ return -1;
+ }
+ src_fd = open (buf, O_RDONLY);
+ free (buf);
+ }
+ if (src_fd == -1) {
+ reply_with_perror ("%s", src);
+ return -1;
+ }
+
+ if (STRPREFIX (dest, "/dev/"))
+ dest_fd = open (dest, O_WRONLY);
+ else {
+ buf = sysroot_path (dest);
+ if (!buf) {
+ reply_with_perror ("malloc");
+ close (src_fd);
+ return -1;
+ }
+ dest_fd = open (buf, O_WRONLY|O_CREAT|O_TRUNC|O_NOCTTY, 0666);
+ free (buf);
+ }
+ if (dest_fd == -1) {
+ reply_with_perror ("%s", dest);
+ close (src_fd);
+ return -1;
+ }
+
+ while (size > 0) {
+ char buf[1024*1024];
+ size_t n = size > (int64_t) (sizeof buf) ? sizeof buf : (size_t) size;
+ ssize_t r = read (src_fd, buf, n);
+ if (r == -1) {
+ reply_with_perror ("%s: read", src);
+ close (src_fd);
+ close (dest_fd);
+ return -1;
+ }
+ if (r == 0) {
+ reply_with_error ("%s: input file too short", src);
+ close (src_fd);
+ close (dest_fd);
+ return -1;
+ }
+
+ if (xwrite (dest_fd, buf, r) == -1) {
+ reply_with_perror ("%s: write", dest);
+ close (src_fd);
+ close (dest_fd);
+ return -1;
+ }
+
+ size -= r;
+ }
+
+ if (close (src_fd) == -1) {
+ reply_with_perror ("%s: close", src);
+ close (dest_fd);
+ return -1;
+ }
+ if (close (dest_fd) == -1) {
+ reply_with_perror ("%s: close", dest);
+ return -1;
+ }
+
+ return 0;
+}