Changes in uspace/srv/fs/mfs/mfs_ops.c [36cb22f:df3caec5] in mainline
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/srv/fs/mfs/mfs_ops.c
r36cb22f rdf3caec5 43 43 44 44 static bool check_magic_number(uint16_t magic, bool *native, 45 45 mfs_version_t *version, bool *longfilenames); 46 46 static int mfs_node_core_get(fs_node_t **rfn, struct mfs_instance *inst, 47 fs_index_t index); 48 47 fs_index_t index); 49 48 static int mfs_node_put(fs_node_t *fsnode); 50 49 static int mfs_node_open(fs_node_t *fsnode); … … 64 63 static hash_index_t open_nodes_hash(unsigned long key[]); 65 64 static int open_nodes_compare(unsigned long key[], hash_count_t keys, 66 65 link_t *item); 67 66 static void open_nodes_remove_cb(link_t *link); 68 69 67 static int mfs_node_get(fs_node_t **rfn, service_id_t service_id, 70 fs_index_t index); 71 static int 72 mfs_instance_get(service_id_t service_id, struct mfs_instance **instance); 73 68 fs_index_t index); 69 static int mfs_instance_get(service_id_t service_id, 70 struct mfs_instance **instance); 71 static int mfs_check_sanity(struct mfs_sb_info *sbi); 72 static bool is_power_of_two(uint32_t n); 74 73 75 74 static hash_table_t open_nodes; … … 96 95 97 96 /* Hash table interface for open nodes hash table */ 98 static hash_index_t open_nodes_hash(unsigned long key[]) 97 static hash_index_t 98 open_nodes_hash(unsigned long key[]) 99 99 { 100 100 /* TODO: This is very simple and probably can be improved */ … … 102 102 } 103 103 104 static int open_nodes_compare(unsigned long key[], hash_count_t keys, 105 link_t *item) 104 static int 105 open_nodes_compare(unsigned long key[], hash_count_t keys, 106 link_t *item) 106 107 { 107 108 struct mfs_node *mnode = hash_table_get_instance(item, struct mfs_node, link); … … 118 119 } 119 120 120 static void open_nodes_remove_cb(link_t *link) 121 static void 122 open_nodes_remove_cb(link_t *link) 121 123 { 122 124 /* We don't use remove callback for this hash table */ … … 129 131 }; 130 132 131 int mfs_global_init(void) 133 int 134 mfs_global_init(void) 132 135 { 133 136 if (!hash_table_create(&open_nodes, OPEN_NODES_BUCKETS, 134 137 OPEN_NODES_KEYS, &open_nodes_ops)) { 135 138 return ENOMEM; 136 139 } … … 140 143 static int 141 144 mfs_mounted(service_id_t service_id, const char *opts, fs_index_t *index, 142 145 aoff64_t *size, unsigned *linkcnt) 143 146 { 144 147 enum cache_mode cmode; … … 163 166 return rc; 164 167 165 /* Allocate space for generic MFS superblock*/168 /* Allocate space for generic MFS superblock */ 166 169 sbi = malloc(sizeof(*sbi)); 167 170 if (!sbi) { … … 170 173 } 171 174 172 /* Allocate space for filesystem instance*/175 /* Allocate space for filesystem instance */ 173 176 instance = malloc(sizeof(*instance)); 174 177 if (!instance) { … … 191 194 192 195 if (check_magic_number(sb->s_magic, &native, &version, &longnames)) { 193 /* This is a V1 or V2 Minix filesystem*/196 /* This is a V1 or V2 Minix filesystem */ 194 197 magic = sb->s_magic; 195 198 } else if (check_magic_number(sb3->s_magic, &native, &version, &longnames)) { 196 /* This is a V3 Minix filesystem*/199 /* This is a V3 Minix filesystem */ 197 200 magic = sb3->s_magic; 198 201 } else { 199 /* Not recognized*/202 /* Not recognized */ 200 203 mfsdebug("magic number not recognized\n"); 201 204 rc = ENOTSUP; … … 205 208 mfsdebug("magic number recognized = %04x\n", magic); 206 209 207 /* Fill superblock info structure*/210 /* Fill superblock info structure */ 208 211 209 212 sbi->fs_version = version; … … 243 246 sbi->dirsize = longnames ? MFSL_DIRSIZE : MFS_DIRSIZE; 244 247 sbi->max_name_len = longnames ? MFS_L_MAX_NAME_LEN : 245 248 MFS_MAX_NAME_LEN; 246 249 } 247 250 … … 259 262 260 263 sbi->itable_off = 2 + sbi->ibmap_blocks + sbi->zbmap_blocks; 264 if ((rc = mfs_check_sanity(sbi)) != EOK) { 265 fprintf(stderr, "Filesystem corrupted, invalid superblock"); 266 goto out_error; 267 } 261 268 262 269 rc = block_cache_init(service_id, sbi->block_size, 0, cmode); … … 267 274 } 268 275 269 /* Initialize the instance structure and remember it*/276 /* Initialize the instance structure and remember it */ 270 277 instance->service_id = service_id; 271 278 instance->sbi = sbi; … … 273 280 rc = fs_instance_create(service_id, instance); 274 281 if (rc != EOK) { 275 free(instance);276 free(sbi);277 282 block_cache_fini(service_id); 278 block_fini(service_id);279 283 mfsdebug("fs instance creation failed\n"); 280 return rc;284 goto out_error; 281 285 } 282 286 … … 331 335 } 332 336 333 service_id_t mfs_service_get(fs_node_t *fsnode) 337 service_id_t 338 mfs_service_get(fs_node_t *fsnode) 334 339 { 335 340 struct mfs_node *node = fsnode->data; … … 337 342 } 338 343 339 static int mfs_create_node(fs_node_t **rfn, service_id_t service_id, int flags) 344 static int 345 mfs_create_node(fs_node_t **rfn, service_id_t service_id, int flags) 340 346 { 341 347 int r; … … 351 357 return r; 352 358 353 /* Alloc a new inode*/359 /* Alloc a new inode */ 354 360 r = mfs_alloc_inode(inst, &inum); 355 361 if (r != EOK) … … 378 384 if (flags & L_DIRECTORY) { 379 385 ino_i->i_mode = S_IFDIR; 380 ino_i->i_nlinks = 2; /* This accounts for the '.' dentry*/386 ino_i->i_nlinks = 2; /* This accounts for the '.' dentry */ 381 387 } else { 382 388 ino_i->i_mode = S_IFREG; … … 431 437 } 432 438 433 static int mfs_match(fs_node_t **rfn, fs_node_t *pfn, const char *component) 439 static int 440 mfs_match(fs_node_t **rfn, fs_node_t *pfn, const char *component) 434 441 { 435 442 struct mfs_node *mnode = pfn->data; … … 453 460 454 461 if (!d_info.d_inum) { 455 /* This entry is not used*/462 /* This entry is not used */ 456 463 continue; 457 464 } … … 460 467 461 468 if (comp_size == dentry_name_size && 462 463 /* Hit!*/469 !bcmp(component, d_info.d_name, dentry_name_size)) { 470 /* Hit! */ 464 471 mfs_node_core_get(rfn, mnode->instance, 465 472 d_info.d_inum); 466 473 goto found; 467 474 } … … 472 479 } 473 480 474 static aoff64_t mfs_size_get(fs_node_t *node) 481 static aoff64_t 482 mfs_size_get(fs_node_t *node) 475 483 { 476 484 const struct mfs_node *mnode = node->data; … … 480 488 static int 481 489 mfs_node_get(fs_node_t **rfn, service_id_t service_id, 482 490 fs_index_t index) 483 491 { 484 492 int rc; … … 524 532 } 525 533 526 static int mfs_node_open(fs_node_t *fsnode) 534 static int 535 mfs_node_open(fs_node_t *fsnode) 527 536 { 528 537 /* … … 533 542 } 534 543 535 static fs_index_t mfs_index_get(fs_node_t *fsnode) 544 static fs_index_t 545 mfs_index_get(fs_node_t *fsnode) 536 546 { 537 547 struct mfs_node *mnode = fsnode->data; … … 539 549 } 540 550 541 static unsigned mfs_lnkcnt_get(fs_node_t *fsnode) 551 static unsigned 552 mfs_lnkcnt_get(fs_node_t *fsnode) 542 553 { 543 554 struct mfs_node *mnode = fsnode->data; … … 554 565 } 555 566 556 static int mfs_node_core_get(fs_node_t **rfn, struct mfs_instance *inst, 557 fs_index_t index) 567 static int 568 mfs_node_core_get(fs_node_t **rfn, struct mfs_instance *inst, 569 fs_index_t index) 558 570 { 559 571 fs_node_t *node = NULL; … … 627 639 } 628 640 629 static bool mfs_is_directory(fs_node_t *fsnode) 641 static bool 642 mfs_is_directory(fs_node_t *fsnode) 630 643 { 631 644 const struct mfs_node *node = fsnode->data; … … 633 646 } 634 647 635 static bool mfs_is_file(fs_node_t *fsnode) 648 static bool 649 mfs_is_file(fs_node_t *fsnode) 636 650 { 637 651 struct mfs_node *node = fsnode->data; … … 639 653 } 640 654 641 static int mfs_root_get(fs_node_t **rfn, service_id_t service_id) 655 static int 656 mfs_root_get(fs_node_t **rfn, service_id_t service_id) 642 657 { 643 658 int rc = mfs_node_get(rfn, service_id, MFS_ROOT_INO); … … 645 660 } 646 661 647 static int mfs_link(fs_node_t *pfn, fs_node_t *cfn, const char *name) 662 static int 663 mfs_link(fs_node_t *pfn, fs_node_t *cfn, const char *name) 648 664 { 649 665 struct mfs_node *parent = pfn->data; … … 720 736 } 721 737 722 static int mfs_has_children(bool *has_children, fs_node_t *fsnode) 738 static int 739 mfs_has_children(bool *has_children, fs_node_t *fsnode) 723 740 { 724 741 struct mfs_node *mnode = fsnode->data; … … 741 758 742 759 if (d_info.d_inum) { 743 /* A valid entry has been found*/760 /* A valid entry has been found */ 744 761 *has_children = true; 745 762 break; … … 753 770 static int 754 771 mfs_read(service_id_t service_id, fs_index_t index, aoff64_t pos, 755 772 size_t *rbytes) 756 773 { 757 774 int rc; … … 783 800 784 801 if (pos < 2) { 785 /* Skip the first two dentries ('.' and '..')*/802 /* Skip the first two dentries ('.' and '..') */ 786 803 pos = 2; 787 804 } … … 793 810 794 811 if (d_info.d_inum) { 795 /* Dentry found!*/812 /* Dentry found! */ 796 813 goto found; 797 814 } … … 809 826 810 827 if (pos >= (size_t) ino_i->i_size) { 811 /* Trying to read beyond the end of file*/828 /* Trying to read beyond the end of file */ 812 829 bytes = 0; 813 830 (void) async_data_read_finalize(callid, NULL, 0); … … 826 843 827 844 if (zone == 0) { 828 /* sparse file*/845 /* sparse file */ 829 846 uint8_t *buf = malloc(sbi->block_size); 830 847 if (!buf) { … … 834 851 memset(buf, 0, sizeof(sbi->block_size)); 835 852 async_data_read_finalize(callid, 836 853 buf + pos % sbi->block_size, bytes); 837 854 free(buf); 838 855 goto out_success; … … 844 861 845 862 async_data_read_finalize(callid, b->data + 846 863 pos % sbi->block_size, bytes); 847 864 848 865 rc = block_put(b); … … 865 882 static int 866 883 mfs_write(service_id_t service_id, fs_index_t index, aoff64_t pos, 867 884 size_t *wbytes, aoff64_t *nsize) 868 885 { 869 886 fs_node_t *fn; … … 900 917 901 918 if (block == 0) { 902 /*Writing in a sparse block*/903 919 uint32_t dummy; 904 920 … … 958 974 return ENOENT; 959 975 960 /* Destroy the inode*/976 /* Destroy the inode */ 961 977 return mfs_destroy_node(fn); 962 978 } … … 977 993 assert(!has_children); 978 994 979 /* Free the entire inode content*/995 /* Free the entire inode content */ 980 996 r = mfs_inode_shrink(mnode, mnode->ino_i->i_size); 981 997 if (r != EOK) 982 998 goto out; 983 999 984 /* Mark the inode as free in the bitmap*/1000 /* Mark the inode as free in the bitmap */ 985 1001 r = mfs_free_inode(mnode->instance, mnode->ino_i->index); 986 1002 … … 1021 1037 1022 1038 rc = fs_instance_get(service_id, &data); 1023 if (rc == EOK) {1039 if (rc == EOK) 1024 1040 *instance = (struct mfs_instance *) data; 1025 }else {1041 else { 1026 1042 mfsdebug("instance not found\n"); 1027 1043 } … … 1030 1046 } 1031 1047 1032 static bool check_magic_number(uint16_t magic, bool *native, 1033 mfs_version_t *version, bool *longfilenames) 1048 static bool 1049 check_magic_number(uint16_t magic, bool *native, 1050 mfs_version_t *version, bool *longfilenames) 1034 1051 { 1035 1052 bool rc = true; … … 1059 1076 } 1060 1077 1078 /** Filesystem sanity check 1079 * 1080 * @param Pointer to the MFS superblock. 1081 * 1082 * @return EOK on success, ENOTSUP otherwise. 1083 */ 1084 static int 1085 mfs_check_sanity(struct mfs_sb_info *sbi) 1086 { 1087 if (!is_power_of_two(sbi->block_size) || 1088 sbi->block_size < MFS_MIN_BLOCKSIZE || 1089 sbi->block_size > MFS_MAX_BLOCKSIZE) 1090 return ENOTSUP; 1091 else if (sbi->ibmap_blocks == 0 || sbi->zbmap_blocks == 0) 1092 return ENOTSUP; 1093 else if (sbi->ninodes == 0 || sbi->nzones == 0) 1094 return ENOTSUP; 1095 else if (sbi->firstdatazone == 0) 1096 return ENOTSUP; 1097 1098 return EOK; 1099 } 1100 1061 1101 static int 1062 1102 mfs_close(service_id_t service_id, fs_index_t index) … … 1079 1119 1080 1120 return mfs_node_put(fn); 1121 } 1122 1123 /** Check if a given number is a power of two. 1124 * 1125 * @param n The number to check. 1126 * 1127 * @return true if it is a power of two, false otherwise. 1128 */ 1129 static bool 1130 is_power_of_two(uint32_t n) 1131 { 1132 if (n == 0) 1133 return false; 1134 1135 return (n & (n - 1)) == 0; 1081 1136 } 1082 1137
Note:
See TracChangeset
for help on using the changeset viewer.