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

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

MySQL数据库

开发平台：

Visual C++

tcl_rep.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_rep.c,v 11.85 2002/08/06 04:45:44 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. #if CONFIG_TEST
  26. /*
  27.  * tcl_RepElect --
  28.  * Call DB_ENV->rep_elect().
  29.  *
  30.  * PUBLIC: int tcl_RepElect
  31.  * PUBLIC:     __P((Tcl_Interp *, int, Tcl_Obj * CONST *, DB_ENV *));
  32.  */
  33. int
  34. tcl_RepElect(interp, objc, objv, dbenv)
  35. Tcl_Interp *interp; /* Interpreter */
  36. int objc; /* How many arguments? */
  37. Tcl_Obj *CONST objv[]; /* The argument objects */
  38. DB_ENV *dbenv; /* Environment pointer */
  39. {
  40. int eid, nsites, pri, result, ret;
  41. u_int32_t timeout;
  43. if (objc != 5) {
  44. Tcl_WrongNumArgs(interp, 5, objv, "nsites pri timeout");
  45. return (TCL_ERROR);
  46. }
  48. if ((result = Tcl_GetIntFromObj(interp, objv[2], &nsites)) != TCL_OK)
  49. return (result);
  50. if ((result = Tcl_GetIntFromObj(interp, objv[3], &pri)) != TCL_OK)
  51. return (result);
  52. if ((result = _GetUInt32(interp, objv[4], &timeout)) != TCL_OK)
  53. return (result);
  55. _debug_check();
  56. if ((ret = dbenv->rep_elect(dbenv, nsites, pri, timeout, &eid)) != 0)
  57. return (_ReturnSetup(interp, ret, DB_RETOK_STD(ret),
  58.     "env rep_elect"));
  60. Tcl_SetObjResult(interp, Tcl_NewIntObj(eid));
  62. return (TCL_OK);
  63. }
  64. #endif
  66. #if CONFIG_TEST
  67. /*
  68.  * tcl_RepFlush --
  69.  * Call DB_ENV->rep_flush().
  70.  *
  71.  * PUBLIC: int tcl_RepFlush
  72.  * PUBLIC:     __P((Tcl_Interp *, int, Tcl_Obj * CONST *, DB_ENV *));
  73.  */
  74. int
  75. tcl_RepFlush(interp, objc, objv, dbenv)
  76. Tcl_Interp *interp;
  77. int objc;
  78. Tcl_Obj *CONST objv[];
  79. DB_ENV *dbenv;
  80. {
  81. int ret;
  83. if (objc != 2) {
  84. Tcl_WrongNumArgs(interp, 2, objv, "");
  85. return TCL_ERROR;
  86. }
  88. _debug_check();
  89. ret = dbenv->rep_flush(dbenv);
  90. return (_ReturnSetup(interp, ret, DB_RETOK_STD(ret), "env rep_flush"));
  91. }
  92. #endif
  93. #if CONFIG_TEST
  94. /*
  95.  * tcl_RepLimit --
  96.  * Call DB_ENV->set_rep_limit().
  97.  *
  98.  * PUBLIC: int tcl_RepLimit
  99.  * PUBLIC:     __P((Tcl_Interp *, int, Tcl_Obj * CONST *, DB_ENV *));
  100.  */
  101. int
  102. tcl_RepLimit(interp, objc, objv, dbenv)
  103. Tcl_Interp *interp; /* Interpreter */
  104. int objc; /* How many arguments? */
  105. Tcl_Obj *CONST objv[]; /* The argument objects */
  106. DB_ENV *dbenv; /* Environment pointer */
  107. {
  108. int result, ret;
  109. u_int32_t bytes, gbytes;
  111. if (objc != 4) {
  112. Tcl_WrongNumArgs(interp, 4, objv, "gbytes bytes");
  113. return (TCL_ERROR);
  114. }
  116. if ((result = _GetUInt32(interp, objv[2], &gbytes)) != TCL_OK)
  117. return (result);
  118. if ((result = _GetUInt32(interp, objv[3], &bytes)) != TCL_OK)
  119. return (result);
  121. _debug_check();
  122. if ((ret = dbenv->set_rep_limit(dbenv, gbytes, bytes)) != 0)
  123. return (_ReturnSetup(interp, ret, DB_RETOK_STD(ret),
  124.     "env set_rep_limit"));
  126. return (_ReturnSetup(interp,
  127.     ret, DB_RETOK_STD(ret), "env set_rep_limit"));
  128. }
  129. #endif
  131. #if CONFIG_TEST
  132. /*
  133.  * tcl_RepRequest --
  134.  * Call DB_ENV->set_rep_request().
  135.  *
  136.  * PUBLIC: int tcl_RepRequest
  137.  * PUBLIC:     __P((Tcl_Interp *, int, Tcl_Obj * CONST *, DB_ENV *));
  138.  */
  139. int
  140. tcl_RepRequest(interp, objc, objv, dbenv)
  141. Tcl_Interp *interp; /* Interpreter */
  142. int objc; /* How many arguments? */
  143. Tcl_Obj *CONST objv[]; /* The argument objects */
  144. DB_ENV *dbenv; /* Environment pointer */
  145. {
  146. int result, ret;
  147. u_int32_t min, max;
  149. if (objc != 4) {
  150. Tcl_WrongNumArgs(interp, 4, objv, "min max");
  151. return (TCL_ERROR);
  152. }
  154. if ((result = _GetUInt32(interp, objv[2], &min)) != TCL_OK)
  155. return (result);
  156. if ((result = _GetUInt32(interp, objv[3], &max)) != TCL_OK)
  157. return (result);
  159. _debug_check();
  160. if ((ret = dbenv->set_rep_request(dbenv, min, max)) != 0)
  161. return (_ReturnSetup(interp, ret, DB_RETOK_STD(ret),
  162.     "env set_rep_request"));
  164. return (_ReturnSetup(interp,
  165.     ret, DB_RETOK_STD(ret), "env set_rep_request"));
  166. }
  167. #endif
  169. #if CONFIG_TEST
  170. /*
  171.  * tcl_RepStart --
  172.  * Call DB_ENV->rep_start().
  173.  *
  174.  * PUBLIC: int tcl_RepStart
  175.  * PUBLIC:     __P((Tcl_Interp *, int, Tcl_Obj * CONST *, DB_ENV *));
  176.  *
  177.  * Note that this normally can/should be achieved as an argument to
  178.  * berkdb env, but we need to test forcible upgrading of clients, which
  179.  * involves calling this on an open environment handle.
  180.  */
  181. int
  182. tcl_RepStart(interp, objc, objv, dbenv)
  183. Tcl_Interp *interp; /* Interpreter */
  184. int objc; /* How many arguments? */
  185. Tcl_Obj *CONST objv[]; /* The argument objects */
  186. DB_ENV *dbenv;
  187. {
  188. static char *tclrpstrt[] = {
  189. "-client",
  190. "-master",
  191. NULL
  192. };
  193. enum tclrpstrt {
  194. TCL_RPSTRT_CLIENT,
  195. TCL_RPSTRT_MASTER
  196. };
  197. char *arg;
  198. int i, optindex, ret;
  199. u_int32_t flag;
  201. flag = 0;
  203. if (objc != 3) {
  204. Tcl_WrongNumArgs(interp, 3, objv, "[-master/-client]");
  205. return (TCL_ERROR);
  206. }
  208. i = 2;
  209. while (i < objc) {
  210. if (Tcl_GetIndexFromObj(interp, objv[i], tclrpstrt,
  211.     "option", TCL_EXACT, &optindex) != TCL_OK) {
  212. arg = Tcl_GetStringFromObj(objv[i], NULL);
  213. if (arg[0] == '-')
  214. return (IS_HELP(objv[i]));
  215. else
  216. Tcl_ResetResult(interp);
  217. break;
  218. }
  219. i++;
  220. switch ((enum tclrpstrt)optindex) {
  221. case TCL_RPSTRT_CLIENT:
  222. flag |= DB_REP_CLIENT;
  223. break;
  224. case TCL_RPSTRT_MASTER:
  225. flag |= DB_REP_MASTER;
  226. break;
  227. }
  228. }
  230. _debug_check();
  231. ret = dbenv->rep_start(dbenv, NULL, flag);
  232. return (_ReturnSetup(interp, ret, DB_RETOK_STD(ret), "env rep_start"));
  233. }
  234. #endif
  236. #if CONFIG_TEST
  237. /*
  238.  * tcl_RepProcessMessage --
  239.  * Call DB_ENV->rep_process_message().
  240.  *
  241.  * PUBLIC: int tcl_RepProcessMessage
  242.  * PUBLIC:     __P((Tcl_Interp *, int, Tcl_Obj * CONST *, DB_ENV *));
  243.  */
  244. int
  245. tcl_RepProcessMessage(interp, objc, objv, dbenv)
  246. Tcl_Interp *interp; /* Interpreter */
  247. int objc; /* How many arguments? */
  248. Tcl_Obj *CONST objv[]; /* The argument objects */
  249. DB_ENV *dbenv; /* Environment pointer */
  250. {
  251. DBT control, rec;
  252. Tcl_Obj *res;
  253. void *ctmp, *rtmp;
  254. int eid;
  255. int freectl, freerec, result, ret;
  257. if (objc != 5) {
  258. Tcl_WrongNumArgs(interp, 5, objv, "id control rec");
  259. return (TCL_ERROR);
  260. }
  261. freectl = freerec = 0;
  263. memset(&control, 0, sizeof(control));
  264. memset(&rec, 0, sizeof(rec));
  266. if ((result = Tcl_GetIntFromObj(interp, objv[2], &eid)) != TCL_OK)
  267. return (result);
  269. ret = _CopyObjBytes(interp, objv[3], &ctmp,
  270.     &control.size, &freectl);
  271. if (ret != 0) {
  272. result = _ReturnSetup(interp, ret,
  273.     DB_RETOK_REPPMSG(ret), "rep_proc_msg");
  274. return (result);
  275. }
  276. control.data = ctmp;
  277. ret = _CopyObjBytes(interp, objv[4], &rtmp,
  278.     &rec.size, &freerec);
  279. if (ret != 0) {
  280. result = _ReturnSetup(interp, ret,
  281.     DB_RETOK_REPPMSG(ret), "rep_proc_msg");
  282. goto out;
  283. }
  284. rec.data = rtmp;
  285. _debug_check();
  286. ret = dbenv->rep_process_message(dbenv, &control, &rec, &eid);
  287. result = _ReturnSetup(interp, ret, DB_RETOK_REPPMSG(ret),
  288.     "env rep_process_message");
  290. /*
  291.  * If we have a new master, return its environment ID.
  292.  *
  293.  * XXX
  294.  * We should do something prettier to differentiate success
  295.  * from an env ID, and figure out how to represent HOLDELECTION.
  296.  */
  297. if (result == TCL_OK && ret == DB_REP_NEWMASTER) {
  298. res = Tcl_NewIntObj(eid);
  299. Tcl_SetObjResult(interp, res);
  300. }
  301. out:
  302. if (freectl)
  303. (void)__os_free(NULL, ctmp);
  304. if (freerec)
  305. (void)__os_free(NULL, rtmp);
  307. return (result);
  308. }
  309. #endif
  311. #if CONFIG_TEST
  312. /*
  313.  * tcl_RepStat --
  314.  * Call DB_ENV->rep_stat().
  315.  *
  316.  * PUBLIC: int tcl_RepStat
  317.  * PUBLIC:     __P((Tcl_Interp *, int, Tcl_Obj * CONST *, DB_ENV *));
  318.  */
  319. int
  320. tcl_RepStat(interp, objc, objv, dbenv)
  321. Tcl_Interp *interp; /* Interpreter */
  322. int objc; /* How many arguments? */
  323. Tcl_Obj *CONST objv[]; /* The argument objects */
  324. DB_ENV *dbenv;
  325. {
  326. DB_REP_STAT *sp;
  327. Tcl_Obj *myobjv[2], *res, *thislist, *lsnlist;
  328. u_int32_t flag;
  329. int myobjc, result, ret;
  330. char *arg;
  332. result = TCL_OK;
  333. flag = 0;
  335. if (objc > 3) {
  336. Tcl_WrongNumArgs(interp, 2, objv, NULL);
  337. return (TCL_ERROR);
  338. }
  339. if (objc == 3) {
  340. arg = Tcl_GetStringFromObj(objv[2], NULL);
  341. if (strcmp(arg, "-clear") == 0)
  342. flag = DB_STAT_CLEAR;
  343. else {
  344. Tcl_SetResult(interp,
  345.     "db stat: unknown arg", TCL_STATIC);
  346. return (TCL_ERROR);
  347. }
  348. }
  350. _debug_check();
  351. ret = dbenv->rep_stat(dbenv, &sp, flag);
  352. result = _ReturnSetup(interp, ret, DB_RETOK_STD(ret),
  353.     "rep stat");
  354. if (result == TCL_ERROR)
  355. return (result);
  357. /*
  358.  * Have our stats, now construct the name value
  359.  * list pairs and free up the memory.
  360.  */
  361. res = Tcl_NewObj();
  362. /*
  363.  * MAKE_STAT_* assumes 'res' and 'error' label.
  364.  */
  365. MAKE_STAT_LSN("Next LSN expected", &sp->st_next_lsn);
  366. MAKE_STAT_LSN("First missed LSN", &sp->st_waiting_lsn);
  367. MAKE_STAT_LIST("Duplicate master conditions", sp->st_dupmasters);
  368. MAKE_STAT_LIST("Environment ID", sp->st_env_id);
  369. MAKE_STAT_LIST("Environment priority", sp->st_env_priority);
  370. MAKE_STAT_LIST("Generation number", sp->st_gen);
  371. MAKE_STAT_LIST("Duplicate log records received", sp->st_log_duplicated);
  372. MAKE_STAT_LIST("Current log records queued", sp->st_log_queued);
  373. MAKE_STAT_LIST("Maximum log records queued", sp->st_log_queued_max);
  374. MAKE_STAT_LIST("Total log records queued", sp->st_log_queued_total);
  375. MAKE_STAT_LIST("Log records received", sp->st_log_records);
  376. MAKE_STAT_LIST("Log records requested", sp->st_log_requested);
  377. MAKE_STAT_LIST("Master environment ID", sp->st_master);
  378. MAKE_STAT_LIST("Master changes", sp->st_master_changes);
  379. MAKE_STAT_LIST("Messages with bad generation number",
  380.     sp->st_msgs_badgen);
  381. MAKE_STAT_LIST("Messages processed", sp->st_msgs_processed);
  382. MAKE_STAT_LIST("Messages ignored for recovery", sp->st_msgs_recover);
  383. MAKE_STAT_LIST("Message send failures", sp->st_msgs_send_failures);
  384. MAKE_STAT_LIST("Messages sent", sp->st_msgs_sent);
  385. MAKE_STAT_LIST("New site messages", sp->st_newsites);
  386. MAKE_STAT_LIST("Transmission limited", sp->st_nthrottles);
  387. MAKE_STAT_LIST("Outdated conditions", sp->st_outdated);
  388. MAKE_STAT_LIST("Transactions applied", sp->st_txns_applied);
  389. MAKE_STAT_LIST("Elections held", sp->st_elections);
  390. MAKE_STAT_LIST("Elections won", sp->st_elections_won);
  391. MAKE_STAT_LIST("Election phase", sp->st_election_status);
  392. MAKE_STAT_LIST("Election winner", sp->st_election_cur_winner);
  393. MAKE_STAT_LIST("Election generation number", sp->st_election_gen);
  394. MAKE_STAT_LSN("Election max LSN", &sp->st_election_lsn);
  395. MAKE_STAT_LIST("Election sites", sp->st_election_nsites);
  396. MAKE_STAT_LIST("Election priority", sp->st_election_priority);
  397. MAKE_STAT_LIST("Election tiebreaker", sp->st_election_tiebreaker);
  398. MAKE_STAT_LIST("Election votes", sp->st_election_votes);
  400. Tcl_SetObjResult(interp, res);
  401. error:
  402. free(sp);
  403. return (result);
  404. }
  405. #endif