subversion/libsvn_fs_fs/transaction.c

60               const svn_fs_fs__id_part_t *txn_id,
68   return svn_dirent_join(svn_fs_fs__path_txn_dir(fs, txn_id, pool),
75                  const svn_fs_fs__id_part_t *txn_id,
78   return svn_dirent_join(svn_fs_fs__path_txn_dir(fs, txn_id, pool),
84                const svn_fs_fs__id_part_t *txn_id,
87   return svn_dirent_join(svn_fs_fs__path_txn_dir(fs, txn_id, pool),
93                   const svn_fs_fs__id_part_t *txn_id,
96   return svn_dirent_join(svn_fs_fs__path_txn_dir(fs, txn_id, pool),
117   svn_fs_fs__id_part_t txn_id;
124   return &ftd->txn_id;
136                const svn_fs_fs__id_part_t *txn_id,
144     if (svn_fs_fs__id_part_eq(&txn->txn_id, txn_id))
164   txn->txn_id = *txn_id;
182 free_shared_txn(svn_fs_t *fs, const svn_fs_fs__id_part_t *txn_id)
189     if (svn_fs_fs__id_part_eq(&txn->txn_id, txn_id))
235   svn_fs_fs__id_part_t txn_id;
245   fs_fs_shared_txn_data_t *txn = get_shared_txn(fs, &b->txn_id, FALSE);
251                              svn_fs_fs__id_txn_unparse(&b->txn_id, pool));
255                              svn_fs_fs__id_txn_unparse(&b->txn_id, pool));
262        svn_fs_fs__id_txn_unparse(&b->txn_id, pool));
268        svn_fs_fs__id_txn_unparse(&b->txn_id, pool));
282                  const svn_fs_fs__id_part_t *txn_id,
288   b.txn_id = *txn_id;
298   svn_fs_fs__id_part_t txn_id;
307   fs_fs_shared_txn_data_t *txn = get_shared_txn(fs, &b->txn_id, TRUE);
317                              svn_fs_fs__id_txn_unparse(&b->txn_id, pool));
330       = svn_fs_fs__path_txn_proto_rev_lock(fs, &b->txn_id, pool);
354                                    svn_fs_fs__id_txn_unparse(&b->txn_id,
382                         const svn_fs_fs__id_part_t *txn_id,
391       const char *path = svn_fs_fs__path_p2l_proto_index(fs, txn_id, pool);
410                                    svn_fs_fs__id_txn_unparse(txn_id, pool));
430                        const svn_fs_fs__id_part_t *txn_id,
438   b.txn_id = *txn_id;
444                          svn_fs_fs__path_txn_proto_rev(fs, txn_id, pool),
464     err = auto_truncate_proto_rev(fs, *file, end_offset, txn_id, pool);
470               unlock_proto_rev(fs, txn_id, *lockcookie, pool));
482   const svn_fs_fs__id_part_t *txn_id = baton;
484   free_shared_txn(fs, txn_id);
494                  const svn_fs_fs__id_part_t *txn_id,
497   return with_txnlist_lock(fs, purge_shared_txn_body, txn_id, pool);
554                                             &noderev->data_rep->txn_id,
901                              const svn_fs_fs__id_part_t *txn_id,
913                            path_txn_changes(fs, txn_id, scratch_pool),
976                                 const svn_fs_fs__id_part_t *txn_id,
998   noderev->id = svn_fs_fs__id_txn_create(node_id, copy_id, txn_id, pool);
1048                svn_fs_fs__id_part_t *txn_id,
1066   txn_id->revision = rev;
1067   txn_id->number = cb.txn_number;
1069   *id_p = svn_fs_fs__id_txn_unparse(txn_id, pool);
1070   txn_dir = svn_fs_fs__path_txn_dir(fs, txn_id, pool);
1083                        svn_fs_fs__id_part_t *txn_id,
1110           SVN_ERR(svn_fs_fs__id_txn_parse(txn_id, *id_p));
1141   /* Get the txn_id. */
1143     SVN_ERR(create_txn_dir(&txn->id, &ftd->txn_id, fs, rev, pool));
1145     SVN_ERR(create_txn_dir_pre_1_5(&txn->id, &ftd->txn_id, fs, rev, pool));
1156   SVN_ERR(create_new_txn_noderev_from_rev(fs, &ftd->txn_id, root_id, pool));
1160                     svn_fs_fs__path_txn_proto_rev(fs, &ftd->txn_id, pool),
1165                svn_fs_fs__path_txn_proto_rev_lock(fs, &ftd->txn_id, pool),
1169   SVN_ERR(svn_io_file_create_empty(path_txn_changes(fs, &ftd->txn_id, pool),
1173   return svn_io_file_create(path_txn_next_ids(fs, &ftd->txn_id, pool),
1182                  const svn_fs_fs__id_part_t *txn_id,
1190   if (!txn_id || !svn_fs_fs__id_txn_used(txn_id))
1196   SVN_ERR(svn_stream_open_readonly(&stream, path_txn_props(fs, txn_id, pool),
1206                path_txn_props(fs, txn_id, pool));
1216                  const svn_fs_fs__id_part_t *txn_id,
1222   const char *final_path = path_txn_props(fs, txn_id, pool);
1266   err = get_txn_proplist(txn_prop, txn->fs, &ftd->txn_id, pool);
1290   SVN_ERR(set_txn_proplist(txn->fs, &ftd->txn_id, txn_prop, pool));
1298                    const svn_fs_fs__id_part_t *txn_id,
1306   root_id = svn_fs_fs__id_txn_create_root(txn_id, pool);
1326                const svn_fs_fs__id_part_t *txn_id,
1342                            path_txn_next_ids(fs, txn_id, pool),
1358               const svn_fs_fs__id_part_t *txn_id,
1364                                   path_txn_next_ids(fs, txn_id, pool),
1391                     const svn_fs_fs__id_part_t *txn_id,
1397   SVN_ERR(read_next_ids(&node_id, &copy_id, fs, txn_id, pool));
1402   SVN_ERR(write_next_ids(fs, txn_id, ++node_id, copy_id, pool));
1410                            const svn_fs_fs__id_part_t *txn_id,
1416   SVN_ERR(read_next_ids(&node_id, &copy_id, fs, txn_id, pool));
1423   SVN_ERR(write_next_ids(fs, txn_id, node_id, ++copy_id, pool));
1433                        const svn_fs_fs__id_part_t *txn_id,
1440   SVN_ERR(get_new_txn_node_id(&node_id, fs, txn_id, pool));
1442   id = svn_fs_fs__id_txn_create(&node_id, copy_id, txn_id, pool);
1459   svn_fs_fs__id_part_t txn_id;
1460   SVN_ERR(svn_fs_fs__id_txn_parse(&txn_id, txn_id_str));
1463   SVN_ERR(purge_shared_txn(fs, &txn_id, pool));
1465   SVN_ERR(svn_io_remove_dir2(svn_fs_fs__path_txn_dir(fs, &txn_id, pool),
1474                   svn_fs_fs__path_txn_proto_rev(fs, &txn_id, pool),
1477                   svn_fs_fs__path_txn_proto_rev_lock(fs, &txn_id, pool),
1511       SVN_ERR(get_new_txn_node_id(&temp, fs, &rep->txn_id, pool));
1512       rep->uniquifier.noderev_txn_id = rep->txn_id;
1524   return svn_fs_fs__id_txn_used(&rep->txn_id);
1532   svn_fs_fs__id_txn_reset(&rep->txn_id);
1537                      const svn_fs_fs__id_part_t *txn_id,
1570       rep->txn_id = *txn_id;
1695                       const svn_fs_fs__id_part_t *txn_id,
1712   SVN_ERR(svn_io_file_open(&file, path_txn_changes(fs, txn_id, pool),
1743                       const svn_fs_fs__id_part_t *txn_id,
1753   path = svn_fs_fs__path_l2p_proto_index(fs, txn_id, pool);
1769                       const svn_fs_fs__id_part_t *txn_id,
1778   path = svn_fs_fs__path_p2l_proto_index(fs, txn_id, pool);
1795                     const svn_fs_fs__id_part_t *txn_id,
1810                          svn_fs_fs__path_txn_item_index(fs, txn_id, pool),
1832       SVN_ERR(store_l2p_index_entry(fs, txn_id, my_offset, *item_index, pool));
2362         = path_txn_sha1(fs, &rep->txn_id, rep->sha1_digest, scratch_pool);
2440         old_rep_norm.txn_id = rep->txn_id;
2535   rep->txn_id = *svn_fs_fs__id_txn_id(b->noderev->id);
2560       SVN_ERR(allocate_item_index(&rep->item_index, b->fs, &rep->txn_id,
2586       SVN_ERR(store_p2l_index_entry(b->fs, &rep->txn_id, &entry,
2597   SVN_ERR(unlock_proto_rev(b->fs, &rep->txn_id, b->lockcookie,
2650                             const svn_fs_fs__id_part_t *txn_id,
2658                                 txn_id, pool);
2700       noderev->prop_rep->txn_id = *svn_fs_fs__id_txn_id(noderev->id);
2853   SVN_ERR(allocate_item_index(&rep->item_index, fs, &rep->txn_id,
2870       SVN_ERR(store_p2l_index_entry(fs, &rep->txn_id, &entry, scratch_pool));
2998   SVN_ERR(allocate_item_index(&rep->item_index, fs, &rep->txn_id,
3015       SVN_ERR(store_p2l_index_entry(fs, &rep->txn_id, &entry, scratch_pool));
3154   const svn_fs_fs__id_part_t *txn_id = svn_fs_fs__id_txn_id(id);
3265       noderev->prop_rep->txn_id = *txn_id;
3296       SVN_ERR(store_l2p_index_entry(fs, txn_id, my_offset,
3300     SVN_ERR(allocate_item_index(&rev_item.number, fs, txn_id,
3390       SVN_ERR(store_p2l_index_entry(fs, txn_id, &entry, pool));
3407                               const svn_fs_fs__id_part_t *txn_id,
3443       SVN_ERR(store_p2l_index_entry(fs, txn_id, &entry, pool));
3444       SVN_ERR(store_l2p_index_entry(fs, txn_id, entry.offset,
3500                     const svn_fs_fs__id_part_t *txn_id,
3515   SVN_ERR(read_next_ids(&txn_node_id, &txn_copy_id, fs, txn_id, pool));
3529              const svn_fs_fs__id_part_t *txn_id,
3755   const svn_fs_fs__id_part_t *txn_id = svn_fs_fs__txn_get_id(cb->txn);
3791   SVN_ERR(svn_fs_fs__txn_changes_fetch(&changed_paths, cb->fs, txn_id,
3798   SVN_ERR(verify_locks(cb->fs, txn_id, changed_paths, pool));
3805                                  cb->fs, txn_id, pool));
3809   root_id = svn_fs_fs__id_txn_create_root(txn_id, pool);
3817                                         cb->fs, txn_id, changed_paths,
3824                       svn_fs_fs__path_l2p_proto_index(cb->fs, txn_id, pool),
3825                       svn_fs_fs__path_p2l_proto_index(cb->fs, txn_id, pool),
3893   proto_filename = svn_fs_fs__path_txn_proto_rev(cb->fs, txn_id, pool);
3902   SVN_ERR(unlock_proto_rev(cb->fs, txn_id, proto_file_lockcookie, pool));
3917   SVN_ERR(write_final_current(cb->fs, txn_id, new_rev, start_node_id,
4075   svn_fs_fs__id_part_t txn_id;
4077   SVN_ERR(svn_fs_fs__id_txn_parse(&txn_id, name));
4080   SVN_ERR(svn_io_check_path(svn_fs_fs__path_txn_dir(fs, &txn_id, pool),
4091   ftd->txn_id = txn_id;
4097   SVN_ERR(svn_fs_fs__get_txn(&local_txn, fs, &txn_id, pool));
4166                        const svn_fs_fs__id_part_t *txn_id,
4170   SVN_ERR(svn_fs_fs__get_txn(&txn, fs, txn_id, pool));
4236   return svn_error_trace(set_txn_proplist(fs, &ftd->txn_id, props, pool));