#define APR_WANT_STRFUNC
#include <apr_want.h>
#include <apr.h>
#include <apr_strings.h>
#include <apr_pools.h>
#include <apr_hash.h>
#include <apr_uri.h>
#include "svn_version.h"
#include "svn_types.h"
#include "svn_error.h"
#include "svn_error_codes.h"
#include "svn_pools.h"
#include "svn_delta.h"
#include "svn_ra.h"
#include "svn_xml.h"
#include "svn_path.h"
#include "svn_dso.h"
#include "svn_config.h"
#include "ra_loader.h"
#include "private/svn_ra_private.h"
#include "svn_private_config.h"
#if defined(SVN_HAVE_NEON) && defined(SVN_HAVE_SERF)
#define CHOOSABLE_DAV_MODULE
#endif
static const char * const dav_schemes[] = { "http", "https", NULL };
static const char * const svn_schemes[] = { "svn", NULL };
static const char * const local_schemes[] = { "file", NULL };
static const struct ra_lib_defn {
const char *ra_name;
const char * const *schemes;
svn_ra__init_func_t initfunc;
svn_ra_init_func_t compat_initfunc;
} ra_libraries[] = {
{
"neon",
dav_schemes,
#ifdef SVN_LIBSVN_CLIENT_LINKS_RA_NEON
svn_ra_neon__init,
svn_ra_dav_init
#endif
},
{
"svn",
svn_schemes,
#ifdef SVN_LIBSVN_CLIENT_LINKS_RA_SVN
svn_ra_svn__init,
svn_ra_svn_init
#endif
},
{
"local",
local_schemes,
#ifdef SVN_LIBSVN_CLIENT_LINKS_RA_LOCAL
svn_ra_local__init,
svn_ra_local_init
#endif
},
{
"serf",
dav_schemes,
#ifdef SVN_LIBSVN_CLIENT_LINKS_RA_SERF
svn_ra_serf__init,
svn_ra_serf_init
#endif
},
{ NULL }
};
static svn_error_t *
load_ra_module(svn_ra__init_func_t *func,
svn_ra_init_func_t *compat_func,
const char *ra_name, apr_pool_t *pool)
{
if (func)
*func = NULL;
if (compat_func)
*compat_func = NULL;
#if defined(SVN_USE_DSO) && APR_HAS_DSO
{
apr_dso_handle_t *dso;
apr_dso_handle_sym_t symbol;
const char *libname;
const char *funcname;
const char *compat_funcname;
apr_status_t status;
libname = apr_psprintf(pool, "libsvn_ra_%s-%d.so.0",
ra_name, SVN_VER_MAJOR);
funcname = apr_psprintf(pool, "svn_ra_%s__init", ra_name);
compat_funcname = apr_psprintf(pool, "svn_ra_%s_init", ra_name);
SVN_ERR(svn_dso_load(&dso, libname));
if (! dso)
return SVN_NO_ERROR;
if (func)
{
status = apr_dso_sym(&symbol, dso, funcname);
if (status)
{
return svn_error_wrap_apr(status,
_("'%s' does not define '%s()'"),
libname, funcname);
}
*func = (svn_ra__init_func_t) symbol;
}
if (compat_func)
{
status = apr_dso_sym(&symbol, dso, compat_funcname);
if (status)
{
return svn_error_wrap_apr(status,
_("'%s' does not define '%s()'"),
libname, compat_funcname);
}
*compat_func = (svn_ra_init_func_t) symbol;
}
}
#endif
return SVN_NO_ERROR;
}
static const char *
has_scheme_of(const struct ra_lib_defn *defn, const char *url)
{
const char * const *schemes;
apr_size_t len;
for (schemes = defn->schemes; *schemes != NULL; ++schemes)
{
const char *scheme = *schemes;
len = strlen(scheme);
if (strncasecmp(scheme, url, len) == 0 &&
(url[len] == ':' || url[len] == '+'))
return scheme;
}
return NULL;
}
static svn_error_t *
check_ra_version(const svn_version_t *ra_version, const char *scheme)
{
const svn_version_t *my_version = svn_ra_version();
if (!svn_ver_equal(my_version, ra_version))
return svn_error_createf(SVN_ERR_VERSION_MISMATCH, NULL,
_("Mismatched RA version for '%s':"
" found %d.%d.%d%s,"
" expected %d.%d.%d%s"),
scheme,
my_version->major, my_version->minor,
my_version->patch, my_version->tag,
ra_version->major, ra_version->minor,
ra_version->patch, ra_version->tag);
return SVN_NO_ERROR;
}
svn_error_t *svn_ra_initialize(apr_pool_t *pool)
{
return SVN_NO_ERROR;
}
svn_error_t *
svn_ra_create_callbacks(svn_ra_callbacks2_t **callbacks,
apr_pool_t *pool)
{
*callbacks = apr_pcalloc(pool, sizeof(**callbacks));
return SVN_NO_ERROR;
}
svn_error_t *svn_ra_open3(svn_ra_session_t **session_p,
const char *repos_URL,
const char *uuid,
const svn_ra_callbacks2_t *callbacks,
void *callback_baton,
apr_hash_t *config,
apr_pool_t *pool)
{
svn_ra_session_t *session;
const struct ra_lib_defn *defn;
const svn_ra__vtable_t *vtable = NULL;
svn_config_t *servers = NULL;
const char *server_group;
apr_uri_t repos_URI;
apr_status_t apr_err;
#ifdef CHOOSABLE_DAV_MODULE
const char *http_library = "neon";
#endif
svn_boolean_t store_passwords = SVN_CONFIG_DEFAULT_OPTION_STORE_PASSWORDS;
svn_boolean_t store_auth_creds = SVN_CONFIG_DEFAULT_OPTION_STORE_AUTH_CREDS;
const char *store_plaintext_passwords
= SVN_CONFIG_DEFAULT_OPTION_STORE_PLAINTEXT_PASSWORDS;
svn_boolean_t store_pp = SVN_CONFIG_DEFAULT_OPTION_STORE_SSL_CLIENT_CERT_PP;
const char *store_pp_plaintext
= SVN_CONFIG_DEFAULT_OPTION_STORE_SSL_CLIENT_CERT_PP_PLAINTEXT;
if (callbacks->auth_baton)
{
if (svn_auth_get_parameter(callbacks->auth_baton,
SVN_AUTH_PARAM_DONT_STORE_PASSWORDS) != NULL)
store_passwords = FALSE;
if (svn_auth_get_parameter(callbacks->auth_baton,
SVN_AUTH_PARAM_NO_AUTH_CACHE) != NULL)
store_auth_creds = FALSE;
}
if (config)
{
servers = apr_hash_get(config, SVN_CONFIG_CATEGORY_SERVERS,
APR_HASH_KEY_STRING);
if (servers)
{
SVN_ERR(svn_config_get_bool
(servers, &store_passwords, SVN_CONFIG_SECTION_GLOBAL,
SVN_CONFIG_OPTION_STORE_PASSWORDS,
store_passwords));
SVN_ERR(svn_config_get_yes_no_ask
(servers, &store_plaintext_passwords, SVN_CONFIG_SECTION_GLOBAL,
SVN_CONFIG_OPTION_STORE_PLAINTEXT_PASSWORDS,
SVN_CONFIG_DEFAULT_OPTION_STORE_PLAINTEXT_PASSWORDS));
SVN_ERR(svn_config_get_bool
(servers, &store_pp, SVN_CONFIG_SECTION_GLOBAL,
SVN_CONFIG_OPTION_STORE_SSL_CLIENT_CERT_PP,
store_pp));
SVN_ERR(svn_config_get_yes_no_ask
(servers, &store_pp_plaintext,
SVN_CONFIG_SECTION_GLOBAL,
SVN_CONFIG_OPTION_STORE_SSL_CLIENT_CERT_PP_PLAINTEXT,
SVN_CONFIG_DEFAULT_OPTION_STORE_SSL_CLIENT_CERT_PP_PLAINTEXT));
SVN_ERR(svn_config_get_bool
(servers, &store_auth_creds, SVN_CONFIG_SECTION_GLOBAL,
SVN_CONFIG_OPTION_STORE_AUTH_CREDS,
store_auth_creds));
apr_err = apr_uri_parse(pool, repos_URL, &repos_URI);
if (apr_err != APR_SUCCESS || repos_URI.hostname == NULL)
return svn_error_createf(SVN_ERR_RA_ILLEGAL_URL, NULL,
_("Illegal repository URL '%s'"),
repos_URL);
server_group = svn_config_find_group(servers, repos_URI.hostname,
SVN_CONFIG_SECTION_GROUPS, pool);
if (server_group)
{
SVN_ERR(svn_config_get_bool(servers, &store_auth_creds,
server_group,
SVN_CONFIG_OPTION_STORE_AUTH_CREDS,
store_auth_creds));
SVN_ERR(svn_config_get_bool(servers, &store_passwords,
server_group,
SVN_CONFIG_OPTION_STORE_PASSWORDS,
store_passwords));
SVN_ERR(svn_config_get_yes_no_ask
(servers, &store_plaintext_passwords, server_group,
SVN_CONFIG_OPTION_STORE_PLAINTEXT_PASSWORDS,
store_plaintext_passwords));
SVN_ERR(svn_config_get_bool
(servers, &store_pp,
server_group, SVN_CONFIG_OPTION_STORE_SSL_CLIENT_CERT_PP,
store_pp));
SVN_ERR(svn_config_get_yes_no_ask
(servers, &store_pp_plaintext, server_group,
SVN_CONFIG_OPTION_STORE_SSL_CLIENT_CERT_PP_PLAINTEXT,
store_pp_plaintext));
}
#ifdef CHOOSABLE_DAV_MODULE
http_library
= svn_config_get_server_setting(servers,
server_group,
SVN_CONFIG_OPTION_HTTP_LIBRARY,
"neon");
if (strcmp(http_library, "neon") != 0 &&
strcmp(http_library, "serf") != 0)
return svn_error_createf(SVN_ERR_BAD_CONFIG_VALUE, NULL,
_("Invalid config: unknown HTTP library "
"'%s'"),
http_library);
#endif
}
}
if (callbacks->auth_baton)
{
if (! store_passwords)
svn_auth_set_parameter(callbacks->auth_baton,
SVN_AUTH_PARAM_DONT_STORE_PASSWORDS, "");
svn_auth_set_parameter(callbacks->auth_baton,
SVN_AUTH_PARAM_STORE_PLAINTEXT_PASSWORDS,
store_plaintext_passwords);
if (! store_pp)
svn_auth_set_parameter(callbacks->auth_baton,
SVN_AUTH_PARAM_DONT_STORE_SSL_CLIENT_CERT_PP,
"");
svn_auth_set_parameter(callbacks->auth_baton,
SVN_AUTH_PARAM_STORE_SSL_CLIENT_CERT_PP_PLAINTEXT,
store_pp_plaintext);
if (! store_auth_creds)
svn_auth_set_parameter(callbacks->auth_baton,
SVN_AUTH_PARAM_NO_AUTH_CACHE, "");
}
for (defn = ra_libraries; defn->ra_name != NULL; ++defn)
{
const char *scheme;
if ((scheme = has_scheme_of(defn, repos_URL)))
{
svn_ra__init_func_t initfunc = defn->initfunc;
#ifdef CHOOSABLE_DAV_MODULE
if (defn->schemes == dav_schemes
&& strcmp(defn->ra_name, http_library) != 0)
continue;
#endif
if (! initfunc)
SVN_ERR(load_ra_module(&initfunc, NULL, defn->ra_name,
pool));
if (! initfunc)
continue;
SVN_ERR(initfunc(svn_ra_version(), &vtable, pool));
SVN_ERR(check_ra_version(vtable->get_version(), scheme));
break;
}
}
if (vtable == NULL)
return svn_error_createf(SVN_ERR_RA_ILLEGAL_URL, NULL,
_("Unrecognized URL scheme for '%s'"),
repos_URL);
session = apr_pcalloc(pool, sizeof(*session));
session->vtable = vtable;
session->pool = pool;
SVN_ERR(vtable->open_session(session, repos_URL, callbacks, callback_baton,
config, pool));
if (uuid)
{
const char *repository_uuid;
SVN_ERR(vtable->get_uuid(session, &repository_uuid, pool));
if (strcmp(uuid, repository_uuid) != 0)
{
return svn_error_createf(SVN_ERR_RA_UUID_MISMATCH, NULL,
_("Repository UUID '%s' doesn't match "
"expected UUID '%s'"),
repository_uuid, uuid);
}
}
*session_p = session;
return SVN_NO_ERROR;
}
svn_error_t *svn_ra_reparent(svn_ra_session_t *session,
const char *url,
apr_pool_t *pool)
{
const char *repos_root;
SVN_ERR(svn_ra_get_repos_root2(session, &repos_root, pool));
if (! svn_path_is_ancestor(repos_root, url))
return svn_error_createf(SVN_ERR_RA_ILLEGAL_URL, NULL,
_("'%s' isn't in the same repository as '%s'"),
url, repos_root);
return session->vtable->reparent(session, url, pool);
}
svn_error_t *svn_ra_get_session_url(svn_ra_session_t *session,
const char **url,
apr_pool_t *pool)
{
return session->vtable->get_session_url(session, url, pool);
}
svn_error_t *svn_ra_get_latest_revnum(svn_ra_session_t *session,
svn_revnum_t *latest_revnum,
apr_pool_t *pool)
{
return session->vtable->get_latest_revnum(session, latest_revnum, pool);
}
svn_error_t *svn_ra_get_dated_revision(svn_ra_session_t *session,
svn_revnum_t *revision,
apr_time_t tm,
apr_pool_t *pool)
{
return session->vtable->get_dated_revision(session, revision, tm, pool);
}
svn_error_t *svn_ra_change_rev_prop(svn_ra_session_t *session,
svn_revnum_t rev,
const char *name,
const svn_string_t *value,
apr_pool_t *pool)
{
SVN_ERR_ASSERT(SVN_IS_VALID_REVNUM(rev));
return session->vtable->change_rev_prop(session, rev, name, value, pool);
}
svn_error_t *svn_ra_rev_proplist(svn_ra_session_t *session,
svn_revnum_t rev,
apr_hash_t **props,
apr_pool_t *pool)
{
SVN_ERR_ASSERT(SVN_IS_VALID_REVNUM(rev));
return session->vtable->rev_proplist(session, rev, props, pool);
}
svn_error_t *svn_ra_rev_prop(svn_ra_session_t *session,
svn_revnum_t rev,
const char *name,
svn_string_t **value,
apr_pool_t *pool)
{
SVN_ERR_ASSERT(SVN_IS_VALID_REVNUM(rev));
return session->vtable->rev_prop(session, rev, name, value, pool);
}
svn_error_t *svn_ra_get_commit_editor3(svn_ra_session_t *session,
const svn_delta_editor_t **editor,
void **edit_baton,
apr_hash_t *revprop_table,
svn_commit_callback2_t callback,
void *callback_baton,
apr_hash_t *lock_tokens,
svn_boolean_t keep_locks,
apr_pool_t *pool)
{
return session->vtable->get_commit_editor(session, editor, edit_baton,
revprop_table, callback,
callback_baton, lock_tokens,
keep_locks, pool);
}
svn_error_t *svn_ra_get_file(svn_ra_session_t *session,
const char *path,
svn_revnum_t revision,
svn_stream_t *stream,
svn_revnum_t *fetched_rev,
apr_hash_t **props,
apr_pool_t *pool)
{
SVN_ERR_ASSERT(*path != '/');
return session->vtable->get_file(session, path, revision, stream,
fetched_rev, props, pool);
}
svn_error_t *svn_ra_get_dir(svn_ra_session_t *session,
const char *path,
svn_revnum_t revision,
apr_hash_t **dirents,
svn_revnum_t *fetched_rev,
apr_hash_t **props,
apr_pool_t *pool)
{
SVN_ERR_ASSERT(*path != '/');
return session->vtable->get_dir(session, dirents, fetched_rev, props,
path, revision, SVN_DIRENT_ALL, pool);
}
svn_error_t *svn_ra_get_dir2(svn_ra_session_t *session,
apr_hash_t **dirents,
svn_revnum_t *fetched_rev,
apr_hash_t **props,
const char *path,
svn_revnum_t revision,
apr_uint32_t dirent_fields,
apr_pool_t *pool)
{
SVN_ERR_ASSERT(*path != '/');
return session->vtable->get_dir(session, dirents, fetched_rev, props,
path, revision, dirent_fields, pool);
}
svn_error_t *svn_ra_get_mergeinfo(svn_ra_session_t *session,
svn_mergeinfo_catalog_t *catalog,
const apr_array_header_t *paths,
svn_revnum_t revision,
svn_mergeinfo_inheritance_t inherit,
svn_boolean_t include_descendants,
apr_pool_t *pool)
{
svn_error_t *err;
int i;
for (i = 0; i < paths->nelts; i++)
{
const char *path = APR_ARRAY_IDX(paths, i, const char *);
SVN_ERR_ASSERT(*path != '/');
}
err = svn_ra__assert_mergeinfo_capable_server(session, NULL, pool);
if (err)
{
*catalog = NULL;
return err;
}
return session->vtable->get_mergeinfo(session, catalog, paths,
revision, inherit,
include_descendants, pool);
}
svn_error_t *svn_ra_do_update2(svn_ra_session_t *session,
const svn_ra_reporter3_t **reporter,
void **report_baton,
svn_revnum_t revision_to_update_to,
const char *update_target,
svn_depth_t depth,
svn_boolean_t send_copyfrom_args,
const svn_delta_editor_t *update_editor,
void *update_baton,
apr_pool_t *pool)
{
SVN_ERR_ASSERT(svn_path_is_empty(update_target)
|| svn_path_is_single_path_component(update_target));
return session->vtable->do_update(session,
reporter, report_baton,
revision_to_update_to, update_target,
depth, send_copyfrom_args,
update_editor, update_baton,
pool);
}
svn_error_t *svn_ra_do_switch2(svn_ra_session_t *session,
const svn_ra_reporter3_t **reporter,
void **report_baton,
svn_revnum_t revision_to_switch_to,
const char *switch_target,
svn_depth_t depth,
const char *switch_url,
const svn_delta_editor_t *switch_editor,
void *switch_baton,
apr_pool_t *pool)
{
SVN_ERR_ASSERT(svn_path_is_empty(switch_target)
|| svn_path_is_single_path_component(switch_target));
return session->vtable->do_switch(session,
reporter, report_baton,
revision_to_switch_to, switch_target,
depth, switch_url, switch_editor,
switch_baton, pool);
}
svn_error_t *svn_ra_do_status2(svn_ra_session_t *session,
const svn_ra_reporter3_t **reporter,
void **report_baton,
const char *status_target,
svn_revnum_t revision,
svn_depth_t depth,
const svn_delta_editor_t *status_editor,
void *status_baton,
apr_pool_t *pool)
{
SVN_ERR_ASSERT(svn_path_is_empty(status_target)
|| svn_path_is_single_path_component(status_target));
return session->vtable->do_status(session,
reporter, report_baton,
status_target, revision, depth,
status_editor, status_baton, pool);
}
svn_error_t *svn_ra_do_diff3(svn_ra_session_t *session,
const svn_ra_reporter3_t **reporter,
void **report_baton,
svn_revnum_t revision,
const char *diff_target,
svn_depth_t depth,
svn_boolean_t ignore_ancestry,
svn_boolean_t text_deltas,
const char *versus_url,
const svn_delta_editor_t *diff_editor,
void *diff_baton,
apr_pool_t *pool)
{
SVN_ERR_ASSERT(svn_path_is_empty(diff_target)
|| svn_path_is_single_path_component(diff_target));
return session->vtable->do_diff(session,
reporter, report_baton,
revision, diff_target,
depth, ignore_ancestry,
text_deltas, versus_url, diff_editor,
diff_baton, pool);
}
svn_error_t *svn_ra_get_log2(svn_ra_session_t *session,
const apr_array_header_t *paths,
svn_revnum_t start,
svn_revnum_t end,
int limit,
svn_boolean_t discover_changed_paths,
svn_boolean_t strict_node_history,
svn_boolean_t include_merged_revisions,
const apr_array_header_t *revprops,
svn_log_entry_receiver_t receiver,
void *receiver_baton,
apr_pool_t *pool)
{
if (paths)
{
int i;
for (i = 0; i < paths->nelts; i++)
{
const char *path = APR_ARRAY_IDX(paths, i, const char *);
SVN_ERR_ASSERT(*path != '/');
}
}
if (include_merged_revisions)
SVN_ERR(svn_ra__assert_mergeinfo_capable_server(session, NULL, pool));
return session->vtable->get_log(session, paths, start, end, limit,
discover_changed_paths, strict_node_history,
include_merged_revisions, revprops,
receiver, receiver_baton, pool);
}
svn_error_t *svn_ra_check_path(svn_ra_session_t *session,
const char *path,
svn_revnum_t revision,
svn_node_kind_t *kind,
apr_pool_t *pool)
{
SVN_ERR_ASSERT(*path != '/');
return session->vtable->check_path(session, path, revision, kind, pool);
}
svn_error_t *svn_ra_stat(svn_ra_session_t *session,
const char *path,
svn_revnum_t revision,
svn_dirent_t **dirent,
apr_pool_t *pool)
{
SVN_ERR_ASSERT(*path != '/');
return session->vtable->stat(session, path, revision, dirent, pool);
}
svn_error_t *svn_ra_get_uuid2(svn_ra_session_t *session,
const char **uuid,
apr_pool_t *pool)
{
SVN_ERR(session->vtable->get_uuid(session, uuid, pool));
*uuid = *uuid ? apr_pstrdup(pool, *uuid) : NULL;
return SVN_NO_ERROR;
}
svn_error_t *svn_ra_get_uuid(svn_ra_session_t *session,
const char **uuid,
apr_pool_t *pool)
{
return session->vtable->get_uuid(session, uuid, pool);
}
svn_error_t *svn_ra_get_repos_root2(svn_ra_session_t *session,
const char **url,
apr_pool_t *pool)
{
SVN_ERR(session->vtable->get_repos_root(session, url, pool));
*url = *url ? apr_pstrdup(pool, *url) : NULL;
return SVN_NO_ERROR;
}
svn_error_t *svn_ra_get_repos_root(svn_ra_session_t *session,
const char **url,
apr_pool_t *pool)
{
return session->vtable->get_repos_root(session, url, pool);
}
svn_error_t *svn_ra_get_locations(svn_ra_session_t *session,
apr_hash_t **locations,
const char *path,
svn_revnum_t peg_revision,
apr_array_header_t *location_revisions,
apr_pool_t *pool)
{
svn_error_t *err;
SVN_ERR_ASSERT(*path != '/');
err = session->vtable->get_locations(session, locations, path,
peg_revision, location_revisions, pool);
if (err && (err->apr_err == SVN_ERR_RA_NOT_IMPLEMENTED))
{
svn_error_clear(err);
err = svn_ra__locations_from_log(session, locations, path,
peg_revision, location_revisions,
pool);
}
return err;
}
svn_error_t *
svn_ra_get_location_segments(svn_ra_session_t *session,
const char *path,
svn_revnum_t peg_revision,
svn_revnum_t start_rev,
svn_revnum_t end_rev,
svn_location_segment_receiver_t receiver,
void *receiver_baton,
apr_pool_t *pool)
{
svn_error_t *err;
SVN_ERR_ASSERT(*path != '/');
err = session->vtable->get_location_segments(session, path, peg_revision,
start_rev, end_rev,
receiver, receiver_baton, pool);
if (err && (err->apr_err == SVN_ERR_RA_NOT_IMPLEMENTED))
{
svn_error_clear(err);
err = svn_ra__location_segments_from_log(session, path,
peg_revision, start_rev,
end_rev, receiver,
receiver_baton, pool);
}
return err;
}
svn_error_t *svn_ra_get_file_revs2(svn_ra_session_t *session,
const char *path,
svn_revnum_t start,
svn_revnum_t end,
svn_boolean_t include_merged_revisions,
svn_file_rev_handler_t handler,
void *handler_baton,
apr_pool_t *pool)
{
svn_error_t *err;
SVN_ERR_ASSERT(*path != '/');
if (include_merged_revisions)
SVN_ERR(svn_ra__assert_mergeinfo_capable_server(session, NULL, pool));
err = session->vtable->get_file_revs(session, path, start, end,
include_merged_revisions,
handler, handler_baton, pool);
if (err && (err->apr_err == SVN_ERR_RA_NOT_IMPLEMENTED))
{
svn_error_clear(err);
err = svn_ra__file_revs_from_log(session, path, start, end,
handler, handler_baton, pool);
}
return err;
}
svn_error_t *svn_ra_lock(svn_ra_session_t *session,
apr_hash_t *path_revs,
const char *comment,
svn_boolean_t steal_lock,
svn_ra_lock_callback_t lock_func,
void *lock_baton,
apr_pool_t *pool)
{
apr_hash_index_t *hi;
for (hi = apr_hash_first(NULL, path_revs); hi; hi = apr_hash_next(hi))
{
const void *path;
apr_hash_this(hi, &path, NULL, NULL);
SVN_ERR_ASSERT(*((const char *)path) != '/');
}
if (comment && ! svn_xml_is_xml_safe(comment, strlen(comment)))
return svn_error_create
(SVN_ERR_XML_UNESCAPABLE_DATA, NULL,
_("Lock comment contains illegal characters"));
return session->vtable->lock(session, path_revs, comment, steal_lock,
lock_func, lock_baton, pool);
}
svn_error_t *svn_ra_unlock(svn_ra_session_t *session,
apr_hash_t *path_tokens,
svn_boolean_t break_lock,
svn_ra_lock_callback_t lock_func,
void *lock_baton,
apr_pool_t *pool)
{
apr_hash_index_t *hi;
for (hi = apr_hash_first(NULL, path_tokens); hi; hi = apr_hash_next(hi))
{
const void *path;
apr_hash_this(hi, &path, NULL, NULL);
SVN_ERR_ASSERT(*((const char *)path) != '/');
}
return session->vtable->unlock(session, path_tokens, break_lock,
lock_func, lock_baton, pool);
}
svn_error_t *svn_ra_get_lock(svn_ra_session_t *session,
svn_lock_t **lock,
const char *path,
apr_pool_t *pool)
{
SVN_ERR_ASSERT(*path != '/');
return session->vtable->get_lock(session, lock, path, pool);
}
svn_error_t *svn_ra_get_locks(svn_ra_session_t *session,
apr_hash_t **locks,
const char *path,
apr_pool_t *pool)
{
SVN_ERR_ASSERT(*path != '/');
return session->vtable->get_locks(session, locks, path, pool);
}
svn_error_t *svn_ra_replay(svn_ra_session_t *session,
svn_revnum_t revision,
svn_revnum_t low_water_mark,
svn_boolean_t text_deltas,
const svn_delta_editor_t *editor,
void *edit_baton,
apr_pool_t *pool)
{
return session->vtable->replay(session, revision, low_water_mark,
text_deltas, editor, edit_baton, pool);
}
svn_error_t *
svn_ra_replay_range(svn_ra_session_t *session,
svn_revnum_t start_revision,
svn_revnum_t end_revision,
svn_revnum_t low_water_mark,
svn_boolean_t text_deltas,
svn_ra_replay_revstart_callback_t revstart_func,
svn_ra_replay_revfinish_callback_t revfinish_func,
void *replay_baton,
apr_pool_t *pool)
{
svn_error_t *err =
session->vtable->replay_range(session, start_revision, end_revision,
low_water_mark, text_deltas,
revstart_func, revfinish_func,
replay_baton, pool);
if (err && (err->apr_err == SVN_ERR_RA_NOT_IMPLEMENTED))
{
apr_pool_t *subpool = svn_pool_create(pool);
svn_revnum_t rev;
svn_error_clear(err);
err = SVN_NO_ERROR;
for (rev = start_revision ; rev <= end_revision ; rev++)
{
const svn_delta_editor_t *editor;
void *edit_baton;
apr_hash_t *rev_props;
svn_pool_clear(subpool);
SVN_ERR(svn_ra_rev_proplist(session, rev, &rev_props, subpool));
SVN_ERR(revstart_func(rev, replay_baton,
&editor, &edit_baton,
rev_props,
subpool));
SVN_ERR(svn_ra_replay(session, rev, low_water_mark,
text_deltas, editor, edit_baton,
subpool));
SVN_ERR(revfinish_func(rev, replay_baton,
editor, edit_baton,
rev_props,
subpool));
}
svn_pool_destroy(subpool);
}
return err;
}
svn_error_t *svn_ra_has_capability(svn_ra_session_t *session,
svn_boolean_t *has,
const char *capability,
apr_pool_t *pool)
{
return session->vtable->has_capability(session, has, capability, pool);
}
svn_error_t *
svn_ra_get_deleted_rev(svn_ra_session_t *session,
const char *path,
svn_revnum_t peg_revision,
svn_revnum_t end_revision,
svn_revnum_t *revision_deleted,
apr_pool_t *pool)
{
svn_error_t *err;
SVN_ERR_ASSERT(*path != '/');
if (!SVN_IS_VALID_REVNUM(peg_revision))
return svn_error_createf(SVN_ERR_CLIENT_BAD_REVISION, NULL,
_("Invalid peg revision %ld"), peg_revision);
if (!SVN_IS_VALID_REVNUM(end_revision))
return svn_error_createf(SVN_ERR_CLIENT_BAD_REVISION, NULL,
_("Invalid end revision %ld"), end_revision);
if (end_revision <= peg_revision)
return svn_error_create(SVN_ERR_CLIENT_BAD_REVISION, NULL,
_("Peg revision must precede end revision"));
err = session->vtable->get_deleted_rev(session, path,
peg_revision,
end_revision,
revision_deleted,
pool);
if (err && (err->apr_err == SVN_ERR_UNSUPPORTED_FEATURE
|| err->apr_err == SVN_ERR_RA_NOT_IMPLEMENTED))
{
svn_error_clear(err);
err = svn_ra__get_deleted_rev_from_log(session, path, peg_revision,
end_revision, revision_deleted,
pool);
}
return err;
}
svn_error_t *
svn_ra_print_modules(svn_stringbuf_t *output,
apr_pool_t *pool)
{
const struct ra_lib_defn *defn;
const char * const *schemes;
svn_ra__init_func_t initfunc;
const svn_ra__vtable_t *vtable;
apr_pool_t *iterpool = svn_pool_create(pool);
for (defn = ra_libraries; defn->ra_name != NULL; ++defn)
{
char *line;
svn_pool_clear(iterpool);
initfunc = defn->initfunc;
if (! initfunc)
SVN_ERR(load_ra_module(&initfunc, NULL, defn->ra_name,
iterpool));
if (initfunc)
{
SVN_ERR(initfunc(svn_ra_version(), &vtable, iterpool));
SVN_ERR(check_ra_version(vtable->get_version(), defn->ra_name));
line = apr_psprintf(iterpool, "* ra_%s : %s\n",
defn->ra_name,
vtable->get_description());
svn_stringbuf_appendcstr(output, line);
for (schemes = vtable->get_schemes(iterpool); *schemes != NULL;
++schemes)
{
line = apr_psprintf(iterpool, _(" - handles '%s' scheme\n"),
*schemes);
svn_stringbuf_appendcstr(output, line);
}
}
}
svn_pool_destroy(iterpool);
return SVN_NO_ERROR;
}
svn_error_t *
svn_ra_print_ra_libraries(svn_stringbuf_t **descriptions,
void *ra_baton,
apr_pool_t *pool)
{
*descriptions = svn_stringbuf_create("", pool);
return svn_ra_print_modules(*descriptions, pool);
}
const svn_version_t *
svn_ra_version(void)
{
SVN_VERSION_BODY;
}
svn_error_t *
svn_ra_init_ra_libs(void **ra_baton,
apr_pool_t *pool)
{
*ra_baton = pool;
return SVN_NO_ERROR;
}
svn_error_t *
svn_ra_get_ra_library(svn_ra_plugin_t **library,
void *ra_baton,
const char *url,
apr_pool_t *pool)
{
const struct ra_lib_defn *defn;
apr_pool_t *load_pool = ra_baton;
apr_hash_t *ht = apr_hash_make(pool);
for (defn = ra_libraries; defn->ra_name != NULL; ++defn)
{
const char *scheme;
if ((scheme = has_scheme_of(defn, url)))
{
svn_ra_init_func_t compat_initfunc = defn->compat_initfunc;
if (! compat_initfunc)
{
SVN_ERR(load_ra_module
(NULL, &compat_initfunc, defn->ra_name, load_pool));
}
if (! compat_initfunc)
{
continue;
}
SVN_ERR(compat_initfunc(SVN_RA_ABI_VERSION, load_pool, ht));
*library = apr_hash_get(ht, scheme, APR_HASH_KEY_STRING);
if (! *library)
break;
return check_ra_version((*library)->get_version(), scheme);
}
}
*library = NULL;
return svn_error_createf(SVN_ERR_RA_ILLEGAL_URL, NULL,
_("Unrecognized URL scheme '%s'"), url);
}
#ifndef SVN_LIBSVN_CLIENT_LINKS_RA_NEON
svn_error_t *
svn_ra_dav_init(int abi_version,
apr_pool_t *pool,
apr_hash_t *hash)
{
return svn_error_create(SVN_ERR_RA_NOT_IMPLEMENTED, NULL, NULL);
}
#endif
#ifndef SVN_LIBSVN_CLIENT_LINKS_RA_SVN
svn_error_t *
svn_ra_svn_init(int abi_version,
apr_pool_t *pool,
apr_hash_t *hash)
{
return svn_error_create(SVN_ERR_RA_NOT_IMPLEMENTED, NULL, NULL);
}
#endif
#ifndef SVN_LIBSVN_CLIENT_LINKS_RA_LOCAL
svn_error_t *
svn_ra_local_init(int abi_version,
apr_pool_t *pool,
apr_hash_t *hash)
{
return svn_error_create(SVN_ERR_RA_NOT_IMPLEMENTED, NULL, NULL);
}
#endif
#ifndef SVN_LIBSVN_CLIENT_LINKS_RA_SERF
svn_error_t *
svn_ra_serf_init(int abi_version,
apr_pool_t *pool,
apr_hash_t *hash)
{
return svn_error_create(SVN_ERR_RA_NOT_IMPLEMENTED, NULL, NULL);
}
#endif