#include "db_config.h"
#include "db_int.h"
#include "dbinc/txn.h"
int
__db_rmid_to_env(rmid, envp)
int rmid;
ENV **envp;
{
ENV *env;
env = TAILQ_FIRST(&DB_GLOBAL(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(envq), env, links);
TAILQ_INSERT_HEAD(&DB_GLOBAL(envq), env, links);
*envp = env;
return (0);
}
return (1);
}
int
__db_xid_to_txn(env, xid, offp)
ENV *env;
XID *xid;
roff_t *offp;
{
struct __txn_detail *td;
return (__txn_map_gid(env, (u_int8_t *)xid->data, &td, offp));
}
int
__db_map_rmid(rmid, env)
int rmid;
ENV *env;
{
env->xa_rmid = rmid;
TAILQ_INSERT_TAIL(&DB_GLOBAL(envq), env, links);
return (0);
}
int
__db_unmap_rmid(rmid)
int rmid;
{
ENV *e;
for (e = TAILQ_FIRST(&DB_GLOBAL(envq));
e->xa_rmid != rmid;
e = TAILQ_NEXT(e, links))
;
if (e == NULL)
return (EINVAL);
TAILQ_REMOVE(&DB_GLOBAL(envq), e, links);
return (0);
}
int
__db_map_xid(env, xid, td)
ENV *env;
XID *xid;
TXN_DETAIL *td;
{
TXN_SYSTEM_LOCK(env);
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;
TXN_SYSTEM_UNLOCK(env);
return (0);
}
void
__db_unmap_xid(env, xid, off)
ENV *env;
XID *xid;
size_t off;
{
TXN_DETAIL *td;
COMPQUIET(xid, NULL);
td = R_ADDR(&env->tx_handle->reginfo, off);
memset(td->xid, 0, sizeof(td->xid));
}