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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
tcl_txn.c
资源名称：mysql-3.23.35.tar.gz　[点击查看]
上传用户：tsgydb
上传日期：2007-04-14
资源大小：10674k
文件大小：11k
源码类别：

MySQL数据库

开发平台：

Visual C++

tcl_txn.c：源码内容
  1. /*-
  2.  * See the file LICENSE for redistribution information.
  3.  *
  4.  * Copyright (c) 1999, 2000
  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.24 2000/12/31 19:26:23 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 "tcl_db.h"
  25. /*
  26.  * Prototypes for procedures defined later in this file:
  27.  */
  28. static int      tcl_TxnCommit __P((Tcl_Interp *, int, Tcl_Obj * CONST*,
  29.     DB_TXN *, DBTCL_INFO *));
  31. /*
  32.  * _TxnInfoDelete --
  33.  * Removes nested txn info structures that are children
  34.  * of this txn.
  35.  * RECURSIVE:  Transactions can be arbitrarily nested, so we
  36.  * must recurse down until we get them all.
  37.  *
  38.  * PUBLIC: void _TxnInfoDelete __P((Tcl_Interp *, DBTCL_INFO *));
  39.  */
  40. void
  41. _TxnInfoDelete(interp, txnip)
  42. Tcl_Interp *interp;             /* Interpreter */
  43. DBTCL_INFO *txnip; /* Info for txn */
  44. {
  45. DBTCL_INFO *nextp, *p;
  47. for (p = LIST_FIRST(&__db_infohead); p != NULL; p = nextp) {
  48. /*
  49.  * Check if this info structure "belongs" to this
  50.  * txn.  Remove its commands and info structure.
  51.  */
  52. nextp = LIST_NEXT(p, entries);
  53.  if (p->i_parent == txnip && p->i_type == I_TXN) {
  54. _TxnInfoDelete(interp, p);
  55. (void)Tcl_DeleteCommand(interp, p->i_name);
  56. _DeleteInfo(p);
  57. }
  58. }
  59. }
  61. /*
  62.  * tcl_TxnCheckpoint --
  63.  *
  64.  * PUBLIC: int tcl_TxnCheckpoint __P((Tcl_Interp *, int,
  65.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  66.  */
  67. int
  68. tcl_TxnCheckpoint(interp, objc, objv, envp)
  69. Tcl_Interp *interp; /* Interpreter */
  70. int objc; /* How many arguments? */
  71. Tcl_Obj *CONST objv[]; /* The argument objects */
  72. DB_ENV *envp; /* Environment pointer */
  73. {
  74. static char *txnckpopts[] = {
  75. "-kbyte", "-min",
  76. NULL
  77. };
  78. enum txnckpopts {
  79. TXNCKP_KB, TXNCKP_MIN
  80. };
  81. int i, kb, min, optindex, result, ret;
  83. result = TCL_OK;
  84. kb = min = 0;
  86. /*
  87.  * Get the flag index from the object based on the options
  88.  * defined above.
  89.  */
  90. i = 2;
  91. while (i < objc) {
  92. if (Tcl_GetIndexFromObj(interp, objv[i],
  93.     txnckpopts, "option", TCL_EXACT, &optindex) != TCL_OK) {
  94. return (IS_HELP(objv[i]));
  95. }
  96. i++;
  97. switch ((enum txnckpopts)optindex) {
  98. case TXNCKP_KB:
  99. if (i == objc) {
  100. Tcl_WrongNumArgs(interp, 2, objv,
  101.     "?-kbyte kb?");
  102. result = TCL_ERROR;
  103. break;
  104. }
  105. result = Tcl_GetIntFromObj(interp, objv[i++], &kb);
  106. break;
  107. case TXNCKP_MIN:
  108. if (i == objc) {
  109. Tcl_WrongNumArgs(interp, 2, objv, "?-min min?");
  110. result = TCL_ERROR;
  111. break;
  112. }
  113. result = Tcl_GetIntFromObj(interp, objv[i++], &min);
  114. break;
  115. }
  116. }
  117. _debug_check();
  118. ret = txn_checkpoint(envp, (u_int32_t)kb, (u_int32_t)min, 0);
  119. result = _ReturnSetup(interp, ret, "txn checkpoint");
  120. return (result);
  121. }
  123. /*
  124.  * tcl_Txn --
  125.  *
  126.  * PUBLIC: int tcl_Txn __P((Tcl_Interp *, int,
  127.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *, DBTCL_INFO *));
  128.  */
  129. int
  130. tcl_Txn(interp, objc, objv, envp, envip)
  131. Tcl_Interp *interp; /* Interpreter */
  132. int objc; /* How many arguments? */
  133. Tcl_Obj *CONST objv[]; /* The argument objects */
  134. DB_ENV *envp; /* Environment pointer */
  135. DBTCL_INFO *envip; /* Info pointer */
  136. {
  137. static char *txnopts[] = {
  138. "-nosync",
  139. "-nowait",
  140. "-parent",
  141. "-sync",
  142. NULL
  143. };
  144. enum txnopts {
  145. TXN_NOSYNC,
  146. TXN_NOWAIT,
  147. TXN_PARENT,
  148. TXN_SYNC
  149. };
  150. DBTCL_INFO *ip;
  151. DB_TXN *parent;
  152. DB_TXN *txn;
  153. Tcl_Obj *res;
  154. u_int32_t flag;
  155. int i, optindex, result, ret;
  156. char *arg, msg[MSG_SIZE], newname[MSG_SIZE];
  158. result = TCL_OK;
  159. memset(newname, 0, MSG_SIZE);
  161. parent = NULL;
  162. flag = 0;
  163. i = 2;
  164. while (i < objc) {
  165. if (Tcl_GetIndexFromObj(interp, objv[i],
  166.     txnopts, "option", TCL_EXACT, &optindex) != TCL_OK) {
  167. return (IS_HELP(objv[i]));
  168. }
  169. i++;
  170. switch ((enum txnopts)optindex) {
  171. case TXN_PARENT:
  172. if (i == objc) {
  173. Tcl_WrongNumArgs(interp, 2, objv,
  174.     "?-parent txn?");
  175. result = TCL_ERROR;
  176. break;
  177. }
  178. arg = Tcl_GetStringFromObj(objv[i++], NULL);
  179. parent = NAME_TO_TXN(arg);
  180. if (parent == NULL) {
  181. snprintf(msg, MSG_SIZE,
  182.     "Invalid parent txn: %sn",
  183.     arg);
  184. Tcl_SetResult(interp, msg, TCL_VOLATILE);
  185. return (TCL_ERROR);
  186. }
  187. break;
  188. case TXN_NOWAIT:
  189. FLAG_CHECK(flag);
  190. flag |= DB_TXN_NOWAIT;
  191. break;
  192. case TXN_SYNC:
  193. FLAG_CHECK(flag);
  194. flag |= DB_TXN_SYNC;
  195. break;
  196. case TXN_NOSYNC:
  197. FLAG_CHECK(flag);
  198. flag |= DB_TXN_NOSYNC;
  199. break;
  200. }
  201. }
  202. snprintf(newname, sizeof(newname), "%s.txn%d",
  203.     envip->i_name, envip->i_envtxnid);
  204. ip = _NewInfo(interp, NULL, newname, I_TXN);
  205. if (ip == NULL) {
  206. Tcl_SetResult(interp, "Could not set up info",
  207.     TCL_STATIC);
  208. return (TCL_ERROR);
  209. }
  210. _debug_check();
  211. ret = txn_begin(envp, parent, &txn, flag);
  212. result = _ReturnSetup(interp, ret, "txn");
  213. if (result == TCL_ERROR)
  214. _DeleteInfo(ip);
  215. else {
  216. /*
  217.  * Success.  Set up return.  Set up new info
  218.  * and command widget for this txn.
  219.  */
  220. envip->i_envtxnid++;
  221. if (parent)
  222. ip->i_parent = _PtrToInfo(parent);
  223. else
  224. ip->i_parent = envip;
  225. _SetInfoData(ip, txn);
  226. Tcl_CreateObjCommand(interp, newname,
  227.     (Tcl_ObjCmdProc *)txn_Cmd, (ClientData)txn, NULL);
  228. res = Tcl_NewStringObj(newname, strlen(newname));
  229. Tcl_SetObjResult(interp, res);
  230. }
  231. return (result);
  232. }
  234. /*
  235.  * tcl_TxnStat --
  236.  *
  237.  * PUBLIC: int tcl_TxnStat __P((Tcl_Interp *, int,
  238.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  239.  */
  240. int
  241. tcl_TxnStat(interp, objc, objv, envp)
  242. Tcl_Interp *interp; /* Interpreter */
  243. int objc; /* How many arguments? */
  244. Tcl_Obj *CONST objv[]; /* The argument objects */
  245. DB_ENV *envp; /* Environment pointer */
  246. {
  247. #define MAKE_STAT_LSN(s, lsn)
  248. do {
  249. myobjc = 2;
  250. myobjv[0] = Tcl_NewIntObj((lsn)->file);
  251. myobjv[1] = Tcl_NewIntObj((lsn)->offset);
  252. lsnlist = Tcl_NewListObj(myobjc, myobjv);
  253. myobjc = 2;
  254. myobjv[0] = Tcl_NewStringObj((s), strlen(s));
  255. myobjv[1] = lsnlist;
  256. thislist = Tcl_NewListObj(myobjc, myobjv);
  257. result = Tcl_ListObjAppendElement(interp, res, thislist);
  258. if (result != TCL_OK)
  259. goto error;
  260. } while (0);
  262. DBTCL_INFO *ip;
  263. DB_TXN_ACTIVE *p;
  264. DB_TXN_STAT *sp;
  265. Tcl_Obj *myobjv[2], *res, *thislist, *lsnlist;
  266. u_int32_t i;
  267. int myobjc, result, ret;
  269. result = TCL_OK;
  270. /*
  271.  * No args for this.  Error if there are some.
  272.  */
  273. if (objc != 2) {
  274. Tcl_WrongNumArgs(interp, 2, objv, NULL);
  275. return (TCL_ERROR);
  276. }
  277. _debug_check();
  278. ret = txn_stat(envp, &sp, NULL);
  279. result = _ReturnSetup(interp, ret, "txn stat");
  280. if (result == TCL_ERROR)
  281. return (result);
  283. /*
  284.  * Have our stats, now construct the name value
  285.  * list pairs and free up the memory.
  286.  */
  287. res = Tcl_NewObj();
  288. /*
  289.  * MAKE_STAT_LIST assumes 'res' and 'error' label.
  290.  */
  291. MAKE_STAT_LIST("Region size", sp->st_regsize);
  292. MAKE_STAT_LSN("LSN of last checkpoint", &sp->st_last_ckp);
  293. MAKE_STAT_LSN("LSN of pending checkpoint", &sp->st_pending_ckp);
  294. MAKE_STAT_LIST("Time of last checkpoint", sp->st_time_ckp);
  295. MAKE_STAT_LIST("Last txn ID allocated", sp->st_last_txnid);
  296. MAKE_STAT_LIST("Max Txns", sp->st_maxtxns);
  297. MAKE_STAT_LIST("Number aborted txns", sp->st_naborts);
  298. MAKE_STAT_LIST("Number active txns", sp->st_nactive);
  299. MAKE_STAT_LIST("Number txns begun", sp->st_nbegins);
  300. MAKE_STAT_LIST("Number committed txns", sp->st_ncommits);
  301. MAKE_STAT_LIST("Number of region lock waits", sp->st_region_wait);
  302. MAKE_STAT_LIST("Number of region lock nowaits", sp->st_region_nowait);
  303. for (i = 0, p = sp->st_txnarray; i < sp->st_nactive; i++, p++)
  304. for (ip = LIST_FIRST(&__db_infohead); ip != NULL;
  305.     ip = LIST_NEXT(ip, entries)) {
  306. if (ip->i_type != I_TXN)
  307. continue;
  308. if (ip->i_type == I_TXN &&
  309.     (txn_id(ip->i_txnp) == p->txnid)) {
  310. MAKE_STAT_LSN(ip->i_name, &p->lsn);
  311. if (p->parentid != 0)
  312. MAKE_STAT_STRLIST("Parent",
  313.     ip->i_parent->i_name);
  314. else
  315. MAKE_STAT_LIST("Parent", 0);
  316. break;
  317. }
  318. }
  319. Tcl_SetObjResult(interp, res);
  320. error:
  321. __os_free(sp, sizeof(*sp));
  322. return (result);
  323. }
  325. /*
  326.  * txn_Cmd --
  327.  * Implements the "txn" widget.
  328.  *
  329.  * PUBLIC: int txn_Cmd __P((ClientData, Tcl_Interp *, int, Tcl_Obj * CONST*));
  330.  */
  331. int
  332. txn_Cmd(clientData, interp, objc, objv)
  333. ClientData clientData;          /* Txn handle */
  334. Tcl_Interp *interp;             /* Interpreter */
  335. int objc;                       /* How many arguments? */
  336. Tcl_Obj *CONST objv[];          /* The argument objects */
  337. {
  338. static char *txncmds[] = {
  339. "abort",
  340. "commit",
  341. "id",
  342. "prepare",
  343. NULL
  344. };
  345. enum txncmds {
  346. TXNABORT,
  347. TXNCOMMIT,
  348. TXNID,
  349. TXNPREPARE
  350. };
  351. DBTCL_INFO *txnip;
  352. DB_TXN *txnp;
  353. Tcl_Obj *res;
  354. int cmdindex, result, ret;
  356. Tcl_ResetResult(interp);
  357. txnp = (DB_TXN *)clientData;
  358. txnip = _PtrToInfo((void *)txnp);
  359. result = TCL_OK;
  360. if (txnp == NULL) {
  361. Tcl_SetResult(interp, "NULL txn pointer", TCL_STATIC);
  362. return (TCL_ERROR);
  363. }
  364. if (txnip == NULL) {
  365. Tcl_SetResult(interp, "NULL txn info pointer", TCL_STATIC);
  366. return (TCL_ERROR);
  367. }
  369. /*
  370.  * Get the command name index from the object based on the dbcmds
  371.  * defined above.
  372.  */
  373. if (Tcl_GetIndexFromObj(interp,
  374.     objv[1], txncmds, "command", TCL_EXACT, &cmdindex) != TCL_OK)
  375. return (IS_HELP(objv[1]));
  377. res = NULL;
  378. switch ((enum txncmds)cmdindex) {
  379. case TXNID:
  380. if (objc != 2) {
  381. Tcl_WrongNumArgs(interp, 1, objv, NULL);
  382. return (TCL_ERROR);
  383. }
  384. _debug_check();
  385. ret = txn_id(txnp);
  386. res = Tcl_NewIntObj(ret);
  387. break;
  388. case TXNPREPARE:
  389. if (objc != 2) {
  390. Tcl_WrongNumArgs(interp, 1, objv, NULL);
  391. return (TCL_ERROR);
  392. }
  393. _debug_check();
  394. ret = txn_prepare(txnp);
  395. result = _ReturnSetup(interp, ret, "txn prepare");
  396. break;
  397. case TXNCOMMIT:
  398. result = tcl_TxnCommit(interp, objc, objv, txnp, txnip);
  399. _TxnInfoDelete(interp, txnip);
  400. (void)Tcl_DeleteCommand(interp, txnip->i_name);
  401. _DeleteInfo(txnip);
  402. break;
  403. case TXNABORT:
  404. if (objc != 2) {
  405. Tcl_WrongNumArgs(interp, 1, objv, NULL);
  406. return (TCL_ERROR);
  407. }
  408. _debug_check();
  409. ret = txn_abort(txnp);
  410. result = _ReturnSetup(interp, ret, "txn abort");
  411. _TxnInfoDelete(interp, txnip);
  412. (void)Tcl_DeleteCommand(interp, txnip->i_name);
  413. _DeleteInfo(txnip);
  414. break;
  415. }
  416. /*
  417.  * Only set result if we have a res.  Otherwise, lower
  418.  * functions have already done so.
  419.  */
  420. if (result == TCL_OK && res)
  421. Tcl_SetObjResult(interp, res);
  422. return (result);
  423. }
  425. static int
  426. tcl_TxnCommit(interp, objc, objv, txnp, txnip)
  427. Tcl_Interp *interp;             /* Interpreter */
  428. int objc;                       /* How many arguments? */
  429. Tcl_Obj *CONST objv[];          /* The argument objects */
  430. DB_TXN *txnp; /* Transaction pointer */
  431. DBTCL_INFO *txnip; /* Info pointer */
  432. {
  433. static char *commitopt[] = {
  434. "-nosync",
  435. "-sync",
  436. NULL
  437. };
  438. enum commitopt {
  439. COMSYNC,
  440. COMNOSYNC
  441. };
  442. u_int32_t flag;
  443. int optindex, result, ret;
  445. COMPQUIET(txnip, NULL);
  447. result = TCL_OK;
  448. flag = 0;
  449. if (objc != 2 && objc != 3) {
  450. Tcl_WrongNumArgs(interp, 1, objv, NULL);
  451. return (TCL_ERROR);
  452. }
  453. if (objc == 3) {
  454. if (Tcl_GetIndexFromObj(interp, objv[2], commitopt,
  455.     "option", TCL_EXACT, &optindex) != TCL_OK)
  456. return (IS_HELP(objv[2]));
  457. switch ((enum commitopt)optindex) {
  458. case COMSYNC:
  459. FLAG_CHECK(flag);
  460. flag = DB_TXN_SYNC;
  461. break;
  462. case COMNOSYNC:
  463. FLAG_CHECK(flag);
  464. flag = DB_TXN_NOSYNC;
  465. break;
  466. }
  467. }
  469. _debug_check();
  470. ret = txn_commit(txnp, flag);
  471. result = _ReturnSetup(interp, ret, "txn commit");
  472. return (result);
  473. }