Changeset ed903174 in mainline for uspace/srv/fs/tmpfs/tmpfs_ops.c
- Timestamp:
- 2010-02-10T23:51:23Z (14 years ago)
- Branches:
- lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export
- Children:
- e70edd1
- Parents:
- b32c604f
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/srv/fs/tmpfs/tmpfs_ops.c
rb32c604f red903174 29 29 /** @addtogroup fs 30 30 * @{ 31 */ 31 */ 32 32 33 33 /** … … 40 40 #include "../../vfs/vfs.h" 41 41 #include <ipc/ipc.h> 42 #include <macros.h> 43 #include <limits.h> 42 44 #include <async.h> 43 45 #include <errno.h> … … 93 95 } 94 96 95 static size_t tmpfs_size_get(fs_node_t *fn)97 static aoff64_t tmpfs_size_get(fs_node_t *fn) 96 98 { 97 99 return TMPFS_NODE(fn)->size; … … 509 511 void tmpfs_read(ipc_callid_t rid, ipc_call_t *request) 510 512 { 511 dev_handle_t dev_handle = (dev_handle_t)IPC_GET_ARG1(*request); 512 fs_index_t index = (fs_index_t)IPC_GET_ARG2(*request); 513 off_t pos = (off_t)IPC_GET_ARG3(*request); 514 513 dev_handle_t dev_handle = (dev_handle_t) IPC_GET_ARG1(*request); 514 fs_index_t index = (fs_index_t) IPC_GET_ARG2(*request); 515 aoff64_t pos = 516 (aoff64_t) MERGE_LOUP32(IPC_GET_ARG3(*request), IPC_GET_ARG4(*request)); 517 515 518 /* 516 519 * Lookup the respective TMPFS node. … … 528 531 tmpfs_node_t *nodep = hash_table_get_instance(hlp, tmpfs_node_t, 529 532 nh_link); 530 533 531 534 /* 532 535 * Receive the read request. … … 535 538 size_t size; 536 539 if (!async_data_read_receive(&callid, &size)) { 537 ipc_answer_0(callid, EINVAL); 540 ipc_answer_0(callid, EINVAL); 538 541 ipc_answer_0(rid, EINVAL); 539 542 return; … … 542 545 size_t bytes; 543 546 if (nodep->type == TMPFS_FILE) { 544 bytes = m ax(0, min(nodep->size - pos, size));547 bytes = min(nodep->size - pos, size); 545 548 (void) async_data_read_finalize(callid, nodep->data + pos, 546 549 bytes); … … 548 551 tmpfs_dentry_t *dentryp; 549 552 link_t *lnk; 550 int i;553 aoff64_t i; 551 554 552 555 assert(nodep->type == TMPFS_DIRECTORY); … … 558 561 */ 559 562 for (i = 0, lnk = nodep->cs_head.next; 560 i < pos && lnk != &nodep->cs_head;563 (i < pos) && (lnk != &nodep->cs_head); 561 564 i++, lnk = lnk->next) 562 565 ; … … 583 586 void tmpfs_write(ipc_callid_t rid, ipc_call_t *request) 584 587 { 585 dev_handle_t dev_handle = (dev_handle_t)IPC_GET_ARG1(*request); 586 fs_index_t index = (fs_index_t)IPC_GET_ARG2(*request); 587 off_t pos = (off_t)IPC_GET_ARG3(*request); 588 588 dev_handle_t dev_handle = (dev_handle_t) IPC_GET_ARG1(*request); 589 fs_index_t index = (fs_index_t) IPC_GET_ARG2(*request); 590 aoff64_t pos = 591 (aoff64_t) MERGE_LOUP32(IPC_GET_ARG3(*request), IPC_GET_ARG4(*request)); 592 589 593 /* 590 594 * Lookup the respective TMPFS node. … … 647 651 void tmpfs_truncate(ipc_callid_t rid, ipc_call_t *request) 648 652 { 653 dev_handle_t dev_handle = (dev_handle_t) IPC_GET_ARG1(*request); 654 fs_index_t index = (fs_index_t) IPC_GET_ARG2(*request); 655 aoff64_t size = 656 (aoff64_t) MERGE_LOUP32(IPC_GET_ARG3(*request), IPC_GET_ARG4(*request)); 657 658 /* 659 * Lookup the respective TMPFS node. 660 */ 661 unsigned long key[] = { 662 [NODES_KEY_DEV] = dev_handle, 663 [NODES_KEY_INDEX] = index 664 }; 665 link_t *hlp = hash_table_find(&nodes, key); 666 if (!hlp) { 667 ipc_answer_0(rid, ENOENT); 668 return; 669 } 670 tmpfs_node_t *nodep = hash_table_get_instance(hlp, tmpfs_node_t, 671 nh_link); 672 673 if (size == nodep->size) { 674 ipc_answer_0(rid, EOK); 675 return; 676 } 677 678 if (size > SIZE_MAX) { 679 ipc_answer_0(rid, ENOMEM); 680 return; 681 } 682 683 void *newdata = realloc(nodep->data, size); 684 if (!newdata) { 685 ipc_answer_0(rid, ENOMEM); 686 return; 687 } 688 689 if (size > nodep->size) { 690 size_t delta = size - nodep->size; 691 memset(newdata + nodep->size, 0, delta); 692 } 693 694 nodep->size = size; 695 nodep->data = newdata; 696 ipc_answer_0(rid, EOK); 697 } 698 699 void tmpfs_close(ipc_callid_t rid, ipc_call_t *request) 700 { 701 ipc_answer_0(rid, EOK); 702 } 703 704 void tmpfs_destroy(ipc_callid_t rid, ipc_call_t *request) 705 { 649 706 dev_handle_t dev_handle = (dev_handle_t)IPC_GET_ARG1(*request); 650 707 fs_index_t index = (fs_index_t)IPC_GET_ARG2(*request); 651 size_t size = (off_t)IPC_GET_ARG3(*request); 652 653 /* 654 * Lookup the respective TMPFS node. 655 */ 708 int rc; 709 656 710 link_t *hlp; 657 711 unsigned long key[] = { … … 666 720 tmpfs_node_t *nodep = hash_table_get_instance(hlp, tmpfs_node_t, 667 721 nh_link); 668 669 if (size == nodep->size) {670 ipc_answer_0(rid, EOK);671 return;672 }673 674 void *newdata = realloc(nodep->data, size);675 if (!newdata) {676 ipc_answer_0(rid, ENOMEM);677 return;678 }679 if (size > nodep->size) {680 size_t delta = size - nodep->size;681 memset(newdata + nodep->size, 0, delta);682 }683 nodep->size = size;684 nodep->data = newdata;685 ipc_answer_0(rid, EOK);686 }687 688 void tmpfs_close(ipc_callid_t rid, ipc_call_t *request)689 {690 ipc_answer_0(rid, EOK);691 }692 693 void tmpfs_destroy(ipc_callid_t rid, ipc_call_t *request)694 {695 dev_handle_t dev_handle = (dev_handle_t)IPC_GET_ARG1(*request);696 fs_index_t index = (fs_index_t)IPC_GET_ARG2(*request);697 int rc;698 699 link_t *hlp;700 unsigned long key[] = {701 [NODES_KEY_DEV] = dev_handle,702 [NODES_KEY_INDEX] = index703 };704 hlp = hash_table_find(&nodes, key);705 if (!hlp) {706 ipc_answer_0(rid, ENOENT);707 return;708 }709 tmpfs_node_t *nodep = hash_table_get_instance(hlp, tmpfs_node_t,710 nh_link);711 722 rc = tmpfs_destroy_node(FS_NODE(nodep)); 712 723 ipc_answer_0(rid, rc);
Note:
See TracChangeset
for help on using the changeset viewer.