db/txn/txn.c

298 	DB_TXNMGR *mgr;
310 	mgr = txn->mgrp;
311 	if (mgr->dbenv->lg_info != NULL && (ret =
312 	    log_put(mgr->dbenv->lg_info, &begin_lsn, NULL, DB_CURLSN)) != 0)
315 	LOCK_TXNREGION(mgr);
318 	if (mgr->region->last_txnid == TXN_INVALID) {
319 		__db_err(mgr->dbenv, "txn_begin: %s  %s",
326 	if ((ret = __txn_validate_region(mgr)) != 0)
330 	if ((ret = __db_shalloc(mgr->mem, sizeof(TXN_DETAIL), 0, &td)) != 0
331 	    && ret == ENOMEM && (ret = __txn_grow_region(mgr)) == 0)
332 	    	ret = __db_shalloc(mgr->mem, sizeof(TXN_DETAIL), 0, &td);
337 	SH_TAILQ_INSERT_HEAD(&mgr->region->active_txn, td, links, __txn_detail);
339 	id = ++mgr->region->last_txnid;
340 	++mgr->region->nbegins;
352 	off = (u_int8_t *)td - (u_int8_t *)mgr->region;
353 	UNLOCK_TXNREGION(mgr);
360 		LOCK_TXNTHREAD(mgr);
361 		TAILQ_INSERT_TAIL(&mgr->txn_chain, txn, links);
362 		UNLOCK_TXNTHREAD(mgr);
367 err1:	UNLOCK_TXNREGION(mgr);
380 	DB_TXNMGR *mgr;
383 	mgr = txnp->mgrp;
385 	TXN_PANIC_CHECK(mgr);
396 	if ((logp = mgr->dbenv->lg_info) != NULL &&
400 			    F_ISSET(mgr, DB_TXN_NOSYNC) ? 0 : DB_FLUSH,
610 	DB_TXNMGR *mgr;
615 	mgr = txnp->mgrp;
622 	if (mgr->dbenv->lk_info) {
624 		    lock_tvec(mgr->dbenv->lk_info, txnp, 0, &request, 1, NULL);
626 			__db_err(mgr->dbenv, "%s: release locks failed %s",
634 	LOCK_TXNREGION(mgr);
641 	tp = (TXN_DETAIL *)((u_int8_t *)mgr->region + txnp->off);
643 		SH_TAILQ_REMOVE(&mgr->region->active_txn,
646 		__db_shalloc_free(mgr->mem, tp);
651 		mgr->region->ncommits++;
653 		mgr->region->naborts++;
655 	UNLOCK_TXNREGION(mgr);
667 		LOCK_TXNTHREAD(mgr);
668 		TAILQ_REMOVE(&mgr->txn_chain, txnp, links);
669 		UNLOCK_TXNTHREAD(mgr);
690 	DB_TXNMGR *mgr;
693 	mgr = txnp->mgrp;
694 	logp = mgr->dbenv->lg_info;
715 			    mgr->recover(logp, &rdbt, &key_lsn, TXN_UNDO, NULL);
739 txn_checkpoint(mgr, kbytes, minutes)
740 	const DB_TXNMGR *mgr;
750 	TXN_PANIC_CHECK(mgr);
759 		LOCK_TXNREGION(mgr);
760 		last_ckp_time = mgr->region->time_ckp;
761 		UNLOCK_TXNREGION(mgr);
768 		dblp = mgr->dbenv->lg_info;
788 		dblp = mgr->dbenv->lg_info;
798 	LOCK_TXNREGION(mgr);
800 	if (!IS_ZERO_LSN(mgr->region->pending_ckp))
801 		ckp_lsn = mgr->region->pending_ckp;
804 		    SH_TAILQ_FIRST(&mgr->region->active_txn, __txn_detail);
817 	mgr->region->pending_ckp = ckp_lsn;
818 	UNLOCK_TXNREGION(mgr);
825 	if (mgr->dbenv->mp_info != NULL &&
826 	    (ret = memp_sync(mgr->dbenv->mp_info, &sync_lsn)) != 0) {
832 			__db_err(mgr->dbenv,
837 	if (mgr->dbenv->lg_info != NULL) {
838 		LOCK_TXNREGION(mgr);
839 		last_ckp = mgr->region->last_ckp;
840 		ZERO_LSN(mgr->region->pending_ckp);
841 		UNLOCK_TXNREGION(mgr);
843 		if ((ret = __txn_ckp_log(mgr->dbenv->lg_info,
845 			__db_err(mgr->dbenv,
852 		LOCK_TXNREGION(mgr);
853 		mgr->region->last_ckp = ckp_lsn;
854 		(void)time(&mgr->region->time_ckp);
855 		UNLOCK_TXNREGION(mgr);
920 txn_stat(mgr, statp, db_malloc)
921 	DB_TXNMGR *mgr;
931 	TXN_PANIC_CHECK(mgr);
933 	LOCK_TXNREGION(mgr);
934 	nactive = mgr->region->nbegins -
935 	    mgr->region->naborts - mgr->region->ncommits;
936 	UNLOCK_TXNREGION(mgr);
946 	LOCK_TXNREGION(mgr);
947 	stats->st_last_txnid = mgr->region->last_txnid;
948 	stats->st_last_ckp = mgr->region->last_ckp;
949 	stats->st_maxtxns = mgr->region->maxtxns;
950 	stats->st_naborts = mgr->region->naborts;
951 	stats->st_nbegins = mgr->region->nbegins;
952 	stats->st_ncommits = mgr->region->ncommits;
953 	stats->st_pending_ckp = mgr->region->pending_ckp;
954 	stats->st_time_ckp = mgr->region->time_ckp;
962 	for (txnp = SH_TAILQ_FIRST(&mgr->region->active_txn, __txn_detail);
973 	stats->st_region_wait = mgr->region->hdr.lock.mutex_set_wait;
974 	stats->st_region_nowait = mgr->region->hdr.lock.mutex_set_nowait;
975 	stats->st_refcnt = mgr->region->hdr.refcnt;
976 	stats->st_regsize = mgr->region->hdr.size;
978 	UNLOCK_TXNREGION(mgr);
987 	DB_TXNMGR *mgr;
991 	mgr = txnp->mgrp;
1000 		LOCK_TXNREGION(mgr);
1001 		tp = (TXN_DETAIL *)((u_int8_t *)mgr->region + kids->off);
1002 		SH_TAILQ_REMOVE(&mgr->region->active_txn,
1005 		__db_shalloc_free(mgr->mem, tp);
1006 		UNLOCK_TXNREGION(mgr);
1011 			LOCK_TXNTHREAD(mgr);
1012 			TAILQ_REMOVE(&mgr->txn_chain, kids, links);
1013 			UNLOCK_TXNTHREAD(mgr);
1029 __txn_is_ancestor(mgr, hold_off, req_off)
1030 	DB_TXNMGR *mgr;
1035 	hold_tp = (TXN_DETAIL *)((u_int8_t *)mgr->region + hold_off);
1036 	req_tp = (TXN_DETAIL *)((u_int8_t *)mgr->region + req_off);
1040 		    (TXN_DETAIL *)((u_int8_t *)mgr->region + req_tp->parent);