Lines Matching refs:td
739 struct dm_thin_device *td, *tmp; in __write_changed_details() local
743 list_for_each_entry_safe(td, tmp, &pmd->thin_devices, list) { in __write_changed_details()
744 if (!td->changed) in __write_changed_details()
747 key = td->id; in __write_changed_details()
749 details.mapped_blocks = cpu_to_le64(td->mapped_blocks); in __write_changed_details()
750 details.transaction_id = cpu_to_le64(td->transaction_id); in __write_changed_details()
751 details.creation_time = cpu_to_le32(td->creation_time); in __write_changed_details()
752 details.snapshotted_time = cpu_to_le32(td->snapshotted_time); in __write_changed_details()
760 if (td->open_count) in __write_changed_details()
761 td->changed = 0; in __write_changed_details()
763 list_del(&td->list); in __write_changed_details()
764 kfree(td); in __write_changed_details()
864 struct dm_thin_device *td, *tmp; in dm_pool_metadata_close() local
867 list_for_each_entry_safe(td, tmp, &pmd->thin_devices, list) { in dm_pool_metadata_close()
868 if (td->open_count) in dm_pool_metadata_close()
871 list_del(&td->list); in dm_pool_metadata_close()
872 kfree(td); in dm_pool_metadata_close()
904 struct dm_thin_device **td) in __open_device() argument
923 *td = td2; in __open_device()
946 *td = kmalloc(sizeof(**td), GFP_NOIO); in __open_device()
947 if (!*td) in __open_device()
950 (*td)->pmd = pmd; in __open_device()
951 (*td)->id = dev; in __open_device()
952 (*td)->open_count = 1; in __open_device()
953 (*td)->changed = changed; in __open_device()
954 (*td)->aborted_with_changes = false; in __open_device()
955 (*td)->mapped_blocks = le64_to_cpu(details_le.mapped_blocks); in __open_device()
956 (*td)->transaction_id = le64_to_cpu(details_le.transaction_id); in __open_device()
957 (*td)->creation_time = le32_to_cpu(details_le.creation_time); in __open_device()
958 (*td)->snapshotted_time = le32_to_cpu(details_le.snapshotted_time); in __open_device()
960 list_add(&(*td)->list, &pmd->thin_devices); in __open_device()
965 static void __close_device(struct dm_thin_device *td) in __close_device() argument
967 --td->open_count; in __close_device()
977 struct dm_thin_device *td; in __create_thin() local
1003 r = __open_device(pmd, dev, 1, &td); in __create_thin()
1009 __close_device(td); in __create_thin()
1031 struct dm_thin_device *td; in __set_snapshot_details() local
1033 r = __open_device(pmd, origin, 0, &td); in __set_snapshot_details()
1037 td->changed = 1; in __set_snapshot_details()
1038 td->snapshotted_time = time; in __set_snapshot_details()
1040 snap->mapped_blocks = td->mapped_blocks; in __set_snapshot_details()
1042 __close_device(td); in __set_snapshot_details()
1053 struct dm_thin_device *td; in __create_snap() local
1084 r = __open_device(pmd, dev, 1, &td); in __create_snap()
1088 r = __set_snapshot_details(pmd, td, origin, pmd->time); in __create_snap()
1089 __close_device(td); in __create_snap()
1121 struct dm_thin_device *td; in __delete_device() local
1124 r = __open_device(pmd, dev, 0, &td); in __delete_device()
1128 if (td->open_count > 1) { in __delete_device()
1129 __close_device(td); in __delete_device()
1133 list_del(&td->list); in __delete_device()
1134 kfree(td); in __delete_device()
1349 struct dm_thin_device **td) in dm_pool_open_thin_device() argument
1355 r = __open_device(pmd, dev, 0, td); in dm_pool_open_thin_device()
1361 int dm_pool_close_thin_device(struct dm_thin_device *td) in dm_pool_close_thin_device() argument
1363 down_write(&td->pmd->root_lock); in dm_pool_close_thin_device()
1364 __close_device(td); in dm_pool_close_thin_device()
1365 up_write(&td->pmd->root_lock); in dm_pool_close_thin_device()
1370 dm_thin_id dm_thin_dev_id(struct dm_thin_device *td) in dm_thin_dev_id() argument
1372 return td->id; in dm_thin_dev_id()
1381 static bool __snapshotted_since(struct dm_thin_device *td, uint32_t time) in __snapshotted_since() argument
1383 return td->snapshotted_time > time; in __snapshotted_since()
1386 int dm_thin_find_block(struct dm_thin_device *td, dm_block_t block, in dm_thin_find_block() argument
1391 struct dm_pool_metadata *pmd = td->pmd; in dm_thin_find_block()
1392 dm_block_t keys[2] = { td->id, block }; in dm_thin_find_block()
1415 result->shared = __snapshotted_since(td, exception_time); in dm_thin_find_block()
1422 static int __insert(struct dm_thin_device *td, dm_block_t block, in __insert() argument
1427 struct dm_pool_metadata *pmd = td->pmd; in __insert()
1428 dm_block_t keys[2] = { td->id, block }; in __insert()
1438 td->changed = 1; in __insert()
1440 td->mapped_blocks++; in __insert()
1445 int dm_thin_insert_block(struct dm_thin_device *td, dm_block_t block, in dm_thin_insert_block() argument
1450 down_write(&td->pmd->root_lock); in dm_thin_insert_block()
1451 if (!td->pmd->fail_io) in dm_thin_insert_block()
1452 r = __insert(td, block, data_block); in dm_thin_insert_block()
1453 up_write(&td->pmd->root_lock); in dm_thin_insert_block()
1458 static int __remove(struct dm_thin_device *td, dm_block_t block) in __remove() argument
1461 struct dm_pool_metadata *pmd = td->pmd; in __remove()
1462 dm_block_t keys[2] = { td->id, block }; in __remove()
1468 td->mapped_blocks--; in __remove()
1469 td->changed = 1; in __remove()
1474 int dm_thin_remove_block(struct dm_thin_device *td, dm_block_t block) in dm_thin_remove_block() argument
1478 down_write(&td->pmd->root_lock); in dm_thin_remove_block()
1479 if (!td->pmd->fail_io) in dm_thin_remove_block()
1480 r = __remove(td, block); in dm_thin_remove_block()
1481 up_write(&td->pmd->root_lock); in dm_thin_remove_block()
1500 bool dm_thin_changed_this_transaction(struct dm_thin_device *td) in dm_thin_changed_this_transaction() argument
1504 down_read(&td->pmd->root_lock); in dm_thin_changed_this_transaction()
1505 r = td->changed; in dm_thin_changed_this_transaction()
1506 up_read(&td->pmd->root_lock); in dm_thin_changed_this_transaction()
1514 struct dm_thin_device *td, *tmp; in dm_pool_changed_this_transaction() local
1517 list_for_each_entry_safe(td, tmp, &pmd->thin_devices, list) { in dm_pool_changed_this_transaction()
1518 if (td->changed) { in dm_pool_changed_this_transaction()
1519 r = td->changed; in dm_pool_changed_this_transaction()
1528 bool dm_thin_aborted_changes(struct dm_thin_device *td) in dm_thin_aborted_changes() argument
1532 down_read(&td->pmd->root_lock); in dm_thin_aborted_changes()
1533 r = td->aborted_with_changes; in dm_thin_aborted_changes()
1534 up_read(&td->pmd->root_lock); in dm_thin_aborted_changes()
1574 struct dm_thin_device *td; in __set_abort_with_changes_flags() local
1576 list_for_each_entry(td, &pmd->thin_devices, list) in __set_abort_with_changes_flags()
1577 td->aborted_with_changes = td->changed; in __set_abort_with_changes_flags()
1650 int dm_thin_get_mapped_count(struct dm_thin_device *td, dm_block_t *result) in dm_thin_get_mapped_count() argument
1653 struct dm_pool_metadata *pmd = td->pmd; in dm_thin_get_mapped_count()
1657 *result = td->mapped_blocks; in dm_thin_get_mapped_count()
1665 static int __highest_block(struct dm_thin_device *td, dm_block_t *result) in __highest_block() argument
1670 struct dm_pool_metadata *pmd = td->pmd; in __highest_block()
1672 r = dm_btree_lookup(&pmd->tl_info, pmd->root, &td->id, &value_le); in __highest_block()
1681 int dm_thin_get_highest_mapped_block(struct dm_thin_device *td, in dm_thin_get_highest_mapped_block() argument
1685 struct dm_pool_metadata *pmd = td->pmd; in dm_thin_get_highest_mapped_block()
1689 r = __highest_block(td, result); in dm_thin_get_highest_mapped_block()