1251881Speter/* txn-table.c : operations on the `transactions' table 2251881Speter * 3251881Speter * ==================================================================== 4251881Speter * Licensed to the Apache Software Foundation (ASF) under one 5251881Speter * or more contributor license agreements. See the NOTICE file 6251881Speter * distributed with this work for additional information 7251881Speter * regarding copyright ownership. The ASF licenses this file 8251881Speter * to you under the Apache License, Version 2.0 (the 9251881Speter * "License"); you may not use this file except in compliance 10251881Speter * with the License. You may obtain a copy of the License at 11251881Speter * 12251881Speter * http://www.apache.org/licenses/LICENSE-2.0 13251881Speter * 14251881Speter * Unless required by applicable law or agreed to in writing, 15251881Speter * software distributed under the License is distributed on an 16251881Speter * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY 17251881Speter * KIND, either express or implied. See the License for the 18251881Speter * specific language governing permissions and limitations 19251881Speter * under the License. 20251881Speter * ==================================================================== 21251881Speter */ 22251881Speter 23251881Speter#include <string.h> 24251881Speter#include <assert.h> 25251881Speter 26251881Speter#include "bdb_compat.h" 27251881Speter 28251881Speter#include "svn_pools.h" 29251881Speter#include "private/svn_skel.h" 30251881Speter 31251881Speter#include "dbt.h" 32251881Speter#include "../err.h" 33251881Speter#include "../fs.h" 34251881Speter#include "../key-gen.h" 35251881Speter#include "../util/fs_skels.h" 36251881Speter#include "../trail.h" 37251881Speter#include "../../libsvn_fs/fs-loader.h" 38251881Speter#include "bdb-err.h" 39251881Speter#include "txn-table.h" 40251881Speter 41251881Speter#include "svn_private_config.h" 42251881Speter 43251881Speter 44251881Speterstatic svn_boolean_t 45251881Speteris_committed(transaction_t *txn) 46251881Speter{ 47251881Speter return (txn->kind == transaction_kind_committed); 48251881Speter} 49251881Speter 50251881Speter 51251881Speterint 52251881Spetersvn_fs_bdb__open_transactions_table(DB **transactions_p, 53251881Speter DB_ENV *env, 54251881Speter svn_boolean_t create) 55251881Speter{ 56251881Speter const u_int32_t open_flags = (create ? (DB_CREATE | DB_EXCL) : 0); 57251881Speter DB *txns; 58251881Speter 59251881Speter BDB_ERR(svn_fs_bdb__check_version()); 60251881Speter BDB_ERR(db_create(&txns, env, 0)); 61251881Speter BDB_ERR((txns->open)(SVN_BDB_OPEN_PARAMS(txns, NULL), 62251881Speter "transactions", 0, DB_BTREE, 63251881Speter open_flags, 0666)); 64251881Speter 65251881Speter /* Create the `next-key' table entry. */ 66251881Speter if (create) 67251881Speter { 68251881Speter DBT key, value; 69251881Speter 70251881Speter BDB_ERR(txns->put(txns, 0, 71251881Speter svn_fs_base__str_to_dbt(&key, NEXT_KEY_KEY), 72251881Speter svn_fs_base__str_to_dbt(&value, "0"), 0)); 73251881Speter } 74251881Speter 75251881Speter *transactions_p = txns; 76251881Speter return 0; 77251881Speter} 78251881Speter 79251881Speter 80251881Spetersvn_error_t * 81251881Spetersvn_fs_bdb__put_txn(svn_fs_t *fs, 82251881Speter const transaction_t *txn, 83251881Speter const char *txn_name, 84251881Speter trail_t *trail, 85251881Speter apr_pool_t *pool) 86251881Speter{ 87251881Speter base_fs_data_t *bfd = fs->fsap_data; 88251881Speter svn_skel_t *txn_skel; 89251881Speter DBT key, value; 90251881Speter 91251881Speter /* Convert native type to skel. */ 92251881Speter SVN_ERR(svn_fs_base__unparse_transaction_skel(&txn_skel, txn, pool)); 93251881Speter 94251881Speter /* Only in the context of this function do we know that the DB call 95251881Speter will not attempt to modify txn_name, so the cast belongs here. */ 96251881Speter svn_fs_base__str_to_dbt(&key, txn_name); 97251881Speter svn_fs_base__skel_to_dbt(&value, txn_skel, pool); 98251881Speter svn_fs_base__trail_debug(trail, "transactions", "put"); 99251881Speter return BDB_WRAP(fs, N_("storing transaction record"), 100251881Speter bfd->transactions->put(bfd->transactions, trail->db_txn, 101251881Speter &key, &value, 0)); 102251881Speter} 103251881Speter 104251881Speter 105251881Speter/* Allocate a Subversion transaction ID in FS, as part of TRAIL. Set 106251881Speter *ID_P to the new transaction ID, allocated in POOL. */ 107251881Speterstatic svn_error_t * 108251881Speterallocate_txn_id(const char **id_p, 109251881Speter svn_fs_t *fs, 110251881Speter trail_t *trail, 111251881Speter apr_pool_t *pool) 112251881Speter{ 113251881Speter base_fs_data_t *bfd = fs->fsap_data; 114251881Speter DBT query, result; 115251881Speter apr_size_t len; 116251881Speter char next_key[MAX_KEY_SIZE]; 117251881Speter int db_err; 118251881Speter 119251881Speter svn_fs_base__str_to_dbt(&query, NEXT_KEY_KEY); 120251881Speter 121251881Speter /* Get the current value associated with the `next-key' key in the table. */ 122251881Speter svn_fs_base__trail_debug(trail, "transactions", "get"); 123251881Speter SVN_ERR(BDB_WRAP(fs, N_("allocating new transaction ID (getting 'next-key')"), 124251881Speter bfd->transactions->get(bfd->transactions, trail->db_txn, 125251881Speter &query, 126251881Speter svn_fs_base__result_dbt(&result), 127251881Speter 0))); 128251881Speter svn_fs_base__track_dbt(&result, pool); 129251881Speter 130251881Speter /* Set our return value. */ 131251881Speter *id_p = apr_pstrmemdup(pool, result.data, result.size); 132251881Speter 133251881Speter /* Bump to future key. */ 134251881Speter len = result.size; 135251881Speter svn_fs_base__next_key(result.data, &len, next_key); 136251881Speter svn_fs_base__str_to_dbt(&query, NEXT_KEY_KEY); 137251881Speter svn_fs_base__str_to_dbt(&result, next_key); 138251881Speter svn_fs_base__trail_debug(trail, "transactions", "put"); 139251881Speter db_err = bfd->transactions->put(bfd->transactions, trail->db_txn, 140251881Speter &query, &result, 0); 141251881Speter 142251881Speter return BDB_WRAP(fs, N_("bumping next transaction key"), db_err); 143251881Speter} 144251881Speter 145251881Speter 146251881Spetersvn_error_t * 147251881Spetersvn_fs_bdb__create_txn(const char **txn_name_p, 148251881Speter svn_fs_t *fs, 149251881Speter const svn_fs_id_t *root_id, 150251881Speter trail_t *trail, 151251881Speter apr_pool_t *pool) 152251881Speter{ 153251881Speter const char *txn_name; 154251881Speter transaction_t txn; 155251881Speter 156251881Speter SVN_ERR(allocate_txn_id(&txn_name, fs, trail, pool)); 157251881Speter txn.kind = transaction_kind_normal; 158251881Speter txn.root_id = root_id; 159251881Speter txn.base_id = root_id; 160251881Speter txn.proplist = NULL; 161251881Speter txn.copies = NULL; 162251881Speter txn.revision = SVN_INVALID_REVNUM; 163251881Speter SVN_ERR(svn_fs_bdb__put_txn(fs, &txn, txn_name, trail, pool)); 164251881Speter 165251881Speter *txn_name_p = txn_name; 166251881Speter return SVN_NO_ERROR; 167251881Speter} 168251881Speter 169251881Speter 170251881Spetersvn_error_t * 171251881Spetersvn_fs_bdb__delete_txn(svn_fs_t *fs, 172251881Speter const char *txn_name, 173251881Speter trail_t *trail, 174251881Speter apr_pool_t *pool) 175251881Speter{ 176251881Speter base_fs_data_t *bfd = fs->fsap_data; 177251881Speter DBT key; 178251881Speter transaction_t *txn; 179251881Speter 180251881Speter /* Make sure TXN is dead. */ 181251881Speter SVN_ERR(svn_fs_bdb__get_txn(&txn, fs, txn_name, trail, pool)); 182251881Speter if (is_committed(txn)) 183251881Speter return svn_fs_base__err_txn_not_mutable(fs, txn_name); 184251881Speter 185251881Speter /* Delete the transaction from the `transactions' table. */ 186251881Speter svn_fs_base__str_to_dbt(&key, txn_name); 187251881Speter svn_fs_base__trail_debug(trail, "transactions", "del"); 188251881Speter return BDB_WRAP(fs, N_("deleting entry from 'transactions' table"), 189251881Speter bfd->transactions->del(bfd->transactions, 190251881Speter trail->db_txn, &key, 0)); 191251881Speter} 192251881Speter 193251881Speter 194251881Spetersvn_error_t * 195251881Spetersvn_fs_bdb__get_txn(transaction_t **txn_p, 196251881Speter svn_fs_t *fs, 197251881Speter const char *txn_name, 198251881Speter trail_t *trail, 199251881Speter apr_pool_t *pool) 200251881Speter{ 201251881Speter base_fs_data_t *bfd = fs->fsap_data; 202251881Speter DBT key, value; 203251881Speter int db_err; 204251881Speter svn_skel_t *skel; 205251881Speter transaction_t *transaction; 206251881Speter 207251881Speter /* Only in the context of this function do we know that the DB call 208251881Speter will not attempt to modify txn_name, so the cast belongs here. */ 209251881Speter svn_fs_base__trail_debug(trail, "transactions", "get"); 210251881Speter db_err = bfd->transactions->get(bfd->transactions, trail->db_txn, 211251881Speter svn_fs_base__str_to_dbt(&key, txn_name), 212251881Speter svn_fs_base__result_dbt(&value), 213251881Speter 0); 214251881Speter svn_fs_base__track_dbt(&value, pool); 215251881Speter 216251881Speter if (db_err == DB_NOTFOUND) 217251881Speter return svn_fs_base__err_no_such_txn(fs, txn_name); 218251881Speter SVN_ERR(BDB_WRAP(fs, N_("reading transaction"), db_err)); 219251881Speter 220251881Speter /* Parse TRANSACTION skel */ 221251881Speter skel = svn_skel__parse(value.data, value.size, pool); 222251881Speter if (! skel) 223251881Speter return svn_fs_base__err_corrupt_txn(fs, txn_name); 224251881Speter 225251881Speter /* Convert skel to native type. */ 226251881Speter SVN_ERR(svn_fs_base__parse_transaction_skel(&transaction, skel, pool)); 227251881Speter *txn_p = transaction; 228251881Speter return SVN_NO_ERROR; 229251881Speter} 230251881Speter 231251881Speter 232251881Spetersvn_error_t * 233251881Spetersvn_fs_bdb__get_txn_list(apr_array_header_t **names_p, 234251881Speter svn_fs_t *fs, 235251881Speter trail_t *trail, 236251881Speter apr_pool_t *pool) 237251881Speter{ 238251881Speter base_fs_data_t *bfd = fs->fsap_data; 239251881Speter apr_size_t const next_key_key_len = strlen(NEXT_KEY_KEY); 240251881Speter apr_pool_t *subpool = svn_pool_create(pool); 241251881Speter apr_array_header_t *names; 242251881Speter DBC *cursor; 243251881Speter DBT key, value; 244251881Speter int db_err, db_c_err; 245251881Speter 246251881Speter /* Allocate the initial names array */ 247251881Speter names = apr_array_make(pool, 4, sizeof(const char *)); 248251881Speter 249251881Speter /* Create a database cursor to list the transaction names. */ 250251881Speter svn_fs_base__trail_debug(trail, "transactions", "cursor"); 251251881Speter SVN_ERR(BDB_WRAP(fs, N_("reading transaction list (opening cursor)"), 252251881Speter bfd->transactions->cursor(bfd->transactions, 253251881Speter trail->db_txn, &cursor, 0))); 254251881Speter 255251881Speter /* Build a null-terminated array of keys in the transactions table. */ 256251881Speter for (db_err = svn_bdb_dbc_get(cursor, 257251881Speter svn_fs_base__result_dbt(&key), 258251881Speter svn_fs_base__result_dbt(&value), 259251881Speter DB_FIRST); 260251881Speter db_err == 0; 261251881Speter db_err = svn_bdb_dbc_get(cursor, 262251881Speter svn_fs_base__result_dbt(&key), 263251881Speter svn_fs_base__result_dbt(&value), 264251881Speter DB_NEXT)) 265251881Speter { 266251881Speter transaction_t *txn; 267251881Speter svn_skel_t *txn_skel; 268251881Speter svn_error_t *err; 269251881Speter 270251881Speter /* Clear the per-iteration subpool */ 271251881Speter svn_pool_clear(subpool); 272251881Speter 273251881Speter /* Track the memory alloc'd for fetching the key and value here 274251881Speter so that when the containing pool is cleared, this memory is 275251881Speter freed. */ 276251881Speter svn_fs_base__track_dbt(&key, subpool); 277251881Speter svn_fs_base__track_dbt(&value, subpool); 278251881Speter 279251881Speter /* Ignore the "next-key" key. */ 280251881Speter if (key.size == next_key_key_len 281251881Speter && 0 == memcmp(key.data, NEXT_KEY_KEY, next_key_key_len)) 282251881Speter continue; 283251881Speter 284251881Speter /* Parse TRANSACTION skel */ 285251881Speter txn_skel = svn_skel__parse(value.data, value.size, subpool); 286251881Speter if (! txn_skel) 287251881Speter { 288251881Speter svn_bdb_dbc_close(cursor); 289251881Speter return svn_fs_base__err_corrupt_txn 290251881Speter (fs, apr_pstrmemdup(pool, key.data, key.size)); 291251881Speter } 292251881Speter 293251881Speter /* Convert skel to native type. */ 294251881Speter if ((err = svn_fs_base__parse_transaction_skel(&txn, txn_skel, 295251881Speter subpool))) 296251881Speter { 297251881Speter svn_bdb_dbc_close(cursor); 298251881Speter return svn_error_trace(err); 299251881Speter } 300251881Speter 301251881Speter /* If this is an immutable "committed" transaction, ignore it. */ 302251881Speter if (is_committed(txn)) 303251881Speter continue; 304251881Speter 305251881Speter /* Add the transaction name to the NAMES array, duping it into POOL. */ 306251881Speter APR_ARRAY_PUSH(names, const char *) = apr_pstrmemdup(pool, key.data, 307251881Speter key.size); 308251881Speter } 309251881Speter 310251881Speter /* Check for errors, but close the cursor first. */ 311251881Speter db_c_err = svn_bdb_dbc_close(cursor); 312251881Speter if (db_err != DB_NOTFOUND) 313251881Speter { 314251881Speter SVN_ERR(BDB_WRAP(fs, N_("reading transaction list (listing keys)"), 315251881Speter db_err)); 316251881Speter } 317251881Speter SVN_ERR(BDB_WRAP(fs, N_("reading transaction list (closing cursor)"), 318251881Speter db_c_err)); 319251881Speter 320251881Speter /* Destroy the per-iteration subpool */ 321251881Speter svn_pool_destroy(subpool); 322251881Speter 323251881Speter *names_p = names; 324251881Speter return SVN_NO_ERROR; 325251881Speter} 326