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

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

MySQL数据库

开发平台：

Visual C++

tcl_env.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_env.c,v 11.33 2001/01/11 18:19:55 bostic Exp $";
  12. #endif /* not lint */
  14. #ifndef NO_SYSTEM_INCLUDES
  15. #include <sys/types.h>
  17. #include <stdlib.h>
  18. #include <tcl.h>
  19. #endif
  21. #include "db_int.h"
  22. #include "tcl_db.h"
  24. /*
  25.  * Prototypes for procedures defined later in this file:
  26.  */
  27. static void _EnvInfoDelete __P((Tcl_Interp *, DBTCL_INFO *));
  29. /*
  30.  * PUBLIC: int env_Cmd __P((ClientData, Tcl_Interp *, int, Tcl_Obj * CONST*));
  31.  *
  32.  * env_Cmd --
  33.  * Implements the "env" command.
  34.  */
  35. int
  36. env_Cmd(clientData, interp, objc, objv)
  37. ClientData clientData;          /* Env handle */
  38. Tcl_Interp *interp;             /* Interpreter */
  39. int objc;                       /* How many arguments? */
  40. Tcl_Obj *CONST objv[];          /* The argument objects */
  41. {
  42. static char *envcmds[] = {
  43. "close",
  44. "lock_detect",
  45. "lock_id",
  46. "lock_get",
  47. "lock_stat",
  48. "lock_vec",
  49. "log_archive",
  50. "log_compare",
  51. "log_file",
  52. "log_flush",
  53. "log_get",
  54. "log_put",
  55. "log_register",
  56. "log_stat",
  57. "log_unregister",
  58. "mpool",
  59. "mpool_stat",
  60. "mpool_sync",
  61. "mpool_trickle",
  62. "mutex",
  63. #if CONFIG_TEST
  64. "test",
  65. #endif
  66. "txn",
  67. "txn_checkpoint",
  68. "txn_stat",
  69. "verbose",
  70. NULL
  71. };
  72. enum envcmds {
  73. ENVCLOSE,
  74. ENVLKDETECT,
  75. ENVLKID,
  76. ENVLKGET,
  77. ENVLKSTAT,
  78. ENVLKVEC,
  79. ENVLOGARCH,
  80. ENVLOGCMP,
  81. ENVLOGFILE,
  82. ENVLOGFLUSH,
  83. ENVLOGGET,
  84. ENVLOGPUT,
  85. ENVLOGREG,
  86. ENVLOGSTAT,
  87. ENVLOGUNREG,
  88. ENVMP,
  89. ENVMPSTAT,
  90. ENVMPSYNC,
  91. ENVTRICKLE,
  92. ENVMUTEX,
  93. #if CONFIG_TEST
  94. ENVTEST,
  95. #endif
  96. ENVTXN,
  97. ENVTXNCKP,
  98. ENVTXNSTAT,
  99. ENVVERB
  100. };
  101. DBTCL_INFO *envip;
  102. DB_ENV *envp;
  103. Tcl_Obj *res;
  104. u_int32_t newval;
  105. int cmdindex, result, ret;
  107. Tcl_ResetResult(interp);
  108. envp = (DB_ENV *)clientData;
  109. envip = _PtrToInfo((void *)envp);
  110. result = TCL_OK;
  112. if (objc <= 1) {
  113. Tcl_WrongNumArgs(interp, 1, objv, "command cmdargs");
  114. return (TCL_ERROR);
  115. }
  116. if (envp == NULL) {
  117. Tcl_SetResult(interp, "NULL env pointer", TCL_STATIC);
  118. return (TCL_ERROR);
  119. }
  120. if (envip == NULL) {
  121. Tcl_SetResult(interp, "NULL env info pointer", TCL_STATIC);
  122. return (TCL_ERROR);
  123. }
  125. /*
  126.  * Get the command name index from the object based on the berkdbcmds
  127.  * defined above.
  128.  */
  129. if (Tcl_GetIndexFromObj(interp, objv[1], envcmds, "command",
  130.     TCL_EXACT, &cmdindex) != TCL_OK)
  131. return (IS_HELP(objv[1]));
  132. res = NULL;
  133. switch ((enum envcmds)cmdindex) {
  134. case ENVCLOSE:
  135. /*
  136.  * No args for this.  Error if there are some.
  137.  */
  138. if (objc > 2) {
  139. Tcl_WrongNumArgs(interp, 2, objv, NULL);
  140. return (TCL_ERROR);
  141. }
  142. /*
  143.  * Any transactions will be aborted, and an mpools
  144.  * closed automatically.  We must delete any txn
  145.  * and mp widgets we have here too for this env.
  146.  * NOTE: envip is freed when we come back from
  147.  * this function.  Set it to NULL to make sure no
  148.  * one tries to use it later.
  149.  */
  150. _EnvInfoDelete(interp, envip);
  151. envip = NULL;
  152. _debug_check();
  153. ret = envp->close(envp, 0);
  154. result = _ReturnSetup(interp, ret, "env close");
  155. break;
  156. case ENVLKDETECT:
  157. result = tcl_LockDetect(interp, objc, objv, envp);
  158. break;
  159. case ENVLKSTAT:
  160. result = tcl_LockStat(interp, objc, objv, envp);
  161. break;
  162. case ENVLKID:
  163. /*
  164.  * No args for this.  Error if there are some.
  165.  */
  166. if (objc > 2) {
  167. Tcl_WrongNumArgs(interp, 2, objv, NULL);
  168. return (TCL_ERROR);
  169. }
  170. _debug_check();
  171. ret = lock_id(envp, &newval);
  172. result = _ReturnSetup(interp, ret, "lock_id");
  173. if (result == TCL_OK)
  174. res = Tcl_NewIntObj((int)newval);
  175. break;
  176. case ENVLKGET:
  177. result = tcl_LockGet(interp, objc, objv, envp);
  178. break;
  179. case ENVLKVEC:
  180. result = tcl_LockVec(interp, objc, objv, envp);
  181. break;
  182. case ENVLOGARCH:
  183. result = tcl_LogArchive(interp, objc, objv, envp);
  184. break;
  185. case ENVLOGCMP:
  186. result = tcl_LogCompare(interp, objc, objv);
  187. break;
  188. case ENVLOGFILE:
  189. result = tcl_LogFile(interp, objc, objv, envp);
  190. break;
  191. case ENVLOGFLUSH:
  192. result = tcl_LogFlush(interp, objc, objv, envp);
  193. break;
  194. case ENVLOGGET:
  195. result = tcl_LogGet(interp, objc, objv, envp);
  196. break;
  197. case ENVLOGPUT:
  198. result = tcl_LogPut(interp, objc, objv, envp);
  199. break;
  200. case ENVLOGREG:
  201. result = tcl_LogRegister(interp, objc, objv, envp);
  202. break;
  203. case ENVLOGUNREG:
  204. result = tcl_LogUnregister(interp, objc, objv, envp);
  205. break;
  206. case ENVLOGSTAT:
  207. result = tcl_LogStat(interp, objc, objv, envp);
  208. break;
  209. case ENVMPSTAT:
  210. result = tcl_MpStat(interp, objc, objv, envp);
  211. break;
  212. case ENVMPSYNC:
  213. result = tcl_MpSync(interp, objc, objv, envp);
  214. break;
  215. case ENVTRICKLE:
  216. result = tcl_MpTrickle(interp, objc, objv, envp);
  217. break;
  218. case ENVMP:
  219. result = tcl_Mp(interp, objc, objv, envp, envip);
  220. break;
  221. case ENVTXNCKP:
  222. result = tcl_TxnCheckpoint(interp, objc, objv, envp);
  223. break;
  224. case ENVTXNSTAT:
  225. result = tcl_TxnStat(interp, objc, objv, envp);
  226. break;
  227. case ENVTXN:
  228. result = tcl_Txn(interp, objc, objv, envp, envip);
  229. break;
  230. case ENVMUTEX:
  231. result = tcl_Mutex(interp, objc, objv, envp, envip);
  232. break;
  233. #if CONFIG_TEST
  234. case ENVTEST:
  235. result = tcl_EnvTest(interp, objc, objv, envp);
  236. break;
  237. #endif
  238. case ENVVERB:
  239. /*
  240.  * Two args for this.  Error if different.
  241.  */
  242. if (objc != 4) {
  243. Tcl_WrongNumArgs(interp, 2, objv, NULL);
  244. return (TCL_ERROR);
  245. }
  246. result = tcl_EnvVerbose(interp, envp, objv[2], objv[3]);
  247. break;
  248. }
  249. /*
  250.  * Only set result if we have a res.  Otherwise, lower
  251.  * functions have already done so.
  252.  */
  253. if (result == TCL_OK && res)
  254. Tcl_SetObjResult(interp, res);
  255. return (result);
  256. }
  258. /*
  259.  * PUBLIC: int tcl_EnvRemove __P((Tcl_Interp *, int, Tcl_Obj * CONST*,
  260.  * PUBLIC:      DB_ENV *, DBTCL_INFO *));
  261.  *
  262.  * tcl_EnvRemove --
  263.  */
  264. int
  265. tcl_EnvRemove(interp, objc, objv, envp, envip)
  266. Tcl_Interp *interp; /* Interpreter */
  267. int objc; /* How many arguments? */
  268. Tcl_Obj *CONST objv[]; /* The argument objects */
  269. DB_ENV *envp; /* Env pointer */
  270. DBTCL_INFO *envip; /* Info pointer */
  271. {
  272. static char *envremopts[] = {
  273. "-data_dir",
  274. "-force",
  275. "-home",
  276. "-log_dir",
  277. "-server",
  278. "-tmp_dir",
  279. "-use_environ",
  280. "-use_environ_root",
  281. NULL
  282. };
  283. enum envremopts {
  284. ENVREM_DATADIR,
  285. ENVREM_FORCE,
  286. ENVREM_HOME,
  287. ENVREM_LOGDIR,
  288. ENVREM_SERVER,
  289. ENVREM_TMPDIR,
  290. ENVREM_USE_ENVIRON,
  291. ENVREM_USE_ENVIRON_ROOT
  292. };
  293. DB_ENV *e;
  294. u_int32_t cflag, flag, forceflag;
  295. int i, optindex, result, ret;
  296. char *datadir, *home, *logdir, *server, *tmpdir;
  298. result = TCL_OK;
  299. cflag = flag = forceflag = 0;
  300. home = NULL;
  301. datadir = logdir = tmpdir = NULL;
  302. server = NULL;
  304. if (objc < 2) {
  305. Tcl_WrongNumArgs(interp, 2, objv, "?args?");
  306. return (TCL_ERROR);
  307. }
  309. i = 2;
  310. while (i < objc) {
  311. if (Tcl_GetIndexFromObj(interp, objv[i], envremopts, "option",
  312.     TCL_EXACT, &optindex) != TCL_OK) {
  313. result = IS_HELP(objv[i]);
  314. goto error;
  315. }
  316. i++;
  317. switch ((enum envremopts)optindex) {
  318. case ENVREM_FORCE:
  319. forceflag |= DB_FORCE;
  320. break;
  321. case ENVREM_HOME:
  322. /* Make sure we have an arg to check against! */
  323. if (i >= objc) {
  324. Tcl_WrongNumArgs(interp, 2, objv,
  325.     "?-home dir?");
  326. result = TCL_ERROR;
  327. break;
  328. }
  329. home = Tcl_GetStringFromObj(objv[i++], NULL);
  330. break;
  331. case ENVREM_SERVER:
  332. /* Make sure we have an arg to check against! */
  333. if (i >= objc) {
  334. Tcl_WrongNumArgs(interp, 2, objv,
  335.     "?-server name?");
  336. result = TCL_ERROR;
  337. break;
  338. }
  339. server = Tcl_GetStringFromObj(objv[i++], NULL);
  340. cflag = DB_CLIENT;
  341. break;
  342. case ENVREM_USE_ENVIRON:
  343. flag |= DB_USE_ENVIRON;
  344. break;
  345. case ENVREM_USE_ENVIRON_ROOT:
  346. flag |= DB_USE_ENVIRON_ROOT;
  347. break;
  348. case ENVREM_DATADIR:
  349. if (i >= objc) {
  350. Tcl_WrongNumArgs(interp, 2, objv,
  351.     "-data_dir dir");
  352. result = TCL_ERROR;
  353. break;
  354. }
  355. datadir = Tcl_GetStringFromObj(objv[i++], NULL);
  356. break;
  357. case ENVREM_LOGDIR:
  358. if (i >= objc) {
  359. Tcl_WrongNumArgs(interp, 2, objv,
  360.     "-log_dir dir");
  361. result = TCL_ERROR;
  362. break;
  363. }
  364. logdir = Tcl_GetStringFromObj(objv[i++], NULL);
  365. break;
  366. case ENVREM_TMPDIR:
  367. if (i >= objc) {
  368. Tcl_WrongNumArgs(interp, 2, objv,
  369.     "-tmp_dir dir");
  370. result = TCL_ERROR;
  371. break;
  372. }
  373. tmpdir = Tcl_GetStringFromObj(objv[i++], NULL);
  374. break;
  375. }
  376. /*
  377.  * If, at any time, parsing the args we get an error,
  378.  * bail out and return.
  379.  */
  380. if (result != TCL_OK)
  381. goto error;
  382. }
  384. /*
  385.  * If envp is NULL, we don't have an open env and we need to open
  386.  * one of the user.  Don't bother with the info stuff.
  387.  */
  388. if (envp == NULL) {
  389. if ((ret = db_env_create(&e, cflag)) != 0) {
  390. result = _ReturnSetup(interp, ret, "db_env_create");
  391. goto error;
  392. }
  393. if (server != NULL) {
  394. ret = e->set_server(e, server, 0, 0, 0);
  395. result = _ReturnSetup(interp, ret, "set_server");
  396. if (result != TCL_OK)
  397. goto error;
  398. }
  399. if (datadir != NULL) {
  400. _debug_check();
  401. ret = e->set_data_dir(e, datadir);
  402. result = _ReturnSetup(interp, ret, "set_data_dir");
  403. if (result != TCL_OK)
  404. goto error;
  405. }
  406. if (logdir != NULL) {
  407. _debug_check();
  408. ret = e->set_lg_dir(e, logdir);
  409. result = _ReturnSetup(interp, ret, "set_log_dir");
  410. if (result != TCL_OK)
  411. goto error;
  412. }
  413. if (tmpdir != NULL) {
  414. _debug_check();
  415. ret = e->set_tmp_dir(e, tmpdir);
  416. result = _ReturnSetup(interp, ret, "set_tmp_dir");
  417. if (result != TCL_OK)
  418. goto error;
  419. }
  420. } else {
  421. /*
  422.  * We have to clean up any info associated with this env,
  423.  * regardless of the result of the remove so do it first.
  424.  * NOTE: envip is freed when we come back from this function.
  425.  */
  426. _EnvInfoDelete(interp, envip);
  427. envip = NULL;
  428. e = envp;
  429. }
  431. flag |= forceflag;
  432. /*
  433.  * When we get here we have parsed all the args.  Now remove
  434.  * the environment.
  435.  */
  436. _debug_check();
  437. ret = e->remove(e, home, flag);
  438. result = _ReturnSetup(interp, ret, "env remove");
  439. error:
  440. return (result);
  441. }
  443. static void
  444. _EnvInfoDelete(interp, envip)
  445. Tcl_Interp *interp; /* Tcl Interpreter */
  446. DBTCL_INFO *envip; /* Info for env */
  447. {
  448. DBTCL_INFO *nextp, *p;
  450. /*
  451.  * Before we can delete the environment info, we must close
  452.  * any open subsystems in this env.  We will:
  453.  * 1.  Abort any transactions (which aborts any nested txns).
  454.  * 2.  Close any mpools (which will put any pages itself).
  455.  * 3.  Put any locks.
  456.  * 4.  Close the error file.
  457.  */
  458. for (p = LIST_FIRST(&__db_infohead); p != NULL; p = nextp) {
  459. /*
  460.  * Check if this info structure "belongs" to this
  461.  * env.  If so, remove its commands and info structure.
  462.  * We do not close/abort/whatever here, because we
  463.  * don't want to replicate DB behavior.
  464.  */
  465.  if (p->i_parent == envip) {
  466. switch (p->i_type) {
  467. case I_TXN:
  468. _TxnInfoDelete(interp, p);
  469. break;
  470. case I_MP:
  471. _MpInfoDelete(interp, p);
  472. break;
  473. default:
  474. Tcl_SetResult(interp,
  475.     "_EnvInfoDelete: bad info type",
  476.     TCL_STATIC);
  477. break;
  478. }
  479. nextp = LIST_NEXT(p, entries);
  480. (void)Tcl_DeleteCommand(interp, p->i_name);
  481. _DeleteInfo(p);
  482. } else
  483. nextp = LIST_NEXT(p, entries);
  484. }
  485. (void)Tcl_DeleteCommand(interp, envip->i_name);
  486. _DeleteInfo(envip);
  487. }
  489. /*
  490.  * PUBLIC: int tcl_EnvVerbose __P((Tcl_Interp *, DB_ENV *, Tcl_Obj *,
  491.  * PUBLIC:    Tcl_Obj *));
  492.  *
  493.  * tcl_EnvVerbose --
  494.  */
  495. int
  496. tcl_EnvVerbose(interp, envp, which, onoff)
  497. Tcl_Interp *interp; /* Interpreter */
  498. DB_ENV *envp; /* Env pointer */
  499. Tcl_Obj *which; /* Which subsystem */
  500. Tcl_Obj *onoff; /* On or off */
  501. {
  502. static char *verbwhich[] = {
  503. "chkpt",
  504. "deadlock",
  505. "recovery",
  506. "wait",
  507. NULL
  508. };
  509. enum verbwhich {
  510. ENVVERB_CHK,
  511. ENVVERB_DEAD,
  512. ENVVERB_REC,
  513. ENVVERB_WAIT
  514. };
  515. static char *verbonoff[] = {
  516. "off",
  517. "on",
  518. NULL
  519. };
  520. enum verbonoff {
  521. ENVVERB_OFF,
  522. ENVVERB_ON
  523. };
  524. int on, optindex, ret;
  525. u_int32_t wh;
  527. if (Tcl_GetIndexFromObj(interp, which, verbwhich, "option",
  528.     TCL_EXACT, &optindex) != TCL_OK)
  529. return (IS_HELP(which));
  531. switch ((enum verbwhich)optindex) {
  532. case ENVVERB_CHK:
  533. wh = DB_VERB_CHKPOINT;
  534. break;
  535. case ENVVERB_DEAD:
  536. wh = DB_VERB_DEADLOCK;
  537. break;
  538. case ENVVERB_REC:
  539. wh = DB_VERB_RECOVERY;
  540. break;
  541. case ENVVERB_WAIT:
  542. wh = DB_VERB_WAITSFOR;
  543. break;
  544. default:
  545. return (TCL_ERROR);
  546. }
  547. if (Tcl_GetIndexFromObj(interp, onoff, verbonoff, "option",
  548.     TCL_EXACT, &optindex) != TCL_OK)
  549. return (IS_HELP(onoff));
  550. switch ((enum verbonoff)optindex) {
  551. case ENVVERB_OFF:
  552. on = 0;
  553. break;
  554. case ENVVERB_ON:
  555. on = 1;
  556. break;
  557. default:
  558. return (TCL_ERROR);
  559. }
  560. ret = envp->set_verbose(envp, wh, on);
  561. return (_ReturnSetup(interp, ret, "env set verbose"));
  562. }
  564. #if CONFIG_TEST
  565. /*
  566.  * PUBLIC: int tcl_EnvTest __P((Tcl_Interp *, int, Tcl_Obj * CONST*, DB_ENV *));
  567.  *
  568.  * tcl_EnvTest --
  569.  */
  570. int
  571. tcl_EnvTest(interp, objc, objv, envp)
  572. Tcl_Interp *interp; /* Interpreter */
  573. int objc; /* How many arguments? */
  574. Tcl_Obj *CONST objv[]; /* The argument objects */
  575. DB_ENV *envp; /* Env pointer */
  576. {
  577. static char *envtestcmd[] = {
  578. "abort",
  579. "copy",
  580. NULL
  581. };
  582. enum envtestcmd {
  583. ENVTEST_ABORT,
  584. ENVTEST_COPY
  585. };
  586. static char *envtestat[] = {
  587. "none",
  588. "preopen",
  589. "prerename",
  590. "postlog",
  591. "postlogmeta",
  592. "postopen",
  593. "postrename",
  594. "postsync",
  595. NULL
  596. };
  597. enum envtestat {
  598. ENVTEST_NONE,
  599. ENVTEST_PREOPEN,
  600. ENVTEST_PRERENAME,
  601. ENVTEST_POSTLOG,
  602. ENVTEST_POSTLOGMETA,
  603. ENVTEST_POSTOPEN,
  604. ENVTEST_POSTRENAME,
  605. ENVTEST_POSTSYNC
  606. };
  607. int *loc, optindex, result, testval;
  609. result = TCL_OK;
  611. if (objc != 4) {
  612. Tcl_WrongNumArgs(interp, 2, objv, "abort|copy location");
  613. return (TCL_ERROR);
  614. }
  616. /*
  617.  * This must be the "copy" or "abort" portion of the command.
  618.  */
  619. if (Tcl_GetIndexFromObj(interp, objv[2], envtestcmd, "command",
  620.     TCL_EXACT, &optindex) != TCL_OK) {
  621. result = IS_HELP(objv[2]);
  622. return (result);
  623. }
  624. switch ((enum envtestcmd)optindex) {
  625. case ENVTEST_ABORT:
  626. loc = &envp->test_abort;
  627. break;
  628. case ENVTEST_COPY:
  629. loc = &envp->test_copy;
  630. break;
  631. default:
  632. Tcl_SetResult(interp, "Illegal store location", TCL_STATIC);
  633. return (TCL_ERROR);
  634. }
  636. /*
  637.  * This must be the location portion of the command.
  638.  */
  639. if (Tcl_GetIndexFromObj(interp, objv[3], envtestat, "location",
  640.     TCL_EXACT, &optindex) != TCL_OK) {
  641. result = IS_HELP(objv[3]);
  642. return (result);
  643. }
  644. switch ((enum envtestat)optindex) {
  645. case ENVTEST_NONE:
  646. testval = 0;
  647. break;
  648. case ENVTEST_PREOPEN:
  649. testval = DB_TEST_PREOPEN;
  650. break;
  651. case ENVTEST_PRERENAME:
  652. testval = DB_TEST_PRERENAME;
  653. break;
  654. case ENVTEST_POSTLOG:
  655. testval = DB_TEST_POSTLOG;
  656. break;
  657. case ENVTEST_POSTLOGMETA:
  658. testval = DB_TEST_POSTLOGMETA;
  659. break;
  660. case ENVTEST_POSTOPEN:
  661. testval = DB_TEST_POSTOPEN;
  662. break;
  663. case ENVTEST_POSTRENAME:
  664. testval = DB_TEST_POSTRENAME;
  665. break;
  666. case ENVTEST_POSTSYNC:
  667. testval = DB_TEST_POSTSYNC;
  668. break;
  669. default:
  670. Tcl_SetResult(interp, "Illegal test location", TCL_STATIC);
  671. return (TCL_ERROR);
  672. }
  674. *loc = testval;
  675. Tcl_SetResult(interp, "0", TCL_STATIC);
  676. return (result);
  677. }
  678. #endif