开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
tcl_txn.c
资源名称：mysql-4.1.16-win-src.zip　[点击查看]
上传用户：romrleung
上传日期：2022-05-23
资源大小：18897k
文件大小：16k
源码类别：

MySQL数据库

开发平台：

Visual C++

tcl_txn.c：源码内容
  1. /*-
  2.  * See the file LICENSE for redistribution information.
  3.  *
  4.  * Copyright (c) 1999-2001
  5.  * Sleepycat Software.  All rights reserved.
  6.  */
  8. #include "db_config.h"
  10. #ifndef lint
  11. static const char revid[] = "$Id: tcl_txn.c,v 11.57 2002/08/06 06:21:36 bostic Exp $";
  12. #endif /* not lint */
  14. #ifndef NO_SYSTEM_INCLUDES
  15. #include <sys/types.h>
  17. #include <stdlib.h>
  18. #include <string.h>
  19. #include <tcl.h>
  20. #endif
  22. #include "db_int.h"
  23. #include "dbinc/tcl_db.h"
  25. static int tcl_TxnCommit __P((Tcl_Interp *,
  26.        int, Tcl_Obj * CONST *, DB_TXN *, DBTCL_INFO *));
  27. static int txn_Cmd __P((ClientData, Tcl_Interp *, int, Tcl_Obj * CONST *));
  29. /*
  30.  * _TxnInfoDelete --
  31.  * Removes nested txn info structures that are children
  32.  * of this txn.
  33.  * RECURSIVE:  Transactions can be arbitrarily nested, so we
  34.  * must recurse down until we get them all.
  35.  *
  36.  * PUBLIC: void _TxnInfoDelete __P((Tcl_Interp *, DBTCL_INFO *));
  37.  */
  38. void
  39. _TxnInfoDelete(interp, txnip)
  40. Tcl_Interp *interp; /* Interpreter */
  41. DBTCL_INFO *txnip; /* Info for txn */
  42. {
  43. DBTCL_INFO *nextp, *p;
  45. for (p = LIST_FIRST(&__db_infohead); p != NULL; p = nextp) {
  46. /*
  47.  * Check if this info structure "belongs" to this
  48.  * txn.  Remove its commands and info structure.
  49.  */
  50. nextp = LIST_NEXT(p, entries);
  51.  if (p->i_parent == txnip && p->i_type == I_TXN) {
  52. _TxnInfoDelete(interp, p);
  53. (void)Tcl_DeleteCommand(interp, p->i_name);
  54. _DeleteInfo(p);
  55. }
  56. }
  57. }
  59. /*
  60.  * tcl_TxnCheckpoint --
  61.  *
  62.  * PUBLIC: int tcl_TxnCheckpoint __P((Tcl_Interp *, int,
  63.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  64.  */
  65. int
  66. tcl_TxnCheckpoint(interp, objc, objv, envp)
  67. Tcl_Interp *interp; /* Interpreter */
  68. int objc; /* How many arguments? */
  69. Tcl_Obj *CONST objv[]; /* The argument objects */
  70. DB_ENV *envp; /* Environment pointer */
  71. {
  72. static char *txnckpopts[] = {
  73. "-kbyte", "-min",
  74. NULL
  75. };
  76. enum txnckpopts {
  77. TXNCKP_KB, TXNCKP_MIN
  78. };
  79. int i, kb, min, optindex, result, ret;
  81. result = TCL_OK;
  82. kb = min = 0;
  84. /*
  85.  * Get the flag index from the object based on the options
  86.  * defined above.
  87.  */
  88. i = 2;
  89. while (i < objc) {
  90. if (Tcl_GetIndexFromObj(interp, objv[i],
  91.     txnckpopts, "option", TCL_EXACT, &optindex) != TCL_OK) {
  92. return (IS_HELP(objv[i]));
  93. }
  94. i++;
  95. switch ((enum txnckpopts)optindex) {
  96. case TXNCKP_KB:
  97. if (i == objc) {
  98. Tcl_WrongNumArgs(interp, 2, objv,
  99.     "?-kbyte kb?");
  100. result = TCL_ERROR;
  101. break;
  102. }
  103. result = Tcl_GetIntFromObj(interp, objv[i++], &kb);
  104. break;
  105. case TXNCKP_MIN:
  106. if (i == objc) {
  107. Tcl_WrongNumArgs(interp, 2, objv, "?-min min?");
  108. result = TCL_ERROR;
  109. break;
  110. }
  111. result = Tcl_GetIntFromObj(interp, objv[i++], &min);
  112. break;
  113. }
  114. }
  115. _debug_check();
  116. ret = envp->txn_checkpoint(envp, (u_int32_t)kb, (u_int32_t)min, 0);
  117. result = _ReturnSetup(interp, ret, DB_RETOK_STD(ret),
  118.     "txn checkpoint");
  119. return (result);
  120. }
  122. /*
  123.  * tcl_Txn --
  124.  *
  125.  * PUBLIC: int tcl_Txn __P((Tcl_Interp *, int,
  126.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *, DBTCL_INFO *));
  127.  */
  128. int
  129. tcl_Txn(interp, objc, objv, envp, envip)
  130. Tcl_Interp *interp; /* Interpreter */
  131. int objc; /* How many arguments? */
  132. Tcl_Obj *CONST objv[]; /* The argument objects */
  133. DB_ENV *envp; /* Environment pointer */
  134. DBTCL_INFO *envip; /* Info pointer */
  135. {
  136. static char *txnopts[] = {
  137. #if CONFIG_TEST
  138. "-dirty",
  139. "-lock_timeout",
  140. "-txn_timeout",
  141. #endif
  142. "-nosync",
  143. "-nowait",
  144. "-parent",
  145. "-sync",
  146. NULL
  147. };
  148. enum txnopts {
  149. #if CONFIG_TEST
  150. TXNDIRTY,
  151. TXN_LOCK_TIMEOUT,
  152. TXN_TIMEOUT,
  153. #endif
  154. TXNNOSYNC,
  155. TXNNOWAIT,
  156. TXNPARENT,
  157. TXNSYNC
  158. };
  159. DBTCL_INFO *ip;
  160. DB_TXN *parent;
  161. DB_TXN *txn;
  162. Tcl_Obj *res;
  163. db_timeout_t lk_time, tx_time;
  164. u_int32_t flag, lk_timeflag, tx_timeflag;
  165. int i, optindex, result, ret;
  166. char *arg, msg[MSG_SIZE], newname[MSG_SIZE];
  168. result = TCL_OK;
  169. memset(newname, 0, MSG_SIZE);
  171. parent = NULL;
  172. flag = 0;
  173. lk_timeflag = tx_timeflag = 0;
  174. i = 2;
  175. while (i < objc) {
  176. if (Tcl_GetIndexFromObj(interp, objv[i],
  177.     txnopts, "option", TCL_EXACT, &optindex) != TCL_OK) {
  178. return (IS_HELP(objv[i]));
  179. }
  180. i++;
  181. switch ((enum txnopts)optindex) {
  182. #ifdef CONFIG_TEST
  183. case TXNDIRTY:
  184. flag |= DB_DIRTY_READ;
  185. break;
  186. case TXN_LOCK_TIMEOUT:
  187. lk_timeflag = DB_SET_LOCK_TIMEOUT;
  188. goto getit;
  189. case TXN_TIMEOUT:
  190. tx_timeflag = DB_SET_TXN_TIMEOUT;
  191. getit:
  192. if (i >= objc) {
  193. Tcl_WrongNumArgs(interp, 2, objv,
  194.     "?-txn_timestamp time?");
  195. return (TCL_ERROR);
  196. }
  197. result = Tcl_GetLongFromObj(interp, objv[i++],
  198.     (long *)(optindex == TXN_LOCK_TIMEOUT ?
  199.     &lk_time : &tx_time));
  200. if (result != TCL_OK)
  201. return (TCL_ERROR);
  202. break;
  203. #endif
  204. case TXNNOSYNC:
  205. FLAG_CHECK2(flag, DB_DIRTY_READ);
  206. flag |= DB_TXN_NOSYNC;
  207. break;
  208. case TXNNOWAIT:
  209. FLAG_CHECK2(flag, DB_DIRTY_READ);
  210. flag |= DB_TXN_NOWAIT;
  211. break;
  212. case TXNPARENT:
  213. if (i == objc) {
  214. Tcl_WrongNumArgs(interp, 2, objv,
  215.     "?-parent txn?");
  216. result = TCL_ERROR;
  217. break;
  218. }
  219. arg = Tcl_GetStringFromObj(objv[i++], NULL);
  220. parent = NAME_TO_TXN(arg);
  221. if (parent == NULL) {
  222. snprintf(msg, MSG_SIZE,
  223.     "Invalid parent txn: %sn",
  224.     arg);
  225. Tcl_SetResult(interp, msg, TCL_VOLATILE);
  226. return (TCL_ERROR);
  227. }
  228. break;
  229. case TXNSYNC:
  230. FLAG_CHECK2(flag, DB_DIRTY_READ);
  231. flag |= DB_TXN_SYNC;
  232. break;
  233. }
  234. }
  235. snprintf(newname, sizeof(newname), "%s.txn%d",
  236.     envip->i_name, envip->i_envtxnid);
  237. ip = _NewInfo(interp, NULL, newname, I_TXN);
  238. if (ip == NULL) {
  239. Tcl_SetResult(interp, "Could not set up info",
  240.     TCL_STATIC);
  241. return (TCL_ERROR);
  242. }
  243. _debug_check();
  244. ret = envp->txn_begin(envp, parent, &txn, flag);
  245. result = _ReturnSetup(interp, ret, DB_RETOK_STD(ret),
  246.     "txn");
  247. if (result == TCL_ERROR)
  248. _DeleteInfo(ip);
  249. else {
  250. /*
  251.  * Success.  Set up return.  Set up new info
  252.  * and command widget for this txn.
  253.  */
  254. envip->i_envtxnid++;
  255. if (parent)
  256. ip->i_parent = _PtrToInfo(parent);
  257. else
  258. ip->i_parent = envip;
  259. _SetInfoData(ip, txn);
  260. Tcl_CreateObjCommand(interp, newname,
  261.     (Tcl_ObjCmdProc *)txn_Cmd, (ClientData)txn, NULL);
  262. res = Tcl_NewStringObj(newname, strlen(newname));
  263. Tcl_SetObjResult(interp, res);
  264. if (tx_timeflag != 0) {
  265. ret = txn->set_timeout(txn, tx_time, tx_timeflag);
  266. if (ret != 0) {
  267. result =
  268.     _ReturnSetup(interp, ret, DB_RETOK_STD(ret),
  269. "set_timeout");
  270. _DeleteInfo(ip);
  271. }
  272. }
  273. if (lk_timeflag != 0) {
  274. ret = txn->set_timeout(txn, lk_time, lk_timeflag);
  275. if (ret != 0) {
  276. result =
  277.     _ReturnSetup(interp, ret, DB_RETOK_STD(ret),
  278. "set_timeout");
  279. _DeleteInfo(ip);
  280. }
  281. }
  282. }
  283. return (result);
  284. }
  286. /*
  287.  * tcl_TxnStat --
  288.  *
  289.  * PUBLIC: int tcl_TxnStat __P((Tcl_Interp *, int,
  290.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  291.  */
  292. int
  293. tcl_TxnStat(interp, objc, objv, envp)
  294. Tcl_Interp *interp; /* Interpreter */
  295. int objc; /* How many arguments? */
  296. Tcl_Obj *CONST objv[]; /* The argument objects */
  297. DB_ENV *envp; /* Environment pointer */
  298. {
  299. DBTCL_INFO *ip;
  300. DB_TXN_ACTIVE *p;
  301. DB_TXN_STAT *sp;
  302. Tcl_Obj *myobjv[2], *res, *thislist, *lsnlist;
  303. u_int32_t i;
  304. int myobjc, result, ret;
  306. result = TCL_OK;
  307. /*
  308.  * No args for this.  Error if there are some.
  309.  */
  310. if (objc != 2) {
  311. Tcl_WrongNumArgs(interp, 2, objv, NULL);
  312. return (TCL_ERROR);
  313. }
  314. _debug_check();
  315. ret = envp->txn_stat(envp, &sp, 0);
  316. result = _ReturnSetup(interp, ret, DB_RETOK_STD(ret),
  317.     "txn stat");
  318. if (result == TCL_ERROR)
  319. return (result);
  321. /*
  322.  * Have our stats, now construct the name value
  323.  * list pairs and free up the memory.
  324.  */
  325. res = Tcl_NewObj();
  326. /*
  327.  * MAKE_STAT_LIST assumes 'res' and 'error' label.
  328.  */
  329. MAKE_STAT_LIST("Region size", sp->st_regsize);
  330. MAKE_STAT_LSN("LSN of last checkpoint", &sp->st_last_ckp);
  331. MAKE_STAT_LIST("Time of last checkpoint", sp->st_time_ckp);
  332. MAKE_STAT_LIST("Last txn ID allocated", sp->st_last_txnid);
  333. MAKE_STAT_LIST("Max Txns", sp->st_maxtxns);
  334. MAKE_STAT_LIST("Number aborted txns", sp->st_naborts);
  335. MAKE_STAT_LIST("Number active txns", sp->st_nactive);
  336. MAKE_STAT_LIST("Maximum  active txns", sp->st_maxnactive);
  337. MAKE_STAT_LIST("Number txns begun", sp->st_nbegins);
  338. MAKE_STAT_LIST("Number committed txns", sp->st_ncommits);
  339. MAKE_STAT_LIST("Number restored txns", sp->st_nrestores);
  340. MAKE_STAT_LIST("Number of region lock waits", sp->st_region_wait);
  341. MAKE_STAT_LIST("Number of region lock nowaits", sp->st_region_nowait);
  342. for (i = 0, p = sp->st_txnarray; i < sp->st_nactive; i++, p++)
  343. for (ip = LIST_FIRST(&__db_infohead); ip != NULL;
  344.     ip = LIST_NEXT(ip, entries)) {
  345. if (ip->i_type != I_TXN)
  346. continue;
  347. if (ip->i_type == I_TXN &&
  348.     (ip->i_txnp->id(ip->i_txnp) == p->txnid)) {
  349. MAKE_STAT_LSN(ip->i_name, &p->lsn);
  350. if (p->parentid != 0)
  351. MAKE_STAT_STRLIST("Parent",
  352.     ip->i_parent->i_name);
  353. else
  354. MAKE_STAT_LIST("Parent", 0);
  355. break;
  356. }
  357. }
  358. Tcl_SetObjResult(interp, res);
  359. error:
  360. free(sp);
  361. return (result);
  362. }
  364. /*
  365.  * tcl_TxnTimeout --
  366.  *
  367.  * PUBLIC: int tcl_TxnTimeout __P((Tcl_Interp *, int,
  368.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  369.  */
  370. int
  371. tcl_TxnTimeout(interp, objc, objv, envp)
  372. Tcl_Interp *interp; /* Interpreter */
  373. int objc; /* How many arguments? */
  374. Tcl_Obj *CONST objv[]; /* The argument objects */
  375. DB_ENV *envp; /* Environment pointer */
  376. {
  377. long timeout;
  378. int result, ret;
  380. /*
  381.  * One arg, the timeout.
  382.  */
  383. if (objc != 3) {
  384. Tcl_WrongNumArgs(interp, 2, objv, "?timeout?");
  385. return (TCL_ERROR);
  386. }
  387. result = Tcl_GetLongFromObj(interp, objv[2], &timeout);
  388. if (result != TCL_OK)
  389. return (result);
  390. _debug_check();
  391. ret = envp->set_timeout(envp, (u_int32_t)timeout, DB_SET_TXN_TIMEOUT);
  392. result = _ReturnSetup(interp, ret, DB_RETOK_STD(ret),
  393.     "lock timeout");
  394. return (result);
  395. }
  397. /*
  398.  * txn_Cmd --
  399.  * Implements the "txn" widget.
  400.  */
  401. static int
  402. txn_Cmd(clientData, interp, objc, objv)
  403. ClientData clientData; /* Txn handle */
  404. Tcl_Interp *interp; /* Interpreter */
  405. int objc; /* How many arguments? */
  406. Tcl_Obj *CONST objv[]; /* The argument objects */
  407. {
  408. static char *txncmds[] = {
  409. #if CONFIG_TEST
  410. "discard",
  411. "id",
  412. "prepare",
  413. #endif
  414. "abort",
  415. "commit",
  416. NULL
  417. };
  418. enum txncmds {
  419. #if CONFIG_TEST
  420. TXNDISCARD,
  421. TXNID,
  422. TXNPREPARE,
  423. #endif
  424. TXNABORT,
  425. TXNCOMMIT
  426. };
  427. DBTCL_INFO *txnip;
  428. DB_TXN *txnp;
  429. Tcl_Obj *res;
  430. int cmdindex, result, ret;
  431. u_int8_t *gid;
  433. Tcl_ResetResult(interp);
  434. txnp = (DB_TXN *)clientData;
  435. txnip = _PtrToInfo((void *)txnp);
  436. result = TCL_OK;
  437. if (txnp == NULL) {
  438. Tcl_SetResult(interp, "NULL txn pointer", TCL_STATIC);
  439. return (TCL_ERROR);
  440. }
  441. if (txnip == NULL) {
  442. Tcl_SetResult(interp, "NULL txn info pointer", TCL_STATIC);
  443. return (TCL_ERROR);
  444. }
  446. /*
  447.  * Get the command name index from the object based on the dbcmds
  448.  * defined above.
  449.  */
  450. if (Tcl_GetIndexFromObj(interp,
  451.     objv[1], txncmds, "command", TCL_EXACT, &cmdindex) != TCL_OK)
  452. return (IS_HELP(objv[1]));
  454. res = NULL;
  455. switch ((enum txncmds)cmdindex) {
  456. #if CONFIG_TEST
  457. case TXNDISCARD:
  458. if (objc != 2) {
  459. Tcl_WrongNumArgs(interp, 1, objv, NULL);
  460. return (TCL_ERROR);
  461. }
  462. _debug_check();
  463. ret = txnp->discard(txnp, 0);
  464. result = _ReturnSetup(interp, ret, DB_RETOK_STD(ret),
  465.     "txn discard");
  466. _TxnInfoDelete(interp, txnip);
  467. (void)Tcl_DeleteCommand(interp, txnip->i_name);
  468. _DeleteInfo(txnip);
  469. break;
  470. case TXNID:
  471. if (objc != 2) {
  472. Tcl_WrongNumArgs(interp, 1, objv, NULL);
  473. return (TCL_ERROR);
  474. }
  475. _debug_check();
  476. ret = txnp->id(txnp);
  477. res = Tcl_NewIntObj(ret);
  478. break;
  479. case TXNPREPARE:
  480. if (objc != 3) {
  481. Tcl_WrongNumArgs(interp, 1, objv, NULL);
  482. return (TCL_ERROR);
  483. }
  484. _debug_check();
  485. gid = (u_int8_t *)Tcl_GetByteArrayFromObj(objv[2], NULL);
  486. ret = txnp->prepare(txnp, gid);
  487. /*
  488.  * !!!
  489.  * DB_TXN->prepare commits all outstanding children.  But it
  490.  * does NOT destroy the current txn handle.  So, we must call
  491.  * _TxnInfoDelete to recursively remove all nested txn handles,
  492.  * we do not call _DeleteInfo on ourselves.
  493.  */
  494. _TxnInfoDelete(interp, txnip);
  495. result = _ReturnSetup(interp, ret, DB_RETOK_STD(ret),
  496.     "txn prepare");
  497. break;
  498. #endif
  499. case TXNABORT:
  500. if (objc != 2) {
  501. Tcl_WrongNumArgs(interp, 1, objv, NULL);
  502. return (TCL_ERROR);
  503. }
  504. _debug_check();
  505. ret = txnp->abort(txnp);
  506. result = _ReturnSetup(interp, ret, DB_RETOK_STD(ret),
  507.     "txn abort");
  508. _TxnInfoDelete(interp, txnip);
  509. (void)Tcl_DeleteCommand(interp, txnip->i_name);
  510. _DeleteInfo(txnip);
  511. break;
  512. case TXNCOMMIT:
  513. result = tcl_TxnCommit(interp, objc, objv, txnp, txnip);
  514. _TxnInfoDelete(interp, txnip);
  515. (void)Tcl_DeleteCommand(interp, txnip->i_name);
  516. _DeleteInfo(txnip);
  517. break;
  518. }
  519. /*
  520.  * Only set result if we have a res.  Otherwise, lower
  521.  * functions have already done so.
  522.  */
  523. if (result == TCL_OK && res)
  524. Tcl_SetObjResult(interp, res);
  525. return (result);
  526. }
  528. static int
  529. tcl_TxnCommit(interp, objc, objv, txnp, txnip)
  530. Tcl_Interp *interp; /* Interpreter */
  531. int objc; /* How many arguments? */
  532. Tcl_Obj *CONST objv[]; /* The argument objects */
  533. DB_TXN *txnp; /* Transaction pointer */
  534. DBTCL_INFO *txnip; /* Info pointer */
  535. {
  536. static char *commitopt[] = {
  537. "-nosync",
  538. "-sync",
  539. NULL
  540. };
  541. enum commitopt {
  542. COMSYNC,
  543. COMNOSYNC
  544. };
  545. u_int32_t flag;
  546. int optindex, result, ret;
  548. COMPQUIET(txnip, NULL);
  550. result = TCL_OK;
  551. flag = 0;
  552. if (objc != 2 && objc != 3) {
  553. Tcl_WrongNumArgs(interp, 1, objv, NULL);
  554. return (TCL_ERROR);
  555. }
  556. if (objc == 3) {
  557. if (Tcl_GetIndexFromObj(interp, objv[2], commitopt,
  558.     "option", TCL_EXACT, &optindex) != TCL_OK)
  559. return (IS_HELP(objv[2]));
  560. switch ((enum commitopt)optindex) {
  561. case COMSYNC:
  562. FLAG_CHECK(flag);
  563. flag = DB_TXN_SYNC;
  564. break;
  565. case COMNOSYNC:
  566. FLAG_CHECK(flag);
  567. flag = DB_TXN_NOSYNC;
  568. break;
  569. }
  570. }
  572. _debug_check();
  573. ret = txnp->commit(txnp, flag);
  574. result = _ReturnSetup(interp, ret, DB_RETOK_STD(ret),
  575.     "txn commit");
  576. return (result);
  577. }
  579. #if CONFIG_TEST
  580. /*
  581.  * tcl_TxnRecover --
  582.  *
  583.  * PUBLIC: int tcl_TxnRecover __P((Tcl_Interp *, int,
  584.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *, DBTCL_INFO *));
  585.  */
  586. int
  587. tcl_TxnRecover(interp, objc, objv, envp, envip)
  588. Tcl_Interp *interp; /* Interpreter */
  589. int objc; /* How many arguments? */
  590. Tcl_Obj *CONST objv[]; /* The argument objects */
  591. DB_ENV *envp; /* Environment pointer */
  592. DBTCL_INFO *envip; /* Info pointer */
  593. {
  594. #define DO_PREPLIST(count)
  595. for (i = 0; i < count; i++) {
  596. snprintf(newname, sizeof(newname), "%s.txn%d",
  597.     envip->i_name, envip->i_envtxnid);
  598. ip = _NewInfo(interp, NULL, newname, I_TXN);
  599. if (ip == NULL) {
  600. Tcl_SetResult(interp, "Could not set up info",
  601.     TCL_STATIC);
  602. return (TCL_ERROR);
  603. }
  604. envip->i_envtxnid++;
  605. ip->i_parent = envip;
  606. p = &prep[i];
  607. _SetInfoData(ip, p->txn);
  608. Tcl_CreateObjCommand(interp, newname,
  609.     (Tcl_ObjCmdProc *)txn_Cmd, (ClientData)p->txn, NULL);
  610. result = _SetListElem(interp, res, newname, strlen(newname),
  611.     p->gid, DB_XIDDATASIZE);
  612. if (result != TCL_OK)
  613. goto error;
  614. }
  616. DBTCL_INFO *ip;
  617. DB_PREPLIST prep[DBTCL_PREP], *p;
  618. Tcl_Obj *res;
  619. long count, i;
  620. int result, ret;
  621. char newname[MSG_SIZE];
  623. result = TCL_OK;
  624. /*
  625.  * No args for this.  Error if there are some.
  626.  */
  627. if (objc != 2) {
  628. Tcl_WrongNumArgs(interp, 2, objv, NULL);
  629. return (TCL_ERROR);
  630. }
  631. _debug_check();
  632. ret = envp->txn_recover(envp, prep, DBTCL_PREP, &count, DB_FIRST);
  633. result = _ReturnSetup(interp, ret, DB_RETOK_STD(ret),
  634.     "txn recover");
  635. if (result == TCL_ERROR)
  636. return (result);
  637. res = Tcl_NewObj();
  638. DO_PREPLIST(count);
  640. /*
  641.  * If count returned is the maximum size we have, then there
  642.  * might be more.  Keep going until we get them all.
  643.  */
  644. while (count == DBTCL_PREP) {
  645. ret = envp->txn_recover(
  646.     envp, prep, DBTCL_PREP, &count, DB_NEXT);
  647. result = _ReturnSetup(interp, ret, DB_RETOK_STD(ret),
  648.     "txn recover");
  649. if (result == TCL_ERROR)
  650. return (result);
  651. DO_PREPLIST(count);
  652. }
  653. Tcl_SetObjResult(interp, res);
  654. error:
  655. return (result);
  656. }
  657. #endif