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

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

MySQL数据库

开发平台：

Visual C++

tcl_log.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_log.c,v 11.21 2000/11/30 00:58:45 ubell 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.  * tcl_LogArchive --
  27.  *
  28.  * PUBLIC: int tcl_LogArchive __P((Tcl_Interp *, int,
  29.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  30.  */
  31. int
  32. tcl_LogArchive(interp, objc, objv, envp)
  33. Tcl_Interp *interp; /* Interpreter */
  34. int objc; /* How many arguments? */
  35. Tcl_Obj *CONST objv[]; /* The argument objects */
  36. DB_ENV *envp; /* Environment pointer */
  37. {
  38. static char *archopts[] = {
  39. "-arch_abs", "-arch_data", "-arch_log",
  40. NULL
  41. };
  42. enum archopts {
  43. ARCH_ABS, ARCH_DATA, ARCH_LOG
  44. };
  45. Tcl_Obj *fileobj, *res;
  46. u_int32_t flag;
  47. int i, optindex, result, ret;
  48. char **file, **list;
  50. result = TCL_OK;
  51. flag = 0;
  52. /*
  53.  * Get the flag index from the object based on the options
  54.  * defined above.
  55.  */
  56. i = 2;
  57. while (i < objc) {
  58. if (Tcl_GetIndexFromObj(interp, objv[i],
  59.     archopts, "option", TCL_EXACT, &optindex) != TCL_OK)
  60. return (IS_HELP(objv[i]));
  61. i++;
  62. switch ((enum archopts)optindex) {
  63. case ARCH_ABS:
  64. flag |= DB_ARCH_ABS;
  65. break;
  66. case ARCH_DATA:
  67. flag |= DB_ARCH_DATA;
  68. break;
  69. case ARCH_LOG:
  70. flag |= DB_ARCH_LOG;
  71. break;
  72. }
  73. }
  74. _debug_check();
  75. list = NULL;
  76. ret = log_archive(envp, &list, flag, NULL);
  77. result = _ReturnSetup(interp, ret, "log archive");
  78. if (result == TCL_OK) {
  79. res = Tcl_NewListObj(0, NULL);
  80. for (file = list; file != NULL && *file != NULL; file++) {
  81. fileobj = Tcl_NewStringObj(*file, strlen(*file));
  82. result = Tcl_ListObjAppendElement(interp, res, fileobj);
  83. if (result != TCL_OK)
  84. break;
  85. }
  86. Tcl_SetObjResult(interp, res);
  87. }
  88. if (list != NULL)
  89. __os_free(list, 0);
  90. return (result);
  91. }
  93. /*
  94.  * tcl_LogCompare --
  95.  *
  96.  * PUBLIC: int tcl_LogCompare __P((Tcl_Interp *, int,
  97.  * PUBLIC:    Tcl_Obj * CONST*));
  98.  */
  99. int
  100. tcl_LogCompare(interp, objc, objv)
  101. Tcl_Interp *interp; /* Interpreter */
  102. int objc; /* How many arguments? */
  103. Tcl_Obj *CONST objv[]; /* The argument objects */
  104. {
  105. DB_LSN lsn0, lsn1;
  106. Tcl_Obj *res;
  107. int result, ret;
  109. result = TCL_OK;
  110. /*
  111.  * No flags, must be 4 args.
  112.  */
  113. if (objc != 4) {
  114. Tcl_WrongNumArgs(interp, 2, objv, "lsn1 lsn2");
  115. return (TCL_ERROR);
  116. }
  118. result = _GetLsn(interp, objv[2], &lsn0);
  119. if (result == TCL_ERROR)
  120. return (result);
  121. result = _GetLsn(interp, objv[3], &lsn1);
  122. if (result == TCL_ERROR)
  123. return (result);
  125. _debug_check();
  126. ret = log_compare(&lsn0, &lsn1);
  127. res = Tcl_NewIntObj(ret);
  128. Tcl_SetObjResult(interp, res);
  129. return (result);
  130. }
  132. /*
  133.  * tcl_LogFile --
  134.  *
  135.  * PUBLIC: int tcl_LogFile __P((Tcl_Interp *, int,
  136.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  137.  */
  138. int
  139. tcl_LogFile(interp, objc, objv, envp)
  140. Tcl_Interp *interp; /* Interpreter */
  141. int objc; /* How many arguments? */
  142. Tcl_Obj *CONST objv[]; /* The argument objects */
  143. DB_ENV *envp; /* Environment pointer */
  144. {
  145. DB_LSN lsn;
  146. Tcl_Obj *res;
  147. size_t len;
  148. int result, ret;
  149. char *name;
  151. result = TCL_OK;
  152. /*
  153.  * No flags, must be 3 args.
  154.  */
  155. if (objc != 3) {
  156. Tcl_WrongNumArgs(interp, 2, objv, "lsn");
  157. return (TCL_ERROR);
  158. }
  160. result = _GetLsn(interp, objv[2], &lsn);
  161. if (result == TCL_ERROR)
  162. return (result);
  164. len = MSG_SIZE;
  165. ret = ENOMEM;
  166. name = NULL;
  167. while (ret == ENOMEM) {
  168. if (name != NULL)
  169. __os_free(name, len/2);
  170. ret = __os_malloc(envp, len, NULL, &name);
  171. if (ret != 0) {
  172. Tcl_SetResult(interp, db_strerror(ret), TCL_STATIC);
  173. break;
  174. }
  175. _debug_check();
  176. ret = log_file(envp, &lsn, name, len);
  177. len *= 2;
  178. }
  179. result = _ReturnSetup(interp, ret, "log_file");
  180. if (ret == 0) {
  181. res = Tcl_NewStringObj(name, strlen(name));
  182. Tcl_SetObjResult(interp, res);
  183. }
  185. if (name != NULL)
  186. __os_free(name, len/2);
  188. return (result);
  189. }
  191. /*
  192.  * tcl_LogFlush --
  193.  *
  194.  * PUBLIC: int tcl_LogFlush __P((Tcl_Interp *, int,
  195.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  196.  */
  197. int
  198. tcl_LogFlush(interp, objc, objv, envp)
  199. Tcl_Interp *interp; /* Interpreter */
  200. int objc; /* How many arguments? */
  201. Tcl_Obj *CONST objv[]; /* The argument objects */
  202. DB_ENV *envp; /* Environment pointer */
  203. {
  204. DB_LSN lsn, *lsnp;
  205. int result, ret;
  207. result = TCL_OK;
  208. /*
  209.  * No flags, must be 2 or 3 args.
  210.  */
  211. if (objc > 3) {
  212. Tcl_WrongNumArgs(interp, 2, objv, "?lsn?");
  213. return (TCL_ERROR);
  214. }
  216. if (objc == 3) {
  217. lsnp = &lsn;
  218. result = _GetLsn(interp, objv[2], &lsn);
  219. if (result == TCL_ERROR)
  220. return (result);
  221. } else
  222. lsnp = NULL;
  224. _debug_check();
  225. ret = log_flush(envp, lsnp);
  226. result = _ReturnSetup(interp, ret, "log_flush");
  227. return (result);
  228. }
  230. /*
  231.  * tcl_LogGet --
  232.  *
  233.  * PUBLIC: int tcl_LogGet __P((Tcl_Interp *, int,
  234.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  235.  */
  236. int
  237. tcl_LogGet(interp, objc, objv, envp)
  238. Tcl_Interp *interp; /* Interpreter */
  239. int objc; /* How many arguments? */
  240. Tcl_Obj *CONST objv[]; /* The argument objects */
  241. DB_ENV *envp; /* Environment pointer */
  242. {
  243. static char *loggetopts[] = {
  244. "-checkpoint", "-current", "-first",
  245. "-last", "-next", "-prev",
  246. "-set",
  247. NULL
  248. };
  249. enum loggetopts {
  250. LOGGET_CKP, LOGGET_CUR, LOGGET_FIRST,
  251. LOGGET_LAST, LOGGET_NEXT, LOGGET_PREV,
  252. LOGGET_SET
  253. };
  254. DB_LSN lsn;
  255. DBT data;
  256. Tcl_Obj *dataobj, *lsnlist, *myobjv[2], *res;
  257. u_int32_t flag;
  258. int i, myobjc, optindex, result, ret;
  260. result = TCL_OK;
  261. flag = 0;
  262. if (objc < 3) {
  263. Tcl_WrongNumArgs(interp, 2, objv, "?-args? lsn");
  264. return (TCL_ERROR);
  265. }
  267. /*
  268.  * Get the command name index from the object based on the options
  269.  * defined above.
  270.  */
  271. i = 2;
  272. while (i < objc) {
  273. if (Tcl_GetIndexFromObj(interp, objv[i],
  274.     loggetopts, "option", TCL_EXACT, &optindex) != TCL_OK)
  275. return (IS_HELP(objv[i]));
  276. i++;
  277. switch ((enum loggetopts)optindex) {
  278. case LOGGET_CKP:
  279. FLAG_CHECK(flag);
  280. flag |= DB_CHECKPOINT;
  281. break;
  282. case LOGGET_CUR:
  283. FLAG_CHECK(flag);
  284. flag |= DB_CURRENT;
  285. break;
  286. case LOGGET_FIRST:
  287. FLAG_CHECK(flag);
  288. flag |= DB_FIRST;
  289. break;
  290. case LOGGET_LAST:
  291. FLAG_CHECK(flag);
  292. flag |= DB_LAST;
  293. break;
  294. case LOGGET_NEXT:
  295. FLAG_CHECK(flag);
  296. flag |= DB_NEXT;
  297. break;
  298. case LOGGET_PREV:
  299. FLAG_CHECK(flag);
  300. flag |= DB_PREV;
  301. break;
  302. case LOGGET_SET:
  303. FLAG_CHECK(flag);
  304. flag |= DB_SET;
  305. if (i == objc) {
  306. Tcl_WrongNumArgs(interp, 2, objv, "?-set lsn?");
  307. result = TCL_ERROR;
  308. break;
  309. }
  310. result = _GetLsn(interp, objv[i++], &lsn);
  311. break;
  312. }
  313. }
  315. if (result == TCL_ERROR)
  316. return (result);
  318. memset(&data, 0, sizeof(data));
  319. data.flags |= DB_DBT_MALLOC;
  320. _debug_check();
  321. ret = log_get(envp, &lsn, &data, flag);
  322. res = Tcl_NewListObj(0, NULL);
  323. result = _ReturnSetup(interp, ret, "log_get");
  324. if (ret == 0) {
  325. /*
  326.  * Success.  Set up return list as {LSN data} where LSN
  327.  * is a sublist {file offset}.
  328.  */
  329. myobjc = 2;
  330. myobjv[0] = Tcl_NewIntObj(lsn.file);
  331. myobjv[1] = Tcl_NewIntObj(lsn.offset);
  332. lsnlist = Tcl_NewListObj(myobjc, myobjv);
  333. if (lsnlist == NULL) {
  334. if (data.data != NULL)
  335. __os_free(data.data, data.size);
  336. return (TCL_ERROR);
  337. }
  338. result = Tcl_ListObjAppendElement(interp, res, lsnlist);
  339. dataobj = Tcl_NewStringObj(data.data, data.size);
  340. result = Tcl_ListObjAppendElement(interp, res, dataobj);
  341. }
  342. if (data.data != NULL)
  343. __os_free(data.data, data.size);
  345. if (result == TCL_OK)
  346. Tcl_SetObjResult(interp, res);
  347. return (result);
  348. }
  350. /*
  351.  * tcl_LogPut --
  352.  *
  353.  * PUBLIC: int tcl_LogPut __P((Tcl_Interp *, int,
  354.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  355.  */
  356. int
  357. tcl_LogPut(interp, objc, objv, envp)
  358. Tcl_Interp *interp; /* Interpreter */
  359. int objc; /* How many arguments? */
  360. Tcl_Obj *CONST objv[]; /* The argument objects */
  361. DB_ENV *envp; /* Environment pointer */
  362. {
  363. static char *logputopts[] = {
  364. "-checkpoint", "-curlsn", "-flush",
  365. NULL
  366. };
  367. enum logputopts {
  368. LOGPUT_CKP, LOGPUT_CUR, LOGPUT_FLUSH
  369. };
  370. DB_LSN lsn;
  371. DBT data;
  372. Tcl_Obj *intobj, *res;
  373. u_int32_t flag;
  374. int itmp, optindex, result, ret;
  376. result = TCL_OK;
  377. flag = 0;
  378. if (objc < 3) {
  379. Tcl_WrongNumArgs(interp, 2, objv, "?-args? record");
  380. return (TCL_ERROR);
  381. }
  383. /*
  384.  * Data/record must be the last arg.
  385.  */
  386. memset(&data, 0, sizeof(data));
  387. data.data = Tcl_GetByteArrayFromObj(objv[objc-1], &itmp);
  388. data.size = itmp;
  390. /*
  391.  * Get the command name index from the object based on the options
  392.  * defined above.
  393.  */
  394. if (objc == 4) {
  395. if (Tcl_GetIndexFromObj(interp, objv[2],
  396.     logputopts, "option", TCL_EXACT, &optindex) != TCL_OK) {
  397. return (IS_HELP(objv[2]));
  398. }
  399. switch ((enum logputopts)optindex) {
  400. case LOGPUT_CKP:
  401. flag = DB_CHECKPOINT;
  402. break;
  403. case LOGPUT_CUR:
  404. flag = DB_CURLSN;
  405. break;
  406. case LOGPUT_FLUSH:
  407. flag = DB_FLUSH;
  408. break;
  409. }
  410. }
  412. if (result == TCL_ERROR)
  413. return (result);
  415. _debug_check();
  416. ret = log_put(envp, &lsn, &data, flag);
  417. result = _ReturnSetup(interp, ret, "log_put");
  418. if (result == TCL_ERROR)
  419. return (result);
  420. res = Tcl_NewListObj(0, NULL);
  421. intobj = Tcl_NewIntObj(lsn.file);
  422. result = Tcl_ListObjAppendElement(interp, res, intobj);
  423. intobj = Tcl_NewIntObj(lsn.offset);
  424. result = Tcl_ListObjAppendElement(interp, res, intobj);
  425. Tcl_SetObjResult(interp, res);
  426. return (result);
  427. }
  429. /*
  430.  * tcl_LogRegister --
  431.  *
  432.  * PUBLIC: int tcl_LogRegister __P((Tcl_Interp *, int,
  433.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  434.  */
  435. int
  436. tcl_LogRegister(interp, objc, objv, envp)
  437. Tcl_Interp *interp; /* Interpreter */
  438. int objc; /* How many arguments? */
  439. Tcl_Obj *CONST objv[]; /* The argument objects */
  440. DB_ENV *envp; /* Environment pointer */
  441. {
  442. DB *dbp;
  443. Tcl_Obj *res;
  444. int result, ret;
  445. char *arg, msg[MSG_SIZE];
  447. result = TCL_OK;
  448. if (objc != 4) {
  449. Tcl_WrongNumArgs(interp, 2, objv, "db filename");
  450. return (TCL_ERROR);
  451. }
  452. /*
  453.  * First comes the DB.
  454.  */
  455. arg = Tcl_GetStringFromObj(objv[2], NULL);
  456. dbp = NAME_TO_DB(arg);
  457. if (dbp == NULL) {
  458. snprintf(msg, MSG_SIZE,
  459.     "LogRegister: Invalid db: %sn", arg);
  460. Tcl_SetResult(interp, msg, TCL_VOLATILE);
  461. return (TCL_ERROR);
  462. }
  464. /*
  465.  * Next is the filename.
  466.  */
  467. arg = Tcl_GetStringFromObj(objv[3], NULL);
  469. _debug_check();
  470. ret = log_register(envp, dbp, arg);
  471. result = _ReturnSetup(interp, ret, "log_register");
  472. if (result == TCL_OK) {
  473. res = Tcl_NewIntObj((int)dbp->log_fileid);
  474. Tcl_SetObjResult(interp, res);
  475. }
  476. return (result);
  477. }
  479. /*
  480.  * tcl_LogStat --
  481.  *
  482.  * PUBLIC: int tcl_LogStat __P((Tcl_Interp *, int,
  483.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  484.  */
  485. int
  486. tcl_LogStat(interp, objc, objv, envp)
  487. Tcl_Interp *interp; /* Interpreter */
  488. int objc; /* How many arguments? */
  489. Tcl_Obj *CONST objv[]; /* The argument objects */
  490. DB_ENV *envp; /* Environment pointer */
  491. {
  492. DB_LOG_STAT *sp;
  493. Tcl_Obj *res;
  494. int result, ret;
  496. result = TCL_OK;
  497. /*
  498.  * No args for this.  Error if there are some.
  499.  */
  500. if (objc != 2) {
  501. Tcl_WrongNumArgs(interp, 2, objv, NULL);
  502. return (TCL_ERROR);
  503. }
  504. _debug_check();
  505. ret = log_stat(envp, &sp, NULL);
  506. result = _ReturnSetup(interp, ret, "log stat");
  507. if (result == TCL_ERROR)
  508. return (result);
  510. /*
  511.  * Have our stats, now construct the name value
  512.  * list pairs and free up the memory.
  513.  */
  514. res = Tcl_NewObj();
  515. /*
  516.  * MAKE_STAT_LIST assumes 'res' and 'error' label.
  517.  */
  518. MAKE_STAT_LIST("Magic", sp->st_magic);
  519. MAKE_STAT_LIST("Log file Version", sp->st_version);
  520. MAKE_STAT_LIST("Region size", sp->st_regsize);
  521. MAKE_STAT_LIST("Log file mode", sp->st_mode);
  522. MAKE_STAT_LIST("Log record cache size", sp->st_lg_bsize);
  523. MAKE_STAT_LIST("Maximum log file size", sp->st_lg_max);
  524. MAKE_STAT_LIST("Mbytes written", sp->st_w_mbytes);
  525. MAKE_STAT_LIST("Bytes written (over Mb)", sp->st_w_bytes);
  526. MAKE_STAT_LIST("Mbytes written since checkpoint", sp->st_wc_mbytes);
  527. MAKE_STAT_LIST("Bytes written (over Mb) since checkpoint",
  528.     sp->st_wc_bytes);
  529. MAKE_STAT_LIST("Times log written", sp->st_wcount);
  530. MAKE_STAT_LIST("Times log written because cache filled up",
  531.     sp->st_wcount_fill);
  532. MAKE_STAT_LIST("Times log flushed", sp->st_scount);
  533. MAKE_STAT_LIST("Current log file number", sp->st_cur_file);
  534. MAKE_STAT_LIST("Current log file offset", sp->st_cur_offset);
  535. MAKE_STAT_LIST("Number of region lock waits", sp->st_region_wait);
  536. MAKE_STAT_LIST("Number of region lock nowaits", sp->st_region_nowait);
  537. Tcl_SetObjResult(interp, res);
  538. error:
  539. __os_free(sp, sizeof(*sp));
  540. return (result);
  541. }
  543. /*
  544.  * tcl_LogUnregister --
  545.  *
  546.  * PUBLIC: int tcl_LogUnregister __P((Tcl_Interp *, int,
  547.  * PUBLIC:    Tcl_Obj * CONST*, DB_ENV *));
  548.  */
  549. int
  550. tcl_LogUnregister(interp, objc, objv, envp)
  551. Tcl_Interp *interp; /* Interpreter */
  552. int objc; /* How many arguments? */
  553. Tcl_Obj *CONST objv[]; /* The argument objects */
  554. DB_ENV *envp; /* Environment pointer */
  555. {
  556. DB *dbp;
  557. char *arg, msg[MSG_SIZE];
  558. int result, ret;
  560. result = TCL_OK;
  561. /*
  562.  * 1 arg for this.  Error if more or less.
  563.  */
  564. if (objc != 3) {
  565. Tcl_WrongNumArgs(interp, 2, objv, NULL);
  566. return (TCL_ERROR);
  567. }
  568. arg = Tcl_GetStringFromObj(objv[2], NULL);
  569. dbp = NAME_TO_DB(arg);
  570. if (dbp == NULL) {
  571. snprintf(msg, MSG_SIZE,
  572.     "log_unregister: Invalid db identifier: %sn", arg);
  573. Tcl_SetResult(interp, msg, TCL_VOLATILE);
  574. return (TCL_ERROR);
  575. }
  576. _debug_check();
  577. ret = log_unregister(envp, dbp);
  578. result = _ReturnSetup(interp, ret, "log_unregister");
  580. return (result);
  581. }