Lines Matching defs:mgr
29 DB_TXNMGR *mgr;
33 if ((ret = __os_calloc(env, 1, sizeof(DB_TXNMGR), &mgr)) != 0)
35 TAILQ_INIT(&mgr->txn_chain);
36 mgr->env = env;
39 mgr->reginfo.env = env;
40 mgr->reginfo.type = REGION_TYPE_TXN;
41 mgr->reginfo.id = INVALID_REGION_ID;
42 mgr->reginfo.flags = REGION_JOIN_OK;
44 F_SET(&mgr->reginfo, REGION_CREATE_OK);
46 &mgr->reginfo, __txn_region_size(env))) != 0)
50 if (F_ISSET(&mgr->reginfo, REGION_CREATE))
51 if ((ret = __txn_init(env, mgr)) != 0)
55 mgr->reginfo.primary =
56 R_ADDR(&mgr->reginfo, mgr->reginfo.rp->primary);
60 env, MTX_TXN_ACTIVE, DB_MUTEX_PROCESS_ONLY, &mgr->mutex)) != 0)
63 env->tx_handle = mgr;
67 if (mgr->reginfo.addr != NULL)
68 (void)__env_region_detach(env, &mgr->reginfo, 0);
70 (void)__mutex_free(env, &mgr->mutex);
71 __os_free(env, mgr);
80 __txn_init(env, mgr)
82 DB_TXNMGR *mgr;
112 if ((ret = __env_alloc(&mgr->reginfo,
113 sizeof(DB_TXNREGION), &mgr->reginfo.primary)) != 0) {
118 mgr->reginfo.rp->primary =
119 R_OFFSET(&mgr->reginfo, mgr->reginfo.primary);
120 region = mgr->reginfo.primary;
221 DB_TXNMGR *mgr;
227 mgr = env->tx_handle;
228 reginfo = &mgr->reginfo;
242 if (TAILQ_FIRST(&mgr->txn_chain) != NULL) {
243 while ((txn = TAILQ_FIRST(&mgr->txn_chain)) != NULL) {
273 if ((t_ret = __mutex_free(env, &mgr->mutex)) != 0 && ret == 0)
280 __os_free(env, mgr);
345 DB_TXNMGR *mgr;
351 mgr = env->tx_handle;
352 region = mgr->reginfo.primary;
383 DB_TXNMGR *mgr;
388 if ((mgr = env->tx_handle) == NULL)
390 region = mgr->reginfo.primary;
441 DB_TXNMGR *mgr;
447 mgr = env->tx_handle;
448 region = mgr->reginfo.primary;
467 __env_alloc_free(&mgr->reginfo, td);