Lines Matching refs:txn
15 #include "dbinc/txn.h"
17 static int __cdsgroup_abort __P((DB_TXN *txn));
18 static int __cdsgroup_commit __P((DB_TXN *txn, u_int32_t flags));
19 static int __cdsgroup_discard __P((DB_TXN *txn, u_int32_t flags));
20 static u_int32_t __cdsgroup_id __P((DB_TXN *txn));
22 static int __cdsgroup_prepare __P((DB_TXN *txn, u_int8_t *gid));
23 static int __cdsgroup_set_name __P((DB_TXN *txn, const char *name));
25 __P((DB_TXN *txn, db_timeout_t timeout, u_int32_t flags));
41 __cdsgroup_abort(txn)
42 DB_TXN *txn;
44 return (__cdsgroup_notsup(txn->mgrp->env, "abort"));
48 __cdsgroup_commit(txn, flags)
49 DB_TXN *txn;
58 env = txn->mgrp->env;
61 if (txn->cursors != 0) {
69 ret = __lock_vec(env, txn->locker, 0, &lreq, 1, NULL);
71 env = txn->mgrp->env;
72 locker = txn->locker;
73 __os_free(env, txn->mgrp);
74 __os_free(env, txn);
80 static int __cdsgroup_discard(txn, flags)
81 DB_TXN *txn;
85 return (__cdsgroup_notsup(txn->mgrp->env, "discard"));
88 static u_int32_t __cdsgroup_id(txn)
89 DB_TXN *txn;
91 return (txn->txnid);
94 static int __cdsgroup_prepare(txn, gid)
95 DB_TXN *txn;
99 return (__cdsgroup_notsup(txn->mgrp->env, "prepare"));
102 static int __cdsgroup_set_name(txn, name)
103 DB_TXN *txn;
107 return (__cdsgroup_notsup(txn->mgrp->env, "set_name"));
110 static int __cdsgroup_set_timeout(txn, timeout, flags)
111 DB_TXN *txn;
117 return (__cdsgroup_notsup(txn->mgrp->env, "set_timeout"));
132 DB_TXN *txn;
143 *txnpp = txn = NULL;
144 if ((ret = __os_calloc(env, 1, sizeof(DB_TXN), &txn)) != 0)
150 if ((ret = __os_calloc(env, 1, sizeof(DB_TXNMGR), &txn->mgrp)) != 0)
152 txn->mgrp->env = env;
154 if ((ret = __lock_id(env, &txn->txnid, &txn->locker)) != 0)
157 txn->flags = TXN_CDSGROUP;
158 txn->abort = __cdsgroup_abort;
159 txn->commit = __cdsgroup_commit;
160 txn->discard = __cdsgroup_discard;
161 txn->id = __cdsgroup_id;
162 txn->prepare = __cdsgroup_prepare;
163 txn->set_name = __cdsgroup_set_name;
164 txn->set_timeout = __cdsgroup_set_timeout;
166 *txnpp = txn;
169 err: if (txn != NULL) {
170 if (txn->mgrp != NULL)
171 __os_free(env, txn->mgrp);
172 __os_free(env, txn);