Changes in uspace/lib/c/generic/vfs/vfs.c [38db6288:6afc9d7] in mainline
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/lib/c/generic/vfs/vfs.c
r38db6288 r6afc9d7 75 75 76 76 while (vfs_sess == NULL) 77 vfs_sess = service_connect_blocking( EXCHANGE_PARALLEL, SERVICE_VFS,78 0 , 0);77 vfs_sess = service_connect_blocking(SERVICE_VFS, INTERFACE_VFS, 78 0); 79 79 80 80 fibril_mutex_unlock(&vfs_mutex); … … 93 93 } 94 94 95 char * absolutize(const char *path, size_t *retlen)95 char *vfs_absolutize(const char *path, size_t *retlen) 96 96 { 97 97 char *ncwd_path; … … 101 101 size_t size = str_size(path); 102 102 if (*path != '/') { 103 if ( !cwd_path) {103 if (cwd_path == NULL) { 104 104 fibril_mutex_unlock(&cwd_mutex); 105 105 return NULL; 106 106 } 107 107 ncwd_path_nc = malloc(cwd_size + 1 + size + 1); 108 if ( !ncwd_path_nc) {108 if (ncwd_path_nc == NULL) { 109 109 fibril_mutex_unlock(&cwd_mutex); 110 110 return NULL; … … 115 115 } else { 116 116 ncwd_path_nc = malloc(size + 1); 117 if ( !ncwd_path_nc) {117 if (ncwd_path_nc == NULL) { 118 118 fibril_mutex_unlock(&cwd_mutex); 119 119 return NULL; … … 123 123 str_append(ncwd_path_nc, cwd_size + 1 + size + 1, path); 124 124 ncwd_path = canonify(ncwd_path_nc, retlen); 125 if ( !ncwd_path) {125 if (ncwd_path == NULL) { 126 126 fibril_mutex_unlock(&cwd_mutex); 127 127 free(ncwd_path_nc); … … 135 135 ncwd_path = str_dup(ncwd_path); 136 136 free(ncwd_path_nc); 137 if ( !ncwd_path) {137 if (ncwd_path == NULL) { 138 138 fibril_mutex_unlock(&cwd_mutex); 139 139 return NULL; … … 143 143 } 144 144 145 int mount(const char *fs_name, const char *mp, const char *fqsn,145 int vfs_mount(const char *fs_name, const char *mp, const char *fqsn, 146 146 const char *opts, unsigned int flags, unsigned int instance) 147 147 { … … 171 171 172 172 size_t mpa_size; 173 char *mpa = absolutize(mp, &mpa_size);174 if ( !mpa) {173 char *mpa = vfs_absolutize(mp, &mpa_size); 174 if (mpa == NULL) { 175 175 if (null_id != -1) 176 176 loc_null_destroy(null_id); … … 255 255 } 256 256 257 int unmount(const char *mp)257 int vfs_unmount(const char *mp) 258 258 { 259 259 sysarg_t rc; … … 263 263 char *mpa; 264 264 265 mpa = absolutize(mp, &mpa_size);266 if ( !mpa)265 mpa = vfs_absolutize(mp, &mpa_size); 266 if (mpa == NULL) 267 267 return ENOMEM; 268 268 … … 289 289 } 290 290 291 static int open_internal(const char *abs, size_t abs_size, int lflag, int oflag) 291 /** Open file (internal). 292 * 293 * @param abs Absolute path to file 294 * @param abs_size Size of @a abs string 295 * @param lflag L_xxx flags 296 * @param oflag O_xxx flags 297 * @param fd Place to store new file descriptor 298 * 299 * @return EOK on success, non-zero error code on error 300 */ 301 static int open_internal(const char *abs, size_t abs_size, int lflag, int oflag, 302 int *fd) 292 303 { 293 304 async_exch_t *exch = vfs_exchange_begin(); … … 315 326 return (int) rc; 316 327 317 return (int) IPC_GET_ARG1(answer); 318 } 319 328 *fd = (int) IPC_GET_ARG1(answer); 329 return EOK; 330 } 331 332 /** Open file. 333 * 334 * @param path File path 335 * @param oflag O_xxx flags 336 * @param mode File mode (only with O_CREAT) 337 * 338 * @return Nonnegative file descriptor on success. On error -1 is returned 339 * and errno is set. 340 */ 320 341 int open(const char *path, int oflag, ...) 321 342 { 322 343 size_t abs_size; 323 char *abs = absolutize(path, &abs_size); 324 if (!abs) 325 return ENOMEM; 326 327 int ret = open_internal(abs, abs_size, L_FILE, oflag); 344 char *abs = vfs_absolutize(path, &abs_size); 345 int fd = -1; 346 347 if (abs == NULL) { 348 errno = ENOMEM; 349 return -1; 350 } 351 352 int rc = open_internal(abs, abs_size, L_FILE, oflag, &fd); 328 353 free(abs); 329 354 330 return ret; 331 } 332 355 if (rc != EOK) { 356 errno = rc; 357 return -1; 358 } 359 360 return fd; 361 } 362 363 /** Close file. 364 * 365 * @param fildes File descriptor 366 * @return Zero on success. On error -1 is returned and errno is set. 367 */ 333 368 int close(int fildes) 334 369 { … … 339 374 vfs_exchange_end(exch); 340 375 341 return (int) rc; 342 } 343 344 ssize_t read(int fildes, void *buf, size_t nbyte) 376 if (rc != EOK) { 377 errno = rc; 378 return -1; 379 } 380 381 return 0; 382 } 383 384 /** Read bytes from file. 385 * 386 * Read up to @a nbyte bytes from file. The actual number of bytes read 387 * may be lower, but greater than zero if there are any bytes available. 388 * If there are no bytes available for reading, then the function will 389 * return success with zero bytes read. 390 * 391 * @param fildes File descriptor 392 * @param buf Buffer 393 * @param nbyte Maximum number of bytes to read 394 * @param nread Place to store actual number of bytes read (0 or more) 395 * 396 * @return EOK on success, non-zero error code on error. 397 */ 398 static int _read_short(int fildes, void *buf, size_t nbyte, ssize_t *nread) 345 399 { 346 400 sysarg_t rc; … … 357 411 if (rc != EOK) { 358 412 vfs_exchange_end(exch); 359 413 360 414 sysarg_t rc_orig; 361 415 async_wait_for(req, &rc_orig); 362 416 363 417 if (rc_orig == EOK) 364 return (ssize_t)rc;418 return rc; 365 419 else 366 return (ssize_t) rc_orig; 367 } 420 return rc_orig; 421 } 422 368 423 vfs_exchange_end(exch); 369 424 async_wait_for(req, &rc); 370 if (rc == EOK) 371 return (ssize_t) IPC_GET_ARG1(answer); 372 else 425 426 if (rc != EOK) 373 427 return rc; 374 } 375 376 ssize_t write(int fildes, const void *buf, size_t nbyte) 428 429 *nread = (ssize_t) IPC_GET_ARG1(answer); 430 return EOK; 431 } 432 433 /** Write bytes to file. 434 * 435 * Write up to @a nbyte bytes from file. The actual number of bytes written 436 * may be lower, but greater than zero. 437 * 438 * @param fildes File descriptor 439 * @param buf Buffer 440 * @param nbyte Maximum number of bytes to write 441 * @param nread Place to store actual number of bytes written (0 or more) 442 * 443 * @return EOK on success, non-zero error code on error. 444 */ 445 static int _write_short(int fildes, const void *buf, size_t nbyte, 446 ssize_t *nwritten) 377 447 { 378 448 sysarg_t rc; … … 389 459 if (rc != EOK) { 390 460 vfs_exchange_end(exch); 391 461 392 462 sysarg_t rc_orig; 393 463 async_wait_for(req, &rc_orig); 394 464 395 465 if (rc_orig == EOK) 396 return (ssize_t)rc;466 return rc; 397 467 else 398 return (ssize_t) rc_orig; 399 } 468 return rc_orig; 469 } 470 400 471 vfs_exchange_end(exch); 401 472 async_wait_for(req, &rc); 402 if (rc == EOK) 403 return (ssize_t) IPC_GET_ARG1(answer); 404 else 405 return -1; 406 } 407 408 /** Read entire buffer. 409 * 410 * In face of short reads this function continues reading until either 411 * the entire buffer is read or no more data is available (at end of file). 473 474 if (rc != EOK) 475 return rc; 476 477 *nwritten = (ssize_t) IPC_GET_ARG1(answer); 478 return EOK; 479 } 480 481 /** Read data. 482 * 483 * Read up to @a nbytes bytes from file if available. This function always reads 484 * all the available bytes up to @a nbytes. 412 485 * 413 486 * @param fildes File descriptor … … 415 488 * @param nbytes Number of bytes to read 416 489 * 417 * @return On success, positive number of bytes read.418 * On failure, negative error code from read().419 */ 420 ssize_t read _all(int fildes, void *buf, size_t nbyte)490 * @return On success, nonnegative number of bytes read. 491 * On failure, -1 and sets errno. 492 */ 493 ssize_t read(int fildes, void *buf, size_t nbyte) 421 494 { 422 495 ssize_t cnt = 0; 423 496 size_t nread = 0; 424 497 uint8_t *bp = (uint8_t *) buf; 425 498 int rc; 499 426 500 do { 427 501 bp += cnt; 428 502 nread += cnt; 429 cnt = read(fildes, bp, nbyte - nread); 430 } while (cnt > 0 && (nbyte - nread - cnt) > 0); 431 432 if (cnt < 0) 433 return cnt; 434 503 rc = _read_short(fildes, bp, nbyte - nread, &cnt); 504 } while (rc == EOK && cnt > 0 && (nbyte - nread - cnt) > 0); 505 506 if (rc != EOK) { 507 errno = rc; 508 return -1; 509 } 510 435 511 return nread + cnt; 436 512 } 437 513 438 /** Write entire buffer.514 /** Write data. 439 515 * 440 516 * This function fails if it cannot write exactly @a len bytes to the file. … … 444 520 * @param nbytes Number of bytes to write 445 521 * 446 * @return EOK on error, return value from write() if writing447 * failed.448 */ 449 ssize_t write _all(int fildes, const void *buf, size_t nbyte)522 * @return On success, nonnegative number of bytes written. 523 * On failure, -1 and sets errno. 524 */ 525 ssize_t write(int fildes, const void *buf, size_t nbyte) 450 526 { 451 527 ssize_t cnt = 0; 452 528 ssize_t nwritten = 0; 453 529 const uint8_t *bp = (uint8_t *) buf; 530 int rc; 454 531 455 532 do { 456 533 bp += cnt; 457 534 nwritten += cnt; 458 cnt = write(fildes, bp, nbyte - nwritten); 459 } while (cnt > 0 && ((ssize_t )nbyte - nwritten - cnt) > 0); 460 461 if (cnt < 0) 462 return cnt; 463 464 if ((ssize_t)nbyte - nwritten - cnt > 0) 465 return EIO; 535 rc = _write_short(fildes, bp, nbyte - nwritten, &cnt); 536 } while (rc == EOK && ((ssize_t )nbyte - nwritten - cnt) > 0); 537 538 if (rc != EOK) { 539 errno = rc; 540 return -1; 541 } 466 542 467 543 return nbyte; 468 544 } 469 545 546 /** Synchronize file. 547 * 548 * @param fildes File descriptor 549 * @return 0 on success. On error returns -1 and sets errno. 550 */ 470 551 int fsync(int fildes) 471 552 { … … 474 555 vfs_exchange_end(exch); 475 556 476 return (int) rc; 477 } 478 557 if (rc != EOK) { 558 errno = rc; 559 return -1; 560 } 561 562 return 0; 563 } 564 565 /** Seek to a position. 566 * 567 * @param fildes File descriptor 568 * @param offset Offset 569 * @param whence SEEK_SET, SEEK_CUR or SEEK_END 570 * 571 * @return On success the nonnegative offset from start of file. On error 572 * returns (off64_t)-1 and sets errno. 573 */ 479 574 off64_t lseek(int fildes, off64_t offset, int whence) 480 575 { … … 489 584 vfs_exchange_end(exch); 490 585 491 if (rc != EOK) 586 if (rc != EOK) { 587 errno = rc; 492 588 return (off64_t) -1; 589 } 493 590 494 591 return (off64_t) MERGE_LOUP32(newoff_lo, newoff_hi); 495 592 } 496 593 594 /** Truncate file to a specified length. 595 * 596 * Truncate file so that its size is exactly @a length 597 * 598 * @param fildes File descriptor 599 * @param length Length 600 * 601 * @return 0 on success, -1 on error and sets errno. 602 */ 497 603 int ftruncate(int fildes, aoff64_t length) 498 604 { … … 504 610 vfs_exchange_end(exch); 505 611 506 return (int) rc; 507 } 508 612 if (rc != EOK) { 613 errno = rc; 614 return -1; 615 } 616 617 return 0; 618 } 619 620 /** Get file status. 621 * 622 * @param fildes File descriptor 623 * @param stat Place to store file information 624 * 625 * @return 0 on success, -1 on error and sets errno. 626 */ 509 627 int fstat(int fildes, struct stat *stat) 510 628 { … … 518 636 if (rc != EOK) { 519 637 vfs_exchange_end(exch); 520 638 521 639 sysarg_t rc_orig; 522 640 async_wait_for(req, &rc_orig); 523 524 if (rc_orig == EOK) 525 return (ssize_t) rc; 526 else 527 return (ssize_t) rc_orig; 528 } 641 642 if (rc_orig != EOK) 643 rc = rc_orig; 644 if (rc != EOK) { 645 errno = rc; 646 return -1; 647 } 648 649 return 0; 650 } 651 529 652 vfs_exchange_end(exch); 530 653 async_wait_for(req, &rc); 531 532 return rc; 533 } 534 654 655 if (rc != EOK) { 656 errno = rc; 657 return -1; 658 } 659 660 return 0; 661 } 662 663 /** Get file status. 664 * 665 * @param path Path to file 666 * @param stat Place to store file information 667 * 668 * @return 0 on success, -1 on error and sets errno. 669 */ 535 670 int stat(const char *path, struct stat *stat) 536 671 { … … 540 675 541 676 size_t pa_size; 542 char *pa = absolutize(path, &pa_size); 543 if (!pa) 544 return ENOMEM; 677 char *pa = vfs_absolutize(path, &pa_size); 678 if (pa == NULL) { 679 errno = ENOMEM; 680 return -1; 681 } 545 682 546 683 async_exch_t *exch = vfs_exchange_begin(); … … 552 689 free(pa); 553 690 async_wait_for(req, &rc_orig); 691 if (rc_orig != EOK) 692 rc = rc_orig; 693 if (rc != EOK) { 694 errno = rc; 695 return -1; 696 } 697 } 698 rc = async_data_read_start(exch, stat, sizeof(struct stat)); 699 if (rc != EOK) { 700 vfs_exchange_end(exch); 701 free(pa); 702 async_wait_for(req, &rc_orig); 703 if (rc_orig != EOK) 704 rc = rc_orig; 705 if (rc != EOK) { 706 errno = rc; 707 return -1; 708 } 709 } 710 vfs_exchange_end(exch); 711 free(pa); 712 async_wait_for(req, &rc); 713 if (rc != EOK) { 714 errno = rc; 715 return -1; 716 } 717 return 0; 718 } 719 720 /** Open directory. 721 * 722 * @param dirname Directory pathname 723 * 724 * @return Non-NULL pointer on success. On error returns @c NULL and sets errno. 725 */ 726 DIR *opendir(const char *dirname) 727 { 728 DIR *dirp = malloc(sizeof(DIR)); 729 int fd = -1; 730 731 if (dirp == NULL) { 732 errno = ENOMEM; 733 return NULL; 734 } 735 736 size_t abs_size; 737 char *abs = vfs_absolutize(dirname, &abs_size); 738 if (abs == NULL) { 739 free(dirp); 740 errno = ENOMEM; 741 return NULL; 742 } 743 744 int rc = open_internal(abs, abs_size, L_DIRECTORY, 0, &fd); 745 free(abs); 746 747 if (rc != EOK) { 748 free(dirp); 749 errno = rc; 750 return NULL; 751 } 752 753 dirp->fd = fd; 754 return dirp; 755 } 756 757 /** Read directory entry. 758 * 759 * @param dirp Open directory 760 * @return Non-NULL pointer to directory entry on success. On error returns 761 * @c NULL and sets errno. 762 */ 763 struct dirent *readdir(DIR *dirp) 764 { 765 int rc; 766 ssize_t len; 767 768 rc = _read_short(dirp->fd, &dirp->res.d_name[0], NAME_MAX + 1, &len); 769 if (rc != EOK) { 770 errno = rc; 771 return NULL; 772 } 773 774 (void) len; 775 return &dirp->res; 776 } 777 778 /** Rewind directory position to the beginning. 779 * 780 * @param dirp Open directory 781 */ 782 void rewinddir(DIR *dirp) 783 { 784 (void) lseek(dirp->fd, 0, SEEK_SET); 785 } 786 787 /** Close directory. 788 * 789 * @param dirp Open directory 790 * @return 0 on success. On error returns -1 and sets errno. 791 */ 792 int closedir(DIR *dirp) 793 { 794 int rc; 795 796 rc = close(dirp->fd); 797 free(dirp); 798 799 /* On error errno was set by close() */ 800 return rc; 801 } 802 803 /** Create directory. 804 * 805 * @param path Path 806 * @param mode File mode 807 * @return 0 on success. On error returns -1 and sets errno. 808 */ 809 int mkdir(const char *path, mode_t mode) 810 { 811 sysarg_t rc; 812 aid_t req; 813 814 size_t pa_size; 815 char *pa = vfs_absolutize(path, &pa_size); 816 if (pa == NULL) { 817 errno = ENOMEM; 818 return -1; 819 } 820 821 async_exch_t *exch = vfs_exchange_begin(); 822 823 req = async_send_1(exch, VFS_IN_MKDIR, mode, NULL); 824 rc = async_data_write_start(exch, pa, pa_size); 825 if (rc != EOK) { 826 vfs_exchange_end(exch); 827 free(pa); 828 829 sysarg_t rc_orig; 830 async_wait_for(req, &rc_orig); 831 832 if (rc_orig != EOK) 833 rc = rc_orig; 834 835 if (rc != EOK) { 836 errno = rc; 837 return -1; 838 } 839 840 return 0; 841 } 842 843 vfs_exchange_end(exch); 844 free(pa); 845 async_wait_for(req, &rc); 846 847 if (rc != EOK) { 848 errno = rc; 849 return -1; 850 } 851 852 return 0; 853 } 854 855 /** Unlink a file or directory. 856 * 857 * @param path Path to file or empty directory 858 * @param lflag L_xxx flag (L_NONE, L_FILE or L_DIRECTORY) 859 * @return EOK on success, non-zero error code on error 860 */ 861 static int _unlink(const char *path, int lflag) 862 { 863 sysarg_t rc; 864 aid_t req; 865 866 size_t pa_size; 867 char *pa = vfs_absolutize(path, &pa_size); 868 if (pa == NULL) 869 return ENOMEM; 870 871 async_exch_t *exch = vfs_exchange_begin(); 872 873 req = async_send_1(exch, VFS_IN_UNLINK, lflag, NULL); 874 rc = async_data_write_start(exch, pa, pa_size); 875 if (rc != EOK) { 876 vfs_exchange_end(exch); 877 free(pa); 878 879 sysarg_t rc_orig; 880 async_wait_for(req, &rc_orig); 881 554 882 if (rc_orig == EOK) 555 883 return (int) rc; … … 557 885 return (int) rc_orig; 558 886 } 559 rc = async_data_read_start(exch, stat, sizeof(struct stat));560 if (rc != EOK) {561 vfs_exchange_end(exch);562 free(pa);563 async_wait_for(req, &rc_orig);564 if (rc_orig == EOK)565 return (int) rc;566 else567 return (int) rc_orig;568 }569 887 vfs_exchange_end(exch); 570 888 free(pa); … … 573 891 } 574 892 575 DIR *opendir(const char *dirname) 576 { 577 DIR *dirp = malloc(sizeof(DIR)); 578 if (!dirp) 579 return NULL; 580 581 size_t abs_size; 582 char *abs = absolutize(dirname, &abs_size); 583 if (!abs) { 584 free(dirp); 585 return NULL; 586 } 587 588 int ret = open_internal(abs, abs_size, L_DIRECTORY, 0); 589 free(abs); 590 591 if (ret < 0) { 592 free(dirp); 593 return NULL; 594 } 595 596 dirp->fd = ret; 597 return dirp; 598 } 599 600 struct dirent *readdir(DIR *dirp) 601 { 602 ssize_t len = read(dirp->fd, &dirp->res.d_name[0], NAME_MAX + 1); 603 if (len <= 0) 604 return NULL; 605 return &dirp->res; 606 } 607 608 void rewinddir(DIR *dirp) 609 { 610 (void) lseek(dirp->fd, 0, SEEK_SET); 611 } 612 613 int closedir(DIR *dirp) 614 { 615 (void) close(dirp->fd); 616 free(dirp); 893 /** Unlink file or directory. 894 * 895 * @param path Path 896 * @return EOk on success, error code on error 897 */ 898 int unlink(const char *path) 899 { 900 int rc; 901 902 rc = _unlink(path, L_NONE); 903 if (rc != EOK) { 904 errno = rc; 905 return -1; 906 } 907 617 908 return 0; 618 909 } 619 910 620 int mkdir(const char *path, mode_t mode) 621 { 622 sysarg_t rc; 623 aid_t req; 624 625 size_t pa_size; 626 char *pa = absolutize(path, &pa_size); 627 if (!pa) 628 return ENOMEM; 629 630 async_exch_t *exch = vfs_exchange_begin(); 631 632 req = async_send_1(exch, VFS_IN_MKDIR, mode, NULL); 633 rc = async_data_write_start(exch, pa, pa_size); 634 if (rc != EOK) { 635 vfs_exchange_end(exch); 636 free(pa); 637 638 sysarg_t rc_orig; 639 async_wait_for(req, &rc_orig); 640 641 if (rc_orig == EOK) 642 return (int) rc; 643 else 644 return (int) rc_orig; 645 } 646 vfs_exchange_end(exch); 647 free(pa); 648 async_wait_for(req, &rc); 649 return rc; 650 } 651 652 static int _unlink(const char *path, int lflag) 653 { 654 sysarg_t rc; 655 aid_t req; 656 657 size_t pa_size; 658 char *pa = absolutize(path, &pa_size); 659 if (!pa) 660 return ENOMEM; 661 662 async_exch_t *exch = vfs_exchange_begin(); 663 664 req = async_send_1(exch, VFS_IN_UNLINK, lflag, NULL); 665 rc = async_data_write_start(exch, pa, pa_size); 666 if (rc != EOK) { 667 vfs_exchange_end(exch); 668 free(pa); 669 670 sysarg_t rc_orig; 671 async_wait_for(req, &rc_orig); 672 673 if (rc_orig == EOK) 674 return (int) rc; 675 else 676 return (int) rc_orig; 677 } 678 vfs_exchange_end(exch); 679 free(pa); 680 async_wait_for(req, &rc); 681 return rc; 682 } 683 684 int unlink(const char *path) 685 { 686 return _unlink(path, L_NONE); 687 } 688 911 /** Remove empty directory. 912 * 913 * @param path Path 914 * @return 0 on success. On error returns -1 and sets errno. 915 */ 689 916 int rmdir(const char *path) 690 917 { 691 return _unlink(path, L_DIRECTORY); 692 } 693 918 int rc; 919 920 rc = _unlink(path, L_DIRECTORY); 921 if (rc != EOK) { 922 errno = rc; 923 return -1; 924 } 925 926 return 0; 927 } 928 929 /** Rename directory entry. 930 * 931 * @param old Old name 932 * @param new New name 933 * 934 * @return 0 on success. On error returns -1 and sets errno. 935 */ 694 936 int rename(const char *old, const char *new) 695 937 { … … 699 941 700 942 size_t olda_size; 701 char *olda = absolutize(old, &olda_size); 702 if (!olda) 703 return ENOMEM; 943 char *olda = vfs_absolutize(old, &olda_size); 944 if (olda == NULL) { 945 errno = ENOMEM; 946 return -1; 947 } 704 948 705 949 size_t newa_size; 706 char *newa = absolutize(new, &newa_size);707 if ( !newa) {950 char *newa = vfs_absolutize(new, &newa_size); 951 if (newa == NULL) { 708 952 free(olda); 709 return ENOMEM; 953 errno = ENOMEM; 954 return -1; 710 955 } 711 956 … … 719 964 free(newa); 720 965 async_wait_for(req, &rc_orig); 721 if (rc_orig == EOK) 722 return (int) rc; 723 else 724 return (int) rc_orig; 966 if (rc_orig != EOK) 967 rc = rc_orig; 968 if (rc != EOK) { 969 errno = rc; 970 return -1; 971 } 972 return 0; 725 973 } 726 974 rc = async_data_write_start(exch, newa, newa_size); … … 730 978 free(newa); 731 979 async_wait_for(req, &rc_orig); 732 if (rc_orig == EOK) 733 return (int) rc; 734 else 735 return (int) rc_orig; 980 if (rc_orig != EOK) 981 rc = rc_orig; 982 if (rc != EOK) { 983 errno = rc; 984 return -1; 985 } 986 return 0; 736 987 } 737 988 vfs_exchange_end(exch); … … 739 990 free(newa); 740 991 async_wait_for(req, &rc); 741 return rc; 742 } 743 992 993 if (rc != EOK) { 994 errno = rc; 995 return -1; 996 } 997 998 return 0; 999 } 1000 1001 /** Remove directory entry. 1002 * 1003 * @param path Path 1004 * @return 0 on success. On error returns -1 and sets errno. 1005 */ 744 1006 int remove(const char *path) 745 1007 { … … 747 1009 } 748 1010 1011 /** Change working directory. 1012 * 1013 * @param path Path 1014 * @return 0 on success. On error returns -1 and sets errno. 1015 */ 749 1016 int chdir(const char *path) 750 1017 { 751 1018 size_t abs_size; 752 char *abs = absolutize(path, &abs_size); 753 if (!abs) 754 return ENOMEM; 755 756 int fd = open_internal(abs, abs_size, L_DIRECTORY, O_DESC); 757 758 if (fd < 0) { 1019 char *abs = vfs_absolutize(path, &abs_size); 1020 int fd = -1; 1021 1022 if (abs == NULL) { 1023 errno = ENOMEM; 1024 return -1; 1025 } 1026 1027 int rc = open_internal(abs, abs_size, L_DIRECTORY, O_DESC, &fd); 1028 1029 if (rc != EOK) { 759 1030 free(abs); 760 return ENOENT; 1031 errno = rc; 1032 return -1; 761 1033 } 762 1034 … … 765 1037 if (cwd_fd >= 0) 766 1038 close(cwd_fd); 767 768 1039 769 1040 if (cwd_path) … … 775 1046 776 1047 fibril_mutex_unlock(&cwd_mutex); 777 return EOK; 778 } 779 1048 return 0; 1049 } 1050 1051 /** Get current working directory path. 1052 * 1053 * @param buf Buffer 1054 * @param size Size of @a buf 1055 * @return On success returns @a buf. On failure returns @c NULL and sets errno. 1056 */ 780 1057 char *getcwd(char *buf, size_t size) 781 1058 { 782 if (size == 0) 1059 if (size == 0) { 1060 errno = EINVAL; 783 1061 return NULL; 1062 } 784 1063 785 1064 fibril_mutex_lock(&cwd_mutex); … … 787 1066 if ((cwd_size == 0) || (size < cwd_size + 1)) { 788 1067 fibril_mutex_unlock(&cwd_mutex); 1068 errno = ERANGE; 789 1069 return NULL; 790 1070 } … … 796 1076 } 797 1077 798 async_sess_t *fd_session(exch_mgmt_t mgmt, int fildes) 1078 /** Open session to service represented by a special file. 1079 * 1080 * Given that the file referred to by @a fildes represents a service, 1081 * open a session to that service. 1082 * 1083 * @param fildes File descriptor 1084 * @param iface Interface to connect to (XXX Should be automatic) 1085 * @return On success returns session pointer. On error returns @c NULL. 1086 */ 1087 async_sess_t *vfs_fd_session(int fildes, iface_t iface) 799 1088 { 800 1089 struct stat stat; 801 1090 int rc = fstat(fildes, &stat); 802 if (rc != 0) { 803 errno = rc; 1091 if (rc != 0) 804 1092 return NULL; 805 } 806 807 if (!stat.service) { 808 errno = ENOENT; 1093 1094 if (stat.service == 0) 809 1095 return NULL; 810 } 811 812 return loc_service_connect(mgmt, stat.service, 0); 813 } 814 1096 1097 return loc_service_connect(stat.service, iface, 0); 1098 } 1099 1100 /** Duplicate open file. 1101 * 1102 * Duplicate open file under a new file descriptor. 1103 * 1104 * @param oldfd Old file descriptor 1105 * @param newfd New file descriptor 1106 * @return 0 on success. On error -1 is returned and errno is set 1107 */ 815 1108 int dup2(int oldfd, int newfd) 816 1109 { … … 823 1116 824 1117 if (rc == EOK) 825 return (int) ret; 826 827 return (int) rc; 828 } 829 830 int fd_wait(void) 1118 rc = ret; 1119 1120 if (rc != EOK) { 1121 errno = rc; 1122 return -1; 1123 } 1124 1125 return 0; 1126 } 1127 1128 int vfs_fd_wait(void) 831 1129 { 832 1130 async_exch_t *exch = vfs_exchange_begin(); … … 843 1141 } 844 1142 845 int get_mtab_list(list_t *mtab_list)1143 int vfs_get_mtab_list(list_t *mtab_list) 846 1144 { 847 1145 sysarg_t rc; … … 863 1161 864 1162 mtab_ent = malloc(sizeof(mtab_ent_t)); 865 if ( !mtab_ent) {1163 if (mtab_ent == NULL) { 866 1164 rc = ENOMEM; 867 1165 goto exit; … … 904 1202 } 905 1203 1204 /** Get filesystem statistics. 1205 * 1206 * @param path Mount point path 1207 * @param st Buffer for storing information 1208 * @return 0 on success. On error -1 is returned and errno is set. 1209 */ 906 1210 int statfs(const char *path, struct statfs *st) 907 1211 { … … 910 1214 size_t pa_size; 911 1215 912 char *pa = absolutize(path, &pa_size); 913 if (!pa) 914 return ENOMEM; 1216 char *pa = vfs_absolutize(path, &pa_size); 1217 if (pa == NULL) { 1218 errno = ENOMEM; 1219 return -1; 1220 } 915 1221 916 1222 async_exch_t *exch = vfs_exchange_begin(); … … 927 1233 free(pa); 928 1234 async_wait_for(req, &rc_orig); 929 return (int) (rc_orig != EOK ? rc_orig : rc); 1235 rc = (rc_orig != EOK ? rc_orig : rc); 1236 1237 if (rc != EOK) { 1238 errno = rc; 1239 return -1; 1240 } 1241 1242 return 0; 930 1243 } 931 1244
Note:
See TracChangeset
for help on using the changeset viewer.