Changeset 8e3498b in mainline for uspace/app/bdsh/cmds/modules/cp/cp.c


Ignore:
Timestamp:
2017-12-04T18:44:24Z (7 years ago)
Author:
Jiri Svoboda <jiri@…>
Branches:
lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
Children:
bde5c04
Parents:
40feeac
Message:

vfs_read/write() should return error code separately from number of bytes transferred.

File:
1 edited

Legend:

Unmodified
Added
Removed
  • uspace/app/bdsh/cmds/modules/cp/cp.c

    r40feeac r8e3498b  
    6666} dentry_type_t;
    6767
    68 static int64_t copy_file(const char *src, const char *dest,
     68static int copy_file(const char *src, const char *dest,
    6969    size_t blen, int vb);
    7070
     
    175175}
    176176
    177 static int64_t do_copy(const char *src, const char *dest,
     177static int do_copy(const char *src, const char *dest,
    178178    size_t blen, int vb, int recursive, int force, int interactive)
    179179{
    180         int r = -1;
     180        int rc = EOK;
    181181        char dest_path[PATH_MAX];
    182182        char src_path[PATH_MAX];
     
    217217                                printf("The dest directory %s does not exists",
    218218                                    dest_path);
     219                                rc = ENOENT;
    219220                                goto exit;
    220221                        }
     
    224225                        printf("Cannot overwrite existing directory %s\n",
    225226                            dest_path);
     227                        rc = EEXIST;
    226228                        goto exit;
    227229                } else if (dest_type == TYPE_FILE) {
     
    233235                         */
    234236                        if (force && !interactive) {
    235                                 if (vfs_unlink_path(dest_path) != EOK) {
     237                                rc = vfs_unlink_path(dest_path);
     238                                if (rc != EOK) {
    236239                                        printf("Unable to remove %s\n",
    237240                                            dest_path);
     
    244247                                if (overwrite) {
    245248                                        printf("Overwriting file: %s\n", dest_path);
    246                                         if (vfs_unlink_path(dest_path) != EOK) {
     249                                        rc = vfs_unlink_path(dest_path);
     250                                        if (rc != EOK) {
    247251                                                printf("Unable to remove %s\n", dest_path);
    248252                                                goto exit;
     
    250254                                } else {
    251255                                        printf("Not overwriting file: %s\n", dest_path);
    252                                         r = 0;
     256                                        rc = EOK;
    253257                                        goto exit;
    254258                                }
    255259                        } else {
    256260                                printf("File already exists: %s\n", dest_path);
     261                                rc = EEXIST;
    257262                                goto exit;
    258263                        }
     
    260265
    261266                /* call copy_file and exit */
    262                 r = (copy_file(src, dest_path, blen, vb) < 0);
     267                rc = (copy_file(src, dest_path, blen, vb) < 0);
    263268
    264269        } else if (src_type == TYPE_DIR) {
     
    268273                        printf("Cannot copy the %s directory without the "
    269274                            "-r option\n", src);
     275                        rc = EINVAL;
    270276                        goto exit;
    271277                } else if (dest_type == TYPE_FILE) {
    272278                        printf("Cannot overwrite a file with a directory\n");
     279                        rc = EEXIST;
    273280                        goto exit;
    274281                }
     
    293300                                merge_paths(dest_path, PATH_MAX, src_dirname);
    294301
    295                                 if (vfs_link_path(dest_path, KIND_DIRECTORY,
    296                                     NULL) != EOK) {
     302                                rc = vfs_link_path(dest_path, KIND_DIRECTORY,
     303                                    NULL);
     304                                if (rc != EOK) {
    297305                                        printf("Unable to create "
    298306                                            "dest directory %s\n", dest_path);
     
    308316                         * e.g. cp -r /src /data/new_dir_src
    309317                         */
    310                         if (vfs_link_path(dest_path, KIND_DIRECTORY,
    311                             NULL) != EOK) {
     318                        rc = vfs_link_path(dest_path, KIND_DIRECTORY, NULL);
     319                        if (rc != EOK) {
    312320                                printf("Unable to create "
    313321                                    "dest directory %s\n", dest_path);
     
    321329                        /* Something strange is happening... */
    322330                        printf("Unable to open src %s directory\n", src);
     331                        rc = ENOENT;
    323332                        goto exit;
    324333                }
     
    348357                                printf("Cannot copy a directory "
    349358                                    "into itself\n");
     359                                rc = EEXIST;
    350360                                goto exit;
    351361                        }
     
    355365
    356366                        /* Recursively call do_copy() */
    357                         r = do_copy(src_dent, dest_dent, blen, vb, recursive,
     367                        rc = do_copy(src_dent, dest_dent, blen, vb, recursive,
    358368                            force, interactive);
    359                         if (r)
     369                        if (rc != EOK)
    360370                                goto exit;
    361371
     
    367377        if (dir)
    368378                closedir(dir);
    369         return r;
    370 }
    371 
    372 static int64_t copy_file(const char *src, const char *dest,
     379        return rc;
     380}
     381
     382static int copy_file(const char *src, const char *dest,
    373383        size_t blen, int vb)
    374384{
    375         int fd1, fd2, bytes;
     385        int fd1, fd2;
     386        size_t rbytes, wbytes;
     387        int rc;
    376388        off64_t total;
    377         int64_t copied = 0;
    378389        char *buff = NULL;
    379390        aoff64_t posr = 0, posw = 0;
     
    410421                printf("Unable to allocate enough memory to read %s\n",
    411422                    src);
    412                 copied = -1;
     423                rc = ENOMEM;
    413424                goto out;
    414425        }
    415426
    416         while ((bytes = vfs_read(fd1, &posr, buff, blen)) > 0) {
    417                 if ((bytes = vfs_write(fd2, &posw, buff, bytes)) < 0)
    418                         break;
    419                 copied += bytes;
    420         }
    421 
    422         if (bytes < 0) {
    423                 printf("\nError copying %s, (%d)\n", src, bytes);
    424                 copied = bytes;
     427        while ((rc = vfs_read(fd1, &posr, buff, blen, &rbytes)) == EOK &&
     428            rbytes > 0) {
     429                if ((rc = vfs_write(fd2, &posw, buff, rbytes, &wbytes)) != EOK)
     430                        break;
     431        }
     432
     433        if (rc != EOK) {
     434                printf("\nError copying %s, (%d)\n", src, rc);
     435                return rc;
    425436        }
    426437
     
    430441        if (buff)
    431442                free(buff);
    432         return copied;
     443        return rc;
    433444}
    434445
Note: See TracChangeset for help on using the changeset viewer.