/* * main.c: Subversion server administration tool. * * ==================================================================== * Copyright (c) 2000-2004 CollabNet. All rights reserved. * * This software is licensed as described in the file COPYING, which * you should have received as part of this distribution. The terms * are also available at http://subversion.tigris.org/license-1.html. * If newer versions of this license are posted there, you may use a * newer version instead, at your option. * * This software consists of voluntary contributions made by many * individuals. For exact contribution history, see the revision * history and logs, available at http://subversion.tigris.org/. * ==================================================================== */ #include #include #include "svn_pools.h" #include "svn_cmdline.h" #include "svn_error.h" #include "svn_opt.h" #include "svn_utf.h" #include "svn_subst.h" #include "svn_path.h" #include "svn_config.h" #include "svn_repos.h" #include "svn_fs.h" #include "svn_version.h" #include "svn_private_config.h" /*** Code. ***/ /* A flag to see if we've been cancelled by the client or not. */ static volatile sig_atomic_t cancelled = FALSE; /* A signal handler to support cancellation. */ static void signal_handler (int signum) { apr_signal (signum, SIG_IGN); cancelled = TRUE; } /* A helper to set up the cancellation signal handlers. */ static void setup_cancellation_signals (void (*handler)(int signum)) { apr_signal (SIGINT, handler); #ifdef SIGBREAK /* SIGBREAK is a Win32 specific signal generated by ctrl-break. */ apr_signal (SIGBREAK, handler); #endif #ifdef SIGHUP apr_signal (SIGHUP, handler); #endif #ifdef SIGTERM apr_signal (SIGTERM, handler); #endif } /* Our cancellation callback. */ static svn_error_t * check_cancel (void *baton) { if (cancelled) return svn_error_create (SVN_ERR_CANCELLED, NULL, _("Caught signal")); else return SVN_NO_ERROR; } /* Helper to open stdio streams */ static svn_error_t * create_stdio_stream (svn_stream_t **stream, APR_DECLARE(apr_status_t) open_fn (apr_file_t **, apr_pool_t *), apr_pool_t *pool) { apr_file_t *stdio_file; apr_status_t apr_err = open_fn (&stdio_file, pool); if (apr_err) return svn_error_wrap_apr (apr_err, _("Can't open stdio file")); *stream = svn_stream_from_aprfile (stdio_file, pool); return SVN_NO_ERROR; } /* Helper to parse local repository path. Try parsing next parameter * of OS as a local path to repository. If successfull *REPOS_PATH * will contain internal style path to the repository. */ static svn_error_t * parse_local_repos_path (apr_getopt_t *os, const char ** repos_path, apr_pool_t *pool) { *repos_path = NULL; /* Check to see if there is one more parameter. */ if (os->ind < os->argc) { const char * path = os->argv[os->ind++]; SVN_ERR (svn_utf_cstring_to_utf8 (repos_path, path, pool)); *repos_path = svn_path_internal_style (*repos_path, pool); } if (*repos_path == NULL) { return svn_error_create (SVN_ERR_CL_ARG_PARSING_ERROR, NULL, _("Repository argument required")); } else if (svn_path_is_url (*repos_path)) { return svn_error_createf (SVN_ERR_CL_ARG_PARSING_ERROR, NULL, _("'%s' is an URL when it should be a path"), *repos_path); } return SVN_NO_ERROR; } /* Custom filesystem warning function. */ static void warning_func (void *baton, svn_error_t *err) { if (! err) return; svn_handle_error (err, stderr, FALSE); } /* Helper to open a repository and set a warning func (so we don't * SEGFAULT when libsvn_fs's default handler gets run). */ static svn_error_t * open_repos (svn_repos_t **repos, const char *path, apr_pool_t *pool) { SVN_ERR (svn_repos_open (repos, path, pool)); svn_fs_set_warning_func (svn_repos_fs (*repos), warning_func, NULL); return SVN_NO_ERROR; } /* Version compatibility check */ static svn_error_t * check_lib_versions (void) { static const svn_version_checklist_t checklist[] = { { "svn_subr", svn_subr_version }, { "svn_repos", svn_repos_version }, { "svn_fs", svn_fs_version }, { "svn_delta", svn_delta_version }, { NULL, NULL } }; SVN_VERSION_DEFINE (my_version); return svn_ver_check_list (&my_version, checklist); } /** Subcommands. **/ static svn_opt_subcommand_t subcommand_create, subcommand_deltify, subcommand_dump, subcommand_help, subcommand_hotcopy, subcommand_load, subcommand_list_dblogs, subcommand_list_unused_dblogs, subcommand_lstxns, subcommand_recover, subcommand_rmtxns, subcommand_setlog, subcommand_verify; enum { svnadmin__version = SVN_OPT_FIRST_LONGOPT_ID, svnadmin__incremental, svnadmin__deltas, svnadmin__ignore_uuid, svnadmin__force_uuid, svnadmin__fs_type, svnadmin__parent_dir, svnadmin__bdb_txn_nosync, svnadmin__bdb_log_keep, svnadmin__config_dir, svnadmin__bypass_hooks, svnadmin__clean_logs, svnadmin__wait }; /* Option codes and descriptions. * * This must not have more than SVN_OPT_MAX_OPTIONS entries; if you * need more, increase that limit first. * * The entire list must be terminated with an entry of nulls. */ static const apr_getopt_option_t options_table[] = { {"help", 'h', 0, N_("show help on a subcommand")}, {NULL, '?', 0, N_("show help on a subcommand")}, {"version", svnadmin__version, 0, N_("show version information")}, {"revision", 'r', 1, N_("specify revision number ARG (or X:Y range)")}, {"incremental", svnadmin__incremental, 0, N_("dump incrementally")}, {"deltas", svnadmin__deltas, 0, N_("use deltas in dump output")}, {"bypass-hooks", svnadmin__bypass_hooks, 0, N_("bypass the repository hook system")}, {"quiet", 'q', 0, N_("no progress (only errors) to stderr")}, {"ignore-uuid", svnadmin__ignore_uuid, 0, N_("ignore any repos UUID found in the stream")}, {"force-uuid", svnadmin__force_uuid, 0, N_("set repos UUID to that found in stream, if any")}, {"fs-type", svnadmin__fs_type, 1, N_("type of repository: 'bdb' or 'fsfs'")}, {"parent-dir", svnadmin__parent_dir, 1, N_("load at specified directory in repository")}, {"bdb-txn-nosync", svnadmin__bdb_txn_nosync, 0, N_("disable fsync at transaction commit [Berkeley DB]")}, {"bdb-log-keep", svnadmin__bdb_log_keep, 0, N_("disable automatic log file removal [Berkeley DB]")}, {"config-dir", svnadmin__config_dir, 1, N_("read user configuration files from directory ARG")}, {"clean-logs", svnadmin__clean_logs, 0, N_("remove redundant log files from source repository")}, {"wait", svnadmin__wait, 0, N_("wait instead of exit if the repository is in\n" " use by another process")}, {NULL} }; /* Array of available subcommands. * The entire list must be terminated with an entry of nulls. */ static const svn_opt_subcommand_desc_t cmd_table[] = { {"create", subcommand_create, {0}, N_("usage: svnadmin create REPOS_PATH\n\n" "Create a new, empty repository at REPOS_PATH.\n"), {svnadmin__bdb_txn_nosync, svnadmin__bdb_log_keep, svnadmin__config_dir, svnadmin__fs_type} }, {"deltify", subcommand_deltify, {0}, N_ ("usage: svnadmin deltify [-r LOWER[:UPPER]] REPOS_PATH\n\n" "Run over the requested revision range, performing predecessor delti-\n" "fication on the paths changed in those revisions. Deltification in\n" "essence compresses the repository by only storing the differences or\n" "delta from the preceding revision. If no revisions are specified,\n" "this will simply deltify the HEAD revision.\n"), {'r', 'q'} }, {"dump", subcommand_dump, {0}, N_ ("usage: svnadmin dump REPOS_PATH [-r LOWER[:UPPER]] [--incremental]\n\n" "Dump the contents of filesystem to stdout in a 'dumpfile'\n" "portable format, sending feedback to stderr. Dump revisions\n" "LOWER rev through UPPER rev. If no revisions are given, dump all\n" "revision trees. If only LOWER is given, dump that one revision tree.\n" "If --incremental is passed, then the first revision dumped will be\n" "a diff against the previous revision, instead of the usual" " fulltext.\n"), {'r', svnadmin__incremental, svnadmin__deltas, 'q'} }, {"help", subcommand_help, {"?", "h"}, N_("usage: svnadmin help [SUBCOMMAND...]\n\n" "Describe the usage of this program or its subcommands.\n"), {svnadmin__version} }, {"hotcopy", subcommand_hotcopy, {0}, N_("usage: svnadmin hotcopy REPOS_PATH NEW_REPOS_PATH\n\n" "Makes a hot copy of a repository.\n"), {svnadmin__clean_logs} }, {"list-dblogs", subcommand_list_dblogs, {0}, N_("usage: svnadmin list-dblogs REPOS_PATH\n\n" "List all Berkeley DB log files.\n\n" "WARNING: Modifying or deleting logfiles which are still in use\n" "will cause your repository to be corrupted.\n"), {0} }, {"list-unused-dblogs", subcommand_list_unused_dblogs, {0}, N_("usage: svnadmin list-unused-dblogs REPOS_PATH\n\n" "List unused Berkeley DB log files.\n\n"), {0} }, {"load", subcommand_load, {0}, N_("usage: svnadmin load REPOS_PATH\n\n" "Read a 'dumpfile'-formatted stream from stdin, committing\n" "new revisions into the repository's filesystem. If the repository\n" "was previously empty, its UUID will, by default, be changed to the\n" "one specified in the stream. Progress feedback is sent to" " stdout.\n"), {'q', svnadmin__ignore_uuid, svnadmin__force_uuid, svnadmin__parent_dir} }, {"lstxns", subcommand_lstxns, {0}, N_("usage: svnadmin lstxns REPOS_PATH\n\n" "Print the names of all uncommitted transactions.\n"), {0} }, {"recover", subcommand_recover, {0}, N_("usage: svnadmin recover REPOS_PATH\n\n" "Run the Berkeley DB recovery procedure on a repository. Do\n" "this if you've been getting errors indicating that recovery\n" "ought to be run. Recovery requires exclusive access and will\n" "exit if the repository is in use by another process.\n\n"), {svnadmin__wait} }, {"rmtxns", subcommand_rmtxns, {0}, N_("usage: svnadmin rmtxns REPOS_PATH TXN_NAME...\n\n" "Delete the named transaction(s).\n"), {'q'} }, {"setlog", subcommand_setlog, {0}, N_("usage: svnadmin setlog REPOS_PATH -r REVISION FILE\n\n" "Set the log-message on revision REVISION to the contents of FILE." " Use\n" "--bypass-hooks to avoid triggering the revision-property-related" " hooks\n" "(for example, if you do not want an email notification sent\n" "from your post-revprop-change hook, or because the modification of\n" "revision properties has not been enabled in the pre-revprop-change\n" "hook).\n\n" "NOTE: revision properties are not historied, so this command\n" "will permanently overwrite the previous log message.\n"), {'r', svnadmin__bypass_hooks} }, {"verify", subcommand_verify, {0}, N_("usage: svnadmin verify REPOS_PATH\n\n" "Verifies the data stored in the repository.\n"), {0} }, { NULL, NULL, {0}, NULL, {0} } }; /* Baton for passing option/argument state to a subcommand function. */ struct svnadmin_opt_state { const char *repository_path; const char *new_repository_path; /* hotcopy dest. path */ const char *fs_type; /* --fs-type */ svn_opt_revision_t start_revision, end_revision; /* -r X[:Y] */ svn_boolean_t help; /* --help or -? */ svn_boolean_t version; /* --version */ svn_boolean_t incremental; /* --incremental */ svn_boolean_t use_deltas; /* --deltas */ svn_boolean_t quiet; /* --quiet */ svn_boolean_t bdb_txn_nosync; /* --bdb-txn-nosync */ svn_boolean_t bdb_log_keep; /* --bdb-log-keep */ svn_boolean_t clean_logs; /* --clean-logs */ svn_boolean_t bypass_hooks; /* --bypass-hooks */ svn_boolean_t wait; /* --wait */ enum svn_repos_load_uuid uuid_action; /* --ignore-uuid, --force-uuid */ const char *parent_dir; const char *config_dir; /* Overriding Configuration Directory */ }; /* Set *REVNUM to the revision specified by REVISION (or to SVN_INVALID_REVNUM if that has the type 'unspecified'), possibly making use of the YOUNGEST revision number in REPOS. */ static svn_error_t * get_revnum (svn_revnum_t *revnum, const svn_opt_revision_t *revision, svn_revnum_t youngest, svn_repos_t *repos, apr_pool_t *pool) { if (revision->kind == svn_opt_revision_number) *revnum = revision->value.number; else if (revision->kind == svn_opt_revision_head) *revnum = youngest; else if (revision->kind == svn_opt_revision_date) SVN_ERR (svn_repos_dated_revision (revnum, repos, revision->value.date, pool)); else if (revision->kind == svn_opt_revision_unspecified) *revnum = SVN_INVALID_REVNUM; else return svn_error_create (SVN_ERR_CL_ARG_PARSING_ERROR, NULL, "Invalid revision specifier"); if (*revnum > youngest) return svn_error_createf (SVN_ERR_CL_ARG_PARSING_ERROR, NULL, "Revisions must not be greater than the youngest revision (%" SVN_REVNUM_T_FMT ")", youngest); return SVN_NO_ERROR; } /* This implements `svn_opt_subcommand_t'. */ static svn_error_t * subcommand_create (apr_getopt_t *os, void *baton, apr_pool_t *pool) { struct svnadmin_opt_state *opt_state = baton; svn_repos_t *repos; apr_hash_t *config; apr_hash_t *fs_config = apr_hash_make (pool);; apr_hash_set (fs_config, SVN_FS_CONFIG_BDB_TXN_NOSYNC, APR_HASH_KEY_STRING, (opt_state->bdb_txn_nosync ? "1" : "0")); apr_hash_set (fs_config, SVN_FS_CONFIG_BDB_LOG_AUTOREMOVE, APR_HASH_KEY_STRING, (opt_state->bdb_log_keep ? "0" : "1")); if (opt_state->fs_type) apr_hash_set (fs_config, SVN_FS_CONFIG_FS_TYPE, APR_HASH_KEY_STRING, opt_state->fs_type); SVN_ERR (svn_config_get_config (&config, opt_state->config_dir, pool)); SVN_ERR (svn_repos_create (&repos, opt_state->repository_path, NULL, NULL, config, fs_config, pool)); return SVN_NO_ERROR; } /* This implements `svn_opt_subcommand_t'. */ static svn_error_t * subcommand_deltify (apr_getopt_t *os, void *baton, apr_pool_t *pool) { struct svnadmin_opt_state *opt_state = baton; svn_repos_t *repos; svn_fs_t *fs; svn_revnum_t start = SVN_INVALID_REVNUM, end = SVN_INVALID_REVNUM; svn_revnum_t youngest, revision; apr_pool_t *subpool = svn_pool_create (pool); SVN_ERR (open_repos (&repos, opt_state->repository_path, pool)); fs = svn_repos_fs (repos); SVN_ERR (svn_fs_youngest_rev (&youngest, fs, pool)); /* Find the revision numbers at which to start and end. */ SVN_ERR (get_revnum (&start, &opt_state->start_revision, youngest, repos, pool)); SVN_ERR (get_revnum (&end, &opt_state->end_revision, youngest, repos, pool)); /* Fill in implied revisions if necessary. */ if (start == SVN_INVALID_REVNUM) start = youngest; if (end == SVN_INVALID_REVNUM) end = start; if (start > end) return svn_error_create (SVN_ERR_CL_ARG_PARSING_ERROR, NULL, _("First revision cannot be higher than second")); /* Loop over the requested revision range, performing the predecessor deltification on paths changed in each. */ for (revision = start; revision <= end; revision++) { svn_pool_clear (subpool); SVN_ERR (check_cancel (NULL)); if (! opt_state->quiet) SVN_ERR (svn_cmdline_printf (subpool, _("Deltifying revision %ld..."), revision)); SVN_ERR (svn_fs_deltify_revision (fs, revision, subpool)); if (! opt_state->quiet) SVN_ERR (svn_cmdline_printf (subpool, _("done.\n"))); } svn_pool_destroy (subpool); return SVN_NO_ERROR; } /* This implements `svn_opt_subcommand_t'. */ static svn_error_t * subcommand_dump (apr_getopt_t *os, void *baton, apr_pool_t *pool) { struct svnadmin_opt_state *opt_state = baton; svn_repos_t *repos; svn_fs_t *fs; svn_stream_t *stdout_stream, *stderr_stream = NULL; svn_revnum_t lower = SVN_INVALID_REVNUM, upper = SVN_INVALID_REVNUM; svn_revnum_t youngest; SVN_ERR (open_repos (&repos, opt_state->repository_path, pool)); fs = svn_repos_fs (repos); SVN_ERR (svn_fs_youngest_rev (&youngest, fs, pool)); /* Find the revision numbers at which to start and end. */ SVN_ERR (get_revnum (&lower, &opt_state->start_revision, youngest, repos, pool)); SVN_ERR (get_revnum (&upper, &opt_state->end_revision, youngest, repos, pool)); /* Fill in implied revisions if necessary. */ if (lower == SVN_INVALID_REVNUM) { lower = 0; upper = youngest; } else if (upper == SVN_INVALID_REVNUM) { upper = lower; } if (lower > upper) return svn_error_create (SVN_ERR_CL_ARG_PARSING_ERROR, NULL, _("First revision cannot be higher than second")); /* Run the dump to STDOUT. Let the user redirect output into a file if they want. :-) */ SVN_ERR (create_stdio_stream (&stdout_stream, apr_file_open_stdout, pool)); /* Progress feedback goes to stderr, unless they asked to suppress it. */ if (! opt_state->quiet) SVN_ERR (create_stdio_stream (&stderr_stream, apr_file_open_stderr, pool)); SVN_ERR (svn_repos_dump_fs2 (repos, stdout_stream, stderr_stream, lower, upper, opt_state->incremental, opt_state->use_deltas, check_cancel, NULL, pool)); return SVN_NO_ERROR; } /* This implements `svn_opt_subcommand_t'. */ static svn_error_t * subcommand_help (apr_getopt_t *os, void *baton, apr_pool_t *pool) { struct svnadmin_opt_state *opt_state = baton; const char *header = _("general usage: svnadmin SUBCOMMAND REPOS_PATH [ARGS & OPTIONS ...]\n" "Type \"svnadmin help \" for help on a specific" " subcommand.\n" "\n" "Available subcommands:\n"); SVN_ERR (svn_opt_print_help (os, "svnadmin", opt_state ? opt_state->version : FALSE, FALSE, NULL, header, cmd_table, options_table, NULL, pool)); return SVN_NO_ERROR; } /* This implements `svn_opt_subcommand_t'. */ static svn_error_t * subcommand_load (apr_getopt_t *os, void *baton, apr_pool_t *pool) { struct svnadmin_opt_state *opt_state = baton; svn_repos_t *repos; svn_stream_t *stdin_stream, *stdout_stream = NULL; SVN_ERR (open_repos (&repos, opt_state->repository_path, pool)); /* Read the stream from STDIN. Users can redirect a file. */ SVN_ERR (create_stdio_stream (&stdin_stream, apr_file_open_stdin, pool)); /* Have the parser dump feedback to STDOUT. */ if (! opt_state->quiet) SVN_ERR (create_stdio_stream (&stdout_stream, apr_file_open_stdout, pool)); SVN_ERR (svn_repos_load_fs (repos, stdin_stream, stdout_stream, opt_state->uuid_action, opt_state->parent_dir, check_cancel, NULL, pool)); return SVN_NO_ERROR; } /* This implements `svn_opt_subcommand_t'. */ static svn_error_t * subcommand_lstxns (apr_getopt_t *os, void *baton, apr_pool_t *pool) { struct svnadmin_opt_state *opt_state = baton; svn_repos_t *repos; svn_fs_t *fs; apr_array_header_t *txns; int i; SVN_ERR (open_repos (&repos, opt_state->repository_path, pool)); fs = svn_repos_fs (repos); SVN_ERR (svn_fs_list_transactions (&txns, fs, pool)); /* Loop, printing revisions. */ for (i = 0; i < txns->nelts; i++) { SVN_ERR (svn_cmdline_printf (pool, "%s\n", APR_ARRAY_IDX (txns, i, const char *))); } return SVN_NO_ERROR; } /* A callback which is called when the recovery starts. */ static svn_error_t * recovery_started (void *baton) { apr_pool_t *pool = (apr_pool_t *)baton; SVN_ERR (svn_cmdline_printf (pool, _("Repository lock acquired.\n" "Please wait; recovering the" " repository may take some time...\n"))); SVN_ERR (svn_cmdline_fflush (stdout)); /* Enable cancellation signal handlers. */ setup_cancellation_signals (signal_handler); return SVN_NO_ERROR; } /* This implements `svn_opt_subcommand_t'. */ static svn_error_t * subcommand_recover (apr_getopt_t *os, void *baton, apr_pool_t *pool) { svn_revnum_t youngest_rev; svn_repos_t *repos; svn_error_t *err; struct svnadmin_opt_state *opt_state = baton; /* Restore default signal handlers until after we have acquired the * exclusive lock so that the user interrupt before we actually * touch the repository. */ setup_cancellation_signals (SIG_DFL); err = svn_repos_recover2 (opt_state->repository_path, TRUE, recovery_started, pool, pool); if (err) { if (! APR_STATUS_IS_EAGAIN (err->apr_err)) return err; svn_error_clear (err); if (! opt_state->wait) return svn_error_create (SVN_ERR_REPOS_LOCKED, NULL, _("Failed to get exclusive repository " "access; perhaps another process\n" "such as httpd, svnserve or svn " "has it open?")); SVN_ERR (svn_cmdline_printf (pool, _("Waiting on repository lock; perhaps" " another process has it open?\n"))); SVN_ERR (svn_cmdline_fflush (stdout)); SVN_ERR (svn_repos_recover2 (opt_state->repository_path, FALSE, recovery_started, pool, pool)); } SVN_ERR (svn_cmdline_printf (pool, _("\nRecovery completed.\n"))); /* Since db transactions may have been replayed, it's nice to tell people what the latest revision is. It also proves that the recovery actually worked. */ SVN_ERR (open_repos (&repos, opt_state->repository_path, pool)); SVN_ERR (svn_fs_youngest_rev (&youngest_rev, svn_repos_fs (repos), pool)); SVN_ERR (svn_cmdline_printf (pool, _("The latest repos revision is %ld.\n"), youngest_rev)); return SVN_NO_ERROR; } /* This implements `svn_opt_subcommand_t'. */ static svn_error_t * list_dblogs (apr_getopt_t *os, void *baton, svn_boolean_t only_unused, apr_pool_t *pool) { struct svnadmin_opt_state *opt_state = baton; apr_array_header_t *logfiles; int i; SVN_ERR (svn_repos_db_logfiles (&logfiles, opt_state->repository_path, only_unused, pool)); /* Loop, printing log files. We append the log paths to the repository path, making sure to return everything to the native style before printing. */ for (i = 0; i < logfiles->nelts; i++) { const char *log_utf8; log_utf8 = svn_path_join (opt_state->repository_path, APR_ARRAY_IDX (logfiles, i, const char *), pool); log_utf8 = svn_path_local_style (log_utf8, pool); SVN_ERR (svn_cmdline_printf (pool, "%s\n", log_utf8)); } return SVN_NO_ERROR; } /* This implements `svn_opt_subcommand_t'. */ static svn_error_t * subcommand_list_dblogs (apr_getopt_t *os, void *baton, apr_pool_t *pool) { SVN_ERR (list_dblogs (os, baton, FALSE, pool)); return SVN_NO_ERROR; } /* This implements `svn_opt_subcommand_t'. */ static svn_error_t * subcommand_list_unused_dblogs (apr_getopt_t *os, void *baton, apr_pool_t *pool) { SVN_ERR (list_dblogs (os, baton, TRUE, pool)); return SVN_NO_ERROR; } /* This implements `svn_opt_subcommand_t'. */ static svn_error_t * subcommand_rmtxns (apr_getopt_t *os, void *baton, apr_pool_t *pool) { struct svnadmin_opt_state *opt_state = baton; svn_repos_t *repos; svn_fs_t *fs; svn_fs_txn_t *txn; apr_array_header_t *args; int i; apr_pool_t *subpool = svn_pool_create (pool); SVN_ERR (open_repos (&repos, opt_state->repository_path, pool)); fs = svn_repos_fs (repos); SVN_ERR (svn_opt_parse_all_args (&args, os, pool)); /* All the rest of the arguments are transaction names. */ for (i = 0; i < args->nelts; i++) { const char *txn_name = APR_ARRAY_IDX (args, i, const char *); const char *txn_name_utf8; svn_error_t *err; SVN_ERR (svn_utf_cstring_to_utf8 (&txn_name_utf8, txn_name, subpool)); /* Try to open the txn. If that succeeds, try to abort it. */ err = svn_fs_open_txn (&txn, fs, txn_name_utf8, subpool); if (! err) err = svn_fs_abort_txn (txn, subpool); /* If either the open or the abort of the txn fails because that transaction is dead, just try to purge the thing. Else, there was either an error worth reporting, or not error at all. */ if (err && (err->apr_err == SVN_ERR_FS_TRANSACTION_DEAD)) { svn_error_clear (err); err = svn_fs_purge_txn (fs, txn_name_utf8, subpool); } /* If we had a real from the txn open, abort, or purge, we clear that error and just report to the user that we had an issue with this particular txn. */ if (err) { svn_handle_error (err, stderr, FALSE /* non-fatal */); svn_error_clear (err); } else if (! opt_state->quiet) { SVN_ERR (svn_cmdline_printf (subpool, _("Transaction '%s' removed.\n"), txn_name)); } svn_pool_clear (subpool); } return SVN_NO_ERROR; } /* This implements `svn_opt_subcommand_t'. */ static svn_error_t * subcommand_setlog (apr_getopt_t *os, void *baton, apr_pool_t *pool) { struct svnadmin_opt_state *opt_state = baton; svn_repos_t *repos; svn_stringbuf_t *file_contents; const char *filename_utf8; apr_array_header_t *args; svn_string_t *log_contents = svn_string_create ("", pool); if (opt_state->start_revision.kind != svn_opt_revision_number) return svn_error_createf (SVN_ERR_CL_ARG_PARSING_ERROR, NULL, _("Missing revision")); else if (opt_state->end_revision.kind != svn_opt_revision_unspecified) return svn_error_createf (SVN_ERR_CL_ARG_PARSING_ERROR, NULL, _("Only one revision allowed")); SVN_ERR (svn_opt_parse_all_args (&args, os, pool)); if (args->nelts != 1) return svn_error_createf (SVN_ERR_CL_ARG_PARSING_ERROR, NULL, _("Exactly one file argument required")); SVN_ERR (svn_utf_cstring_to_utf8 (&filename_utf8, APR_ARRAY_IDX (args, 0, const char *), pool)); filename_utf8 = svn_path_internal_style (filename_utf8, pool); SVN_ERR (svn_stringbuf_from_file (&file_contents, filename_utf8, pool)); log_contents->data = file_contents->data; log_contents->len = file_contents->len; SVN_ERR (svn_subst_translate_string (&log_contents, log_contents, NULL, pool)); /* Open the filesystem */ SVN_ERR (open_repos (&repos, opt_state->repository_path, pool)); /* If we are bypassing the hooks system, we just hit the filesystem directly. */ if (opt_state->bypass_hooks) { svn_fs_t *fs = svn_repos_fs (repos); SVN_ERR (svn_fs_change_rev_prop (fs, opt_state->start_revision.value.number, SVN_PROP_REVISION_LOG, log_contents, pool)); } else { SVN_ERR (svn_repos_fs_change_rev_prop (repos, opt_state->start_revision.value.number, NULL, SVN_PROP_REVISION_LOG, log_contents, pool)); } return SVN_NO_ERROR; } /* This implements `svn_opt_subcommand_t'. */ static svn_error_t * subcommand_verify (apr_getopt_t *os, void *baton, apr_pool_t *pool) { struct svnadmin_opt_state *opt_state = baton; svn_repos_t *repos; svn_stream_t *stderr_stream = NULL; svn_revnum_t youngest; /* This whole process is basically just a dump of the repository with no interest in the output. */ SVN_ERR (open_repos (&repos, opt_state->repository_path, pool)); SVN_ERR (svn_fs_youngest_rev (&youngest, svn_repos_fs (repos), pool)); SVN_ERR (create_stdio_stream (&stderr_stream, apr_file_open_stderr, pool)); SVN_ERR (svn_repos_dump_fs (repos, NULL, stderr_stream, 0, youngest, FALSE, check_cancel, NULL, pool)); return SVN_NO_ERROR; } /* This implements `svn_opt_subcommand_t'. */ svn_error_t * subcommand_hotcopy (apr_getopt_t *os, void *baton, apr_pool_t *pool) { struct svnadmin_opt_state *opt_state = baton; SVN_ERR (svn_repos_hotcopy (opt_state->repository_path, opt_state->new_repository_path, opt_state->clean_logs, pool)); return SVN_NO_ERROR; } /** Main. **/ int main (int argc, const char * const *argv) { svn_error_t *err; apr_status_t apr_err; apr_allocator_t *allocator; apr_pool_t *pool; const svn_opt_subcommand_desc_t *subcommand = NULL; struct svnadmin_opt_state opt_state; apr_getopt_t *os; int opt_id; int received_opts[SVN_OPT_MAX_OPTIONS]; int i, num_opts = 0; /* Initialize the app. */ if (svn_cmdline_init ("svnadmin", stderr) != EXIT_SUCCESS) return EXIT_FAILURE; /* Create our top-level pool. Use a seperate mutexless allocator, * given this application is single threaded. */ if (apr_allocator_create (&allocator)) return EXIT_FAILURE; apr_allocator_max_free_set (allocator, SVN_ALLOCATOR_RECOMMENDED_MAX_FREE); pool = svn_pool_create_ex (NULL, allocator); apr_allocator_owner_set (allocator, pool); /* Check library versions */ err = check_lib_versions (); if (err) { svn_handle_error (err, stderr, FALSE); svn_error_clear (err); svn_pool_destroy (pool); return EXIT_FAILURE; } if (argc <= 1) { subcommand_help (NULL, NULL, pool); svn_pool_destroy (pool); return EXIT_FAILURE; } /* Initialize opt_state. */ memset (&opt_state, 0, sizeof (opt_state)); opt_state.start_revision.kind = svn_opt_revision_unspecified; opt_state.end_revision.kind = svn_opt_revision_unspecified; /* Parse options. */ apr_getopt_init (&os, pool, argc, argv); os->interleave = 1; while (1) { const char *opt_arg; const char *utf8_opt_arg; /* Parse the next option. */ apr_err = apr_getopt_long (os, options_table, &opt_id, &opt_arg); if (APR_STATUS_IS_EOF (apr_err)) break; else if (apr_err) { subcommand_help (NULL, NULL, pool); svn_pool_destroy (pool); return EXIT_FAILURE; } /* Stash the option code in an array before parsing it. */ received_opts[num_opts] = opt_id; num_opts++; switch (opt_id) { case 'r': { if (opt_state.start_revision.kind != svn_opt_revision_unspecified) { err = svn_error_create (SVN_ERR_CL_ARG_PARSING_ERROR, NULL, _("Multiple revision arguments encountered; " "try '-r M:N' instead of '-r M -r N'")); svn_handle_error (err, stderr, FALSE); svn_error_clear (err); svn_pool_destroy (pool); return EXIT_FAILURE; } if (svn_opt_parse_revision (&(opt_state.start_revision), &(opt_state.end_revision), opt_arg, pool) != 0) { err = svn_utf_cstring_to_utf8 (&utf8_opt_arg, opt_arg, pool); if (! err) err = svn_error_createf (SVN_ERR_CL_ARG_PARSING_ERROR, NULL, _("Syntax error in revision argument '%s'"), utf8_opt_arg); svn_handle_error (err, stderr, FALSE); svn_error_clear (err); svn_pool_destroy (pool); return EXIT_FAILURE; } } break; case 'q': opt_state.quiet = TRUE; break; case 'h': case '?': opt_state.help = TRUE; break; case svnadmin__version: opt_state.version = TRUE; opt_state.help = TRUE; break; case svnadmin__incremental: opt_state.incremental = TRUE; break; case svnadmin__deltas: opt_state.use_deltas = TRUE; break; case svnadmin__ignore_uuid: opt_state.uuid_action = svn_repos_load_uuid_ignore; break; case svnadmin__force_uuid: opt_state.uuid_action = svn_repos_load_uuid_force; break; case svnadmin__fs_type: err = svn_utf_cstring_to_utf8 (&opt_state.fs_type, opt_arg, pool); if (err) { svn_handle_error (err, stderr, FALSE); svn_error_clear (err); svn_pool_destroy (pool); return EXIT_FAILURE; } break; case svnadmin__parent_dir: err = svn_utf_cstring_to_utf8 (&opt_state.parent_dir, opt_arg, pool); if (err) { svn_handle_error (err, stderr, FALSE); svn_error_clear (err); svn_pool_destroy (pool); return EXIT_FAILURE; } opt_state.parent_dir = svn_path_internal_style (opt_state.parent_dir, pool); break; case svnadmin__bdb_txn_nosync: opt_state.bdb_txn_nosync = TRUE; break; case svnadmin__bdb_log_keep: opt_state.bdb_log_keep = TRUE; break; case svnadmin__bypass_hooks: opt_state.bypass_hooks = TRUE; break; case svnadmin__clean_logs: opt_state.clean_logs = TRUE; break; case svnadmin__config_dir: opt_state.config_dir = apr_pstrdup (pool, svn_path_canonicalize (opt_arg, pool)); break; case svnadmin__wait: opt_state.wait = TRUE; break; default: { subcommand_help (NULL, NULL, pool); svn_pool_destroy (pool); return EXIT_FAILURE; } } /* close `switch' */ } /* close `while' */ /* If the user asked for help, then the rest of the arguments are the names of subcommands to get help on (if any), or else they're just typos/mistakes. Whatever the case, the subcommand to actually run is subcommand_help(). */ if (opt_state.help) subcommand = svn_opt_get_canonical_subcommand (cmd_table, "help"); /* If we're not running the `help' subcommand, then look for a subcommand in the first argument. */ if (subcommand == NULL) { if (os->ind >= os->argc) { svn_error_clear (svn_cmdline_fprintf (stderr, pool, _("subcommand argument required\n"))); subcommand_help (NULL, NULL, pool); svn_pool_destroy (pool); return EXIT_FAILURE; } else { const char *first_arg = os->argv[os->ind++]; subcommand = svn_opt_get_canonical_subcommand (cmd_table, first_arg); if (subcommand == NULL) { const char* first_arg_utf8; err = svn_utf_cstring_to_utf8 (&first_arg_utf8, first_arg, pool); if (err) { svn_handle_error (err, stderr, FALSE); svn_error_clear (err); svn_pool_destroy (pool); return EXIT_FAILURE; } svn_error_clear (svn_cmdline_fprintf (stderr, pool, _("Unknown command: '%s'\n"), first_arg_utf8)); subcommand_help (NULL, NULL, pool); svn_pool_destroy (pool); return EXIT_FAILURE; } } } /* If there's a second argument, it's probably the repository. Every subcommand except `help' requires one, so we parse it out here and store it in opt_state. */ if (subcommand->cmd_func != subcommand_help) { err = parse_local_repos_path (os, &(opt_state.repository_path), pool); if(err) { svn_handle_error (err, stderr, 0); svn_opt_subcommand_help (subcommand->name, cmd_table, options_table, pool); svn_error_clear (err); svn_pool_destroy (pool); return EXIT_FAILURE; } } /* If command is hot copy the third argument will be the new repository path. */ if (subcommand->cmd_func == subcommand_hotcopy) { err = parse_local_repos_path (os, &(opt_state.new_repository_path), pool); if(err) { svn_handle_error (err, stderr, 0); svn_opt_subcommand_help (subcommand->name, cmd_table, options_table, pool); svn_error_clear (err); svn_pool_destroy (pool); return EXIT_FAILURE; } } /* Check that the subcommand wasn't passed any inappropriate options. */ for (i = 0; i < num_opts; i++) { opt_id = received_opts[i]; /* All commands implicitly accept --help, so just skip over this when we see it. Note that we don't want to include this option in their "accepted options" list because it would be awfully redundant to display it in every commands' help text. */ if (opt_id == 'h' || opt_id == '?') continue; if (! svn_opt_subcommand_takes_option (subcommand, opt_id)) { const char *optstr; const apr_getopt_option_t *badopt = svn_opt_get_option_from_code (opt_id, options_table); svn_opt_format_option (&optstr, badopt, FALSE, pool); svn_error_clear (svn_cmdline_fprintf (stderr, pool, _("subcommand '%s' doesn't accept option '%s'\n" "Type 'svnadmin help %s' for usage.\n"), subcommand->name, optstr, subcommand->name)); svn_pool_destroy (pool); return EXIT_FAILURE; } } /* Set up our cancellation support. */ setup_cancellation_signals (signal_handler); #ifdef SIGPIPE /* Disable SIGPIPE generation for the platforms that have it. */ apr_signal(SIGPIPE, SIG_IGN); #endif /* Run the subcommand. */ err = (*subcommand->cmd_func) (os, &opt_state, pool); if (err) { if (err->apr_err == SVN_ERR_CL_ARG_PARSING_ERROR) { svn_handle_error (err, stderr, 0); svn_opt_subcommand_help (subcommand->name, cmd_table, options_table, pool); } else svn_handle_error (err, stderr, 0); svn_error_clear (err); svn_pool_destroy (pool); return EXIT_FAILURE; } else { svn_pool_destroy (pool); /* Ensure that everything is written to stdout, so the user will see any print errors. */ err = svn_cmdline_fflush (stdout); if (err) { svn_handle_error(err, stderr, FALSE); svn_error_clear (err); return EXIT_FAILURE; } return EXIT_SUCCESS; } }