30 #include "transaction.h"
54                              struct transaction* tr,
62  * @tr:         Transaction object.
68 static data_block_t path_hash(struct transaction* tr, const char* path) {  in path_hash()
81  * @tr:         Transaction object.
88 void file_block_map_init(struct transaction* tr,  in file_block_map_init()
110         pr_warn("can't read file entry at %" PRIu64 ", transaction failed\n",  in file_block_map_init()
121  * @tr:         Transaction object.
124 void file_print(struct transaction* tr,  in file_print()
148  * @tr:         Transaction object.
150 void files_print(struct transaction* tr) {  in files_print()
167  * @tr:         Transaction object.
173 bool file_check(struct transaction* tr,  in file_check()
185  * @tr:         Transaction object.
190 static void file_block_map_update(struct transaction* tr,  in file_block_map_update()
206         pr_warn("transaction failed, abort\n");  in file_block_map_update()
215         pr_warn("transaction failed, abort\n");  in file_block_map_update()
225             pr_warn("transaction failed, abort\n");  in file_block_map_update()
240                 pr_warn("transaction failed, abort\n");  in file_block_map_update()
248                 pr_warn("transaction failed, abort\n");  in file_block_map_update()
268                 pr_warn("transaction failed, abort\n");  in file_block_map_update()
282             pr_warn("transaction failed, abort\n");  in file_block_map_update()
319             pr_warn("transaction failed, abort\n");  in file_block_map_update()
331      * Move to head of list so opening the same file twice in a transaction  in file_block_map_update()
361  * @tr:         Transaction object.
371 static const void* file_get_block_etc(struct transaction* tr,  in file_get_block_etc()
386         pr_warn("transaction failed, ignore\n");  in file_get_block_etc()
392         pr_warn("transaction failed, abort\n");  in file_get_block_etc()
413             pr_warn("transaction failed, abort\n");  in file_get_block_etc()
434             pr_warn("transaction failed, abort\n");  in file_get_block_etc()
442             pr_warn("transaction failed, abort\n");  in file_get_block_etc()
465  * @tr:         Transaction object.
473 const void* file_get_block(struct transaction* tr,  in file_get_block()
482  * @tr:         Transaction object.
490 void* file_get_block_write(struct transaction* tr,  in file_get_block_write()
509  * @tr:         Transaction
518 void file_block_put_dirty(struct transaction* tr,  in file_block_put_dirty()
535  * @tr:         Transaction object.
542 const struct file_info* file_get_info(struct transaction* tr,  in file_get_info()
550         pr_warn("transaction failed, abort\n");  in file_get_info()
572  * @tr:         Transaction
579 bool file_get_size(struct transaction* tr,  in file_get_size()
583         pr_warn("transaction failed, ignore\n");  in file_get_size()
600  * @tr:         Transaction
607 void file_set_size(struct transaction* tr,  in file_set_size()
615         pr_warn("transaction failed, ignore\n");  in file_set_size()
621         pr_warn("transaction failed, abort\n");  in file_set_size()
638  * @tr:             Transaction object.
647                              struct transaction* tr,  in file_tree_lookup()
682             pr_warn("transaction failed, abort\n");  in file_tree_lookup()
689             pr_warn("transaction failed, abort\n");  in file_tree_lookup()
724  * @tr:             Transaction object.
733                         struct transaction* tr,  in file_create()
748         pr_warn("transaction failed, abort\n");  in file_create()
761         pr_warn("transaction failed, abort\n");  in file_create()
766         pr_warn("transaction failed, abort\n");  in file_create()
776  * file_is_removed - Helper function to check if transaction deletes file
777  * @tr:         Transaction object.
782 static bool file_is_removed(struct transaction* tr, data_block_t block) {  in file_is_removed()
791  * file_check_updated - Helper function to check if transaction updated file
792  * @tr:                     Transaction object.
799 static bool file_check_updated(struct transaction* tr,  in file_check_updated()
808                 ", already updated in this transaction, use new copy %" PRIu64  in file_check_updated()
824  * @tr:                         Transaction object.
835                                     struct transaction* tr,  in file_lookup_not_removed()
859                 ", already updated in this transaction, use new copy %" PRIu64  in file_lookup_not_removed()
870      * will cause this transaction to fail. Currently conflicts are only  in file_lookup_not_removed()
871      * detected after each transaction writes to the file.  in file_lookup_not_removed()
879  * file_find_open - Check if transaction has file open and return it
880  * @tr:         Transaction object.
886         struct transaction* tr,  in file_find_open()
902  * @tr:         Transaction object.
913 enum file_op_result file_iterate(struct transaction* tr,  in file_iterate()
972  * @tr:         Transaction object.
985 enum file_op_result file_open(struct transaction* tr,  in file_open()
1046         pr_warn("transaction failed, abort\n");  in file_open()
1073  * @tr:         Transaction object.
1082 enum file_op_result file_delete(struct transaction* tr,  in file_delete()
1122         pr_warn("transaction failed, abort\n");  in file_delete()
1140                 pr_warn("transaction failed, abort\n");  in file_delete()
1162  * @tr:             Transaction object.
1176 enum file_op_result file_move(struct transaction* tr,  in file_move()
1201         pr_warn("transaction failed, abort\n");  in file_move()
1220         pr_warn("transaction failed, abort\n");  in file_move()
1225         pr_warn("transaction failed, abort\n");  in file_move()
1232  * file_for_each_open - Call function for every open file in every transaction
1233  * @tr:         Transaction object.
1236 static void file_for_each_open(struct transaction* tr,  in file_for_each_open()
1237                                void (*func)(struct transaction* tr,  in file_for_each_open()
1238                                             struct transaction* file_tr,  in file_for_each_open()
1240     struct transaction* tmp_tr;  in file_for_each_open()
1241     struct transaction* other_tr;  in file_for_each_open()
1245                               struct transaction, node) {  in file_for_each_open()
1255  * @tr:         Current transaction.
1256  * @file_tr:    Transaction that @file was found in.
1259 static void file_restore_to_commit(struct transaction* tr,  in file_restore_to_commit()
1260                                    struct transaction* file_tr,  in file_restore_to_commit()
1279  * @tr:         Current transaction.
1280  * @file_tr:    Transaction that @file was found in.
1286 static void file_apply_to_commit(struct transaction* tr,  in file_apply_to_commit()
1287                                  struct transaction* file_tr,  in file_apply_to_commit()
1333  * @tr:                     Transaction object.
1337 void file_transaction_complete_failed(struct transaction* tr) {  in file_transaction_complete_failed()
1343  * @tr:                 Current transaction object.
1344  * @other_tr:           Transaction object to find files in.
1352 static void file_update_block_mac_tr(struct transaction* tr,  in file_update_block_mac_tr()
1353                                      struct transaction* other_tr,  in file_update_block_mac_tr()
1389  * @tr:                 Transaction object.
1398 static void file_update_block_mac_all(struct transaction* tr,  in file_update_block_mac_all()
1403     struct transaction* tmp_tr;  in file_update_block_mac_all()
1404     struct transaction* other_tr;  in file_update_block_mac_all()
1407                               struct transaction, node) {  in file_update_block_mac_all()
1415  * @tr:                     Transaction object.
1420  * @tr->fs->files if the transaction succeeds.
1422 void file_transaction_complete(struct transaction* tr,  in file_transaction_complete()
1446             pr_warn("transaction failed, abort\n");  in file_transaction_complete()
1464             pr_warn("transaction failed, abort\n");  in file_transaction_complete()
1471             pr_warn("transaction failed, abort\n");  in file_transaction_complete()
1489             pr_warn("transaction failed, abort\n");  in file_transaction_complete()
1504             pr_warn("transaction failed, abort\n");  in file_transaction_complete()
1522             pr_warn("transaction failed, abort\n");  in file_transaction_complete()
1547             pr_warn("transaction failed, abort\n");  in file_transaction_complete()
1553             pr_warn("transaction failed, abort\n");  in file_transaction_complete()
1563  * transaction_changed_file - Check if file was modified by current transaction
1564  * @tr:         Transaction object.
1569 static bool transaction_changed_file(struct transaction* tr,  in transaction_changed_file()
1576  * file_transaction_success - Update all file handles modified by transaction
1577  * @tr:         Transaction object.
1579 void file_transaction_success(struct transaction* tr) {  in file_transaction_success()
1585  * @tr:         Transaction object.
1591 static bool file_read_size(struct transaction* tr,  in file_read_size()
1612  * file_transaction_failed - Restore file handles after failed transaction
1613  * @tr:         Transaction object.
1618 void file_transaction_failed(struct transaction* tr) {  in file_transaction_failed()
1641  * @tr:             Transaction object
1651 static void file_rebuild_free_set(struct transaction* tr,  in file_rebuild_free_set()
1683  * @tr:             Transaction object
1693 void files_rebuild_free_set(struct transaction* tr,  in files_rebuild_free_set()