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

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

MySQL数据库

开发平台：

Visual C++

tcl_log.c：源码内容
  1. /*-
  2.  * See the file LICENSE for redistribution information.
  3.  *
  4.  * Copyright (c) 1999-2002
  5.  * Sleepycat Software.  All rights reserved.
  6.  */
  8. #include "db_config.h"
  10. #ifndef lint
  11. static const char revid[] = "$Id: tcl_log.c,v 11.52 2002/08/14 20:11:57 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/log.h"
  24. #include "dbinc/tcl_db.h"
  25. #include "dbinc/txn.h"
  27. #ifdef CONFIG_TEST
  28. static int tcl_LogcGet __P((Tcl_Interp *, int, Tcl_Obj * CONST*, DB_LOGC *));
  30. /*
  31.  * tcl_LogArchive --
  32.  *
  33.  * PUBLIC: int tcl_LogArchive __P((Tcl_Interp *, int,
  34.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  35.  */
  36. int
  37. tcl_LogArchive(interp, objc, objv, envp)
  38. Tcl_Interp *interp; /* Interpreter */
  39. int objc; /* How many arguments? */
  40. Tcl_Obj *CONST objv[]; /* The argument objects */
  41. DB_ENV *envp; /* Environment pointer */
  42. {
  43. static char *archopts[] = {
  44. "-arch_abs", "-arch_data", "-arch_log",
  45. NULL
  46. };
  47. enum archopts {
  48. ARCH_ABS, ARCH_DATA, ARCH_LOG
  49. };
  50. Tcl_Obj *fileobj, *res;
  51. u_int32_t flag;
  52. int i, optindex, result, ret;
  53. char **file, **list;
  55. result = TCL_OK;
  56. flag = 0;
  57. /*
  58.  * Get the flag index from the object based on the options
  59.  * defined above.
  60.  */
  61. i = 2;
  62. while (i < objc) {
  63. if (Tcl_GetIndexFromObj(interp, objv[i],
  64.     archopts, "option", TCL_EXACT, &optindex) != TCL_OK)
  65. return (IS_HELP(objv[i]));
  66. i++;
  67. switch ((enum archopts)optindex) {
  68. case ARCH_ABS:
  69. flag |= DB_ARCH_ABS;
  70. break;
  71. case ARCH_DATA:
  72. flag |= DB_ARCH_DATA;
  73. break;
  74. case ARCH_LOG:
  75. flag |= DB_ARCH_LOG;
  76. break;
  77. }
  78. }
  79. _debug_check();
  80. list = NULL;
  81. ret = envp->log_archive(envp, &list, flag);
  82. result = _ReturnSetup(interp, ret, DB_RETOK_STD(ret), "log archive");
  83. if (result == TCL_OK) {
  84. res = Tcl_NewListObj(0, NULL);
  85. for (file = list; file != NULL && *file != NULL; file++) {
  86. fileobj = Tcl_NewStringObj(*file, strlen(*file));
  87. result = Tcl_ListObjAppendElement(interp, res, fileobj);
  88. if (result != TCL_OK)
  89. break;
  90. }
  91. Tcl_SetObjResult(interp, res);
  92. }
  93. if (list != NULL)
  94. __os_ufree(envp, list);
  95. return (result);
  96. }
  98. /*
  99.  * tcl_LogCompare --
  100.  *
  101.  * PUBLIC: int tcl_LogCompare __P((Tcl_Interp *, int,
  102.  * PUBLIC:    Tcl_Obj * CONST*));
  103.  */
  104. int
  105. tcl_LogCompare(interp, objc, objv)
  106. Tcl_Interp *interp; /* Interpreter */
  107. int objc; /* How many arguments? */
  108. Tcl_Obj *CONST objv[]; /* The argument objects */
  109. {
  110. DB_LSN lsn0, lsn1;
  111. Tcl_Obj *res;
  112. int result, ret;
  114. result = TCL_OK;
  115. /*
  116.  * No flags, must be 4 args.
  117.  */
  118. if (objc != 4) {
  119. Tcl_WrongNumArgs(interp, 2, objv, "lsn1 lsn2");
  120. return (TCL_ERROR);
  121. }
  123. result = _GetLsn(interp, objv[2], &lsn0);
  124. if (result == TCL_ERROR)
  125. return (result);
  126. result = _GetLsn(interp, objv[3], &lsn1);
  127. if (result == TCL_ERROR)
  128. return (result);
  130. _debug_check();
  131. ret = log_compare(&lsn0, &lsn1);
  132. res = Tcl_NewIntObj(ret);
  133. Tcl_SetObjResult(interp, res);
  134. return (result);
  135. }
  137. /*
  138.  * tcl_LogFile --
  139.  *
  140.  * PUBLIC: int tcl_LogFile __P((Tcl_Interp *, int,
  141.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  142.  */
  143. int
  144. tcl_LogFile(interp, objc, objv, envp)
  145. Tcl_Interp *interp; /* Interpreter */
  146. int objc; /* How many arguments? */
  147. Tcl_Obj *CONST objv[]; /* The argument objects */
  148. DB_ENV *envp; /* Environment pointer */
  149. {
  150. DB_LSN lsn;
  151. Tcl_Obj *res;
  152. size_t len;
  153. int result, ret;
  154. char *name;
  156. result = TCL_OK;
  157. /*
  158.  * No flags, must be 3 args.
  159.  */
  160. if (objc != 3) {
  161. Tcl_WrongNumArgs(interp, 2, objv, "lsn");
  162. return (TCL_ERROR);
  163. }
  165. result = _GetLsn(interp, objv[2], &lsn);
  166. if (result == TCL_ERROR)
  167. return (result);
  169. len = MSG_SIZE;
  170. ret = ENOMEM;
  171. name = NULL;
  172. while (ret == ENOMEM) {
  173. if (name != NULL)
  174. __os_free(envp, name);
  175. ret = __os_malloc(envp, len, &name);
  176. if (ret != 0) {
  177. Tcl_SetResult(interp, db_strerror(ret), TCL_STATIC);
  178. break;
  179. }
  180. _debug_check();
  181. ret = envp->log_file(envp, &lsn, name, len);
  182. len *= 2;
  183. }
  184. result = _ReturnSetup(interp, ret, DB_RETOK_STD(ret), "log_file");
  185. if (ret == 0) {
  186. res = Tcl_NewStringObj(name, strlen(name));
  187. Tcl_SetObjResult(interp, res);
  188. }
  190. if (name != NULL)
  191. __os_free(envp, name);
  193. return (result);
  194. }
  196. /*
  197.  * tcl_LogFlush --
  198.  *
  199.  * PUBLIC: int tcl_LogFlush __P((Tcl_Interp *, int,
  200.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  201.  */
  202. int
  203. tcl_LogFlush(interp, objc, objv, envp)
  204. Tcl_Interp *interp; /* Interpreter */
  205. int objc; /* How many arguments? */
  206. Tcl_Obj *CONST objv[]; /* The argument objects */
  207. DB_ENV *envp; /* Environment pointer */
  208. {
  209. DB_LSN lsn, *lsnp;
  210. int result, ret;
  212. result = TCL_OK;
  213. /*
  214.  * No flags, must be 2 or 3 args.
  215.  */
  216. if (objc > 3) {
  217. Tcl_WrongNumArgs(interp, 2, objv, "?lsn?");
  218. return (TCL_ERROR);
  219. }
  221. if (objc == 3) {
  222. lsnp = &lsn;
  223. result = _GetLsn(interp, objv[2], &lsn);
  224. if (result == TCL_ERROR)
  225. return (result);
  226. } else
  227. lsnp = NULL;
  229. _debug_check();
  230. ret = envp->log_flush(envp, lsnp);
  231. result = _ReturnSetup(interp, ret, DB_RETOK_STD(ret), "log_flush");
  232. return (result);
  233. }
  235. /*
  236.  * tcl_LogGet --
  237.  *
  238.  * PUBLIC: int tcl_LogGet __P((Tcl_Interp *, int,
  239.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  240.  */
  241. int
  242. tcl_LogGet(interp, objc, objv, envp)
  243. Tcl_Interp *interp; /* Interpreter */
  244. int objc; /* How many arguments? */
  245. Tcl_Obj *CONST objv[]; /* The argument objects */
  246. DB_ENV *envp; /* Environment pointer */
  247. {
  249. COMPQUIET(objv, NULL);
  250. COMPQUIET(objc, 0);
  251. COMPQUIET(envp, NULL);
  253. Tcl_SetResult(interp, "FAIL: log_get deprecatedn", TCL_STATIC);
  254. return (TCL_ERROR);
  255. }
  257. /*
  258.  * tcl_LogPut --
  259.  *
  260.  * PUBLIC: int tcl_LogPut __P((Tcl_Interp *, int,
  261.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  262.  */
  263. int
  264. tcl_LogPut(interp, objc, objv, envp)
  265. Tcl_Interp *interp; /* Interpreter */
  266. int objc; /* How many arguments? */
  267. Tcl_Obj *CONST objv[]; /* The argument objects */
  268. DB_ENV *envp; /* Environment pointer */
  269. {
  270. static char *logputopts[] = {
  271. "-flush",
  272. NULL
  273. };
  274. enum logputopts {
  275. LOGPUT_FLUSH
  276. };
  277. DB_LSN lsn;
  278. DBT data;
  279. Tcl_Obj *intobj, *res;
  280. void *dtmp;
  281. u_int32_t flag;
  282. int freedata, optindex, result, ret;
  284. result = TCL_OK;
  285. flag = 0;
  286. freedata = 0;
  287. if (objc < 3) {
  288. Tcl_WrongNumArgs(interp, 2, objv, "?-args? record");
  289. return (TCL_ERROR);
  290. }
  292. /*
  293.  * Data/record must be the last arg.
  294.  */
  295. memset(&data, 0, sizeof(data));
  296. ret = _CopyObjBytes(interp, objv[objc-1], &dtmp,
  297.     &data.size, &freedata);
  298. if (ret != 0) {
  299. result = _ReturnSetup(interp, ret,
  300.     DB_RETOK_STD(ret), "log put");
  301. return (result);
  302. }
  303. data.data = dtmp;
  305. /*
  306.  * Get the command name index from the object based on the options
  307.  * defined above.
  308.  */
  309. if (objc == 4) {
  310. if (Tcl_GetIndexFromObj(interp, objv[2],
  311.     logputopts, "option", TCL_EXACT, &optindex) != TCL_OK) {
  312. return (IS_HELP(objv[2]));
  313. }
  314. switch ((enum logputopts)optindex) {
  315. case LOGPUT_FLUSH:
  316. flag = DB_FLUSH;
  317. break;
  318. }
  319. }
  321. if (result == TCL_ERROR)
  322. return (result);
  324. _debug_check();
  325. ret = envp->log_put(envp, &lsn, &data, flag);
  326. result = _ReturnSetup(interp, ret, DB_RETOK_STD(ret), "log_put");
  327. if (result == TCL_ERROR)
  328. return (result);
  329. res = Tcl_NewListObj(0, NULL);
  330. intobj = Tcl_NewLongObj((long)lsn.file);
  331. result = Tcl_ListObjAppendElement(interp, res, intobj);
  332. intobj = Tcl_NewLongObj((long)lsn.offset);
  333. result = Tcl_ListObjAppendElement(interp, res, intobj);
  334. Tcl_SetObjResult(interp, res);
  335. if (freedata)
  336. (void)__os_free(NULL, dtmp);
  337. return (result);
  338. }
  339. /*
  340.  * tcl_LogStat --
  341.  *
  342.  * PUBLIC: int tcl_LogStat __P((Tcl_Interp *, int,
  343.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  344.  */
  345. int
  346. tcl_LogStat(interp, objc, objv, envp)
  347. Tcl_Interp *interp; /* Interpreter */
  348. int objc; /* How many arguments? */
  349. Tcl_Obj *CONST objv[]; /* The argument objects */
  350. DB_ENV *envp; /* Environment pointer */
  351. {
  352. DB_LOG_STAT *sp;
  353. Tcl_Obj *res;
  354. int result, ret;
  356. result = TCL_OK;
  357. /*
  358.  * No args for this.  Error if there are some.
  359.  */
  360. if (objc != 2) {
  361. Tcl_WrongNumArgs(interp, 2, objv, NULL);
  362. return (TCL_ERROR);
  363. }
  364. _debug_check();
  365. ret = envp->log_stat(envp, &sp, 0);
  366. result = _ReturnSetup(interp, ret, DB_RETOK_STD(ret), "log stat");
  367. if (result == TCL_ERROR)
  368. return (result);
  370. /*
  371.  * Have our stats, now construct the name value
  372.  * list pairs and free up the memory.
  373.  */
  374. res = Tcl_NewObj();
  375. /*
  376.  * MAKE_STAT_LIST assumes 'res' and 'error' label.
  377.  */
  378. MAKE_STAT_LIST("Magic", sp->st_magic);
  379. MAKE_STAT_LIST("Log file Version", sp->st_version);
  380. MAKE_STAT_LIST("Region size", sp->st_regsize);
  381. MAKE_STAT_LIST("Log file mode", sp->st_mode);
  382. MAKE_STAT_LIST("Log record cache size", sp->st_lg_bsize);
  383. MAKE_STAT_LIST("Current log file size", sp->st_lg_size);
  384. MAKE_STAT_LIST("Mbytes written", sp->st_w_mbytes);
  385. MAKE_STAT_LIST("Bytes written (over Mb)", sp->st_w_bytes);
  386. MAKE_STAT_LIST("Mbytes written since checkpoint", sp->st_wc_mbytes);
  387. MAKE_STAT_LIST("Bytes written (over Mb) since checkpoint",
  388.     sp->st_wc_bytes);
  389. MAKE_STAT_LIST("Times log written", sp->st_wcount);
  390. MAKE_STAT_LIST("Times log written because cache filled up",
  391.     sp->st_wcount_fill);
  392. MAKE_STAT_LIST("Times log flushed", sp->st_scount);
  393. MAKE_STAT_LIST("Current log file number", sp->st_cur_file);
  394. MAKE_STAT_LIST("Current log file offset", sp->st_cur_offset);
  395. MAKE_STAT_LIST("On-disk log file number", sp->st_disk_file);
  396. MAKE_STAT_LIST("On-disk log file offset", sp->st_disk_offset);
  397. MAKE_STAT_LIST("Max commits in a log flush", sp->st_maxcommitperflush);
  398. MAKE_STAT_LIST("Min commits in a log flush", sp->st_mincommitperflush);
  399. MAKE_STAT_LIST("Number of region lock waits", sp->st_region_wait);
  400. MAKE_STAT_LIST("Number of region lock nowaits", sp->st_region_nowait);
  401. Tcl_SetObjResult(interp, res);
  402. error:
  403. free(sp);
  404. return (result);
  405. }
  407. /*
  408.  * logc_Cmd --
  409.  * Implements the log cursor command.
  410.  *
  411.  * PUBLIC: int logc_Cmd __P((ClientData, Tcl_Interp *, int, Tcl_Obj * CONST*));
  412.  */
  413. int
  414. logc_Cmd(clientData, interp, objc, objv)
  415. ClientData clientData; /* Cursor handle */
  416. Tcl_Interp *interp; /* Interpreter */
  417. int objc; /* How many arguments? */
  418. Tcl_Obj *CONST objv[]; /* The argument objects */
  419. {
  420. static char *logccmds[] = {
  421. "close",
  422. "get",
  423. NULL
  424. };
  425. enum logccmds {
  426. LOGCCLOSE,
  427. LOGCGET
  428. };
  429. DB_LOGC *logc;
  430. DBTCL_INFO *logcip;
  431. int cmdindex, result, ret;
  433. Tcl_ResetResult(interp);
  434. logc = (DB_LOGC *)clientData;
  435. logcip = _PtrToInfo((void *)logc);
  436. result = TCL_OK;
  438. if (objc <= 1) {
  439. Tcl_WrongNumArgs(interp, 1, objv, "command cmdargs");
  440. return (TCL_ERROR);
  441. }
  442. if (logc == NULL) {
  443. Tcl_SetResult(interp, "NULL logc pointer", TCL_STATIC);
  444. return (TCL_ERROR);
  445. }
  446. if (logcip == NULL) {
  447. Tcl_SetResult(interp, "NULL logc info pointer", TCL_STATIC);
  448. return (TCL_ERROR);
  449. }
  451. /*
  452.  * Get the command name index from the object based on the berkdbcmds
  453.  * defined above.
  454.  */
  455. if (Tcl_GetIndexFromObj(interp, objv[1], logccmds, "command",
  456.     TCL_EXACT, &cmdindex) != TCL_OK)
  457. return (IS_HELP(objv[1]));
  458. switch ((enum logccmds)cmdindex) {
  459. case LOGCCLOSE:
  460. /*
  461.  * No args for this.  Error if there are some.
  462.  */
  463. if (objc > 2) {
  464. Tcl_WrongNumArgs(interp, 2, objv, NULL);
  465. return (TCL_ERROR);
  466. }
  467. _debug_check();
  468. ret = logc->close(logc, 0);
  469. result = _ReturnSetup(interp, ret, DB_RETOK_STD(ret),
  470.     "logc close");
  471. if (result == TCL_OK) {
  472. (void)Tcl_DeleteCommand(interp, logcip->i_name);
  473. _DeleteInfo(logcip);
  474. }
  475. break;
  476. case LOGCGET:
  477. result = tcl_LogcGet(interp, objc, objv, logc);
  478. break;
  479. }
  480. return (result);
  481. }
  483. static int
  484. tcl_LogcGet(interp, objc, objv, logc)
  485. Tcl_Interp *interp;
  486. int objc;
  487. Tcl_Obj * CONST *objv;
  488. DB_LOGC *logc;
  489. {
  490. static char *logcgetopts[] = {
  491. "-current",
  492. "-first",
  493. "-last",
  494. "-next",
  495. "-prev",
  496. "-set",
  497. NULL
  498. };
  499. enum logcgetopts {
  500. LOGCGET_CURRENT,
  501. LOGCGET_FIRST,
  502. LOGCGET_LAST,
  503. LOGCGET_NEXT,
  504. LOGCGET_PREV,
  505. LOGCGET_SET
  506. };
  507. DB_LSN lsn;
  508. DBT data;
  509. Tcl_Obj *dataobj, *lsnlist, *myobjv[2], *res;
  510. u_int32_t flag;
  511. int i, myobjc, optindex, result, ret;
  513. result = TCL_OK;
  514. res = NULL;
  515. flag = 0;
  517. if (objc < 3) {
  518. Tcl_WrongNumArgs(interp, 2, objv, "?-args? lsn");
  519. return (TCL_ERROR);
  520. }
  522. /*
  523.  * Get the command name index from the object based on the options
  524.  * defined above.
  525.  */
  526. i = 2;
  527. while (i < objc) {
  528. if (Tcl_GetIndexFromObj(interp, objv[i],
  529.     logcgetopts, "option", TCL_EXACT, &optindex) != TCL_OK)
  530. return (IS_HELP(objv[i]));
  531. i++;
  532. switch ((enum logcgetopts)optindex) {
  533. case LOGCGET_CURRENT:
  534. FLAG_CHECK(flag);
  535. flag |= DB_CURRENT;
  536. break;
  537. case LOGCGET_FIRST:
  538. FLAG_CHECK(flag);
  539. flag |= DB_FIRST;
  540. break;
  541. case LOGCGET_LAST:
  542. FLAG_CHECK(flag);
  543. flag |= DB_LAST;
  544. break;
  545. case LOGCGET_NEXT:
  546. FLAG_CHECK(flag);
  547. flag |= DB_NEXT;
  548. break;
  549. case LOGCGET_PREV:
  550. FLAG_CHECK(flag);
  551. flag |= DB_PREV;
  552. break;
  553. case LOGCGET_SET:
  554. FLAG_CHECK(flag);
  555. flag |= DB_SET;
  556. if (i == objc) {
  557. Tcl_WrongNumArgs(interp, 2, objv, "?-set lsn?");
  558. result = TCL_ERROR;
  559. break;
  560. }
  561. result = _GetLsn(interp, objv[i++], &lsn);
  562. break;
  563. }
  564. }
  566. if (result == TCL_ERROR)
  567. return (result);
  569. memset(&data, 0, sizeof(data));
  571. _debug_check();
  572. ret = logc->get(logc, &lsn, &data, flag);
  574. res = Tcl_NewListObj(0, NULL);
  575. if (res == NULL)
  576. goto memerr;
  578. if (ret == 0) {
  579. /*
  580.  * Success.  Set up return list as {LSN data} where LSN
  581.  * is a sublist {file offset}.
  582.  */
  583. myobjc = 2;
  584. myobjv[0] = Tcl_NewLongObj((long)lsn.file);
  585. myobjv[1] = Tcl_NewLongObj((long)lsn.offset);
  586. lsnlist = Tcl_NewListObj(myobjc, myobjv);
  587. if (lsnlist == NULL)
  588. goto memerr;
  590. result = Tcl_ListObjAppendElement(interp, res, lsnlist);
  591. dataobj = Tcl_NewStringObj(data.data, data.size);
  592. if (dataobj == NULL) {
  593. goto memerr;
  594. }
  595. result = Tcl_ListObjAppendElement(interp, res, dataobj);
  596. } else
  597. result = _ReturnSetup(interp, ret, DB_RETOK_LGGET(ret),
  598.     "DB_LOGC->get");
  600. Tcl_SetObjResult(interp, res);
  602. if (0) {
  603. memerr: if (res != NULL)
  604. Tcl_DecrRefCount(res);
  605. Tcl_SetResult(interp, "allocation failed", TCL_STATIC);
  606. }
  608. return (result);
  609. }
  610. #endif