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

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

MySQL数据库

开发平台：

Visual C++

gen_rpc.awk：源码内容
  1. #
  2. # $Id: gen_rpc.awk,v 11.25 2001/01/02 20:04:55 sue Exp $
  3. # Awk script for generating client/server RPC code.
  4. #
  5. # This awk script generates most of the RPC routines for DB client/server
  6. # use. It also generates a template for server and client procedures.  These
  7. # functions must still be edited, but are highly stylized and the initial
  8. # template gets you a fair way along the path).
  9. #
  10. # This awk script requires that these variables be set when it is called:
  11. #
  12. # client_file -- the C source file being created for client code
  13. # cproto_file -- the header file create for client prototypes
  14. # ctmpl_file -- the C template file being created for client code
  15. # sed_file -- the sed file created to alter server proc code
  16. # server_file -- the C source file being created for server code
  17. # sproto_file -- the header file create for server prototypes
  18. # stmpl_file -- the C template file being created for server code
  19. # xdr_file -- the XDR message file created
  20. #
  21. # And stdin must be the input file that defines the RPC setup.
  22. BEGIN {
  23. if (client_file == "" || cproto_file == "" || ctmpl_file == "" ||
  24.     sed_file == "" || server_file == "" ||
  25.     sproto_file == "" || stmpl_file == "" || xdr_file == "") {
  26. print "Usage: gen_rpc.awk requires these variables be set:"
  27. print "tclient_filet-- the client C source file being created"
  28. print "tcproto_filet-- the client prototype header created"
  29. print "tctmpl_filet-- the client template file being created"
  30. print "tsed_filet-- the sed command file being created"
  31. print "tserver_filet-- the server C source file being created"
  32. print "tsproto_filet-- the server prototype header created"
  33. print "tstmpl_filet-- the server template file being created"
  34. print "txdr_filet-- the XDR message file being created"
  35. error = 1; exit
  36. }
  38. FS="tt*"
  39. CFILE=client_file
  40. printf("/* Do not edit: automatically built by gen_rpc.awk. */n") 
  41.     > CFILE
  43. CHFILE=cproto_file
  44. printf("/* Do not edit: automatically built by gen_rpc.awk. */n") 
  45.     > CHFILE
  47. TFILE = ctmpl_file
  48. printf("/* Do not edit: automatically built by gen_rpc.awk. */n") 
  49.     > TFILE
  51. SFILE = server_file
  52. printf("/* Do not edit: automatically built by gen_rpc.awk. */n") 
  53.     > SFILE
  55. SHFILE=sproto_file
  56. printf("/* Do not edit: automatically built by gen_rpc.awk. */n") 
  57.     > SHFILE
  59. # Server procedure template and a sed file to massage an existing
  60. # template source file to change args.
  61. # SEDFILE should be same name as PFILE but .c
  62. #
  63. PFILE = stmpl_file
  64. SEDFILE = sed_file
  65. printf("") > SEDFILE
  66. printf("/* Do not edit: automatically built by gen_rpc.awk. */n") 
  67.     > PFILE
  69. XFILE = xdr_file
  70. printf("/* Do not edit: automatically built by gen_rpc.awk. */n") 
  71.     > XFILE
  72. nendlist = 1;
  73. }
  74. END {
  75. printf("#endif /* HAVE_RPC */n") >> CFILE
  76. printf("#endif /* HAVE_RPC */n") >> TFILE
  77. printf("program DB_SERVERPROG {n") >> XFILE
  78. printf("tversion DB_SERVERVERS {n") >> XFILE
  80. for (i = 1; i < nendlist; ++i)
  81. printf("tt%s;n", endlist[i]) >> XFILE
  83. printf("t} = 1;n") >> XFILE
  84. printf("} = 351457;n") >> XFILE
  85. }
  87. /^[  ]*BEGIN/ {
  88. name = $2;
  89. msgid = $3;
  90. nofunc_code = 0;
  91. funcvars = 0;
  92. gen_code = 1;
  93. ret_code = 0;
  94. if ($4 == "NOCLNTCODE")
  95. gen_code = 0;
  96. if ($4 == "NOFUNC")
  97. nofunc_code = 1;
  98. if ($4 == "RETCODE")
  99. ret_code = 1;
  101. nvars = 0;
  102. rvars = 0;
  103. newvars = 0;
  104. db_handle = 0;
  105. env_handle = 0;
  106. dbc_handle = 0;
  107. txn_handle = 0;
  108. mp_handle = 0;
  109. dbt_handle = 0;
  110. xdr_free = 0;
  111. }
  112. /^[  ]*ARG/ {
  113. rpc_type[nvars] = $2;
  114. c_type[nvars] = $3;
  115. pr_type[nvars] = $3;
  116. args[nvars] = $4;
  117. func_arg[nvars] = 0;
  118. if (rpc_type[nvars] == "LIST") {
  119. list_type[nvars] = $5;
  120. } else
  121. list_type[nvars] = 0;
  123. if (c_type[nvars] == "DBT *")
  124. dbt_handle = 1;
  126. if (c_type[nvars] == "DB_ENV *") {
  127. ctp_type[nvars] = "CT_ENV";
  128. env_handle = 1;
  129. env_idx = nvars;
  130. }
  132. if (c_type[nvars] == "DB *") {
  133. ctp_type[nvars] = "CT_DB";
  134. db_handle = 1;
  135. db_idx = nvars;
  136. }
  138. if (c_type[nvars] == "DBC *") {
  139. ctp_type[nvars] = "CT_CURSOR";
  140. dbc_handle = 1;
  141. dbc_idx = nvars;
  142. }
  144. if (c_type[nvars] == "DB_TXN *") {
  145. ctp_type[nvars] = "CT_TXN";
  146. txn_handle = 1;
  147. txn_idx = nvars;
  148. }
  150. if (c_type[nvars] == "DB_MPOOLFILE *") {
  151. mp_handle = 1;
  152. mp_idx = nvars;
  153. }
  155. ++nvars;
  156. }
  157. /^[  ]*FUNCPROT/ {
  158. pr_type[nvars] = $2;
  159. }
  160. /^[  ]*FUNCARG/ {
  161. rpc_type[nvars] = "IGNORE";
  162. c_type[nvars] = $2;
  163. args[nvars] = sprintf("func%d", funcvars);
  164. func_arg[nvars] = 1;
  165. ++funcvars;
  166. ++nvars;
  167. }
  168. /^[  ]*RET/ {
  169. ret_type[rvars] = $2;
  170. retc_type[rvars] = $3;
  171. retargs[rvars] = $4;
  172. if (ret_type[rvars] == "LIST" || ret_type[rvars] == "DBT") {
  173. xdr_free = 1;
  174. }
  175. if (ret_type[rvars] == "LIST") {
  176. retlist_type[rvars] = $5;
  177. } else
  178. retlist_type[rvars] = 0;
  180. ++rvars;
  181. }
  182. /^[  ]*END/ {
  183. #
  184. # =====================================================
  185. # Generate Client Nofunc code first if necessary
  186. # NOTE:  This code must be first, because we don't want any
  187. # other code other than this function, so before we write
  188. # out to the XDR and server files, we just generate this
  189. # and move on if this is all we are doing.
  190. #
  191. if (nofunc_code == 1) {
  192. #
  193. # First time through, put out the general illegal function
  194. #
  195. if (first_nofunc == 0) {
  196. printf("int __dbcl_rpc_illegal ") >> CHFILE
  197. printf("__P((DB_ENV *, char *));n") >> CHFILE
  198. printf("intn__dbcl_rpc_illegal(dbenv, name)n") 
  199. >> CFILE
  200. printf("tDB_ENV *dbenv;ntchar *name;n") >> CFILE
  201. printf("{nt__db_err(dbenv,n") >> CFILE
  202. printf("t    "%%s method meaningless in RPC") >> CFILE
  203. printf(" environment", name);n") >> CFILE
  204. printf("treturn (__db_eopnotsup(dbenv));n") >> CFILE
  205. printf("}nn") >> CFILE
  206. first_nofunc = 1
  207. }
  208. #
  209. # If we are doing a list, spit out prototype decl.
  210. #
  211. for (i = 0; i < nvars; i++) {
  212. if (rpc_type[i] != "LIST")
  213. continue;
  214. printf("static int __dbcl_%s_%slist __P((", 
  215.     name, args[i]) >> CFILE
  216. printf("__%s_%slist **, ", name, args[i]) >> CFILE
  217. if (list_type[i] == "STRING")
  218. printf("%s));n", c_type[i]) >> CFILE
  219. if (list_type[i] == "INT")
  220. printf("u_int32_t));n") >> CFILE
  221. if (list_type[i] == "ID")
  222. printf("%s));n", c_type[i]) >> CFILE
  223. printf("static void __dbcl_%s_%sfree __P((", 
  224.     name, args[i]) >> CFILE
  225. printf("__%s_%slist **));n", name, args[i]) >> CFILE
  226. }
  227. #
  228. # Spit out PUBLIC prototypes.
  229. #
  230. printf("int __dbcl_%s __P((",name) >> CHFILE
  231. sep = "";
  232. for (i = 0; i < nvars; ++i) {
  233. printf("%s%s", sep, pr_type[i]) >> CHFILE
  234. sep = ", ";
  235. }
  236. printf("));n") >> CHFILE
  237. #
  238. # Spit out function name/args.
  239. #
  240. printf("intn") >> CFILE
  241. printf("__dbcl_%s(", name) >> CFILE
  242. sep = "";
  243. for (i = 0; i < nvars; ++i) {
  244. printf("%s%s", sep, args[i]) >> CFILE
  245. sep = ", ";
  246. }
  247. printf(")n") >> CFILE
  249. for (i = 0; i < nvars; ++i)
  250. if (func_arg[i] == 0)
  251. printf("t%s %s;n", c_type[i], args[i]) 
  252.     >> CFILE
  253. else
  254. printf("t%s;n", c_type[i]) >> CFILE
  256. #
  257. # Call error function and return EINVAL
  258. #
  259. printf("{n") >> CFILE
  261. #
  262. # If we don't have a local env, set one.
  263. #
  264. if (env_handle == 0) {
  265. printf("tDB_ENV *dbenv;nn") >> CFILE
  266. if (db_handle)
  267. printf("tdbenv = %s->dbenv;n", 
  268.     args[db_idx]) >> CFILE
  269. else if (dbc_handle)
  270. printf("tdbenv = %s->dbp->dbenv;n", 
  271.     args[dbc_idx]) >> CFILE
  272. else if (txn_handle)
  273. printf("tdbenv = %s->mgrp->dbenv;n", 
  274.     args[txn_idx]) >> CFILE
  275. else if (mp_handle)
  276. printf("tdbenv = %s->dbmp->dbenv;n", 
  277.     args[mp_idx]) >> CFILE
  278. else
  279. printf("tdbenv = NULL;n") >> CFILE
  280. }
  281. #
  282. # Quiet the compiler for all variables.
  283. #
  284. # NOTE:  Index 'i' starts at 1, not 0.  Our first arg is
  285. # the handle we need to get to the env, and we do not want
  286. # to COMPQUIET that one.
  287. for (i = 1; i < nvars; ++i) {
  288. if (rpc_type[i] == "CONST" || rpc_type[i] == "DBT" ||
  289.     rpc_type[i] == "LIST" || rpc_type[i] == "STRING") {
  290. printf("tCOMPQUIET(%s, NULL);n", args[i]) 
  291.     >> CFILE
  292. }
  293. if (rpc_type[i] == "INT" || rpc_type[i] == "IGNORE" ||
  294.     rpc_type[i] == "ID") {
  295. printf("tCOMPQUIET(%s, 0);n", args[i]) 
  296.     >> CFILE
  297. }
  298. }
  300. if (!env_handle) {
  301. printf("treturn (__dbcl_rpc_illegal(dbenv, ") >> CFILE
  302. printf(""%s"));n", name) >> CFILE
  303. } else
  304. printf("treturn (__dbcl_rpc_illegal(%s, "%s"));n", 
  305.     args[env_idx], name) >> CFILE
  306. printf("}nn") >> CFILE
  308. next;
  309. }
  311. #
  312. # =====================================================
  313. # XDR messages.
  314. #
  315. printf("n") >> XFILE
  316. #
  317. # If there are any lists, generate the structure to contain them.
  318. #
  319. for (i = 0; i < nvars; ++i) {
  320. if (rpc_type[i] == "LIST") {
  321. printf("struct __%s_%slist {n", name, args[i]) >> XFILE
  322. printf("topaque ent<>;n") >> XFILE
  323. printf("t__%s_%slist *next;n", name, args[i]) >> XFILE
  324. printf("};nn") >> XFILE
  325. }
  326. }
  327. printf("struct __%s_msg {n", name) >> XFILE
  328. for (i = 0; i < nvars; ++i) {
  329. if (rpc_type[i] == "ID") {
  330. printf("tunsigned int %scl_id;n", args[i]) >> XFILE
  331. }
  332. if (rpc_type[i] == "STRING") {
  333. printf("tstring %s<>;n", args[i]) >> XFILE
  334. }
  335. if (rpc_type[i] == "INT") {
  336. printf("tunsigned int %s;n", args[i]) >> XFILE
  337. }
  338. if (rpc_type[i] == "DBT") {
  339. printf("tunsigned int %sdlen;n", args[i]) >> XFILE
  340. printf("tunsigned int %sdoff;n", args[i]) >> XFILE
  341. printf("tunsigned int %sflags;n", args[i]) >> XFILE
  342. printf("topaque %sdata<>;n", args[i]) >> XFILE
  343. }
  344. if (rpc_type[i] == "LIST") {
  345. printf("t__%s_%slist *%slist;n", 
  346.     name, args[i], args[i]) >> XFILE
  347. }
  348. }
  349. printf("};n") >> XFILE
  351. printf("n") >> XFILE
  352. #
  353. # If there are any lists, generate the structure to contain them.
  354. #
  355. for (i = 0; i < rvars; ++i) {
  356. if (ret_type[i] == "LIST") {
  357. printf("struct __%s_%sreplist {n", 
  358.     name, retargs[i]) >> XFILE
  359. printf("topaque ent<>;n") >> XFILE
  360. printf("t__%s_%sreplist *next;n", 
  361.     name, retargs[i]) >> XFILE
  362. printf("};nn") >> XFILE
  363. }
  364. }
  365. #
  366. # Generate the reply message
  367. #
  368. printf("struct __%s_reply {n", name) >> XFILE
  369. printf("tunsigned int status;n") >> XFILE
  370. for (i = 0; i < rvars; ++i) {
  371. if (ret_type[i] == "ID") {
  372. printf("tunsigned int %scl_id;n", retargs[i]) >> XFILE
  373. }
  374. if (ret_type[i] == "STRING") {
  375. printf("tstring %s<>;n", retargs[i]) >> XFILE
  376. }
  377. if (ret_type[i] == "INT") {
  378. printf("tunsigned int %s;n", retargs[i]) >> XFILE
  379. }
  380. if (ret_type[i] == "DBL") {
  381. printf("tdouble %s;n", retargs[i]) >> XFILE
  382. }
  383. if (ret_type[i] == "DBT") {
  384. printf("topaque %sdata<>;n", retargs[i]) >> XFILE
  385. }
  386. if (ret_type[i] == "LIST") {
  387. printf("t__%s_%sreplist *%slist;n", 
  388.     name, retargs[i], retargs[i]) >> XFILE
  389. }
  390. }
  391. printf("};n") >> XFILE
  393. endlist[nendlist] = 
  394.     sprintf("__%s_reply __DB_%s(__%s_msg) = %d", 
  395. name, name, name, nendlist);
  396. nendlist++;
  398. #
  399. # =====================================================
  400. # File headers, if necessary.
  401. #
  402. if (first == 0) {
  403. printf("#include "db_config.h"n") >> CFILE
  404. printf("n") >> CFILE
  405. printf("#ifdef HAVE_RPCn") >> CFILE
  406. printf("#ifndef NO_SYSTEM_INCLUDESn") >> CFILE
  407. printf("#include <sys/types.h>n") >> CFILE
  408. printf("#include <rpc/rpc.h>n") >> CFILE
  409. printf("#include <rpc/xdr.h>n") >> CFILE
  410. printf("n") >> CFILE
  411. printf("#include <errno.h>n") >> CFILE
  412. printf("#include <string.h>n") >> CFILE
  413. printf("#endifn") >> CFILE
  414. printf("#include "db_server.h"n") >> CFILE
  415. printf("n") >> CFILE
  416. printf("#include "db_int.h"n") >> CFILE
  417. printf("#include "db_page.h"n") >> CFILE
  418. printf("#include "db_ext.h"n") >> CFILE
  419. printf("#include "mp.h"n") >> CFILE
  420. printf("#include "rpc_client_ext.h"n") >> CFILE
  421. printf("#include "txn.h"n") >> CFILE
  422. printf("n") >> CFILE
  423. n = split(CHFILE, hpieces, "/");
  424. printf("#include "%s"n", hpieces[n]) >> CFILE
  425. printf("n") >> CFILE
  427. printf("#include "db_config.h"n") >> TFILE
  428. printf("n") >> TFILE
  429. printf("#ifdef HAVE_RPCn") >> TFILE
  430. printf("#ifndef NO_SYSTEM_INCLUDESn") >> TFILE
  431. printf("#include <sys/types.h>n") >> TFILE
  432. printf("#include <rpc/rpc.h>n") >> TFILE
  433. printf("n") >> TFILE
  434. printf("#include <errno.h>n") >> TFILE
  435. printf("#include <string.h>n") >> TFILE
  436. printf("#endifn") >> TFILE
  437. printf("#include "db_server.h"n") >> TFILE
  438. printf("n") >> TFILE
  439. printf("#include "db_int.h"n") >> TFILE
  440. printf("#include "db_page.h"n") >> TFILE
  441. printf("#include "db_ext.h"n") >> TFILE
  442. printf("#include "txn.h"n") >> TFILE
  443. printf("n") >> TFILE
  444. n = split(CHFILE, hpieces, "/");
  445. printf("#include "%s"n", hpieces[n]) >> TFILE
  446. printf("n") >> TFILE
  448. printf("#include "db_config.h"n") >> SFILE
  449. printf("n") >> SFILE
  450. printf("#ifndef NO_SYSTEM_INCLUDESn") >> SFILE
  451. printf("#include <sys/types.h>n") >> SFILE
  452. printf("n") >> SFILE
  453. printf("#include <rpc/rpc.h>n") >> SFILE
  454. printf("#include <rpc/xdr.h>n") >> SFILE
  455. printf("n") >> SFILE
  456. printf("#include <errno.h>n") >> SFILE
  457. printf("#include <string.h>n") >> SFILE
  458. printf("#endifn") >> SFILE
  459. printf("#include "db_server.h"n") >> SFILE
  460. printf("n") >> SFILE
  461. printf("#include "db_int.h"n") >> SFILE
  462. printf("#include "db_server_int.h"n") >> SFILE
  463. printf("#include "rpc_server_ext.h"n") >> SFILE
  464. printf("n") >> SFILE
  465. n = split(SHFILE, hpieces, "/");
  466. printf("#include "%s"n", hpieces[n]) >> SFILE
  467. printf("n") >> SFILE
  469. printf("#include "db_config.h"n") >> PFILE
  470. printf("n") >> PFILE
  471. printf("#ifndef NO_SYSTEM_INCLUDESn") >> PFILE
  472. printf("#include <sys/types.h>n") >> PFILE
  473. printf("n") >> PFILE
  474. printf("#include <rpc/rpc.h>n") >> PFILE
  475. printf("n") >> PFILE
  476. printf("#include <errno.h>n") >> PFILE
  477. printf("#include <string.h>n") >> PFILE
  478. printf("#include "db_server.h"n") >> PFILE
  479. printf("#endifn") >> PFILE
  480. printf("n") >> PFILE
  481. printf("#include "db_int.h"n") >> PFILE
  482. printf("#include "db_server_int.h"n") >> PFILE
  483. printf("#include "rpc_server_ext.h"n") >> PFILE
  484. printf("n") >> PFILE
  485. n = split(SHFILE, hpieces, "/");
  486. printf("#include "%s"n", hpieces[n]) >> PFILE
  487. printf("n") >> PFILE
  489. first = 1;
  490. }
  492. #
  493. # =====================================================
  494. # Server functions.
  495. #
  496. # If we are doing a list, send out local list prototypes.
  497. #
  498. for (i = 0; i < nvars; ++i) {
  499. if (rpc_type[i] != "LIST")
  500. continue;
  501. if (list_type[i] != "STRING" && list_type[i] != "INT" &&
  502.     list_type[i] != "ID")
  503. continue;
  504. printf("int __db_%s_%slist __P((", name, args[i]) >> SFILE
  505. printf("__%s_%slist *, ", name, args[i]) >> SFILE
  506. if (list_type[i] == "STRING") {
  507. printf("char ***));n") >> SFILE
  508. }
  509. if (list_type[i] == "INT" || list_type[i] == "ID") {
  510. printf("u_int32_t **));n") >> SFILE
  511. }
  512. printf("void __db_%s_%sfree __P((", name, args[i]) >> SFILE
  513. if (list_type[i] == "STRING")
  514. printf("char **));nn") >> SFILE
  515. if (list_type[i] == "INT" || list_type[i] == "ID")
  516. printf("u_int32_t *));nn") >> SFILE
  518. }
  519. #
  520. # First spit out PUBLIC prototypes for server functions.
  521. #
  522. printf("__%s_reply * __db_%s_%d __P((__%s_msg *));n", 
  523.     name, name, msgid, name) >> SHFILE
  525. printf("__%s_reply *n", name) >> SFILE
  526. printf("__db_%s_%d(req)n", name, msgid) >> SFILE
  527. printf("t__%s_msg *req;n", name) >> SFILE;
  528. printf("{n") >> SFILE
  529. doing_list = 0;
  530. #
  531. # If we are doing a list, decompose it for server proc we'll call.
  532. #
  533. for (i = 0; i < nvars; ++i) {
  534. if (rpc_type[i] != "LIST")
  535. continue;
  536. doing_list = 1;
  537. if (list_type[i] == "STRING")
  538. printf("tchar **__db_%slist;n", args[i]) >> SFILE
  539. if (list_type[i] == "ID" || list_type[i] == "INT")
  540. printf("tu_int32_t *__db_%slist;n", args[i]) >> SFILE
  541. }
  542. if (doing_list)
  543. printf("tint ret;n") >> SFILE
  544. printf("tstatic __%s_reply reply; /* must be static */n", 
  545.     name) >> SFILE
  546. if (xdr_free) {
  547. printf("tstatic int __%s_free = 0; /* must be static */nn", 
  548.     name) >> SFILE
  549. printf("tif (__%s_free)n", name) >> SFILE
  550. printf("ttxdr_free((xdrproc_t)xdr___%s_reply, (void *)&reply);n", 
  551.     name) >> SFILE
  552. printf("t__%s_free = 0;n", name) >> SFILE
  553. printf("nt/* Reinitialize allocated fields */n") >> SFILE
  554. for (i = 0; i < rvars; ++i) {
  555. if (ret_type[i] == "LIST") {
  556. printf("treply.%slist = NULL;n", 
  557.     retargs[i]) >> SFILE
  558. }
  559. if (ret_type[i] == "DBT") {
  560. printf("treply.%sdata.%sdata_val = NULL;n", 
  561.     retargs[i], retargs[i]) >> SFILE
  562. }
  563. }
  564. }
  566. need_out = 0;
  567. for (i = 0; i < nvars; ++i) {
  568. if (rpc_type[i] == "LIST") {
  569. printf("ntif ((ret = __db_%s_%slist(", 
  570.     name, args[i]) >> SFILE
  571. printf("req->%slist, &__db_%slist)) != 0)n", 
  572.     args[i], args[i]) >> SFILE
  573. printf("ttgoto out;n") >> SFILE
  574. need_out = 1;
  575. }
  576. }
  578. #
  579. # Compose server proc to call.  Decompose message components as args.
  580. #
  581. printf("nt__%s_%d_proc(", name, msgid) >> SFILE
  582. sep = "";
  583. for (i = 0; i < nvars; ++i) {
  584. if (rpc_type[i] == "ID") {
  585. printf("%sreq->%scl_id", sep, args[i]) >> SFILE
  586. }
  587. if (rpc_type[i] == "STRING") {
  588. printf("%s(*req->%s == '\0') ? NULL : req->%s", 
  589.     sep, args[i], args[i]) >> SFILE
  590. }
  591. if (rpc_type[i] == "INT") {
  592. printf("%sreq->%s", sep, args[i]) >> SFILE
  593. }
  594. if (rpc_type[i] == "LIST") {
  595. printf("%s__db_%slist", sep, args[i]) >> SFILE
  596. }
  597. if (rpc_type[i] == "DBT") {
  598. printf("%sreq->%sdlen", sep, args[i]) >> SFILE
  599. sep = ",nt    ";
  600. printf("%sreq->%sdoff", sep, args[i]) >> SFILE
  601. printf("%sreq->%sflags", sep, args[i]) >> SFILE
  602. printf("%sreq->%sdata.%sdata_val", 
  603.     sep, args[i], args[i]) >> SFILE
  604. printf("%sreq->%sdata.%sdata_len", 
  605.     sep, args[i], args[i]) >> SFILE
  606. }
  607. sep = ",nt    ";
  608. }
  609. printf("%s&reply", sep) >> SFILE
  610. if (xdr_free)
  611. printf("%s&__%s_free);n", sep, name) >> SFILE
  612. else
  613. printf(");nn") >> SFILE
  614. for (i = 0; i < nvars; ++i) {
  615. if (rpc_type[i] == "LIST") {
  616. printf("t__db_%s_%sfree(__db_%slist);n", 
  617.     name, args[i], args[i]) >> SFILE
  618. }
  619. }
  620. if (need_out) {
  621. printf("nout:n") >> SFILE
  622. }
  623. printf("treturn (&reply);n") >> SFILE
  624. printf("}nn") >> SFILE
  626. #
  627. # If we are doing a list, write list functions for this op.
  628. #
  629. for (i = 0; i < nvars; ++i) {
  630. if (rpc_type[i] != "LIST")
  631. continue;
  632. if (list_type[i] != "STRING" && list_type[i] != "INT" &&
  633.     list_type[i] != "ID")
  634. continue;
  635. printf("intn") >> SFILE
  636. printf("__db_%s_%slist(locp, ppp)n", name, args[i]) >> SFILE
  637. printf("t__%s_%slist *locp;n", name, args[i]) >> SFILE
  638. if (list_type[i] == "STRING") {
  639. printf("tchar ***ppp;n{n") >> SFILE
  640. printf("tchar **pp;n") >> SFILE
  641. }
  642. if (list_type[i] == "INT" || list_type[i] == "ID") {
  643. printf("tu_int32_t **ppp;n{n") >> SFILE
  644. printf("tu_int32_t *pp;n") >> SFILE
  645. }
  646. printf("tint cnt, ret, size;n") >> SFILE
  647. printf("t__%s_%slist *nl;nn", name, args[i]) >> SFILE
  648. printf("tfor (cnt = 0, nl = locp;") >> SFILE
  649. printf(" nl != NULL; cnt++, nl = nl->next)ntt;nn") >> SFILE
  650. printf("tif (cnt == 0) {n") >> SFILE
  651. printf("tt*ppp = NULL;n") >> SFILE
  652. printf("ttreturn (0);nt}n") >> SFILE
  653. printf("tsize = sizeof(*pp) * (cnt + 1);n") >> SFILE
  654. printf("tif ((ret = __os_malloc(NULL, size, ") >> SFILE
  655. printf("NULL, ppp)) != 0)n") >> SFILE
  656. printf("ttreturn (ret);n") >> SFILE
  657. printf("tmemset(*ppp, 0, size);n") >> SFILE
  658. printf("tfor (pp = *ppp, nl = locp;") >> SFILE
  659. printf(" nl != NULL; nl = nl->next, pp++) {n") >> SFILE
  660. if (list_type[i] == "STRING") {
  661. printf("ttif ((ret = __os_malloc(NULL ,") >> SFILE
  662. printf("nl->ent.ent_len + 1, NULL, pp)) != 0)n") 
  663.     >> SFILE
  664. printf("tttgoto out;n") >> SFILE
  665. printf("ttif ((ret = __os_strdup(NULL, ") >> SFILE
  666. printf("(char *)nl->ent.ent_val, pp)) != 0)n") >> SFILE
  667. printf("tttgoto out;n") >> SFILE
  668. }
  669. if (list_type[i] == "INT" || list_type[i] == "ID")
  670. printf("tt*pp = *(u_int32_t *)nl->ent.ent_val;n") 
  671.     >> SFILE
  672. printf("t}n") >> SFILE
  673. printf("treturn (0);n") >> SFILE
  674. if (list_type[i] == "STRING") {
  675. printf("out:n") >> SFILE
  676. printf("t__db_%s_%sfree(*ppp);n", 
  677.     name, args[i]) >> SFILE
  678. printf("treturn (ret);n") >> SFILE
  679. }
  680. printf("}nn") >> SFILE
  682. printf("voidn") >> SFILE
  683. printf("__db_%s_%sfree(pp)n", name, args[i]) >> SFILE
  685. if (list_type[i] == "STRING")
  686. printf("tchar **pp;n") >> SFILE
  687. if (list_type[i] == "INT" || list_type[i] == "ID")
  688. printf("tu_int32_t *pp;n") >> SFILE
  690. printf("{n") >> SFILE
  691. printf("tsize_t size;n") >> SFILE
  693. if (list_type[i] == "STRING")
  694. printf("tchar **p;nn") >> SFILE
  695. if (list_type[i] == "INT" || list_type[i] == "ID")
  696. printf("tu_int32_t *p;nn") >> SFILE
  698. printf("tif (pp == NULL)nttreturn;n") >> SFILE
  699. printf("tsize = sizeof(*p);n") >> SFILE
  700. printf("tfor (p = pp; *p != 0; p++) {n") >> SFILE
  701. printf("ttsize += sizeof(*p);n") >> SFILE
  703. if (list_type[i] == "STRING")
  704. printf("tt__os_free(*p, strlen(*p)+1);n") >> SFILE
  705. printf("t}n") >> SFILE
  706. printf("t__os_free(pp, size);n") >> SFILE
  707. printf("}nn") >> SFILE
  708. }
  710. #
  711. # =====================================================
  712. # Generate Procedure Template Server code
  713. #
  714. # Produce SED file commands if needed at the same time
  715. #
  716. # Start with PUBLIC prototypes
  717. #
  718. printf("void __%s_%d_proc __P((", name, msgid) >> SHFILE
  719. sep = "";
  720. argcount = 0;
  721. for (i = 0; i < nvars; ++i) {
  722. argcount++;
  723. split_lines(1);
  724. if (argcount == 0) {
  725. sep = "";
  726. }
  727. if (rpc_type[i] == "IGNORE")
  728. continue;
  729. if (rpc_type[i] == "ID") {
  730. printf("%slong", sep) >> SHFILE
  731. }
  732. if (rpc_type[i] == "STRING") {
  733. printf("%schar *", sep) >> SHFILE
  734. }
  735. if (rpc_type[i] == "INT") {
  736. printf("%su_int32_t", sep) >> SHFILE
  737. }
  738. if (rpc_type[i] == "LIST" && list_type[i] == "STRING") {
  739. printf("%schar **", sep) >> SHFILE
  740. }
  741. if (rpc_type[i] == "LIST" && list_type[i] == "INT") {
  742. printf("%su_int32_t *", sep) >> SHFILE
  743. }
  744. if (rpc_type[i] == "LIST" && list_type[i] == "ID") {
  745. printf("%su_int32_t *", sep) >> SHFILE
  746. }
  747. if (rpc_type[i] == "DBT") {
  748. printf("%su_int32_t", sep) >> SHFILE
  749. sep = ", ";
  750. argcount++;
  751. split_lines(1);
  752. if (argcount == 0) {
  753. sep = "";
  754. } else {
  755. sep = ", ";
  756. }
  757. printf("%su_int32_t", sep) >> SHFILE
  758. argcount++;
  759. split_lines(1);
  760. if (argcount == 0) {
  761. sep = "";
  762. } else {
  763. sep = ", ";
  764. }
  765. printf("%su_int32_t", sep) >> SHFILE
  766. argcount++;
  767. split_lines(1);
  768. if (argcount == 0) {
  769. sep = "";
  770. } else {
  771. sep = ", ";
  772. }
  773. printf("%svoid *", sep) >> SHFILE
  774. argcount++;
  775. split_lines(1);
  776. if (argcount == 0) {
  777. sep = "";
  778. } else {
  779. sep = ", ";
  780. }
  781. printf("%su_int32_t", sep) >> SHFILE
  782. }
  783. sep = ", ";
  784. }
  785. printf("%s__%s_reply *", sep, name) >> SHFILE
  786. if (xdr_free) {
  787. printf("%sint *));n", sep) >> SHFILE
  788. } else {
  789. printf("));n") >> SHFILE
  790. }
  791. #
  792. # Spit out function name and arg list
  793. #
  794. printf("/^\/\* BEGIN __%s_%d_proc/,/^\/\* END __%s_%d_proc/c\n", 
  795.     name, msgid, name, msgid) >> SEDFILE
  797. printf("/* BEGIN __%s_%d_proc */n", name, msgid) >> PFILE
  798. printf("/* BEGIN __%s_%d_proc */\n", name, msgid) >> SEDFILE
  799. printf("voidn") >> PFILE
  800. printf("void\n") >> SEDFILE
  801. printf("__%s_%d_proc(", name, msgid) >> PFILE
  802. printf("__%s_%d_proc(", name, msgid) >> SEDFILE
  803. sep = "";
  804. argcount = 0;
  805. for (i = 0; i < nvars; ++i) {
  806. argcount++;
  807. split_lines(0);
  808. if (argcount == 0) {
  809. sep = "";
  810. }
  811. if (rpc_type[i] == "IGNORE") 
  812. continue;
  813. if (rpc_type[i] == "ID") {
  814. printf("%s%scl_id", sep, args[i]) >> PFILE
  815. printf("%s%scl_id", sep, args[i]) >> SEDFILE
  816. }
  817. if (rpc_type[i] == "STRING") {
  818. printf("%s%s", sep, args[i]) >> PFILE
  819. printf("%s%s", sep, args[i]) >> SEDFILE
  820. }
  821. if (rpc_type[i] == "INT") {
  822. printf("%s%s", sep, args[i]) >> PFILE
  823. printf("%s%s", sep, args[i]) >> SEDFILE
  824. }
  825. if (rpc_type[i] == "LIST") {
  826. printf("%s%slist", sep, args[i]) >> PFILE
  827. printf("%s%slist", sep, args[i]) >> SEDFILE
  828. }
  829. if (rpc_type[i] == "DBT") {
  830. printf("%s%sdlen", sep, args[i]) >> PFILE
  831. printf("%s%sdlen", sep, args[i]) >> SEDFILE
  832. sep = ", ";
  833. argcount++;
  834. split_lines(0);
  835. if (argcount == 0) {
  836. sep = "";
  837. } else {
  838. sep = ", ";
  839. }
  840. printf("%s%sdoff", sep, args[i]) >> PFILE
  841. printf("%s%sdoff", sep, args[i]) >> SEDFILE
  842. argcount++;
  843. split_lines(0);
  844. if (argcount == 0) {
  845. sep = "";
  846. } else {
  847. sep = ", ";
  848. }
  849. printf("%s%sflags", sep, args[i]) >> PFILE
  850. printf("%s%sflags", sep, args[i]) >> SEDFILE
  851. argcount++;
  852. split_lines(0);
  853. if (argcount == 0) {
  854. sep = "";
  855. } else {
  856. sep = ", ";
  857. }
  858. printf("%s%sdata", sep, args[i]) >> PFILE
  859. printf("%s%sdata", sep, args[i]) >> SEDFILE
  860. argcount++;
  861. split_lines(0);
  862. if (argcount == 0) {
  863. sep = "";
  864. } else {
  865. sep = ", ";
  866. }
  867. printf("%s%ssize", sep, args[i]) >> PFILE
  868. printf("%s%ssize", sep, args[i]) >> SEDFILE
  869. }
  870. sep = ", ";
  871. }
  872. printf("%sreplyp",sep) >> PFILE
  873. printf("%sreplyp",sep) >> SEDFILE
  874. if (xdr_free) {
  875. printf("%sfreep)n",sep) >> PFILE
  876. printf("%sfreep)\n",sep) >> SEDFILE
  877. } else {
  878. printf(")n") >> PFILE
  879. printf(")\n") >> SEDFILE
  880. }
  881. #
  882. # Spit out arg types/names;
  883. #
  884. for (i = 0; i < nvars; ++i) {
  885. if (rpc_type[i] == "ID") {
  886. printf("tlong %scl_id;n", args[i]) >> PFILE
  887. printf("\tlong %scl_id;\n", args[i]) >> SEDFILE
  888. }
  889. if (rpc_type[i] == "STRING") {
  890. printf("tchar *%s;n", args[i]) >> PFILE
  891. printf("\tchar *%s;\n", args[i]) >> SEDFILE
  892. }
  893. if (rpc_type[i] == "INT") {
  894. printf("tu_int32_t %s;n", args[i]) >> PFILE
  895. printf("\tu_int32_t %s;\n", args[i]) >> SEDFILE
  896. }
  897. if (rpc_type[i] == "LIST" && list_type[i] == "STRING") {
  898. printf("tchar ** %slist;n", args[i]) >> PFILE
  899. printf("\tchar ** %slist;\n", args[i]) >> SEDFILE
  900. }
  901. if (rpc_type[i] == "LIST" && list_type[i] == "INT") {
  902. printf("tu_int32_t * %slist;n", args[i]) >> PFILE
  903. printf("\tu_int32_t * %slist;\n", 
  904.     args[i]) >> SEDFILE
  905. }
  906. if (rpc_type[i] == "LIST" && list_type[i] == "ID") {
  907. printf("tu_int32_t * %slist;n", args[i]) >> PFILE
  908. printf("\tu_int32_t * %slist;\n", args[i]) 
  909.     >> SEDFILE
  910. }
  911. if (rpc_type[i] == "DBT") {
  912. printf("tu_int32_t %sdlen;n", args[i]) >> PFILE
  913. printf("\tu_int32_t %sdlen;\n", args[i]) >> SEDFILE
  914. printf("tu_int32_t %sdoff;n", args[i]) >> PFILE
  915. printf("\tu_int32_t %sdoff;\n", args[i]) >> SEDFILE
  916. printf("tu_int32_t %sflags;n", args[i]) >> PFILE
  917. printf("\tu_int32_t %sflags;\n", args[i]) >> SEDFILE
  918. printf("tvoid *%sdata;n", args[i]) >> PFILE
  919. printf("\tvoid *%sdata;\n", args[i]) >> SEDFILE
  920. printf("tu_int32_t %ssize;n", args[i]) >> PFILE
  921. printf("\tu_int32_t %ssize;\n", args[i]) >> SEDFILE
  922. }
  923. }
  924. printf("t__%s_reply *replyp;n",name) >> PFILE
  925. printf("\t__%s_reply *replyp;\n",name) >> SEDFILE
  926. if (xdr_free) {
  927. printf("tint * freep;n") >> PFILE
  928. printf("\tint * freep;\n") >> SEDFILE
  929. }
  931. printf("/* END __%s_%d_proc */n", name, msgid) >> PFILE
  932. printf("/* END __%s_%d_proc */n", name, msgid) >> SEDFILE
  934. #
  935. # Function body
  936. #
  937. printf("{n") >> PFILE
  938. printf("tint ret;n") >> PFILE
  939. for (i = 0; i < nvars; ++i) {
  940. if (rpc_type[i] == "ID") {
  941. printf("t%s %s;n", c_type[i], args[i]) >> PFILE
  942. printf("tct_entry *%s_ctp;n", args[i]) >> PFILE
  943. }
  944. }
  945. printf("n") >> PFILE
  946. for (i = 0; i < nvars; ++i) {
  947. if (rpc_type[i] == "ID") {
  948. printf("tACTIVATE_CTP(%s_ctp, %scl_id, %s);n", 
  949.     args[i], args[i], ctp_type[i]) >> PFILE
  950. printf("t%s = (%s)%s_ctp->ct_anyp;n", 
  951.     args[i], c_type[i], args[i]) >> PFILE
  952. }
  953. }
  954. printf("nt/*nt * XXX Code goes herent */nn") >> PFILE
  955. printf("treplyp->status = ret;n") >> PFILE
  956. printf("treturn;n") >> PFILE
  957. printf("}nn") >> PFILE
  959. #
  960. # If we don't want client code generated, go on to next.
  961. #
  962. if (gen_code == 0)
  963. next;
  965. #
  966. # =====================================================
  967. # Generate Client code
  968. #
  969. # If we are doing a list, spit out prototype decl.
  970. #
  971. for (i = 0; i < nvars; i++) {
  972. if (rpc_type[i] != "LIST")
  973. continue;
  974. printf("static int __dbcl_%s_%slist __P((", 
  975.     name, args[i]) >> CFILE
  976. printf("__%s_%slist **, ", name, args[i]) >> CFILE
  977. if (list_type[i] == "STRING")
  978. printf("%s));n", c_type[i]) >> CFILE
  979. if (list_type[i] == "INT")
  980. printf("u_int32_t));n") >> CFILE
  981. if (list_type[i] == "ID")
  982. printf("%s));n", c_type[i]) >> CFILE
  983. printf("static void __dbcl_%s_%sfree __P((", 
  984.     name, args[i]) >> CFILE
  985. printf("__%s_%slist **));n", name, args[i]) >> CFILE
  986. }
  987. #
  988. # Spit out PUBLIC prototypes.
  989. #
  990. printf("int __dbcl_%s __P((",name) >> CHFILE
  991. sep = "";
  992. for (i = 0; i < nvars; ++i) {
  993. printf("%s%s", sep, pr_type[i]) >> CHFILE
  994. sep = ", ";
  995. }
  996. printf("));n") >> CHFILE
  997. #
  998. # Spit out function name/args.
  999. #
  1000. printf("intn") >> CFILE
  1001. printf("__dbcl_%s(", name) >> CFILE
  1002. sep = "";
  1003. for (i = 0; i < nvars; ++i) {
  1004. printf("%s%s", sep, args[i]) >> CFILE
  1005. sep = ", ";
  1006. }
  1007. printf(")n") >> CFILE
  1009. for (i = 0; i < nvars; ++i)
  1010. if (func_arg[i] == 0)
  1011. printf("t%s %s;n", c_type[i], args[i]) >> CFILE
  1012. else
  1013. printf("t%s;n", c_type[i]) >> CFILE
  1015. printf("{n") >> CFILE
  1016. printf("tCLIENT *cl;n") >> CFILE
  1017. printf("t__%s_msg req;n", name) >> CFILE
  1018. printf("tstatic __%s_reply *replyp = NULL;n", name) >> CFILE;
  1019. printf("tint ret;n") >> CFILE
  1020. if (!env_handle)
  1021. printf("tDB_ENV *dbenv;n") >> CFILE
  1023. printf("n") >> CFILE
  1024. printf("tret = 0;n") >> CFILE
  1025. if (!env_handle) {
  1026. printf("tdbenv = NULL;n") >> CFILE
  1027. if (db_handle)
  1028. printf("tdbenv = %s->dbenv;n", args[db_idx]) >> CFILE
  1029. else if (dbc_handle)
  1030. printf("tdbenv = %s->dbp->dbenv;n", 
  1031.     args[dbc_idx]) >> CFILE
  1032. else if (txn_handle)
  1033. printf("tdbenv = %s->mgrp->dbenv;n", 
  1034.     args[txn_idx]) >> CFILE
  1035. printf("tif (dbenv == NULL || dbenv->cl_handle == NULL) {n") 
  1036.     >> CFILE
  1037. printf("tt__db_err(dbenv, "No server environment.");n") 
  1038.     >> CFILE
  1039. } else {
  1040. printf("tif (%s == NULL || %s->cl_handle == NULL) {n", 
  1041.     args[env_idx], args[env_idx]) >> CFILE
  1042. printf("tt__db_err(%s, "No server environment.");n", 
  1043.     args[env_idx]) >> CFILE
  1044. }
  1045. printf("ttreturn (DB_NOSERVER);n") >> CFILE
  1046. printf("t}n") >> CFILE
  1047. printf("n") >> CFILE
  1049. #
  1050. # Free old reply if there was one.
  1051. #
  1052. printf("tif (replyp != NULL) {n") >> CFILE
  1053. printf("ttxdr_free((xdrproc_t)xdr___%s_reply, (void *)replyp);n", 
  1054.     name) >> CFILE
  1055. printf("ttreplyp = NULL;nt}n") >> CFILE
  1056. if (!env_handle)
  1057. printf("tcl = (CLIENT *)dbenv->cl_handle;n") >> CFILE
  1058. else
  1059. printf("tcl = (CLIENT *)%s->cl_handle;n", 
  1060.     args[env_idx]) >> CFILE
  1062. printf("n") >> CFILE
  1064. #
  1065. # If there is a function arg, check that it is NULL
  1066. #
  1067. for (i = 0; i < nvars; ++i) {
  1068. if (func_arg[i] != 1)
  1069. continue;
  1070. printf("tif (%s != NULL) {n", args[i]) >> CFILE
  1071. printf("tt__db_err(%s, ", args[env_idx]) >> CFILE
  1072. printf(""User functions not supported in RPC.");n") >> CFILE
  1073. printf("ttreturn (EINVAL);nt}n") >> CFILE
  1074. }
  1076. #
  1077. # Compose message components
  1078. #
  1079. for (i = 0; i < nvars; ++i) {
  1080. if (rpc_type[i] == "ID") {
  1081. printf("tif (%s == NULL)n", args[i]) >> CFILE
  1082. printf("ttreq.%scl_id = 0;ntelsen", 
  1083.     args[i]) >> CFILE
  1084. if (c_type[i] == "DB_TXN *") {
  1085. printf("ttreq.%scl_id = %s->txnid;n", 
  1086.     args[i], args[i]) >> CFILE
  1087. } else {
  1088. printf("ttreq.%scl_id = %s->cl_id;n", 
  1089.     args[i], args[i]) >> CFILE
  1090. }
  1091. }
  1092. if (rpc_type[i] == "INT") {
  1093. printf("treq.%s = %s;n", args[i], args[i]) >> CFILE
  1094. }
  1095. if (rpc_type[i] == "STRING") {
  1096. printf("tif (%s == NULL)n", args[i]) >> CFILE
  1097. printf("ttreq.%s = "";n", args[i]) >> CFILE
  1098. printf("telsen") >> CFILE
  1099. printf("ttreq.%s = (char *)%s;n", 
  1100.     args[i], args[i]) >> CFILE
  1101. }
  1102. if (rpc_type[i] == "DBT") {
  1103. printf("treq.%sdlen = %s->dlen;n", 
  1104.     args[i], args[i]) >> CFILE
  1105. printf("treq.%sdoff = %s->doff;n", 
  1106.     args[i], args[i]) >> CFILE
  1107. printf("treq.%sflags = %s->flags;n", 
  1108.     args[i], args[i]) >> CFILE
  1109. printf("treq.%sdata.%sdata_val = %s->data;n", 
  1110.     args[i], args[i], args[i]) >> CFILE
  1111. printf("treq.%sdata.%sdata_len = %s->size;n", 
  1112.     args[i], args[i], args[i]) >> CFILE
  1113. }
  1114. if (rpc_type[i] == "LIST") {
  1115. printf("tif ((ret = __dbcl_%s_%slist(", 
  1116.     name, args[i]) >> CFILE
  1117. printf("&req.%slist, %s)) != 0)n", 
  1118.     args[i], args[i]) >> CFILE
  1119. printf("ttgoto out;n") >> CFILE
  1120. }
  1121. }
  1123. printf("n") >> CFILE
  1124. printf("treplyp = __db_%s_%d(&req, cl);n", name, msgid) >> CFILE
  1125. printf("tif (replyp == NULL) {n") >> CFILE
  1126. if (!env_handle) {
  1127. printf("tt__db_err(dbenv, ") >> CFILE
  1128. printf("clnt_sperror(cl, "Berkeley DB"));n") >> CFILE
  1129. } else {
  1130. printf("tt__db_err(%s, ", args[env_idx]) >> CFILE
  1131. printf("clnt_sperror(cl, "Berkeley DB"));n") >> CFILE
  1132. }
  1133. printf("ttret = DB_NOSERVER;n") >> CFILE
  1134. printf("ttgoto out;n") >> CFILE
  1135. printf("t}n") >> CFILE
  1137. if (ret_code == 0) {
  1138. printf("tret = replyp->status;n") >> CFILE
  1139. } else {
  1140. for (i = 0; i < nvars; ++i) {
  1141. if (rpc_type[i] == "LIST") {
  1142. printf("t__dbcl_%s_%sfree(&req.%slist);n", 
  1143.     name, args[i], args[i]) >> CFILE
  1144. }
  1145. }
  1146. printf("treturn (__dbcl_%s_ret(", name) >> CFILE
  1147. sep = "";
  1148. for (i = 0; i < nvars; ++i) {
  1149. printf("%s%s", sep, args[i]) >> CFILE
  1150. sep = ", ";
  1151. }
  1152. printf("%sreplyp));n", sep) >> CFILE
  1153. }
  1154. printf("out:n") >> CFILE
  1155. for (i = 0; i < nvars; ++i) {
  1156. if (rpc_type[i] == "LIST") {
  1157. printf("t__dbcl_%s_%sfree(&req.%slist);n", 
  1158.     name, args[i], args[i]) >> CFILE
  1159. }
  1160. }
  1161. printf("treturn (ret);n") >> CFILE
  1162. printf("}nn") >> CFILE
  1164. #
  1165. # If we are doing a list, write list functions for op.
  1166. #
  1167. for (i = 0; i < nvars; i++) {
  1168. if (rpc_type[i] != "LIST")
  1169. continue;
  1170. printf("intn__dbcl_%s_%slist(locp, pp)n", 
  1171.     name, args[i]) >> CFILE
  1172. printf("t__%s_%slist **locp;n", name, args[i]) >> CFILE
  1173. if (list_type[i] == "STRING")
  1174. printf("t%s pp;n{nt%s p;n", 
  1175.     c_type[i], c_type[i]) >> CFILE
  1176. if (list_type[i] == "INT")
  1177. printf("tu_int32_t *pp;n{ntu_int32_t *p, *q;n") 
  1178.     >> CFILE
  1179. if (list_type[i] == "ID")
  1180. printf("t%s pp;n{nt%s p;ntu_int32_t *q;n", 
  1181.     c_type[i], c_type[i]) >> CFILE
  1183. printf("tint ret;n") >> CFILE
  1184. printf("t__%s_%slist *nl, **nlp;nn", name, args[i]) >> CFILE
  1185. printf("t*locp = NULL;n") >> CFILE
  1186. printf("tif (pp == NULL)nttreturn (0);n") >> CFILE
  1187. printf("tnlp = locp;n") >> CFILE
  1188. printf("tfor (p = pp; *p != 0; p++) {n") >> CFILE
  1189. printf("ttif ((ret = __os_malloc(NULL, ") >> CFILE
  1190. printf("sizeof(*nl), NULL, nlp)) != 0)n") >> CFILE
  1191. printf("tttgoto out;n") >> CFILE
  1192. printf("ttnl = *nlp;n") >> CFILE
  1193. printf("ttnl->next = NULL;n") >> CFILE
  1194. printf("ttnl->ent.ent_val = NULL;n") >> CFILE
  1195. printf("ttnl->ent.ent_len = 0;n") >> CFILE
  1196. if (list_type[i] == "STRING") {
  1197. printf("ttif ((ret = __os_strdup(NULL, ") >> CFILE
  1198. printf("*p, &nl->ent.ent_val)) != 0)n") >> CFILE
  1199. printf("tttgoto out;n") >> CFILE
  1200. printf("ttnl->ent.ent_len = strlen(*p)+1;n") >> CFILE
  1201. }
  1202. if (list_type[i] == "INT") {
  1203. printf("ttif ((ret = __os_malloc(NULL, ") >> CFILE
  1204. printf("sizeof(%s), NULL, &nl->ent.ent_val)) != 0)n", 
  1205.     c_type[i]) >> CFILE
  1206. printf("tttgoto out;n") >> CFILE
  1207. printf("ttq = (u_int32_t *)nl->ent.ent_val;n") 
  1208.     >> CFILE
  1209. printf("tt*q = *p;n") >> CFILE
  1210. printf("ttnl->ent.ent_len = sizeof(%s);n", 
  1211.     c_type[i]) >> CFILE
  1212. }
  1213. if (list_type[i] == "ID") {
  1214. printf("ttif ((ret = __os_malloc(NULL, ") >> CFILE
  1215. printf("sizeof(u_int32_t),") >> CFILE
  1216. printf(" NULL, &nl->ent.ent_val)) != 0)n") >> CFILE
  1217. printf("tttgoto out;n") >> CFILE
  1218. printf("ttq = (u_int32_t *)nl->ent.ent_val;n") 
  1219.     >> CFILE
  1220. printf("tt*q = (*p)->cl_id;n") >> CFILE
  1221. printf("ttnl->ent.ent_len = sizeof(u_int32_t);n") 
  1222.     >> CFILE
  1223. }
  1224. printf("ttnlp = &nl->next;n") >> CFILE
  1225. printf("t}n") >> CFILE
  1226. printf("treturn (0);n") >> CFILE
  1227. printf("out:n") >> CFILE
  1228. printf("t__dbcl_%s_%sfree(locp);n", name, args[i]) >> CFILE
  1229. printf("treturn (ret);n") >> CFILE
  1231. printf("}nn") >> CFILE
  1233. printf("voidn__dbcl_%s_%sfree(locp)n", name, args[i]) >> CFILE
  1234. printf("t__%s_%slist **locp;n", name, args[i]) >> CFILE
  1235. printf("{n") >> CFILE
  1236. printf("t__%s_%slist *nl, *nl1;nn", name, args[i]) >> CFILE
  1237. printf("tif (locp == NULL)nttreturn;n") >> CFILE
  1238. printf("tfor (nl = *locp; nl != NULL; nl = nl1) {n") >> CFILE
  1239. printf("ttnl1 = nl->next;n") >> CFILE
  1240. printf("ttif (nl->ent.ent_val)n") >> CFILE
  1241. printf("ttt__os_free(nl->ent.ent_val, nl->ent.ent_len);n") 
  1242.     >> CFILE
  1243. printf("tt__os_free(nl, sizeof(*nl));n") >> CFILE
  1244. printf("t}n}nn") >> CFILE
  1245. }
  1246. #
  1247. # Generate Client Template code
  1248. #
  1249. if (ret_code) {
  1250. #
  1251. # If we are doing a list, write prototypes
  1252. #
  1253. for (i = 0; i < rvars; ++i) {
  1254. if (ret_type[i] != "LIST")
  1255. continue;
  1256. if (retlist_type[i] != "STRING" &&
  1257.     retlist_type[i] != "INT" && list_type[i] != "ID")
  1258. continue;
  1259. printf("int __db_%s_%sreplist __P((", 
  1260.     name, retargs[i]) >> TFILE
  1261. printf("__%s_%sreplist, ", 
  1262.     name, retargs[i]) >> TFILE
  1263. if (retlist_type[i] == "STRING") {
  1264. printf("char ***));n") >> TFILE
  1265. }
  1266. if (retlist_type[i] == "INT" ||
  1267.     retlist_type[i] == "ID") {
  1268. printf("u_int32_t **));n") >> TFILE
  1269. }
  1270. printf("void __db_%s_%sfree __P((", 
  1271.     name, retargs[i]) >> TFILE
  1272. if (retlist_type[i] == "STRING")
  1273. printf("char **));n") >> TFILE
  1274. if (retlist_type[i] == "INT" || retlist_type[i] == "ID")
  1275. printf("u_int32_t *));nn") >> TFILE
  1276. }
  1278. printf("int __dbcl_%s_ret __P((", name) >> CHFILE
  1279. sep = "";
  1280. for (i = 0; i < nvars; ++i) {
  1281. printf("%s%s", sep, pr_type[i]) >> CHFILE
  1282. sep = ", ";
  1283. }
  1284. printf("%s__%s_reply *));n", sep, name) >> CHFILE
  1286. printf("intn") >> TFILE
  1287. printf("__dbcl_%s_ret(", name) >> TFILE
  1288. sep = "";
  1289. for (i = 0; i < nvars; ++i) {
  1290. printf("%s%s", sep, args[i]) >> TFILE
  1291. sep = ", ";
  1292. }
  1293. printf("%sreplyp)n",sep) >> TFILE
  1295. for (i = 0; i < nvars; ++i)
  1296. if (func_arg[i] == 0)
  1297. printf("t%s %s;n", c_type[i], args[i]) 
  1298.     >> TFILE
  1299. else
  1300. printf("t%s;n", c_type[i]) >> TFILE
  1301. printf("t__%s_reply *replyp;n", name) >> TFILE;
  1302. printf("{n") >> TFILE
  1303. printf("tint ret;n") >> TFILE
  1304. #
  1305. # Local vars in template
  1306. #
  1307. for (i = 0; i < rvars; ++i) {
  1308. if (ret_type[i] == "ID" || ret_type[i] == "STRING" ||
  1309.     ret_type[i] == "INT" || ret_type[i] == "DBL") {
  1310. printf("t%s %s;n", 
  1311.     retc_type[i], retargs[i]) >> TFILE
  1312. } else if (ret_type[i] == "LIST") {
  1313. if (retlist_type[i] == "STRING")
  1314. printf("tchar **__db_%slist;n", 
  1315.     retargs[i]) >> TFILE
  1316. if (retlist_type[i] == "ID" ||
  1317.     retlist_type[i] == "INT")
  1318. printf("tu_int32_t *__db_%slist;n", 
  1319.     retargs[i]) >> TFILE
  1320. } else {
  1321. printf("t/* %s %s; */n", 
  1322.     ret_type[i], retargs[i]) >> TFILE
  1323. }
  1324. }
  1325. #
  1326. # Client return code
  1327. #
  1328. printf("n") >> TFILE
  1329. printf("tif (replyp->status != 0)n") >> TFILE
  1330. printf("ttreturn (replyp->status);n") >> TFILE
  1331. for (i = 0; i < rvars; ++i) {
  1332. varname = "";
  1333. if (ret_type[i] == "ID") {
  1334. varname = sprintf("%scl_id", retargs[i]);
  1335. }
  1336. if (ret_type[i] == "STRING") {
  1337. varname =  retargs[i];
  1338. }
  1339. if (ret_type[i] == "INT" || ret_type[i] == "DBL") {
  1340. varname =  retargs[i];
  1341. }
  1342. if (ret_type[i] == "DBT") {
  1343. varname = sprintf("%sdata", retargs[i]);
  1344. }
  1345. if (ret_type[i] == "ID" || ret_type[i] == "STRING" ||
  1346.     ret_type[i] == "INT" || ret_type[i] == "DBL") {
  1347. printf("t%s = replyp->%s;n", 
  1348.     retargs[i], varname) >> TFILE
  1349. } else if (ret_type[i] == "LIST") {
  1350. printf("ntif ((ret = __db_%s_%slist(", 
  1351.     name, retargs[i]) >> TFILE
  1352. printf("replyp->%slist, &__db_%slist)) != 0)", 
  1353.     retargs[i], retargs[i]) >> TFILE
  1354. printf("nttreturn (ret);n") >> TFILE
  1355. printf("nt/*n") >> TFILE
  1356. printf("t * XXX Handle listn") >> TFILE
  1357. printf("t */nn") >> TFILE
  1358. printf("t__db_%s_%sfree(__db_%slist);n", 
  1359.     name, retargs[i], retargs[i]) >> TFILE
  1360. } else {
  1361. printf("t/* Handle replyp->%s; */n", 
  1362.     varname) >> TFILE
  1363. }
  1364. }
  1365. printf("nt/*nt * XXX Code goes herent */nn") >> TFILE
  1366. printf("treturn (replyp->status);n") >> TFILE
  1367. printf("}nn") >> TFILE
  1368. #
  1369. # If we are doing a list, write list functions for this op.
  1370. #
  1371. for (i = 0; i < rvars; ++i) {
  1372. if (ret_type[i] != "LIST")
  1373. continue;
  1374. if (retlist_type[i] != "STRING" &&
  1375.     retlist_type[i] != "INT" && list_type[i] != "ID")
  1376. continue;
  1377. printf("intn") >> TFILE
  1378. printf("__db_%s_%sreplist(locp, ppp)n", 
  1379.     name, retargs[i]) >> TFILE
  1380. printf("t__%s_%sreplist *locp;n", 
  1381.     name, retargs[i]) >> TFILE
  1382. if (retlist_type[i] == "STRING") {
  1383. printf("tchar ***ppp;n{n") >> TFILE
  1384. printf("tchar **pp;n") >> TFILE
  1385. }
  1386. if (retlist_type[i] == "INT" ||
  1387.     retlist_type[i] == "ID") {
  1388. printf("tu_int32_t **ppp;n{n") >> TFILE
  1389. printf("tu_int32_t *pp;n") >> TFILE
  1390. }
  1392. printf("tint cnt, ret, size;n") >> TFILE
  1393. printf("t__%s_%sreplist *nl;nn", 
  1394.     name, retargs[i]) >> TFILE
  1395. printf("tfor (cnt = 0, nl = locp; ") >> TFILE
  1396. printf("nl != NULL; cnt++, nl = nl->next)ntt;nn") 
  1397.     >> TFILE
  1398. printf("tif (cnt == 0) {n") >> TFILE
  1399. printf("tt*ppp = NULL;n") >> TFILE
  1400. printf("ttreturn (0);nt}n") >> TFILE
  1401. printf("tsize = sizeof(*pp) * cnt;n") >> TFILE
  1402. printf("tif ((ret = __os_malloc(NULL, ") >> TFILE
  1403. printf("size, NULL, ppp)) != 0)n") >> TFILE
  1404. printf("ttreturn (ret);n") >> TFILE
  1405. printf("tmemset(*ppp, 0, size);n") >> TFILE
  1406. printf("tfor (pp = *ppp, nl = locp; ") >> TFILE
  1407. printf("nl != NULL; nl = nl->next, pp++) {n") >> TFILE
  1408. if (retlist_type[i] == "STRING") {
  1409. printf("ttif ((ret = __os_malloc(NULL, ") 
  1410.     >> TFILE
  1411. printf("nl->ent.ent_len + 1, NULL,") >> TFILE
  1412. printf(" pp)) != 0)n") >> TFILE
  1413. printf("tttgoto out;n") >> TFILE
  1414. printf("ttif ((ret = __os_strdup(") >> TFILE
  1415. printf("NULL, (char *)nl->ent.ent_val,") 
  1416.     >> TFILE
  1417. printf(" pp)) != 0)n") >> TFILE
  1418. printf("tttgoto out;n") >> TFILE
  1419. }
  1420. if (retlist_type[i] == "INT" ||
  1421.     retlist_type[i] == "ID") {
  1422. printf("tt*pp = *(u_int32_t *)") >> TFILE
  1423. printf("nl->ent.ent_val;n") >> TFILE
  1424. }
  1425. printf("t}n") >> TFILE
  1426. printf("treturn (0);n") >> TFILE
  1427. printf("out:n") >> TFILE
  1428. printf("t__db_%s_%sfree(*ppp);n", 
  1429.     name, retargs[i]) >> TFILE
  1430. printf("treturn (ret);n") >> TFILE
  1431. printf("}nn") >> TFILE
  1433. printf("voidn") >> TFILE
  1434. printf("__db_%s_%sfree(pp)n", 
  1435.     name, retargs[i]) >> TFILE
  1437. if (retlist_type[i] == "STRING")
  1438. printf("tchar **pp;n") >> TFILE
  1439. if (retlist_type[i] == "INT" || retlist_type[i] == "ID")
  1440. printf("tu_int32_t *pp;n") >> TFILE
  1442. printf("{n") >> TFILE
  1443. printf("tsize_t size;n") >> TFILE
  1445. if (retlist_type[i] == "STRING")
  1446. printf("tchar **p;nn") >> TFILE
  1447. if (retlist_type[i] == "INT" || retlist_type[i] == "ID")
  1448. printf("tu_int32_t *p;nn") >> TFILE
  1450. printf("tif (pp == NULL)nttreturn;n") >> TFILE
  1451. printf("tsize = sizeof(*p);n") >> TFILE
  1452. printf("tfor (p = pp; *p != 0; p++) {n") >> TFILE
  1453. printf("ttsize += sizeof(*p);n") >> TFILE
  1455. if (retlist_type[i] == "STRING")
  1456. printf("tt__os_free(*p, strlen(*p)+1);n") 
  1457.     >> TFILE
  1458. printf("t}n") >> TFILE
  1459. printf("t__os_free(pp, size);n") >> TFILE
  1460. printf("}nn") >> TFILE
  1461. }
  1462. }
  1463. }
  1465. #
  1466. # split_lines --
  1467. # Add line separators to pretty-print the output.
  1468. function split_lines(is_public) {
  1469. if (argcount > 3) {
  1470. # Reset the counter, remove any trailing whitespace from
  1471. # the separator.
  1472. argcount = 0;
  1473. sub("[  ]$", "", sep)
  1475. if (is_public) {
  1476. printf("%snt", sep) >> SHFILE
  1477. } else {
  1478. printf("%sntt", sep) >> PFILE
  1479. printf("%s\n\t\t", sep) >> SEDFILE
  1480. }
  1481. }
  1482. }