Lines Matching refs:txn
35 /* This clashes with the txn abort method in Berkeley DB 4.x */
243 DB_TXN * txn ;
280 DB_TXN * txn ;
306 DB_TXN * txn ;
679 Trace((" Aborting Transaction [%d] in [%d] Active [%d]\n", tid->txn, tid, tid->active));
682 tid->txn->abort(tid->txn) ;
684 txn_abort(tid->txn);
846 if ( ((db->dbp)->cursor)(db->dbp, db->txn, &cursor) == 0 )
848 if ( ((db->dbp)->cursor)(db->dbp, db->txn, &cursor, 0) == 0 )
1430 BerkeleyDB__Txn txn,
1455 if (txn)
1456 txnid = txn->txn;
1458 Trace(("_db_open(dbenv[%p] ref_dbenv [%p] txn [%p] file[%s] subname [%s] type[%d] flags[%d] mode[%d]\n",
1459 dbenv, ref_dbenv, txn, file, subname, type, flags, mode)) ;
1659 RETVAL->txn = txnid ;
1740 BerkeleyDB__Txn txn = NULL ;
1749 if (txn) {
1753 RETVAL = env->Status = env->Env->dbremove(env->Env, txn->txn, db, subdb, flags);
1835 BerkeleyDB__Txn txn = NULL ;
1845 SetValue_ov(txn, "Txn", BerkeleyDB__Txn) ;
1846 if (txn) {
1850 RETVAL = env->Status = env->Env->dbrename(env->Env, txn->txn, db, subdb, newname, flags);
2265 DB_TXN *txn ;
2275 p_id = pid->txn ;
2278 txn_begin(env->Env->tx_info, p_id, &txn) ;
2281 env->Env->txn_begin(env->Env, p_id, &txn, flags) ;
2283 txn_begin(env->Env, p_id, &txn, flags) ;
2288 RETVAL->txn = txn ;
2290 Trace(("_txn_begin created txn [%p] in [%p]\n", txn, RETVAL));
2497 /* hash_store_iv("BerkeleyDB::Term::TxnMgr", (char *)txn, 1) ; */
2828 BerkeleyDB__Txn txn = NULL ;
2836 SetValue_ov(txn, "Txn", BerkeleyDB__Txn) ;
2866 RETVAL = my_db_open(db, ref, ref_dbenv, dbenv, txn, file, subname, DB_HASH, flags, mode, &info, enc_passwd, enc_flags) ;
2889 db->Status = ((db->dbp)->stat)(db->dbp, db->txn, &stat, flags) ;
2952 BerkeleyDB__Txn txn = NULL ;
2960 SetValue_ov(txn, "Txn", BerkeleyDB__Txn) ;
2977 RETVAL = my_db_open(db, ref, ref_dbenv, dbenv, txn, file, subname, DB_UNKNOWN, flags, mode, &info, enc_passwd, enc_flags) ;
3007 BerkeleyDB__Txn txn = NULL ;
3015 SetValue_ov(txn, "Txn", BerkeleyDB__Txn) ;
3052 RETVAL = my_db_open(db, ref, ref_dbenv, dbenv, txn, file, subname, DB_BTREE, flags, mode, &info, enc_passwd, enc_flags) ;
3071 db->Status = ((db->dbp)->stat)(db->dbp, db->txn, &stat, flags) ;
3151 BerkeleyDB__Txn txn = NULL ;
3160 SetValue_ov(txn, "Txn", BerkeleyDB__Txn) ;
3192 RETVAL = my_db_open(db, ref, ref_dbenv, dbenv, txn, file, subname, DB_RECNO, flags, mode, &info, enc_passwd, enc_flags) ;
3221 BerkeleyDB__Txn txn = NULL ;
3230 SetValue_ov(txn, "Txn", BerkeleyDB__Txn) ;
3259 RETVAL = my_db_open(db, ref, ref_dbenv, dbenv, txn, file, subname, DB_QUEUE, flags, mode, &info, enc_passwd, enc_flags) ;
3281 db->Status = ((db->dbp)->stat)(db->dbp, db->txn, &stat, flags) ;
3336 if (db->txn)
3364 #define db_cursor(db, txn, cur,flags) ((db->dbp)->cursor)(db->dbp, txn, cur)
3366 #define db_cursor(db, txn, cur,flags) ((db->dbp)->cursor)(db->dbp, txn, cur,flags)
3389 if ((db->Status = db_cursor(db, db->txn, &cursor, flags)) == 0){
3395 RETVAL->txn = db->txn ;
3676 (db->Status = ((db->dbp)->del)(db->dbp, db->txn, &key, flags))
3685 Trace(("db_del db[%p] in [%p] txn[%p] key[%.*s] flags[%d]\n", db->dbp, db, db->txn, key.size, key.data, flags)) ;
3700 (db->Status = ((db->dbp)->get)(db->dbp, db->txn, &key, &data, flags))
3713 Trace(("db_get db[%p] in [%p] txn[%p] key [%.*s] flags[%d]\n", db->dbp, db, db->txn, key.size, key.data, flags)) ;
3722 (db->Status = ((db->dbp)->pget)(db->dbp, db->txn, &key, &pkey, &data, flags))
3736 Trace(("db_pget db [%p] in [%p] txn [%p] flags [%d]\n", db->dbp, db, db->txn, flags)) ;
3751 (db->Status = (db->dbp->put)(db->dbp,db->txn,&key,&data,flag))
3764 Trace(("db_put db[%p] in [%p] txn[%p] key[%.*s] data [%.*s] flags[%d]\n", db->dbp, db, db->txn, key.size, key.data, data.size, data.data, flags)) ;
3772 (db->Status = ((db->dbp)->key_range)(db->dbp, db->txn, &key, &range, flags))
3834 _Txn(db, txn=NULL)
3836 BerkeleyDB::Txn txn
3842 if (txn) {
3843 Trace(("_Txn[%p] in[%p] active [%d]\n", txn->txn, txn, txn->active));
3844 ckActive_Transaction(txn->active) ;
3845 db->txn = txn->txn ;
3849 db->txn = NULL ;
3854 (db->Status = ((db->dbp)->truncate)(db->dbp, db->txn, &countp, flags))
3963 RETVAL = (db->dbp)->compact(db->dbp, db->txn, start_p, stop_p, cmpt_p, flags, end_p);
4198 DB_TXN *txn ;
4205 p_id = pid->txn ;
4208 txn_begin(txnmgr->env->Env->tx_info, p_id, &txn) ;
4211 txnmgr->env->Env->txn_begin(txnmgr->env->Env, p_id, &txn, flags) ;
4213 txn_begin(txnmgr->env->Env, p_id, &txn, flags) ;
4218 RETVAL->txn = txn ;
4220 Trace(("_txn_begin created txn [%d] in [%d]\n", txn, RETVAL));
4344 set_timeout(txn, timeout, flags=0)
4345 BerkeleyDB::Txn txn
4351 ckActive_Transaction(txn->active) ;
4356 RETVAL = txn->Status = txn->txn->set_timeout(txn->txn, timeout, flags);
4362 set_tx_max(txn, max)
4363 BerkeleyDB::Txn txn
4368 ckActive_Transaction(txn->active) ;
4373 RETVAL = txn->Status = txn->txn->set_tx_max(txn->txn, max);
4379 get_tx_max(txn, max)
4380 BerkeleyDB::Txn txn
4385 ckActive_Transaction(txn->active) ;
4390 RETVAL = txn->Status = txn->txn->get_tx_max(txn->txn, &max);
4402 Trace(("In BerkeleyDB::Txn::_DESTROY txn [%d] active [%d] dirty=%d\n", tid->txn, tid->active, PL_dirty)) ;
4405 tid->txn->abort(tid->txn) ;
4407 txn_abort(tid->txn) ;
4425 # define xx_txn_prepare(t) (t->Status = t->txn->prepare(t->txn, 0))
4428 # define xx_txn_prepare(t) (t->Status = txn_prepare(t->txn, 0))
4430 # define xx_txn_prepare(t) (t->Status = txn_prepare(t->txn))
4442 # define _txn_commit(t,flags) (t->Status = t->txn->commit(t->txn, flags))
4445 # define _txn_commit(t,flags) (t->Status = txn_commit(t->txn))
4447 # define _txn_commit(t, flags) (t->Status = txn_commit(t->txn, flags))
4462 # define _txn_abort(t) (t->Status = t->txn->abort(t->txn))
4464 # define _txn_abort(t) (t->Status = txn_abort(t->txn))
4477 # define _txn_discard(t,f) (t->Status = t->txn->discard(t->txn, f))
4480 # define _txn_discard(t,f) (t->Status = txn_discard(t->txn, f))
4497 # define xx_txn_id(t) t->txn->id(t->txn)
4499 # define xx_txn_id(t) txn_id(t->txn)
4532 (db->Status = db_cursor(db, db->txn, &cursor, 0)) == 0 )