Lines Matching refs:td
165 TXN_DETAIL *ptd, *td;
212 td = txn->td;
215 ptd = parent->td;
217 SH_TAILQ_INSERT_HEAD(&ptd->kids, td, klinks, __txn_detail);
293 TXN_DETAIL *td;
304 SH_TAILQ_FOREACH(td, ®ion->active_txn, links, __txn_detail)
305 ids[nids++] = td->txnid;
365 TXN_DETAIL *td;
395 __env_alloc(&mgr->reginfo, sizeof(TXN_DETAIL), &td)) != 0) {
402 SH_TAILQ_INSERT_HEAD(®ion->active_txn, td, links, __txn_detail);
412 td->txnid = id;
413 dbenv->thread_id(dbenv, &td->pid, &td->tid);
420 ZERO_LSN(td->last_lsn);
421 ZERO_LSN(td->begin_lsn);
422 SH_TAILQ_INIT(&td->kids);
424 td->parent = R_OFFSET(&mgr->reginfo, txn->parent->td);
426 td->parent = INVALID_ROFF;
427 td->name = INVALID_ROFF;
428 MAX_LSN(td->read_lsn);
429 MAX_LSN(td->visible_lsn);
430 td->mvcc_ref = 0;
431 td->mvcc_mtx = MUTEX_INVALID;
432 td->status = TXN_RUNNING;
433 td->flags = 0;
434 td->xa_status = 0;
435 td->nlog_dbs = 0;
436 td->nlog_slots = TXN_NSLOTS;
437 td->log_dbs = R_OFFSET(&mgr->reginfo, td->slots);
442 txn->td = td;
483 __txn_continue(env, txn, td)
486 TXN_DETAIL *td;
494 txn->txnid = td->txnid;
495 txn->td = td;
512 if (F_ISSET(td, TXN_DTL_RESTORED))
564 TXN_DETAIL *td;
569 td = txn->td;
656 if (DBENV_LOGGING(env) && (!IS_ZERO_LSN(td->last_lsn) ||
675 !IS_ZERO_LSN(td->last_lsn)) {
683 if (ret == 0 && !IS_ZERO_LSN(td->last_lsn)) {
685 &td->visible_lsn, LOG_FLAGS(txn),
689 td->last_lsn = td->visible_lsn;
697 &td->visible_lsn, &s_lsn) <= 0);
709 if (!IS_ZERO_LSN(td->last_lsn) &&
711 &((TXN_DETAIL *)txn->parent->td)->last_lsn,
712 0, txn->txnid, &td->last_lsn)) != 0) {
759 if (td->status == TXN_PREPARED)
807 TXN_DETAIL *td;
812 td = txn->td;
842 if (IS_ZERO_LSN(td->last_lsn) && STAILQ_FIRST(&txn->logs) == NULL) {
889 done: if (DBENV_LOGGING(env) && td->status == TXN_PREPARED &&
890 (ret = __txn_regop_log(env, txn, &td->last_lsn,
980 TXN_DETAIL *td;
985 td = txn->td;
1005 * to fill in the td->xid.
1012 if (!IS_ZERO_LSN(td->last_lsn)) {
1023 if (td->xa_status != TXN_XA_ENDED &&
1024 td->xa_status != TXN_XA_SUSPENDED)
1026 memcpy(td->xid, gid, sizeof(td->xid));
1028 xid.size = sizeof(td->xid);
1029 xid.data = td->xid;
1032 if ((ret = __txn_xa_regop_log(env, txn, &td->last_lsn,
1033 lflags, TXN_PREPARE, &xid, td->format, td->gtrid, td->bqual,
1034 &td->begin_lsn, request.obj)) != 0)
1046 td->status = TXN_PREPARED;
1095 TXN_DETAIL *td;
1102 td = txn->td;
1111 if (td->name != INVALID_ROFF) {
1113 &mgr->reginfo, R_ADDR(&mgr->reginfo, td->name));
1114 td->name = INVALID_ROFF;
1128 td->name = R_OFFSET(&mgr->reginfo, p);
1183 TXN_DETAIL *td;
1203 td = txn->td;
1214 if (txn->txnid != td->txnid)
1221 if (td->status != TXN_PREPARED &&
1222 !F_ISSET(td, TXN_DTL_RESTORED)) {
1248 switch (td->status) {
1266 td->status == TXN_COMMITTED ? "committed" : "aborted");
1294 TXN_DETAIL *ptd, *td;
1332 td = txn->td;
1333 if (td->nlog_dbs != 0 && (ret = __txn_dref_fname(env, txn)) != 0)
1336 if (td->mvcc_ref != 0 && IS_MAX_LSN(td->visible_lsn)) {
1342 * visible_lsn before setting td->status to ensure safe reads
1345 if ((ret = __log_current_lsn(env, &td->visible_lsn,
1351 td->status = is_commit ? TXN_COMMITTED : TXN_ABORTED;
1352 SH_TAILQ_REMOVE(®ion->active_txn, td, links, __txn_detail);
1353 if (F_ISSET(td, TXN_DTL_RESTORED)) {
1358 if (td->name != INVALID_ROFF) {
1360 &mgr->reginfo, R_ADDR(&mgr->reginfo, td->name));
1361 td->name = INVALID_ROFF;
1364 ptd = txn->parent->td;
1365 SH_TAILQ_REMOVE(&ptd->kids, td, klinks, __txn_detail);
1366 } else if ((mvcc_mtx = td->mvcc_mtx) != MUTEX_INVALID) {
1368 if (td->mvcc_ref != 0) {
1370 td, links, __txn_detail);
1377 td = NULL;
1380 if (td != NULL)
1381 if ((ret = __mutex_free(env, &td->mvcc_mtx)) != 0)
1385 if (td != NULL) {
1386 if (td->nlog_slots != TXN_NSLOTS)
1388 R_ADDR(&mgr->reginfo, td->log_dbs));
1389 __env_alloc_free(&mgr->reginfo, td);
1458 txnlist->td = txn->td;
1541 key_lsn = ((TXN_DETAIL *)txn->td)->last_lsn;
1732 TXN_DETAIL *td;
1734 td = txn->td;
1735 *llsnp = &td->last_lsn;
1740 td = txn->td;
1741 if (IS_ZERO_LSN(td->begin_lsn))
1742 *blsnp = &td->begin_lsn;