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

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

MySQL数据库

开发平台：

Visual C++

gen_rec.awk：源码内容
  1. #!/bin/sh -
  2. #
  3. # See the file LICENSE for redistribution information.
  4. #
  5. # Copyright (c) 1996, 1997, 1998, 1999, 2000
  6. # Sleepycat Software.  All rights reserved.
  7. #
  8. # $Id: gen_rec.awk,v 11.26 2001/01/08 21:06:46 bostic Exp $
  9. #
  11. # This awk script generates all the log, print, and read routines for the DB
  12. # logging. It also generates a template for the recovery functions (these
  13. # functions must still be edited, but are highly stylized and the initial
  14. # template gets you a fair way along the path).
  15. #
  16. # For a given file prefix.src, we generate a file prefix_auto.c, and a file
  17. # prefix_auto.h that contains:
  18. #
  19. # external declarations for the file's functions
  20. #  defines for the physical record types
  21. #     (logical types are defined in each subsystem manually)
  22. # structures to contain the data unmarshalled from the log.
  23. #
  24. # This awk script requires that five variables be set when it is called:
  25. #
  26. # source_file -- the C source file being created
  27. # subsystem -- the subsystem prefix, e.g., "db"
  28. # header_file -- the C #include file being created
  29. # template_file -- the template file being created
  30. # template_dir -- the directory to find the source template
  31. #
  32. # And stdin must be the input file that defines the recovery setup.
  34. BEGIN {
  35. if (source_file == "" || subsystem == "" ||
  36.     header_file == "" || template_file == "" || template_dir == "") {
  37.     print "Usage: gen_rec.awk requires five variables to be set:"
  38.     print "tsource_filet-- the C source file being created"
  39.     print "tsubsystemt-- the subsystem prefix, e.g., "db""
  40.     print "theader_filet-- the C #include file being created"
  41.     print "ttemplate_filet-- the template file being created"
  42.     print "ttemplate_dirt-- the directory to find the source template"
  43.     exit
  44. }
  45. FS="[t ][t ]*"
  46. CFILE=source_file
  47. NAME=subsystem
  48. HFILE=header_file
  49. TFILE=template_file
  50. TDIR=template_dir
  51. }
  52. /^[  ]*PREFIX/ {
  53. prefix = $2
  54. num_funcs = 0;
  56. # Start .c file.
  57. printf("/* Do not edit: automatically built by gen_rec.awk. */n") 
  58.     > CFILE
  60. # Start .h file, make the entire file conditional.
  61. printf("/* Do not edit: automatically built by gen_rec.awk. */nn") 
  62.     > HFILE
  63. printf("#ifndeft%s_AUTO_Hn#definet%s_AUTO_Hn", prefix, prefix) 
  64.     >> HFILE;
  66. # Write recovery template file headers
  67. # This assumes we're doing DB recovery.
  68. printf("#include "db_config.h"nn") > TFILE
  69. printf("#ifndef NO_SYSTEM_INCLUDESn") >> TFILE
  70. printf("#include <sys/types.h>nn") >> TFILE
  71. printf("#include <string.h>n") >> TFILE
  72. printf("#endifnn") >> TFILE
  73. printf("#include "db_int.h"n") >> TFILE
  74. printf("#include "db_page.h"n") >> TFILE
  75. printf("#include "%s.h"n", prefix) >> TFILE
  76. printf("#include "log.h"nn") >> TFILE
  77. }
  78. /^[  ]*INCLUDE/ {
  79. if ($3 == "")
  80. printf("%sn", $2) >> CFILE
  81. else
  82. printf("%s %sn", $2, $3) >> CFILE
  83. }
  84. /^[  ]*(BEGIN|DEPRECATED)/ {
  85. if (in_begin) {
  86. print "Invalid format: missing END statement"
  87. exit
  88. }
  89. in_begin = 1;
  90. is_dbt = 0;
  91. is_deprecated = ($1 == "DEPRECATED");
  92. nvars = 0;
  94. thisfunc = $2;
  95. funcname = sprintf("%s_%s", prefix, $2);
  97. rectype = $3;
  99. funcs[num_funcs] = funcname;
  100. funcs_dep[num_funcs] = is_deprecated;
  101. ++num_funcs;
  102. }
  103. /^[  ]*(ARG|DBT|POINTER)/ {
  104. vars[nvars] = $2;
  105. types[nvars] = $3;
  106. atypes[nvars] = $1;
  107. modes[nvars] = $1;
  108. formats[nvars] = $NF;
  109. for (i = 4; i < NF; i++)
  110. types[nvars] = sprintf("%s %s", types[nvars], $i);
  112. if ($1 == "ARG")
  113. sizes[nvars] = sprintf("sizeof(%s)", $2);
  114. else if ($1 == "POINTER")
  115. sizes[nvars] = sprintf("sizeof(*%s)", $2);
  116. else { # DBT
  117. sizes[nvars] = 
  118.     sprintf("sizeof(u_int32_t) + (%s == NULL ? 0 : %s->size)", 
  119.     $2, $2);
  120. is_dbt = 1;
  121. }
  122. nvars++;
  123. }
  124. /^[  ]*END/ {
  125. if (!in_begin) {
  126. print "Invalid format: missing BEGIN statement"
  127. exit;
  128. }
  130. # Declare the record type.
  131. printf("n#definetDB_%st%dn", funcname, rectype) >> HFILE
  133. # Structure declaration.
  134. printf("typedef struct _%s_args {n", funcname) >> HFILE
  136. # Here are the required fields for every structure
  137. printf("tu_int32_t type;ntDB_TXN *txnid;n") >> HFILE
  138. printf("tDB_LSN prev_lsn;n") >>HFILE
  140. # Here are the specified fields.
  141. for (i = 0; i < nvars; i++) {
  142. t = types[i];
  143. if (modes[i] == "POINTER") {
  144. ndx = index(t, "*");
  145. t = substr(types[i], 0, ndx - 2);
  146. }
  147. printf("t%st%s;n", t, vars[i]) >> HFILE
  148. }
  149. printf("} __%s_args;nn", funcname) >> HFILE
  151. # Output the log, print and read functions.
  152. if (!is_deprecated)
  153. log_function();
  154. print_function();
  155. read_function();
  157. # Recovery template
  158. cmd = sprintf("sed -e s/PREF/%s/ -e s/FUNC/%s/ < %s/rec_ctemp >> %s",
  159.     prefix, thisfunc, TDIR, TFILE)
  160. system(cmd);
  162. # Done writing stuff, reset and continue.
  163. in_begin = 0;
  164. }
  166. END {
  167. # Print initialization routine; function prototype
  168. printf("int __%s_init_print __P((DB_ENV *));n", prefix) >> HFILE;
  170. # Create the routine to call db_add_recovery(print_fn, id)
  171. printf("intn__%s_init_print(dbenv)n", prefix) >> CFILE;
  172. printf("tDB_ENV *dbenv;n{ntint ret;nn") >> CFILE;
  173. for (i = 0; i < num_funcs; i++) {
  174. printf("tif ((ret = __db_add_recovery(dbenv,n") >> CFILE;
  175. printf("t    __%s_print, DB_%s)) != 0)n", 
  176.     funcs[i], funcs[i]) >> CFILE;
  177. printf("ttreturn (ret);n") >> CFILE;
  178. }
  179. printf("treturn (0);n}nn") >> CFILE;
  181. # Recover initialization routine
  182. printf("int __%s_init_recover __P((DB_ENV *));n", prefix) >> HFILE;
  184. # Create the routine to call db_add_recovery(func, id)
  185. printf("intn__%s_init_recover(dbenv)n", prefix) >> CFILE;
  186. printf("tDB_ENV *dbenv;n{ntint ret;nn") >> CFILE;
  187. for (i = 0; i < num_funcs; i++) {
  188. printf("tif ((ret = __db_add_recovery(dbenv,n") >> CFILE;
  189. if (funcs_dep[i] == 1)
  190. printf("t    __deprecated_recover, DB_%s)) != 0)n", 
  191.     funcs[i]) >> CFILE;
  192. else
  193. printf("t    __%s_recover, DB_%s)) != 0)n", 
  194.     funcs[i], funcs[i]) >> CFILE;
  195. printf("ttreturn (ret);n") >> CFILE;
  196. }
  197. printf("treturn (0);n}nn") >> CFILE;
  199. # End the conditional for the HFILE
  200. printf("#endifn") >> HFILE;
  201. }
  203. function log_function() {
  204. # Write the log function; function prototype
  205. printf("int __%s_log __P((", funcname) >> HFILE;
  206. printf("DB_ENV *, DB_TXN *, DB_LSN *, u_int32_t") >> HFILE;
  207. for (i = 0; i < nvars; i++) {
  208. printf(", ") >> HFILE;
  209. if (modes[i] == "DBT")
  210. printf("const ") >> HFILE;
  211. printf("%s", types[i]) >> HFILE;
  212. if (modes[i] == "DBT")
  213. printf(" *") >> HFILE;
  214. }
  215. printf("));n") >> HFILE;
  217. # Function declaration
  218. printf("intn__%s_log(dbenv, txnid, ret_lsnp, flags", 
  219.     funcname) >> CFILE;
  220. for (i = 0; i < nvars; i++) {
  221. printf(",") >> CFILE;
  222. if ((i % 6) == 0)
  223. printf("nt") >> CFILE;
  224. else
  225. printf(" ") >> CFILE;
  226. printf("%s", vars[i]) >> CFILE;
  227. }
  228. printf(")n") >> CFILE;
  230. # Now print the parameters
  231. printf("tDB_ENV *dbenv;n") >> CFILE;
  232. printf("tDB_TXN *txnid;ntDB_LSN *ret_lsnp;n") >> CFILE;
  233. printf("tu_int32_t flags;n") >> CFILE;
  234. for (i = 0; i < nvars; i++) {
  235. if (modes[i] == "DBT")
  236. printf("tconst %s *%s;n", types[i], vars[i]) >> CFILE;
  237. else
  238. printf("t%s %s;n", types[i], vars[i]) >> CFILE;
  239. }
  241. # Function body and local decls
  242. printf("{n") >> CFILE;
  243. printf("tDBT logrec;n") >> CFILE;
  244. printf("tDB_LSN *lsnp, null_lsn;n") >> CFILE;
  245. if (is_dbt == 1)
  246. printf("tu_int32_t zero;n") >> CFILE;
  247. printf("tu_int32_t rectype, txn_num;n") >> CFILE;
  248. printf("tint ret;n") >> CFILE;
  249. printf("tu_int8_t *bp;nn") >> CFILE;
  251. # Initialization
  252. printf("trectype = DB_%s;n", funcname) >> CFILE;
  253. printf("tif (txnid != NULL &&n") >> CFILE;
  254. printf("t    TAILQ_FIRST(&txnid->kids) != NULL &&n") >> CFILE;
  255. printf("t    (ret = __txn_activekids(dbenv, rectype, txnid)) != 0)n")
  256.     >> CFILE;
  257. printf("ttreturn (ret);n") >> CFILE;
  258. printf("ttxn_num = txnid == NULL ? 0 : txnid->txnid;n") >> CFILE;
  259. printf("tif (txnid == NULL) {n") >> CFILE;
  260. printf("ttZERO_LSN(null_lsn);n") >> CFILE;
  261. printf("ttlsnp = &null_lsn;n") >> CFILE;
  262. printf("t} elsenttlsnp = &txnid->last_lsn;n") >> CFILE;
  264. # Malloc
  265. printf("tlogrec.size = sizeof(rectype) + ") >> CFILE;
  266. printf("sizeof(txn_num) + sizeof(DB_LSN)") >> CFILE;
  267. for (i = 0; i < nvars; i++)
  268. printf("nt    + %s", sizes[i]) >> CFILE;
  269. printf(";ntif ((ret = ") >> CFILE;
  270. printf(
  271.     "__os_malloc(dbenv, logrec.size, NULL, &logrec.data)) != 0)n")
  272.     >> CFILE;
  273. printf("ttreturn (ret);nn") >> CFILE;
  275. # Copy args into buffer
  276. printf("tbp = logrec.data;n") >> CFILE;
  277. printf("tmemcpy(bp, &rectype, sizeof(rectype));n") >> CFILE;
  278. printf("tbp += sizeof(rectype);n") >> CFILE;
  279. printf("tmemcpy(bp, &txn_num, sizeof(txn_num));n") >> CFILE;
  280. printf("tbp += sizeof(txn_num);n") >> CFILE;
  281. printf("tmemcpy(bp, lsnp, sizeof(DB_LSN));n") >> CFILE;
  282. printf("tbp += sizeof(DB_LSN);n") >> CFILE;
  284. for (i = 0; i < nvars; i ++) {
  285. if (modes[i] == "ARG") {
  286. printf("tmemcpy(bp, &%s, %s);n", 
  287.     vars[i], sizes[i]) >> CFILE;
  288. printf("tbp += %s;n", sizes[i]) >> CFILE;
  289. } else if (modes[i] == "DBT") {
  290. printf("tif (%s == NULL) {n", vars[i]) >> CFILE;
  291. printf("ttzero = 0;n") >> CFILE;
  292. printf("ttmemcpy(bp, &zero, sizeof(u_int32_t));n") 
  293. >> CFILE;
  294. printf("ttbp += sizeof(u_int32_t);n") >> CFILE;
  295. printf("t} else {n") >> CFILE;
  296. printf("ttmemcpy(bp, &%s->size, ", vars[i]) >> CFILE;
  297. printf("sizeof(%s->size));n", vars[i]) >> CFILE;
  298. printf("ttbp += sizeof(%s->size);n", vars[i]) 
  299.     >> CFILE;
  300. printf("ttmemcpy(bp, %s->data, %s->size);n", 
  301.     vars[i], vars[i]) >> CFILE;
  302. printf("ttbp += %s->size;nt}n", vars[i]) >> CFILE;
  303. } else { # POINTER
  304. printf("tif (%s != NULL)n", vars[i]) >> CFILE;
  305. printf("ttmemcpy(bp, %s, %s);n", vars[i], 
  306.     sizes[i]) >> CFILE;
  307. printf("telsen") >> CFILE;
  308. printf("ttmemset(bp, 0, %s);n", sizes[i]) >> CFILE;
  309. printf("tbp += %s;n", sizes[i]) >> CFILE;
  310. }
  311. }
  313. # Error checking
  314. printf("tDB_ASSERT((u_int32_t)") >> CFILE;
  315. printf("(bp - (u_int8_t *)logrec.data) == logrec.size);n") >> CFILE;
  317. # Issue log call
  318. # The logging system cannot call the public log_put routine
  319. # due to mutual exclusion constraints.  So, if we are
  320. # generating code for the log subsystem, use the internal
  321. # __log_put.
  322. if (prefix == "log")
  323. printf("tret = __log_put(dbenv, ret_lsnp, ") >> CFILE;
  324. else
  325. printf("tret = log_put(dbenv, ret_lsnp, ") >> CFILE;
  326. printf("(DBT *)&logrec, flags);n") >> CFILE;
  328. # Update the transactions last_lsn
  329. printf("tif (txnid != NULL)n") >> CFILE;
  330. printf("tttxnid->last_lsn = *ret_lsnp;n") >> CFILE;
  332. # Free and return
  333. printf("t__os_free(logrec.data, logrec.size);n") >> CFILE;
  334. printf("treturn (ret);n}nn") >> CFILE;
  335. }
  337. function print_function() {
  338. # Write the print function; function prototype
  339. printf("int __%s_print", funcname) >> HFILE;
  340. printf(" __P((DB_ENV *, DBT *, DB_LSN *, db_recops, void *));n") 
  341.     >> HFILE;
  343. # Function declaration
  344. printf("intn__%s_print(dbenv, ", funcname) >> CFILE;
  345. printf("dbtp, lsnp, notused2, notused3)n") >> CFILE;
  346. printf("tDB_ENV *dbenv;n") >> CFILE;
  347. printf("tDBT *dbtp;n") >> CFILE;
  348. printf("tDB_LSN *lsnp;n") >> CFILE;
  349. printf("tdb_recops notused2;ntvoid *notused3;n{n") >> CFILE;
  351. # Locals
  352. printf("t__%s_args *argp;n", funcname) >> CFILE;
  353. printf("tu_int32_t i;ntu_int ch;ntint ret;nn") >> CFILE;
  355. # Get rid of complaints about unused parameters.
  356. printf("ti = 0;ntch = 0;n") >> CFILE;
  357. printf("tnotused2 = DB_TXN_ABORT;ntnotused3 = NULL;nn") >> CFILE;
  359. # Call read routine to initialize structure
  360. printf("tif ((ret = __%s_read(dbenv, dbtp->data, &argp)) != 0)n", 
  361.     funcname) >> CFILE;
  362. printf("ttreturn (ret);n") >> CFILE;
  364. # Print values in every record
  365. printf("tprintf("[%%lu][%%lu]%s: ", funcname) >> CFILE;
  366. printf("rec: %%lu txnid %%lx ") >> CFILE;
  367. printf("prevlsn [%%lu][%%lu]\n",n") >> CFILE;
  368. printf("t    (u_long)lsnp->file,n") >> CFILE;
  369. printf("t    (u_long)lsnp->offset,n") >> CFILE;
  370. printf("t    (u_long)argp->type,n") >> CFILE;
  371. printf("t    (u_long)argp->txnid->txnid,n") >> CFILE;
  372. printf("t    (u_long)argp->prev_lsn.file,n") >> CFILE;
  373. printf("t    (u_long)argp->prev_lsn.offset);n") >> CFILE;
  375. # Now print fields of argp
  376. for (i = 0; i < nvars; i ++) {
  377. printf("tprintf("\t%s: ", vars[i]) >> CFILE;
  379. if (modes[i] == "DBT") {
  380. printf("");n") >> CFILE;
  381. printf("tfor (i = 0; i < ") >> CFILE;
  382. printf("argp->%s.size; i++) {n", vars[i]) >> CFILE;
  383. printf("ttch = ((u_int8_t *)argp->%s.data)[i];n", 
  384.     vars[i]) >> CFILE;
  385. printf("ttif (isprint(ch) || ch == 0xa)n") >> CFILE;
  386. printf("tttputchar(ch);n") >> CFILE;
  387. printf("ttelsen") >> CFILE;
  388. printf("tttprintf("%%#x ", ch);n") >> CFILE;
  389. printf("t}ntprintf("\n");n") >> CFILE;
  390. } else if (types[i] == "DB_LSN *") {
  391. printf("[%%%s][%%%s]\n",n", 
  392.     formats[i], formats[i]) >> CFILE;
  393. printf("t    (u_long)argp->%s.file,", 
  394.     vars[i]) >> CFILE;
  395. printf(" (u_long)argp->%s.offset);n", 
  396.     vars[i]) >> CFILE;
  397. } else {
  398. if (formats[i] == "lx")
  399. printf("0x") >> CFILE;
  400. printf("%%%s\n", ", formats[i]) >> CFILE;
  401. if (formats[i] == "lx" || formats[i] == "lu")
  402. printf("(u_long)") >> CFILE;
  403. if (formats[i] == "ld")
  404. printf("(long)") >> CFILE;
  405. printf("argp->%s);n", vars[i]) >> CFILE;
  406. }
  407. }
  408. printf("tprintf("\n");n") >> CFILE;
  409. printf("t__os_free(argp, 0);n") >> CFILE;
  410. printf("treturn (0);n") >> CFILE;
  411. printf("}nn") >> CFILE;
  412. }
  414. function read_function() {
  415. # Write the read function; function prototype
  416. printf("int __%s_read __P((DB_ENV *, void *, ", funcname) >> HFILE;
  417. printf("__%s_args **));n", funcname) >> HFILE;
  419. # Function declaration
  420. printf("intn__%s_read(dbenv, recbuf, argpp)n", funcname) >> CFILE;
  422. # Now print the parameters
  423. printf("tDB_ENV *dbenv;n") >> CFILE;
  424. printf("tvoid *recbuf;n") >> CFILE;
  425. printf("t__%s_args **argpp;n", funcname) >> CFILE;
  427. # Function body and local decls
  428. printf("{nt__%s_args *argp;n", funcname) >> CFILE;
  429. printf("tu_int8_t *bp;n") >> CFILE;
  430. printf("tint ret;n") >> CFILE;
  432. printf("ntret = __os_malloc(dbenv, sizeof(") >> CFILE;
  433. printf("__%s_args) +nt    sizeof(DB_TXN), NULL, &argp);n", 
  434.     funcname) >> CFILE;
  435. printf("tif (ret != 0)nttreturn (ret);n") >> CFILE;
  437. # Set up the pointers to the txnid and the prev lsn
  438. printf("targp->txnid = (DB_TXN *)&argp[1];n") >> CFILE;
  440. # First get the record type, prev_lsn, and txnid fields.
  442. printf("tbp = recbuf;n") >> CFILE;
  443. printf("tmemcpy(&argp->type, bp, sizeof(argp->type));n") >> CFILE;
  444. printf("tbp += sizeof(argp->type);n") >> CFILE;
  445. printf("tmemcpy(&argp->txnid->txnid,  bp, ") >> CFILE;
  446. printf("sizeof(argp->txnid->txnid));n") >> CFILE;
  447. printf("tbp += sizeof(argp->txnid->txnid);n") >> CFILE;
  448. printf("tmemcpy(&argp->prev_lsn, bp, sizeof(DB_LSN));n") >> CFILE;
  449. printf("tbp += sizeof(DB_LSN);n") >> CFILE;
  451. # Now get rest of data.
  452. for (i = 0; i < nvars; i ++) {
  453. if (modes[i] == "DBT") {
  454. printf("tmemset(&argp->%s, 0, sizeof(argp->%s));n", 
  455.     vars[i], vars[i]) >> CFILE;
  456. printf("tmemcpy(&argp->%s.size, ", vars[i]) >> CFILE;
  457. printf("bp, sizeof(u_int32_t));n") >> CFILE;
  458. printf("tbp += sizeof(u_int32_t);n") >> CFILE;
  459. printf("targp->%s.data = bp;n", vars[i]) >> CFILE;
  460. printf("tbp += argp->%s.size;n", vars[i]) >> CFILE;
  461. } else if (modes[i] == "ARG") {
  462. printf("tmemcpy(&argp->%s, bp, %s%s));n", 
  463.     vars[i], "sizeof(argp->", vars[i]) >> CFILE;
  464. printf("tbp += sizeof(argp->%s);n", vars[i]) >> CFILE;
  465. } else { # POINTER
  466. printf("tmemcpy(&argp->%s, bp, ", vars[i]) >> CFILE;
  467. printf(" sizeof(argp->%s));n", vars[i]) >> CFILE;
  468. printf("tbp += sizeof(argp->%s);n", vars[i]) >> CFILE;
  469. }
  470. }
  472. # Free and return
  473. printf("t*argpp = argp;n") >> CFILE;
  474. printf("treturn (0);n}nn") >> CFILE;
  475. }