#include <apr_pools.h>
#include "svn_dirent_uri.h"
#include "svn_types.h"
#include "svn_pools.h"
#include "blncache.h"
typedef struct baseline_info_t
{
const char *bc_url;
svn_revnum_t revision;
} baseline_info_t;
struct svn_ra_serf__blncache_t
{
apr_hash_t *revnum_to_bc;
apr_hash_t *baseline_info;
};
static baseline_info_t *
baseline_info_make(const char *bc_url,
svn_revnum_t revision,
apr_pool_t *pool)
{
baseline_info_t *result = apr_palloc(pool, sizeof(*result));
result->bc_url = apr_pstrdup(pool, bc_url);
result->revision = revision;
return result;
}
static void
hash_set_copy(apr_hash_t *hash,
const void *key,
apr_ssize_t klen,
const void *val)
{
if (klen == APR_HASH_KEY_STRING)
klen = strlen(key);
apr_hash_set(hash, apr_pmemdup(apr_hash_pool_get(hash), key, klen),
klen, val);
}
svn_error_t *
svn_ra_serf__blncache_create(svn_ra_serf__blncache_t **blncache_p,
apr_pool_t *pool)
{
svn_ra_serf__blncache_t *blncache = apr_pcalloc(pool, sizeof(*blncache));
apr_pool_t *cache_pool;
cache_pool = svn_pool_create(pool);
blncache->revnum_to_bc = apr_hash_make(cache_pool);
blncache->baseline_info = apr_hash_make(cache_pool);
*blncache_p = blncache;
return SVN_NO_ERROR;
}
#define MAX_CACHE_SIZE 1000
svn_error_t *
svn_ra_serf__blncache_set(svn_ra_serf__blncache_t *blncache,
const char *baseline_url,
svn_revnum_t revision,
const char *bc_url,
apr_pool_t *pool)
{
if (bc_url && SVN_IS_VALID_REVNUM(revision))
{
apr_pool_t *cache_pool = apr_hash_pool_get(blncache->revnum_to_bc);
if (MAX_CACHE_SIZE < (apr_hash_count(blncache->baseline_info)
+ apr_hash_count(blncache->revnum_to_bc)))
{
svn_pool_clear(cache_pool);
blncache->revnum_to_bc = apr_hash_make(cache_pool);
blncache->baseline_info = apr_hash_make(cache_pool);
}
hash_set_copy(blncache->revnum_to_bc, &revision, sizeof(revision),
apr_pstrdup(cache_pool, bc_url));
if (baseline_url)
{
hash_set_copy(blncache->baseline_info, baseline_url,
APR_HASH_KEY_STRING,
baseline_info_make(bc_url, revision, cache_pool));
}
}
return SVN_NO_ERROR;
}
#undef MAX_CACHE_SIZE
svn_error_t *
svn_ra_serf__blncache_get_bc_url(const char **bc_url_p,
svn_ra_serf__blncache_t *blncache,
svn_revnum_t revnum,
apr_pool_t *pool)
{
const char *value = apr_hash_get(blncache->revnum_to_bc,
&revnum, sizeof(revnum));
*bc_url_p = value ? apr_pstrdup(pool, value) : NULL;
return SVN_NO_ERROR;
}
svn_error_t *
svn_ra_serf__blncache_get_baseline_info(const char **bc_url_p,
svn_revnum_t *revision_p,
svn_ra_serf__blncache_t *blncache,
const char *baseline_url,
apr_pool_t *pool)
{
baseline_info_t *info = apr_hash_get(blncache->baseline_info, baseline_url,
APR_HASH_KEY_STRING);
if (info)
{
*bc_url_p = apr_pstrdup(pool, info->bc_url);
*revision_p = info->revision;
}
else
{
*bc_url_p = NULL;
*revision_p = SVN_INVALID_REVNUM;
}
return SVN_NO_ERROR;
}