diff options
Diffstat (limited to 'debian/htdig/htdig-3.2.0b6/db/xa_map.c')
| -rw-r--r-- | debian/htdig/htdig-3.2.0b6/db/xa_map.c | 187 |
1 files changed, 187 insertions, 0 deletions
diff --git a/debian/htdig/htdig-3.2.0b6/db/xa_map.c b/debian/htdig/htdig-3.2.0b6/db/xa_map.c new file mode 100644 index 00000000..a20297a6 --- /dev/null +++ b/debian/htdig/htdig-3.2.0b6/db/xa_map.c @@ -0,0 +1,187 @@ +/*- + * See the file LICENSE for redistribution information. + * + * Copyright (c) 1996, 1997, 1998, 1999 + * Sleepycat Software. All rights reserved. + */ + +#include "db_config.h" + +#ifndef lint +static const char sccsid[] = "@(#)xa_map.c 11.1 (Sleepycat) 7/25/99"; +#endif /* not lint */ + +#ifndef NO_SYSTEM_INCLUDES +#include <sys/types.h> + +#include <errno.h> +#include <string.h> +#endif + +#include "db_int.h" +#include "txn.h" + +/* + * This file contains all the mapping information that we need to support + * the DB/XA interface. + */ + +/* + * CDB___db_rmid_to_env + * Return the environment associated with a given XA rmid. + * + * PUBLIC: int CDB___db_rmid_to_env __P((int rmid, DB_ENV **envp)); + */ +int +CDB___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); + } + + /* + * When we map an rmid, move that environment to be the first one in + * the list of environments, so we acquire the correct environment + * in DB->open. + */ + 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); +} + +/* + * CDB___db_xid_to_txn + * Return the txn that corresponds to this XID. + * + * PUBLIC: int CDB___db_xid_to_txn __P((DB_ENV *, XID *, size_t *)); + */ +int +CDB___db_xid_to_txn(dbenv, xid, offp) + DB_ENV *dbenv; + XID *xid; + size_t *offp; +{ + DB_TXNMGR *mgr; + DB_TXNREGION *tmr; + struct __txn_detail *td; + + mgr = dbenv->tx_handle; + tmr = mgr->reginfo.primary; + + /* + * Search the internal active transaction table to find the + * matching xid. If this is a performance hit, then we + * can create a hash table, but I doubt it's worth it. + */ + R_LOCK(dbenv, &mgr->reginfo); + for (td = SH_TAILQ_FIRST(&tmr->active_txn, __txn_detail); + td != NULL; + td = SH_TAILQ_NEXT(td, links, __txn_detail)) + if (memcmp(xid->data, td->xid, XIDDATASIZE) == 0) + break; + R_UNLOCK(dbenv, &mgr->reginfo); + + if (td == NULL) + return (EINVAL); + + *offp = R_OFFSET(&mgr->reginfo, td); + return (0); +} + +/* + * CDB___db_map_rmid + * Create a mapping between the specified rmid and environment. + * + * PUBLIC: int CDB___db_map_rmid __P((int, DB_ENV *)); + */ +int +CDB___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); +} + +/* + * CDB___db_unmap_rmid + * Destroy the mapping for the given rmid. + * + * PUBLIC: int CDB___db_unmap_rmid __P((int)); + */ +int +CDB___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); +} + +/* + * CDB___db_map_xid + * Create a mapping between this XID and the transaction at + * "off" in the shared region. + * + * PUBLIC: int CDB___db_map_xid __P((DB_ENV *, XID *, size_t)); + */ +int +CDB___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); + R_UNLOCK(env, infop); + + return (0); +} + +/* + * CDB___db_unmap_xid + * Destroy the mapping for the specified XID. + * + * PUBLIC: void CDB___db_unmap_xid __P((DB_ENV *, XID *, size_t)); + */ + +void +CDB___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)); +} |