#include "db_config.h"
#ifndef lint
static const char revid[] = "$Id: xa_map.c,v 1.2 2004/03/30 01:24:48 jtownsen Exp $";
#endif
#ifndef NO_SYSTEM_INCLUDES
#include <sys/types.h>
#include <string.h>
#endif
#include "db_int.h"
#include "dbinc/txn.h"
int
__db_rmid_to_env(rmid, envp)
int rmid;
DB_ENV **envp;
{
DB_ENV *env;
env = TAILQ_FIRST(&DB_GLOBAL(db_envq));
if (env != NULL && env->xa_rmid == rmid) {
*envp = env;
return (0);
}
for (; env != NULL; env = TAILQ_NEXT(env, links))
if (env->xa_rmid == rmid) {
TAILQ_REMOVE(&DB_GLOBAL(db_envq), env, links);
TAILQ_INSERT_HEAD(&DB_GLOBAL(db_envq), env, links);
*envp = env;
return (0);
}
return (1);
}
int
__db_xid_to_txn(dbenv, xid, offp)
DB_ENV *dbenv;
XID *xid;
size_t *offp;
{
struct __txn_detail *td;
return (__txn_map_gid(dbenv, (u_int8_t *)xid->data, &td, offp));
}
int
__db_map_rmid(rmid, env)
int rmid;
DB_ENV *env;
{
env->xa_rmid = rmid;
TAILQ_INSERT_TAIL(&DB_GLOBAL(db_envq), env, links);
return (0);
}
int
__db_unmap_rmid(rmid)
int rmid;
{
DB_ENV *e;
for (e = TAILQ_FIRST(&DB_GLOBAL(db_envq));
e->xa_rmid != rmid;
e = TAILQ_NEXT(e, links));
if (e == NULL)
return (EINVAL);
TAILQ_REMOVE(&DB_GLOBAL(db_envq), e, links);
return (0);
}
int
__db_map_xid(env, xid, off)
DB_ENV *env;
XID *xid;
size_t off;
{
REGINFO *infop;
TXN_DETAIL *td;
infop = &((DB_TXNMGR *)env->tx_handle)->reginfo;
td = (TXN_DETAIL *)R_ADDR(infop, off);
R_LOCK(env, infop);
memcpy(td->xid, xid->data, XIDDATASIZE);
td->bqual = (u_int32_t)xid->bqual_length;
td->gtrid = (u_int32_t)xid->gtrid_length;
td->format = (int32_t)xid->formatID;
R_UNLOCK(env, infop);
return (0);
}
void
__db_unmap_xid(env, xid, off)
DB_ENV *env;
XID *xid;
size_t off;
{
TXN_DETAIL *td;
COMPQUIET(xid, NULL);
td = (TXN_DETAIL *)R_ADDR(&((DB_TXNMGR *)env->tx_handle)->reginfo, off);
memset(td->xid, 0, sizeof(td->xid));
}