WebSVN – HelenOS – Diff – /branches/sparc/uspace/app/bdsh/cmds/modules/cp/cp.c

  * POSSIBILITY OF SUCH DAMAGE.
  */
 #include <stdio.h>
 #include <stdlib.h>
+#include <unistd.h>
+#include <getopt.h>
+#include <string.h>
+#include <fcntl.h>
+#include <assert.h>
 #include "config.h"
 #include "util.h"
 #include "errors.h"
 #include "entry.h"
 #include "cp.h"
 #include "cmds.h"
+#define CP_VERSION "0.0.1"
+#define CP_DEFAULT_BUFLEN  1024
-static char *cmdname = "cp";
+static const char *cmdname = "cp";
+static struct option const long_options[] = {
+    { "buffer", required_argument, 0, 'b' },
+    { "force", no_argument, 0, 'f' },
+    { "recursive", no_argument, 0, 'r' },
+    { "help", no_argument, 0, 'h' },
+    { "version", no_argument, 0, 'v' },
+    { "verbose", no_argument, 0, 'V' },
+    { 0, 0, 0, 0 }
+};
+static int strtoint(const char *s1)
+{
+    long t1;
+    if (-1 == (t1 = strtol(s1, (char **) NULL, 10)))
+        return -1;
+    if (t1 <= 0)
+        return -1;
+    return (int) t1;
+}
+static int64_t copy_file(const char *src, const char *dest, size_t blen, int vb)
+{
+    int fd1, fd2, bytes = 0;
+    off_t total = 0;
+    int64_t copied = 0;
+    char *buff = NULL;
+    if (vb)
+        printf("Copying %s to %s\n", src, dest);
+    if (-1 == (fd1 = open(src, O_RDONLY))) {
+        printf("Unable to open source file %s\n", src);
+        return -1;
+    }
+    if (-1 == (fd2 = open(dest, O_CREAT))) {
+        printf("Unable to open destination file %s\n", dest);
+        close(fd1);
+        return -1;
+    }
+    total = lseek(fd1, 0, SEEK_END);
+    if (vb)
+        printf("%d bytes to copy\n", total);
+    lseek(fd1, 0, SEEK_SET);
+    if (NULL == (buff = (char *) malloc(blen))) {
+        printf("Unable to allocate enough memory to read %s\n",
+            src);
+        copied = -1;
+        goto out;
+    }
+    for (;;) {
+        ssize_t res;
+        bytes = read(fd1, buff, blen);
+        if (bytes <= 0)
+            break;
+        copied += bytes;
+        res = bytes;
+        do {
+            /*
+             * Theoretically, it may not be enough to call write()
+             * only once. Also the previous read() may have
+             * returned less data than requested.
+             */
+            bytes = write(fd2, buff, res);
+            if (bytes < 0)
+                goto err;
+            res -= bytes;
+        } while (res > 0);
+        assert(res == 0);
+    }
+    if (bytes < 0) {
+err:
+        printf("Error copying %s, (%d)\n", src, bytes);
+        copied = bytes;
+    }
+out:
+    close(fd1);
+    close(fd2);
+    if (buff)
+        free(buff);
+    return copied;
+}
-/* Dispays help for cp in various levels */
 void help_cmd_cp(unsigned int level)
+{
+    static char helpfmt[] =
+        "Usage:  %s [options] <source> <dest>\n"
+        "Options: (* indicates not yet implemented)\n"
+        "  -h, --help       A short option summary\n"
+        "  -v, --version    Print version information and exit\n"
+        "* -V, --verbose    Be annoyingly noisy about what's being done\n"
+        "* -f, --force      Do not complain when <dest> exists\n"
+        "* -r, --recursive  Copy entire directories\n"
+        "  -b, --buffer ## Set the read buffer size to ##\n"
+        "Currently, %s is under development, some options may not work.\n";
+    if (level == HELP_SHORT) {
-    printf("This is the %s help for '%s'.\n",
+        printf("`%s' copies files and directories\n", cmdname);
+    } else {
+        help_cmd_cp(HELP_SHORT);
-        level ? EXT_HELP : SHORT_HELP, cmdname);
+        printf(helpfmt, cmdname, cmdname);
+    }
     return;
+}
-/* Main entry point for cp, accepts an array of arguments */
 int cmd_cp(char **argv)
+{
+    unsigned int argc, buffer = 0, verbose = 0;
+    int c, opt_ind;
-    unsigned int argc;
+    int64_t ret;
+    argc = cli_count_args(argv);
+    for (c = 0, optind = 0, opt_ind = 0; c != -1;) {
+        c = getopt_long(argc, argv, "hvVfrb:", long_options, &opt_ind);
-    unsigned int i;
+        switch (c) {
+        case 'h':
+            help_cmd_cp(1);
+            return CMD_SUCCESS;
+        case 'v':
+            printf("%d\n", CP_VERSION);
+            return CMD_SUCCESS;
+        case 'V':
+            verbose = 1;
+            break;
+        case 'f':
+            break;
+        case 'r':
+            break;
+        case 'b':
+            if (-1 == (buffer = strtoint(optarg))) {
+                printf("%s: Invalid buffer specification, "
+                    "(should be a number greater than zero)\n",
+                    cmdname);
+                return CMD_FAILURE;
+            }
+            if (verbose)
+                printf("Buffer = %d\n", buffer);
+            break;
+        }
+    }
-    /* Count the arguments */
+    if (buffer == 0)
-    for (argc = 0; argv[argc] != NULL; argc ++);
+        buffer = CP_DEFAULT_BUFLEN;
-    printf("%s %s\n", TEST_ANNOUNCE, cmdname);
+    argc -= optind;
-    printf("%d arguments passed to %s", argc - 1, cmdname);
-    if (argc < 2) {
+    if (argc != 2) {
+        printf("%s: invalid number of arguments. Try %s --help\n",
-        printf("\n");
+            cmdname, cmdname);
-        return CMD_SUCCESS;
+        return CMD_FAILURE;
+    }
-    printf(":\n");
+    ret = copy_file(argv[optind], argv[optind + 1], buffer, verbose);
-    for (i = 1; i < argc; i++)
+    if (verbose)
-        printf("[%d] -> %s\n", i, argv[i]);
+        printf("%d bytes copied\n", ret);
+    if (ret >= 0)
-    return CMD_SUCCESS;
+        return CMD_SUCCESS;
+    else
+        return CMD_FAILURE;
+}

Subversion Repositories HelenOS

(root)/branches/sparc/uspace/app/bdsh/cmds/modules/cp/cp.c – Rev 3492 → 3665