3 # Awk script for generating client/server RPC code.
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).
10 # This awk script requires that these variables be set when it is called:
12 # major -- Major version number
13 # minor -- Minor version number
14 # gidsize -- size of GIDs
15 # client_file -- the C source file being created for client code
16 # ctmpl_file -- the C template file being created for client code
17 # server_file -- the C source file being created for server code
18 # stmpl_file -- the C template file being created for server code
19 # xdr_file -- the XDR message file created
21 # And stdin must be the input file that defines the RPC setup.
23 if (major == "" || minor == "" || gidsize == "" ||
24 client_file == "" || ctmpl_file == "" ||
25 server_file == "" || stmpl_file == "" || xdr_file == "") {
26 print "Usage: gen_rpc.awk requires these variables be set:"
27 print "\tmajor\t-- Major version number"
28 print "\tminor\t-- Minor version number"
29 print "\tgidsize\t-- GID size"
30 print "\tclient_file\t-- the client C source file being created"
31 print "\tctmpl_file\t-- the client template file being created"
32 print "\tserver_file\t-- the server C source file being created"
33 print "\tstmpl_file\t-- the server template file being created"
34 print "\txdr_file\t-- the XDR message file being created"
40 printf("/* Do not edit: automatically built by gen_rpc.awk. */\n") \
44 printf("/* Do not edit: automatically built by gen_rpc.awk. */\n") \
48 printf("/* Do not edit: automatically built by gen_rpc.awk. */\n") \
51 # Server procedure template.
54 printf("/* Do not edit: automatically built by gen_rpc.awk. */\n") \
61 # Put out the actual illegal and no-server functions.
62 illegal_functions(CFILE)
66 printf("program DB_RPC_SERVERPROG {\n") >> XFILE
67 printf("\tversion DB_RPC_SERVERVERS {\n") >> XFILE
69 for (i = 1; i < nendlist; ++i)
70 printf("\t\t%s;\n", endlist[i]) >> XFILE
72 printf("\t} = %d%03d;\n", major, minor) >> XFILE
73 printf("} = 351457;\n") >> XFILE
75 obj_init("DB", "dbp", obj_db, CFILE)
76 obj_init("DBC", "dbc", obj_dbc, CFILE)
77 obj_init("DB_ENV", "dbenv", obj_dbenv, CFILE)
78 obj_init("DB_TXN", "txn", obj_txn, CFILE)
83 # LOCAL methods are ones where we don't override the handle
84 # method for RPC, nor is it illegal -- it's just satisfied
91 # NOFUNC methods are illegal on the RPC client.
93 obj_illegal(obj_db, "dbp", $2, $3)
94 else if ($2 ~ "^dbc_")
95 obj_illegal(obj_dbc, "dbc", $2, $3)
96 else if ($2 ~ "^env_")
97 obj_illegal(obj_dbenv, "dbenv", $2, $3)
98 else if ($2 ~ "^txn_")
99 obj_illegal(obj_txn, "txn", $2, $3)
101 print "unexpected handle prefix: " $2
110 link_only = ret_code = 0
111 if ($3 == "LINKONLY")
113 else if ($3 == "RETCODE")
130 rpc_type[nvars] = $2;
135 if (rpc_type[nvars] == "LIST") {
136 list_type[nvars] = $5;
138 list_type[nvars] = 0;
140 if (c_type[nvars] == "DBT *")
142 else if (c_type[nvars] == "DB_ENV *") {
143 ctp_type[nvars] = "CT_ENV";
148 obj_func("dbenv", obj_dbenv);
149 } else if (c_type[nvars] == "DB *") {
150 ctp_type[nvars] = "CT_DB";
151 if (db_handle != 1) {
157 obj_func("dbp", obj_db);
158 } else if (c_type[nvars] == "DBC *") {
159 ctp_type[nvars] = "CT_CURSOR";
164 obj_func("dbc", obj_dbc);
165 } else if (c_type[nvars] == "DB_TXN *") {
166 ctp_type[nvars] = "CT_TXN";
171 obj_func("txn", obj_txn);
180 rpc_type[nvars] = "IGNORE";
182 args[nvars] = sprintf("func%d", funcvars);
188 ret_type[rvars] = $2;
189 retc_type[rvars] = $3;
191 if (ret_type[rvars] == "LIST" || ret_type[rvars] == "DBT") {
194 if (ret_type[rvars] == "LIST") {
195 retlist_type[rvars] = $5;
197 retlist_type[rvars] = 0;
198 ret_isarg[rvars] = 0;
203 ret_type[rvars] = $2;
204 rpc_type[nvars] = "IGNORE";
205 retc_type[rvars] = $3;
206 c_type[nvars] = sprintf("%s *", $3);
207 pr_type[nvars] = c_type[nvars];
209 args[nvars] = sprintf("%sp", $4);
210 if (ret_type[rvars] == "LIST" || ret_type[rvars] == "DBT") {
214 if (ret_type[nvars] == "LIST") {
215 retlist_type[rvars] = $5;
216 list_type[nvars] = $5;
218 retlist_type[rvars] = 0;
219 list_type[nvars] = 0;
221 ret_isarg[rvars] = 1;
228 # =====================================================
229 # LINKONLY -- just reference the function, that's all.
235 # =====================================================
238 printf("\n") >> XFILE
239 printf("struct __%s_msg {\n", name) >> XFILE
240 for (i = 0; i < nvars; ++i) {
241 if (rpc_type[i] == "LIST") {
242 if (list_type[i] == "GID") {
243 printf("\topaque %s<>;\n", args[i]) >> XFILE
245 printf("\tunsigned int %s<>;\n", args[i]) >> XFILE
248 if (rpc_type[i] == "ID") {
249 printf("\tunsigned int %scl_id;\n", args[i]) >> XFILE
251 if (rpc_type[i] == "STRING") {
252 printf("\tstring %s<>;\n", args[i]) >> XFILE
254 if (rpc_type[i] == "GID") {
255 printf("\topaque %s[%d];\n", args[i], gidsize) >> XFILE
257 if (rpc_type[i] == "INT") {
258 printf("\tunsigned int %s;\n", args[i]) >> XFILE
260 if (rpc_type[i] == "DBT") {
261 printf("\tunsigned int %sdlen;\n", args[i]) >> XFILE
262 printf("\tunsigned int %sdoff;\n", args[i]) >> XFILE
263 printf("\tunsigned int %sulen;\n", args[i]) >> XFILE
264 printf("\tunsigned int %sflags;\n", args[i]) >> XFILE
265 printf("\topaque %sdata<>;\n", args[i]) >> XFILE
268 printf("};\n") >> XFILE
270 printf("\n") >> XFILE
272 # Generate the reply message
274 printf("struct __%s_reply {\n", name) >> XFILE
275 printf("\t/* num return vars: %d */\n", rvars) >> XFILE
276 printf("\tint status;\n") >> XFILE
277 for (i = 0; i < rvars; ++i) {
278 if (ret_type[i] == "ID") {
279 printf("\tunsigned int %scl_id;\n", retargs[i]) >> XFILE
281 if (ret_type[i] == "STRING") {
282 printf("\tstring %s<>;\n", retargs[i]) >> XFILE
284 if (ret_type[i] == "INT") {
285 printf("\tunsigned int %s;\n", retargs[i]) >> XFILE
287 if (ret_type[i] == "DBL") {
288 printf("\tdouble %s;\n", retargs[i]) >> XFILE
290 if (ret_type[i] == "DBT") {
291 printf("\topaque %sdata<>;\n", retargs[i]) >> XFILE
293 if (ret_type[i] == "LIST") {
294 if (retlist_type[i] == "GID") {
295 printf("\topaque %s<>;\n", retargs[i]) >> XFILE
297 printf("\tunsigned int %s<>;\n", retargs[i]) >> XFILE
301 printf("};\n") >> XFILE
303 endlist[nendlist] = \
304 sprintf("__%s_reply __DB_%s(__%s_msg) = %d", \
305 name, name, name, nendlist);
308 # =====================================================
311 # First spit out PUBLIC prototypes for server functions.
313 printf("__%s_reply *\n", name) >> SFILE
314 printf("__db_%s_%d%03d__SVCSUFFIX__(msg, req)\n", \
315 name, major, minor) >> SFILE
316 printf("\t__%s_msg *msg;\n", name) >> SFILE;
317 printf("\tstruct svc_req *req;\n", name) >> SFILE;
318 printf("{\n") >> SFILE
319 printf("\tstatic __%s_reply reply; /* must be static */\n", \
322 printf("\tstatic int __%s_free = 0; /* must be static */\n\n", \
325 printf("\tCOMPQUIET(req, NULL);\n", name) >> SFILE
327 printf("\tif (__%s_free)\n", name) >> SFILE
328 printf("\t\txdr_free((xdrproc_t)xdr___%s_reply, (void *)&reply);\n", \
330 printf("\t__%s_free = 0;\n", name) >> SFILE
331 printf("\n\t/* Reinitialize allocated fields */\n") >> SFILE
332 for (i = 0; i < rvars; ++i) {
333 if (ret_type[i] == "LIST") {
334 printf("\treply.%s.%s_val = NULL;\n", \
335 retargs[i], retargs[i]) >> SFILE
337 if (ret_type[i] == "DBT") {
338 printf("\treply.%sdata.%sdata_val = NULL;\n", \
339 retargs[i], retargs[i]) >> SFILE
346 # Compose server proc to call. Decompose message components as args.
348 printf("\n\t__%s_proc(", name) >> SFILE
350 for (i = 0; i < nvars; ++i) {
351 if (rpc_type[i] == "IGNORE") {
354 if (rpc_type[i] == "ID") {
355 printf("%smsg->%scl_id", sep, args[i]) >> SFILE
357 if (rpc_type[i] == "STRING") {
358 printf("%s(*msg->%s == '\\0') ? NULL : msg->%s", \
359 sep, args[i], args[i]) >> SFILE
361 if (rpc_type[i] == "GID") {
362 printf("%s(u_int8_t *)msg->%s", sep, args[i]) >> SFILE
364 if (rpc_type[i] == "INT") {
365 printf("%smsg->%s", sep, args[i]) >> SFILE
367 if (rpc_type[i] == "LIST") {
368 printf("%smsg->%s.%s_val", \
369 sep, args[i], args[i]) >> SFILE
370 printf("%smsg->%s.%s_len", \
371 sep, args[i], args[i]) >> SFILE
373 if (rpc_type[i] == "DBT") {
374 printf("%smsg->%sdlen", sep, args[i]) >> SFILE
376 printf("%smsg->%sdoff", sep, args[i]) >> SFILE
377 printf("%smsg->%sulen", sep, args[i]) >> SFILE
378 printf("%smsg->%sflags", sep, args[i]) >> SFILE
379 printf("%smsg->%sdata.%sdata_val", \
380 sep, args[i], args[i]) >> SFILE
381 printf("%smsg->%sdata.%sdata_len", \
382 sep, args[i], args[i]) >> SFILE
386 printf("%s&reply", sep) >> SFILE
388 printf("%s&__%s_free);\n", sep, name) >> SFILE
390 printf(");\n\n") >> SFILE
392 printf("\nout:\n") >> SFILE
394 printf("\treturn (&reply);\n") >> SFILE
395 printf("}\n\n") >> SFILE
398 # =====================================================
399 # Generate Procedure Template Server code
401 # Spit out comment, prototype, function name and arg list.
402 printf("/* BEGIN __%s_proc */\n", name) >> PFILE
405 p[pi++] = sprintf("void __%s_proc __P((", name);
407 for (i = 0; i < nvars; ++i) {
408 if (rpc_type[i] == "IGNORE")
410 if (rpc_type[i] == "ID") {
414 if (rpc_type[i] == "STRING") {
418 if (rpc_type[i] == "GID") {
419 p[pi++] = "u_int8_t *";
422 if (rpc_type[i] == "INT") {
423 p[pi++] = "u_int32_t";
426 if (rpc_type[i] == "INTRET") {
427 p[pi++] = "u_int32_t *";
430 if (rpc_type[i] == "LIST" && list_type[i] == "GID") {
431 p[pi++] = "u_int8_t *";
433 p[pi++] = "u_int32_t";
436 if (rpc_type[i] == "LIST" && list_type[i] == "INT") {
437 p[pi++] = "u_int32_t *";
439 p[pi++] = "u_int32_t";
442 if (rpc_type[i] == "LIST" && list_type[i] == "ID") {
443 p[pi++] = "u_int32_t *";
445 p[pi++] = "u_int32_t";
448 if (rpc_type[i] == "DBT") {
449 p[pi++] = "u_int32_t";
451 p[pi++] = "u_int32_t";
453 p[pi++] = "u_int32_t";
455 p[pi++] = "u_int32_t";
459 p[pi++] = "u_int32_t";
463 p[pi++] = sprintf("__%s_reply *", name);
466 p[pi++] = "int *));";
473 printf("void\n") >> PFILE
474 printf("__%s_proc(", name) >> PFILE
477 for (i = 0; i < nvars; ++i) {
483 if (rpc_type[i] == "IGNORE")
485 if (rpc_type[i] == "ID") {
486 printf("%s%scl_id", sep, args[i]) >> PFILE
488 if (rpc_type[i] == "STRING") {
489 printf("%s%s", sep, args[i]) >> PFILE
491 if (rpc_type[i] == "GID") {
492 printf("%s%s", sep, args[i]) >> PFILE
494 if (rpc_type[i] == "INT") {
495 printf("%s%s", sep, args[i]) >> PFILE
497 if (rpc_type[i] == "INTRET") {
498 printf("%s%s", sep, args[i]) >> PFILE
500 if (rpc_type[i] == "LIST") {
501 printf("%s%s", sep, args[i]) >> PFILE
509 printf("%s%slen", sep, args[i]) >> PFILE
511 if (rpc_type[i] == "DBT") {
512 printf("%s%sdlen", sep, args[i]) >> PFILE
521 printf("%s%sdoff", sep, args[i]) >> PFILE
529 printf("%s%sulen", sep, args[i]) >> PFILE
537 printf("%s%sflags", sep, args[i]) >> PFILE
545 printf("%s%sdata", sep, args[i]) >> PFILE
553 printf("%s%ssize", sep, args[i]) >> PFILE
557 printf("%sreplyp",sep) >> PFILE
559 printf("%sfreep)\n",sep) >> PFILE
561 printf(")\n") >> PFILE
564 # Spit out arg types/names;
566 for (i = 0; i < nvars; ++i) {
567 if (rpc_type[i] == "ID") {
568 printf("\tunsigned int %scl_id;\n", args[i]) >> PFILE
570 if (rpc_type[i] == "STRING") {
571 printf("\tchar *%s;\n", args[i]) >> PFILE
573 if (rpc_type[i] == "GID") {
574 printf("\tu_int8_t *%s;\n", args[i]) >> PFILE
576 if (rpc_type[i] == "INT") {
577 printf("\tu_int32_t %s;\n", args[i]) >> PFILE
579 if (rpc_type[i] == "LIST" && list_type[i] == "GID") {
580 printf("\tu_int8_t * %s;\n", args[i]) >> PFILE
582 if (rpc_type[i] == "LIST" && list_type[i] == "INT") {
583 printf("\tu_int32_t * %s;\n", args[i]) >> PFILE
584 printf("\tu_int32_t %ssize;\n", args[i]) >> PFILE
586 if (rpc_type[i] == "LIST" && list_type[i] == "ID") {
587 printf("\tu_int32_t * %s;\n", args[i]) >> PFILE
589 if (rpc_type[i] == "LIST") {
590 printf("\tu_int32_t %slen;\n", args[i]) >> PFILE
592 if (rpc_type[i] == "DBT") {
593 printf("\tu_int32_t %sdlen;\n", args[i]) >> PFILE
594 printf("\tu_int32_t %sdoff;\n", args[i]) >> PFILE
595 printf("\tu_int32_t %sulen;\n", args[i]) >> PFILE
596 printf("\tu_int32_t %sflags;\n", args[i]) >> PFILE
597 printf("\tvoid *%sdata;\n", args[i]) >> PFILE
598 printf("\tu_int32_t %ssize;\n", args[i]) >> PFILE
601 printf("\t__%s_reply *replyp;\n",name) >> PFILE
603 printf("\tint * freep;\n") >> PFILE
606 printf("/* END __%s_proc */\n", name) >> PFILE
611 printf("{\n") >> PFILE
612 printf("\tint ret;\n") >> PFILE
613 for (i = 0; i < nvars; ++i) {
614 if (rpc_type[i] == "ID") {
615 printf("\t%s %s;\n", c_type[i], args[i]) >> PFILE
616 printf("\tct_entry *%s_ctp;\n", args[i]) >> PFILE
619 printf("\n") >> PFILE
620 for (i = 0; i < nvars; ++i) {
621 if (rpc_type[i] == "ID") {
622 printf("\tACTIVATE_CTP(%s_ctp, %scl_id, %s);\n", \
623 args[i], args[i], ctp_type[i]) >> PFILE
624 printf("\t%s = (%s)%s_ctp->ct_anyp;\n", \
625 args[i], c_type[i], args[i]) >> PFILE
628 printf("\n\t/*\n\t * XXX Code goes here\n\t */\n\n") >> PFILE
629 printf("\treplyp->status = ret;\n") >> PFILE
630 printf("\treturn;\n") >> PFILE
631 printf("}\n\n") >> PFILE
634 # =====================================================
635 # Generate Client code
637 # Spit out PUBLIC prototypes.
641 p[pi++] = sprintf("int __dbcl_%s __P((", name);
643 for (i = 0; i < nvars; ++i) {
644 p[pi++] = pr_type[i];
649 proto_format(p, CFILE);
652 # Spit out function name/args.
654 printf("int\n") >> CFILE
655 printf("__dbcl_%s(", name) >> CFILE
657 for (i = 0; i < nvars; ++i) {
658 printf("%s%s", sep, args[i]) >> CFILE
661 printf(")\n") >> CFILE
663 for (i = 0; i < nvars; ++i)
664 if (func_arg[i] == 0)
665 printf("\t%s %s;\n", c_type[i], args[i]) >> CFILE
667 printf("\t%s;\n", c_type[i]) >> CFILE
669 printf("{\n") >> CFILE
670 printf("\tCLIENT *cl;\n") >> CFILE
671 printf("\t__%s_msg msg;\n", name) >> CFILE
672 printf("\t__%s_reply *replyp = NULL;\n", name) >> CFILE;
673 printf("\tint ret;\n") >> CFILE
675 printf("\tDB_ENV *dbenv;\n") >> CFILE
677 # If we are managing a list, we need a few more vars.
679 for (i = 0; i < nvars; ++i) {
680 if (rpc_type[i] == "LIST") {
681 printf("\t%s %sp;\n", c_type[i], args[i]) >> CFILE
682 printf("\tint %si;\n", args[i]) >> CFILE
683 if (list_type[i] == "GID")
684 printf("\tu_int8_t ** %sq;\n", args[i]) >> CFILE
686 printf("\tu_int32_t * %sq;\n", args[i]) >> CFILE
690 printf("\n") >> CFILE
691 printf("\tret = 0;\n") >> CFILE
694 printf("\tdbenv = %s->dbenv;\n", args[db_idx]) >> CFILE
696 printf("\tdbenv = %s->dbenv;\n", \
697 args[dbc_idx]) >> CFILE
699 printf("\tdbenv = %s->mgrp->env->dbenv;\n", \
700 args[txn_idx]) >> CFILE
702 printf("\tdbenv = NULL;\n") >> CFILE
703 printf("\tif (dbenv == NULL || !RPC_ON(dbenv))\n") >> CFILE
704 printf("\t\treturn (__dbcl_noserver(NULL));\n") >> CFILE
706 printf("\tif (%s == NULL || !RPC_ON(%s))\n", \
707 args[env_idx], args[env_idx]) >> CFILE
708 printf("\t\treturn (__dbcl_noserver(%s));\n", \
709 args[env_idx]) >> CFILE
711 printf("\n") >> CFILE
713 printf("\tcl = (CLIENT *)%s->cl_handle;\n\n", \
714 env_handle ? args[env_idx] : "dbenv") >> CFILE
717 # If there is a function arg, check that it is NULL
719 for (i = 0; i < nvars; ++i) {
720 if (func_arg[i] != 1)
722 printf("\tif (%s != NULL) {\n", args[i]) >> CFILE
724 printf("\t\t__db_errx(dbenv->env, ") >> CFILE
727 "\t\t__db_errx(%s->env, ", args[env_idx]) >> CFILE
729 printf("\"User functions not supported in RPC\");\n") >> CFILE
730 printf("\t\treturn (EINVAL);\n\t}\n") >> CFILE
734 # Compose message components
736 for (i = 0; i < nvars; ++i) {
737 if (rpc_type[i] == "ID") {
738 # We don't need to check for a NULL DB_ENV *, because
739 # we already checked for it. I frankly couldn't care
740 # less, but lint gets all upset at the wasted cycles.
741 if (c_type[i] != "DB_ENV *") {
742 printf("\tif (%s == NULL)\n", args[i]) >> CFILE
743 printf("\t\tmsg.%scl_id = 0;\n\telse\n", \
748 if (c_type[i] == "DB_TXN *") {
749 printf("%smsg.%scl_id = %s->txnid;\n", \
750 indent, args[i], args[i]) >> CFILE
752 printf("%smsg.%scl_id = %s->cl_id;\n", \
753 indent, args[i], args[i]) >> CFILE
756 if (rpc_type[i] == "GID") {
757 printf("\tmemcpy(msg.%s, %s, %d);\n", \
758 args[i], args[i], gidsize) >> CFILE
760 if (rpc_type[i] == "INT") {
761 printf("\tmsg.%s = (u_int)%s;\n",
762 args[i], args[i]) >> CFILE
764 if (rpc_type[i] == "STRING") {
765 printf("\tif (%s == NULL)\n", args[i]) >> CFILE
766 printf("\t\tmsg.%s = \"\";\n", args[i]) >> CFILE
767 printf("\telse\n") >> CFILE
768 printf("\t\tmsg.%s = (char *)%s;\n", \
769 args[i], args[i]) >> CFILE
771 if (rpc_type[i] == "DBT") {
772 printf("\tmsg.%sdlen = %s->dlen;\n", \
773 args[i], args[i]) >> CFILE
774 printf("\tmsg.%sdoff = %s->doff;\n", \
775 args[i], args[i]) >> CFILE
776 printf("\tmsg.%sulen = %s->ulen;\n", \
777 args[i], args[i]) >> CFILE
778 printf("\tmsg.%sflags = %s->flags;\n", \
779 args[i], args[i]) >> CFILE
780 printf("\tmsg.%sdata.%sdata_val = %s->data;\n", \
781 args[i], args[i], args[i]) >> CFILE
782 printf("\tmsg.%sdata.%sdata_len = %s->size;\n", \
783 args[i], args[i], args[i]) >> CFILE
785 if (rpc_type[i] == "LIST") {
786 printf("\tfor (%si = 0, %sp = %s; *%sp != 0; ", \
787 args[i], args[i], args[i], args[i]) >> CFILE
788 printf(" %si++, %sp++)\n\t\t;\n", args[i], args[i]) \
792 # If we are an array of ints, *_len is how many
793 # elements. If we are a GID, *_len is total bytes.
795 printf("\tmsg.%s.%s_len = (u_int)%si",
796 args[i], args[i], args[i]) >> CFILE
797 if (list_type[i] == "GID")
798 printf(" * %d;\n", gidsize) >> CFILE
800 printf(";\n") >> CFILE
801 printf("\tif ((ret = __os_calloc(") >> CFILE
803 printf("dbenv->env,\n") >> CFILE
805 printf("%s->env,\n", args[env_idx]) >> CFILE
806 printf("\t msg.%s.%s_len,", \
807 args[i], args[i]) >> CFILE
808 if (list_type[i] == "GID")
809 printf(" 1,") >> CFILE
811 printf(" sizeof(u_int32_t),") >> CFILE
812 printf(" &msg.%s.%s_val)) != 0)\n",\
813 args[i], args[i], args[i], args[i]) >> CFILE
814 printf("\t\treturn (ret);\n") >> CFILE
815 printf("\tfor (%sq = msg.%s.%s_val, %sp = %s; ", \
816 args[i], args[i], args[i], \
817 args[i], args[i]) >> CFILE
818 printf("%si--; %sq++, %sp++)\n", \
819 args[i], args[i], args[i]) >> CFILE
820 printf("\t\t*%sq = ", args[i]) >> CFILE
821 if (list_type[i] == "GID")
822 printf("*%sp;\n", args[i]) >> CFILE
823 if (list_type[i] == "ID")
824 printf("(*%sp)->cl_id;\n", args[i]) >> CFILE
825 if (list_type[i] == "INT")
826 printf("*%sp;\n", args[i]) >> CFILE
830 printf("\n") >> CFILE
831 printf("\treplyp = __db_%s_%d%03d(&msg, cl);\n", name, major, minor) \
833 for (i = 0; i < nvars; ++i)
834 if (rpc_type[i] == "LIST")
835 printf("\t__os_free(%s->env, msg.%s.%s_val);\n",
836 env_handle ? args[env_idx] : "dbenv",
837 args[i], args[i]) >> CFILE
839 printf("\tif (replyp == NULL) {\n") >> CFILE
840 printf("\t\t__db_errx(%s->env, clnt_sperror(cl, \"Berkeley DB\"));\n",
841 env_handle ? args[env_idx] : "dbenv") >> CFILE
843 printf("\t\tret = DB_NOSERVER;\n") >> CFILE
844 printf("\t\tgoto out;\n") >> CFILE
845 printf("\t}\n") >> CFILE
848 printf("\tret = replyp->status;\n") >> CFILE
851 # Set any arguments that are returned
853 for (i = 0; i < rvars; ++i) {
855 printf("\tif (%sp != NULL)\n",
856 retargs[i]) >> CFILE;
857 printf("\t\t*%sp = (%s)replyp->%s;\n",
859 retc_type[i], retargs[i]) >> CFILE;
863 printf("\tret = __dbcl_%s_ret(", name) >> CFILE
865 for (i = 0; i < nvars; ++i) {
866 printf("%s%s", sep, args[i]) >> CFILE
869 printf("%sreplyp);\n", sep) >> CFILE
871 printf("out:\n") >> CFILE
873 # Free reply if there was one.
875 printf("\tif (replyp != NULL)\n") >> CFILE
876 printf("\t\txdr_free((xdrproc_t)xdr___%s_reply,",name) >> CFILE
877 printf(" (void *)replyp);\n") >> CFILE
878 printf("\treturn (ret);\n") >> CFILE
879 printf("}\n\n") >> CFILE
882 # Generate Client Template code
886 # If we are doing a list, write prototypes
890 p[pi++] = sprintf("int __dbcl_%s_ret __P((", name);
892 for (i = 0; i < nvars; ++i) {
893 p[pi++] = pr_type[i];
896 p[pi] = sprintf("__%s_reply *));", name);
897 proto_format(p, TFILE);
899 printf("int\n") >> TFILE
900 printf("__dbcl_%s_ret(", name) >> TFILE
902 for (i = 0; i < nvars; ++i) {
903 printf("%s%s", sep, args[i]) >> TFILE
906 printf("%sreplyp)\n",sep) >> TFILE
908 for (i = 0; i < nvars; ++i)
909 if (func_arg[i] == 0)
910 printf("\t%s %s;\n", c_type[i], args[i]) \
913 printf("\t%s;\n", c_type[i]) >> TFILE
914 printf("\t__%s_reply *replyp;\n", name) >> TFILE;
915 printf("{\n") >> TFILE
916 printf("\tint ret;\n") >> TFILE
918 # Local vars in template
920 for (i = 0; i < rvars; ++i) {
921 if (ret_type[i] == "ID" || ret_type[i] == "STRING" ||
922 ret_type[i] == "INT" || ret_type[i] == "DBL") {
923 printf("\t%s %s;\n", \
924 retc_type[i], retargs[i]) >> TFILE
925 } else if (ret_type[i] == "LIST") {
926 if (retlist_type[i] == "GID")
927 printf("\tu_int8_t *__db_%s;\n", \
929 if (retlist_type[i] == "ID" ||
930 retlist_type[i] == "INT")
931 printf("\tu_int32_t *__db_%s;\n", \
934 printf("\t/* %s %s; */\n", \
935 ret_type[i], retargs[i]) >> TFILE
941 printf("\n") >> TFILE
942 printf("\tif (replyp->status != 0)\n") >> TFILE
943 printf("\t\treturn (replyp->status);\n") >> TFILE
944 for (i = 0; i < rvars; ++i) {
946 if (ret_type[i] == "ID") {
947 varname = sprintf("%scl_id", retargs[i]);
949 if (ret_type[i] == "STRING") {
950 varname = retargs[i];
952 if (ret_type[i] == "INT" || ret_type[i] == "DBL") {
953 varname = retargs[i];
955 if (ret_type[i] == "DBT") {
956 varname = sprintf("%sdata", retargs[i]);
958 if (ret_type[i] == "ID" || ret_type[i] == "STRING" ||
959 ret_type[i] == "INT" || ret_type[i] == "DBL") {
960 printf("\t%s = replyp->%s;\n", \
961 retargs[i], varname) >> TFILE
962 } else if (ret_type[i] == "LIST") {
963 printf("\n\t/*\n") >> TFILE
964 printf("\t * XXX Handle list\n") >> TFILE
965 printf("\t */\n\n") >> TFILE
967 printf("\t/* Handle replyp->%s; */\n", \
971 printf("\n\t/*\n\t * XXX Code goes here\n\t */\n\n") >> TFILE
972 printf("\treturn (replyp->status);\n") >> TFILE
973 printf("}\n\n") >> TFILE
977 function general_headers()
979 printf("#include \"db_config.h\"\n") >> CFILE
980 printf("\n") >> CFILE
981 printf("#include \"db_int.h\"\n") >> CFILE
982 printf("#ifdef HAVE_SYSTEM_INCLUDE_FILES\n") >> CFILE
983 printf("#include <rpc/rpc.h>\n") >> CFILE
984 printf("#endif\n") >> CFILE
985 printf("#include \"db_server.h\"\n") >> CFILE
986 printf("#include \"dbinc/txn.h\"\n") >> CFILE
987 printf("#include \"dbinc_auto/rpc_client_ext.h\"\n") >> CFILE
988 printf("\n") >> CFILE
990 printf("#include \"db_config.h\"\n") >> TFILE
991 printf("\n") >> TFILE
992 printf("#include \"db_int.h\"\n") >> TFILE
993 printf("#include \"dbinc/txn.h\"\n") >> TFILE
994 printf("\n") >> TFILE
996 printf("#include \"db_config.h\"\n") >> SFILE
997 printf("\n") >> SFILE
998 printf("#include \"db_int.h\"\n") >> SFILE
999 printf("#ifdef HAVE_SYSTEM_INCLUDE_FILES\n") >> SFILE
1000 printf("#include <rpc/rpc.h>\n") >> SFILE
1001 printf("#endif\n") >> SFILE
1002 printf("#include \"db_server.h\"\n") >> SFILE
1003 printf("#include \"dbinc/db_server_int.h\"\n") >> SFILE
1004 printf("#include \"dbinc_auto/rpc_server_ext.h\"\n") >> SFILE
1005 printf("\n") >> SFILE
1007 printf("#include \"db_config.h\"\n") >> PFILE
1008 printf("\n") >> PFILE
1009 printf("#include \"db_int.h\"\n") >> PFILE
1010 printf("#ifdef HAVE_SYSTEM_INCLUDE_FILES\n") >> PFILE
1011 printf("#include <rpc/rpc.h>\n") >> PFILE
1012 printf("#endif\n") >> PFILE
1013 printf("#include \"db_server.h\"\n") >> PFILE
1014 printf("#include \"dbinc/db_server_int.h\"\n") >> PFILE
1015 printf("\n") >> PFILE
1019 # illegal_functions --
1020 # Output general illegal-call functions
1021 function illegal_functions(OUTPUT)
1023 printf("static int __dbcl_dbp_illegal __P((DB *));\n") >> OUTPUT
1024 printf("static int __dbcl_noserver __P((DB_ENV *));\n") >> OUTPUT
1025 printf("static int __dbcl_txn_illegal __P((DB_TXN *));\n") >> OUTPUT
1026 # If we ever need an "illegal" function for a DBC method.
1027 # printf("static int __dbcl_dbc_illegal __P((DBC *));\n") >> OUTPUT
1028 printf("\n") >> OUTPUT
1030 printf("static int\n") >> OUTPUT
1031 printf("__dbcl_noserver(dbenv)\n") >> OUTPUT
1032 printf("\tDB_ENV *dbenv;\n") >> OUTPUT
1033 printf("{\n\t__db_errx(dbenv == NULL ? NULL : dbenv->env,") >> OUTPUT
1035 "\n\t \"No Berkeley DB RPC server environment\");\n") >> OUTPUT
1036 printf("\treturn (DB_NOSERVER);\n") >> OUTPUT
1037 printf("}\n\n") >> OUTPUT
1039 printf("/*\n") >> OUTPUT
1040 printf(" * __dbcl_dbenv_illegal --\n") >> OUTPUT
1041 printf(" * DB_ENV method not supported under RPC.\n") >> OUTPUT
1042 printf(" *\n") >> OUTPUT
1043 printf(" * PUBLIC: int __dbcl_dbenv_illegal __P((DB_ENV *));\n")\
1045 printf(" */\n") >> OUTPUT
1046 printf("int\n") >> OUTPUT
1047 printf("__dbcl_dbenv_illegal(dbenv)\n") >> OUTPUT
1048 printf("\tDB_ENV *dbenv;\n") >> OUTPUT
1049 printf("{\n\t__db_errx(dbenv == NULL ? NULL : dbenv->env,") >> OUTPUT
1050 printf("\n\t \"Interface not supported by ") >> OUTPUT
1051 printf("Berkeley DB RPC client environments\");\n") >> OUTPUT
1052 printf("\treturn (DB_OPNOTSUP);\n") >> OUTPUT
1053 printf("}\n\n") >> OUTPUT
1054 printf("/*\n") >> OUTPUT
1055 printf(" * __dbcl_dbp_illegal --\n") >> OUTPUT
1056 printf(" * DB method not supported under RPC.\n") >> OUTPUT
1057 printf(" */\n") >> OUTPUT
1058 printf("static int\n") >> OUTPUT
1059 printf("__dbcl_dbp_illegal(dbp)\n") >> OUTPUT
1060 printf("\tDB *dbp;\n") >> OUTPUT
1061 printf("{\n\treturn (__dbcl_dbenv_illegal(dbp->dbenv));\n") >> OUTPUT
1062 printf("}\n\n") >> OUTPUT
1063 printf("/*\n") >> OUTPUT
1064 printf(" * __dbcl_txn_illegal --\n") >> OUTPUT
1065 printf(" * DB_TXN method not supported under RPC.\n") >> OUTPUT
1066 printf(" */\n") >> OUTPUT
1067 printf("static int\n__dbcl_txn_illegal(txn)\n") >> OUTPUT
1068 printf("\tDB_TXN *txn;\n") >> OUTPUT
1069 printf("{\n\treturn (__dbcl_dbenv_illegal(txn->mgrp->env->dbenv));\n")\
1071 printf("}\n\n") >> OUTPUT
1072 # If we ever need an "illegal" function for a DBC method.
1073 # printf("static int\n") >> OUTPUT
1074 # printf("__dbcl_dbc_illegal(dbc)\n") >> OUTPUT
1075 # printf("\tDBC *dbc;\n") >> OUTPUT
1076 # printf("{\n\treturn (__dbcl_dbenv_illegal(dbc->dbenv));\n") \
1078 # printf("}\n\n") >> OUTPUT
1081 function obj_func(v, l)
1083 # Ignore db_create and env_create -- there's got to be something
1084 # cleaner, but I don't want to rewrite rpc.src right now.
1085 if (name == "db_create")
1087 if (name == "env_create")
1090 # Strip off the leading prefix for the method name.
1092 # There are two method names for cursors, the old and the new.
1094 # There just has to be something cleaner, but yadda, yadda, yadda.
1096 i = index(name, "_");
1097 s = substr(name, i + 1, len - i)
1099 if (v != "dbc" || s == "get_priority" || s == "set_priority")
1102 o = sprintf(" = %s->c_%s", v, s)
1103 l[obj_indx] = sprintf("\t%s->%s%s = __dbcl_%s;", v, s, o, name)
1106 function obj_illegal(l, handle, method, proto)
1108 # All of the functions return an int, with one exception. Hack
1109 # to make that work.
1110 type = method == "db_get_mpf" ? "DB_MPOOLFILE *" : "int"
1112 # Strip off the leading prefix for the method name -- there's got to
1113 # be something cleaner, but I don't want to rewrite rpc.src right now.
1114 len = length(method);
1115 i = index(method, "_");
1118 sprintf("\t%s->%s =\n\t (%s (*)(",\
1119 handle, substr(method, i + 1, len - i), type)\
1121 sprintf("))\n\t __dbcl_%s_illegal;", handle);
1124 function obj_init(obj, v, list, OUTPUT) {
1125 printf("/*\n") >> OUTPUT
1126 printf(" * __dbcl_%s_init --\n", v) >> OUTPUT
1127 printf(" *\tInitialize %s handle methods.\n", obj) >> OUTPUT
1128 printf(" *\n") >> OUTPUT
1130 " * PUBLIC: void __dbcl_%s_init __P((%s *));\n", v, obj) >> OUTPUT
1131 printf(" */\n") >> OUTPUT
1132 printf("void\n") >> OUTPUT
1133 printf("__dbcl_%s_init(%s)\n", v, v) >> OUTPUT
1134 printf("\t%s *%s;\n", obj, v) >> OUTPUT
1135 printf("{\n") >> OUTPUT
1136 for (i = 1; i < obj_indx; ++i) {
1138 print list[i] >> OUTPUT
1140 printf("\treturn;\n}\n\n") >> OUTPUT
1145 # Add line separators to pretty-print the output.
1146 function split_lines() {
1148 # Reset the counter, remove any trailing whitespace from
1151 sub("[ ]$", "", sep)
1153 printf("%s\n\t\t", sep) >> PFILE
1158 # Pretty-print a function prototype.
1159 function proto_format(p, OUTPUT)
1161 printf("/*\n") >> OUTPUT;
1164 for (i = 1; i in p; ++i)
1168 if (length(s) + length(t) < 80)
1169 printf("%s%s", t, s) >> OUTPUT;
1172 len = length(t) + length(p[1]);
1173 printf("%s%s", t, p[1]) >> OUTPUT
1175 n = split(p[2], comma, ",");
1176 comma[1] = "__P" comma[1];
1177 for (i = 1; i <= n; i++) {
1178 if (len + length(comma[i]) > 75) {
1179 printf("\n * PUBLIC: ") >> OUTPUT;
1182 printf("%s%s", comma[i], i == n ? "" : ",") >> OUTPUT;
1183 len += length(comma[i]);
1186 printf("\n */\n") >> OUTPUT;