Changes in uspace/srv/fs/fat/fat_ops.c [a93d79a:19f857a] in mainline
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
uspace/srv/fs/fat/fat_ops.c
ra93d79a r19f857a 60 60 #define FS_NODE(node) ((node) ? (node)->bp : NULL) 61 61 62 #define DPS(bs) (BPS((bs)) / sizeof(fat_dentry_t))63 #define BPC(bs) (BPS((bs)) * SPC((bs)))64 65 62 /** Mutex protecting the list of cached free FAT nodes. */ 66 63 static FIBRIL_MUTEX_INITIALIZE(ffn_mutex); … … 104 101 node->refcnt = 0; 105 102 node->dirty = false; 106 node->lastc_cached_valid = false;107 node->lastc_cached_value = FAT_CLST_LAST1;108 node->currc_cached_valid = false;109 node->currc_cached_bn = 0;110 node->currc_cached_value = FAT_CLST_LAST1;111 103 } 112 104 … … 116 108 fat_bs_t *bs; 117 109 fat_dentry_t *d; 110 uint16_t bps; 111 unsigned dps; 118 112 int rc; 119 113 … … 121 115 122 116 bs = block_bb_get(node->idx->dev_handle); 117 bps = uint16_t_le2host(bs->bps); 118 dps = bps / sizeof(fat_dentry_t); 123 119 124 120 /* Read the block that contains the dentry of interest. */ 125 121 rc = _fat_block_get(&b, bs, node->idx->dev_handle, node->idx->pfc, 126 NULL, (node->idx->pdi * sizeof(fat_dentry_t)) / BPS(bs), 127 BLOCK_FLAGS_NONE); 122 (node->idx->pdi * sizeof(fat_dentry_t)) / bps, BLOCK_FLAGS_NONE); 128 123 if (rc != EOK) 129 124 return rc; 130 125 131 d = ((fat_dentry_t *)b->data) + (node->idx->pdi % DPS(bs));126 d = ((fat_dentry_t *)b->data) + (node->idx->pdi % dps); 132 127 133 128 d->firstc = host2uint16_t_le(node->firstc); … … 271 266 fat_dentry_t *d; 272 267 fat_node_t *nodep = NULL; 268 unsigned bps; 269 unsigned spc; 270 unsigned dps; 273 271 int rc; 274 272 … … 300 298 301 299 bs = block_bb_get(idxp->dev_handle); 300 bps = uint16_t_le2host(bs->bps); 301 spc = bs->spc; 302 dps = bps / sizeof(fat_dentry_t); 302 303 303 304 /* Read the block that contains the dentry of interest. */ 304 rc = _fat_block_get(&b, bs, idxp->dev_handle, idxp->pfc, NULL,305 (idxp->pdi * sizeof(fat_dentry_t)) / BPS(bs), BLOCK_FLAGS_NONE);305 rc = _fat_block_get(&b, bs, idxp->dev_handle, idxp->pfc, 306 (idxp->pdi * sizeof(fat_dentry_t)) / bps, BLOCK_FLAGS_NONE); 306 307 if (rc != EOK) { 307 308 (void) fat_node_put(FS_NODE(nodep)); … … 309 310 } 310 311 311 d = ((fat_dentry_t *)b->data) + (idxp->pdi % DPS(bs));312 d = ((fat_dentry_t *)b->data) + (idxp->pdi % dps); 312 313 if (d->attr & FAT_ATTR_SUBDIR) { 313 314 /* … … 329 330 return rc; 330 331 } 331 nodep->size = BPS(bs) * SPC(bs)* clusters;332 nodep->size = bps * spc * clusters; 332 333 } else { 333 334 nodep->type = FAT_FILE; … … 367 368 char name[FAT_NAME_LEN + 1 + FAT_EXT_LEN + 1]; 368 369 unsigned i, j; 370 unsigned bps; /* bytes per sector */ 371 unsigned dps; /* dentries per sector */ 369 372 unsigned blocks; 370 373 fat_dentry_t *d; 371 dev_handle_t dev_handle;372 374 block_t *b; 373 375 int rc; 374 376 375 377 fibril_mutex_lock(&parentp->idx->lock); 376 dev_handle = parentp->idx->dev_handle; 377 fibril_mutex_unlock(&parentp->idx->lock); 378 379 bs = block_bb_get(dev_handle); 380 blocks = parentp->size / BPS(bs); 378 bs = block_bb_get(parentp->idx->dev_handle); 379 bps = uint16_t_le2host(bs->bps); 380 dps = bps / sizeof(fat_dentry_t); 381 blocks = parentp->size / bps; 381 382 for (i = 0; i < blocks; i++) { 382 383 rc = fat_block_get(&b, bs, parentp, i, BLOCK_FLAGS_NONE); 383 if (rc != EOK) 384 if (rc != EOK) { 385 fibril_mutex_unlock(&parentp->idx->lock); 384 386 return rc; 385 for (j = 0; j < DPS(bs); j++) { 387 } 388 for (j = 0; j < dps; j++) { 386 389 d = ((fat_dentry_t *)b->data) + j; 387 390 switch (fat_classify_dentry(d)) { … … 392 395 /* miss */ 393 396 rc = block_put(b); 397 fibril_mutex_unlock(&parentp->idx->lock); 394 398 *rfn = NULL; 395 399 return rc; … … 402 406 /* hit */ 403 407 fat_node_t *nodep; 404 fat_idx_t *idx = fat_idx_get_by_pos(dev_handle, 405 parentp->firstc, i * DPS(bs) + j); 408 /* 409 * Assume tree hierarchy for locking. We 410 * already have the parent and now we are going 411 * to lock the child. Never lock in the oposite 412 * order. 413 */ 414 fat_idx_t *idx = fat_idx_get_by_pos( 415 parentp->idx->dev_handle, parentp->firstc, 416 i * dps + j); 417 fibril_mutex_unlock(&parentp->idx->lock); 406 418 if (!idx) { 407 419 /* … … 426 438 } 427 439 rc = block_put(b); 428 if (rc != EOK) 440 if (rc != EOK) { 441 fibril_mutex_unlock(&parentp->idx->lock); 429 442 return rc; 430 } 431 443 } 444 } 445 446 fibril_mutex_unlock(&parentp->idx->lock); 432 447 *rfn = NULL; 433 448 return EOK; … … 498 513 fat_bs_t *bs; 499 514 fat_cluster_t mcl, lcl; 515 uint16_t bps; 500 516 int rc; 501 517 502 518 bs = block_bb_get(dev_handle); 519 bps = uint16_t_le2host(bs->bps); 503 520 if (flags & L_DIRECTORY) { 504 521 /* allocate a cluster */ … … 529 546 nodep->type = FAT_DIRECTORY; 530 547 nodep->firstc = mcl; 531 nodep->size = BPS(bs) * SPC(bs);548 nodep->size = bps * bs->spc; 532 549 } else { 533 550 nodep->type = FAT_FILE; … … 592 609 block_t *b; 593 610 unsigned i, j; 611 uint16_t bps; 612 unsigned dps; 594 613 unsigned blocks; 595 614 fat_cluster_t mcl, lcl; … … 621 640 fibril_mutex_lock(&parentp->idx->lock); 622 641 bs = block_bb_get(parentp->idx->dev_handle); 623 624 blocks = parentp->size / BPS(bs); 642 bps = uint16_t_le2host(bs->bps); 643 dps = bps / sizeof(fat_dentry_t); 644 645 blocks = parentp->size / bps; 625 646 626 647 for (i = 0; i < blocks; i++) { … … 630 651 return rc; 631 652 } 632 for (j = 0; j < DPS(bs); j++) {653 for (j = 0; j < dps; j++) { 633 654 d = ((fat_dentry_t *)b->data) + j; 634 655 switch (fat_classify_dentry(d)) { … … 670 691 return rc; 671 692 } 672 rc = fat_append_clusters(bs, parentp, mcl , lcl);693 rc = fat_append_clusters(bs, parentp, mcl); 673 694 if (rc != EOK) { 674 695 (void) fat_free_clusters(bs, parentp->idx->dev_handle, mcl); … … 676 697 return rc; 677 698 } 678 parentp->size += BPS(bs) * SPC(bs);699 parentp->size += bps * bs->spc; 679 700 parentp->dirty = true; /* need to sync node */ 680 701 rc = fat_block_get(&b, bs, parentp, i, BLOCK_FLAGS_NONE); … … 750 771 751 772 childp->idx->pfc = parentp->firstc; 752 childp->idx->pdi = i * DPS(bs)+ j;773 childp->idx->pdi = i * dps + j; 753 774 fibril_mutex_unlock(&childp->idx->lock); 754 775 … … 772 793 fat_bs_t *bs; 773 794 fat_dentry_t *d; 795 uint16_t bps; 774 796 block_t *b; 775 797 bool has_children; … … 790 812 fibril_mutex_lock(&childp->idx->lock); 791 813 bs = block_bb_get(childp->idx->dev_handle); 814 bps = uint16_t_le2host(bs->bps); 792 815 793 816 rc = _fat_block_get(&b, bs, childp->idx->dev_handle, childp->idx->pfc, 794 NULL, (childp->idx->pdi * sizeof(fat_dentry_t)) / BPS(bs),817 (childp->idx->pdi * sizeof(fat_dentry_t)) / bps, 795 818 BLOCK_FLAGS_NONE); 796 819 if (rc != EOK) 797 820 goto error; 798 821 d = (fat_dentry_t *)b->data + 799 (childp->idx->pdi % ( BPS(bs)/ sizeof(fat_dentry_t)));822 (childp->idx->pdi % (bps / sizeof(fat_dentry_t))); 800 823 /* mark the dentry as not-currently-used */ 801 824 d->name[0] = FAT_DENTRY_ERASED; … … 829 852 fat_bs_t *bs; 830 853 fat_node_t *nodep = FAT_NODE(fn); 854 unsigned bps; 855 unsigned dps; 831 856 unsigned blocks; 832 857 block_t *b; … … 841 866 fibril_mutex_lock(&nodep->idx->lock); 842 867 bs = block_bb_get(nodep->idx->dev_handle); 843 844 blocks = nodep->size / BPS(bs); 868 bps = uint16_t_le2host(bs->bps); 869 dps = bps / sizeof(fat_dentry_t); 870 871 blocks = nodep->size / bps; 845 872 846 873 for (i = 0; i < blocks; i++) { … … 852 879 return rc; 853 880 } 854 for (j = 0; j < DPS(bs); j++) {881 for (j = 0; j < dps; j++) { 855 882 d = ((fat_dentry_t *)b->data) + j; 856 883 switch (fat_classify_dentry(d)) { … … 949 976 enum cache_mode cmode; 950 977 fat_bs_t *bs; 978 uint16_t bps; 979 uint16_t rde; 951 980 952 981 /* Accept the mount options */ … … 985 1014 bs = block_bb_get(dev_handle); 986 1015 987 if (BPS(bs) != BS_SIZE) { 1016 /* Read the number of root directory entries. */ 1017 bps = uint16_t_le2host(bs->bps); 1018 rde = uint16_t_le2host(bs->root_ent_max); 1019 1020 if (bps != BS_SIZE) { 988 1021 block_fini(dev_handle); 989 1022 ipc_answer_0(rid, ENOTSUP); … … 992 1025 993 1026 /* Initialize the block cache */ 994 rc = block_cache_init(dev_handle, BPS(bs), 0 /* XXX */, cmode);1027 rc = block_cache_init(dev_handle, bps, 0 /* XXX */, cmode); 995 1028 if (rc != EOK) { 996 1029 block_fini(dev_handle); … … 1054 1087 rootp->refcnt = 1; 1055 1088 rootp->lnkcnt = 0; /* FS root is not linked */ 1056 rootp->size = RDE(bs)* sizeof(fat_dentry_t);1089 rootp->size = rde * sizeof(fat_dentry_t); 1057 1090 rootp->idx = ridxp; 1058 1091 ridxp->nodep = rootp; … … 1132 1165 fat_node_t *nodep; 1133 1166 fat_bs_t *bs; 1167 uint16_t bps; 1134 1168 size_t bytes; 1135 1169 block_t *b; … … 1157 1191 1158 1192 bs = block_bb_get(dev_handle); 1193 bps = uint16_t_le2host(bs->bps); 1159 1194 1160 1195 if (nodep->type == FAT_FILE) { … … 1169 1204 (void) async_data_read_finalize(callid, NULL, 0); 1170 1205 } else { 1171 bytes = min(len, BPS(bs) - pos % BPS(bs));1206 bytes = min(len, bps - pos % bps); 1172 1207 bytes = min(bytes, nodep->size - pos); 1173 rc = fat_block_get(&b, bs, nodep, pos / BPS(bs),1208 rc = fat_block_get(&b, bs, nodep, pos / bps, 1174 1209 BLOCK_FLAGS_NONE); 1175 1210 if (rc != EOK) { … … 1179 1214 return; 1180 1215 } 1181 (void) async_data_read_finalize(callid, 1182 b ->data + pos % BPS(bs), bytes);1216 (void) async_data_read_finalize(callid, b->data + pos % bps, 1217 bytes); 1183 1218 rc = block_put(b); 1184 1219 if (rc != EOK) { … … 1195 1230 1196 1231 assert(nodep->type == FAT_DIRECTORY); 1197 assert(nodep->size % BPS(bs)== 0);1198 assert( BPS(bs)% sizeof(fat_dentry_t) == 0);1232 assert(nodep->size % bps == 0); 1233 assert(bps % sizeof(fat_dentry_t) == 0); 1199 1234 1200 1235 /* … … 1204 1239 * the position pointer accordingly. 1205 1240 */ 1206 bnum = (pos * sizeof(fat_dentry_t)) / BPS(bs);1207 while (bnum < nodep->size / BPS(bs)) {1241 bnum = (pos * sizeof(fat_dentry_t)) / bps; 1242 while (bnum < nodep->size / bps) { 1208 1243 aoff64_t o; 1209 1244 … … 1212 1247 if (rc != EOK) 1213 1248 goto err; 1214 for (o = pos % ( BPS(bs)/ sizeof(fat_dentry_t));1215 o < BPS(bs)/ sizeof(fat_dentry_t);1249 for (o = pos % (bps / sizeof(fat_dentry_t)); 1250 o < bps / sizeof(fat_dentry_t); 1216 1251 o++, pos++) { 1217 1252 d = ((fat_dentry_t *)b->data) + o; … … 1271 1306 size_t bytes, size; 1272 1307 block_t *b; 1308 uint16_t bps; 1309 unsigned spc; 1310 unsigned bpc; /* bytes per cluster */ 1273 1311 aoff64_t boundary; 1274 1312 int flags = BLOCK_FLAGS_NONE; … … 1296 1334 1297 1335 bs = block_bb_get(dev_handle); 1336 bps = uint16_t_le2host(bs->bps); 1337 spc = bs->spc; 1338 bpc = bps * spc; 1298 1339 1299 1340 /* … … 1304 1345 * value signalizing a smaller number of bytes written. 1305 1346 */ 1306 bytes = min(len, BPS(bs) - pos % BPS(bs));1307 if (bytes == BPS(bs))1347 bytes = min(len, bps - pos % bps); 1348 if (bytes == bps) 1308 1349 flags |= BLOCK_FLAGS_NOREAD; 1309 1350 1310 boundary = ROUND_UP(nodep->size, BPC(bs));1351 boundary = ROUND_UP(nodep->size, bpc); 1311 1352 if (pos < boundary) { 1312 1353 /* … … 1323 1364 return; 1324 1365 } 1325 rc = fat_block_get(&b, bs, nodep, pos / BPS(bs), flags);1366 rc = fat_block_get(&b, bs, nodep, pos / bps, flags); 1326 1367 if (rc != EOK) { 1327 1368 (void) fat_node_put(fn); … … 1330 1371 return; 1331 1372 } 1332 (void) async_data_write_finalize(callid, 1333 b ->data + pos % BPS(bs), bytes);1373 (void) async_data_write_finalize(callid, b->data + pos % bps, 1374 bytes); 1334 1375 b->dirty = true; /* need to sync block */ 1335 1376 rc = block_put(b); … … 1355 1396 fat_cluster_t mcl, lcl; 1356 1397 1357 nclsts = (ROUND_UP(pos + bytes, BPC(bs)) - boundary) / BPC(bs);1398 nclsts = (ROUND_UP(pos + bytes, bpc) - boundary) / bpc; 1358 1399 /* create an independent chain of nclsts clusters in all FATs */ 1359 1400 rc = fat_alloc_clusters(bs, dev_handle, nclsts, &mcl, &lcl); … … 1374 1415 return; 1375 1416 } 1376 rc = _fat_block_get(&b, bs, dev_handle, lcl, NULL,1377 (pos / BPS(bs)) % SPC(bs),flags);1417 rc = _fat_block_get(&b, bs, dev_handle, lcl, (pos / bps) % spc, 1418 flags); 1378 1419 if (rc != EOK) { 1379 1420 (void) fat_free_clusters(bs, dev_handle, mcl); … … 1383 1424 return; 1384 1425 } 1385 (void) async_data_write_finalize(callid, 1386 b ->data + pos % BPS(bs), bytes);1426 (void) async_data_write_finalize(callid, b->data + pos % bps, 1427 bytes); 1387 1428 b->dirty = true; /* need to sync block */ 1388 1429 rc = block_put(b); … … 1397 1438 * node's cluster chain. 1398 1439 */ 1399 rc = fat_append_clusters(bs, nodep, mcl , lcl);1440 rc = fat_append_clusters(bs, nodep, mcl); 1400 1441 if (rc != EOK) { 1401 1442 (void) fat_free_clusters(bs, dev_handle, mcl); … … 1421 1462 fat_node_t *nodep; 1422 1463 fat_bs_t *bs; 1464 uint16_t bps; 1465 uint8_t spc; 1466 unsigned bpc; /* bytes per cluster */ 1423 1467 int rc; 1424 1468 … … 1435 1479 1436 1480 bs = block_bb_get(dev_handle); 1481 bps = uint16_t_le2host(bs->bps); 1482 spc = bs->spc; 1483 bpc = bps * spc; 1437 1484 1438 1485 if (nodep->size == size) { … … 1444 1491 */ 1445 1492 rc = EINVAL; 1446 } else if (ROUND_UP(nodep->size, BPC(bs)) == ROUND_UP(size, BPC(bs))) {1493 } else if (ROUND_UP(nodep->size, bpc) == ROUND_UP(size, bpc)) { 1447 1494 /* 1448 1495 * The node will be shrunk, but no clusters will be deallocated. … … 1462 1509 fat_cluster_t lastc; 1463 1510 rc = fat_cluster_walk(bs, dev_handle, nodep->firstc, 1464 &lastc, NULL, (size - 1) / BPC(bs));1511 &lastc, NULL, (size - 1) / bpc); 1465 1512 if (rc != EOK) 1466 1513 goto out; … … 1517 1564 void fat_sync(ipc_callid_t rid, ipc_call_t *request) 1518 1565 { 1519 dev_handle_t dev_handle = (dev_handle_t) IPC_GET_ARG1(*request); 1520 fs_index_t index = (fs_index_t) IPC_GET_ARG2(*request); 1521 1522 fs_node_t *fn; 1523 int rc = fat_node_get(&fn, dev_handle, index); 1524 if (rc != EOK) { 1525 ipc_answer_0(rid, rc); 1526 return; 1527 } 1528 if (!fn) { 1529 ipc_answer_0(rid, ENOENT); 1530 return; 1531 } 1532 1533 fat_node_t *nodep = FAT_NODE(fn); 1534 1535 nodep->dirty = true; 1536 rc = fat_node_sync(nodep); 1537 1538 fat_node_put(fn); 1539 ipc_answer_0(rid, rc); 1566 /* Dummy implementation */ 1567 ipc_answer_0(rid, EOK); 1540 1568 } 1541 1569
Note:
See TracChangeset
for help on using the changeset viewer.