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

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

MySQL数据库

开发平台：

Visual C++

db_server_svc.c：源码内容
  1. /*
  2.  * Please do not edit this file.
  3.  * It was generated using rpcgen.
  4.  */
  6. #include "../rpc_server/db_server.h"
  7. #include <stdio.h>
  8. #include <stdlib.h>
  9. #include <rpc/pmap_clnt.h>
  10. #include <string.h>
  11. #include <memory.h>
  12. #include <sys/socket.h>
  13. #include <netinet/in.h>
  14. #endif
  16. #include "db_int.h"
  17. #include "dbinc_auto/db_server.h"
  18. #include "dbinc/db_server_int.h"
  19. #include "dbinc_auto/rpc_server_ext.h"
  21. #ifndef SIG_PF
  22. #define SIG_PF void(*)(int)
  23. #endif
  25. static void
  26. db_rpc_serverprog_4001(struct svc_req *rqstp, register SVCXPRT *transp)
  27. {
  28. union {
  29. __env_cachesize_msg __db_env_cachesize_4001_arg;
  30. __env_close_msg __db_env_close_4001_arg;
  31. __env_create_msg __db_env_create_4001_arg;
  32. __env_dbremove_msg __db_env_dbremove_4001_arg;
  33. __env_dbrename_msg __db_env_dbrename_4001_arg;
  34. __env_encrypt_msg __db_env_encrypt_4001_arg;
  35. __env_flags_msg __db_env_flags_4001_arg;
  36. __env_open_msg __db_env_open_4001_arg;
  37. __env_remove_msg __db_env_remove_4001_arg;
  38. __txn_abort_msg __db_txn_abort_4001_arg;
  39. __txn_begin_msg __db_txn_begin_4001_arg;
  40. __txn_commit_msg __db_txn_commit_4001_arg;
  41. __txn_discard_msg __db_txn_discard_4001_arg;
  42. __txn_prepare_msg __db_txn_prepare_4001_arg;
  43. __txn_recover_msg __db_txn_recover_4001_arg;
  44. __db_associate_msg __db_db_associate_4001_arg;
  45. __db_bt_maxkey_msg __db_db_bt_maxkey_4001_arg;
  46. __db_bt_minkey_msg __db_db_bt_minkey_4001_arg;
  47. __db_close_msg __db_db_close_4001_arg;
  48. __db_create_msg __db_db_create_4001_arg;
  49. __db_del_msg __db_db_del_4001_arg;
  50. __db_encrypt_msg __db_db_encrypt_4001_arg;
  51. __db_extentsize_msg __db_db_extentsize_4001_arg;
  52. __db_flags_msg __db_db_flags_4001_arg;
  53. __db_get_msg __db_db_get_4001_arg;
  54. __db_h_ffactor_msg __db_db_h_ffactor_4001_arg;
  55. __db_h_nelem_msg __db_db_h_nelem_4001_arg;
  56. __db_key_range_msg __db_db_key_range_4001_arg;
  57. __db_lorder_msg __db_db_lorder_4001_arg;
  58. __db_open_msg __db_db_open_4001_arg;
  59. __db_pagesize_msg __db_db_pagesize_4001_arg;
  60. __db_pget_msg __db_db_pget_4001_arg;
  61. __db_put_msg __db_db_put_4001_arg;
  62. __db_re_delim_msg __db_db_re_delim_4001_arg;
  63. __db_re_len_msg __db_db_re_len_4001_arg;
  64. __db_re_pad_msg __db_db_re_pad_4001_arg;
  65. __db_remove_msg __db_db_remove_4001_arg;
  66. __db_rename_msg __db_db_rename_4001_arg;
  67. __db_stat_msg __db_db_stat_4001_arg;
  68. __db_sync_msg __db_db_sync_4001_arg;
  69. __db_truncate_msg __db_db_truncate_4001_arg;
  70. __db_cursor_msg __db_db_cursor_4001_arg;
  71. __db_join_msg __db_db_join_4001_arg;
  72. __dbc_close_msg __db_dbc_close_4001_arg;
  73. __dbc_count_msg __db_dbc_count_4001_arg;
  74. __dbc_del_msg __db_dbc_del_4001_arg;
  75. __dbc_dup_msg __db_dbc_dup_4001_arg;
  76. __dbc_get_msg __db_dbc_get_4001_arg;
  77. __dbc_pget_msg __db_dbc_pget_4001_arg;
  78. __dbc_put_msg __db_dbc_put_4001_arg;
  79. } argument;
  80. char *result;
  81. xdrproc_t _xdr_argument, _xdr_result;
  82. char *(*local)(char *, struct svc_req *);
  84. switch (rqstp->rq_proc) {
  85. case NULLPROC:
  86. (void) svc_sendreply (transp, (xdrproc_t) xdr_void, (char *)NULL);
  87. return;
  89. case __DB_env_cachesize:
  90. _xdr_argument = (xdrproc_t) xdr___env_cachesize_msg;
  91. _xdr_result = (xdrproc_t) xdr___env_cachesize_reply;
  92. local = (char *(*)(char *, struct svc_req *)) __db_env_cachesize_4001_svc;
  93. break;
  95. case __DB_env_close:
  96. _xdr_argument = (xdrproc_t) xdr___env_close_msg;
  97. _xdr_result = (xdrproc_t) xdr___env_close_reply;
  98. local = (char *(*)(char *, struct svc_req *)) __db_env_close_4001_svc;
  99. break;
  101. case __DB_env_create:
  102. _xdr_argument = (xdrproc_t) xdr___env_create_msg;
  103. _xdr_result = (xdrproc_t) xdr___env_create_reply;
  104. local = (char *(*)(char *, struct svc_req *)) __db_env_create_4001_svc;
  105. break;
  107. case __DB_env_dbremove:
  108. _xdr_argument = (xdrproc_t) xdr___env_dbremove_msg;
  109. _xdr_result = (xdrproc_t) xdr___env_dbremove_reply;
  110. local = (char *(*)(char *, struct svc_req *)) __db_env_dbremove_4001_svc;
  111. break;
  113. case __DB_env_dbrename:
  114. _xdr_argument = (xdrproc_t) xdr___env_dbrename_msg;
  115. _xdr_result = (xdrproc_t) xdr___env_dbrename_reply;
  116. local = (char *(*)(char *, struct svc_req *)) __db_env_dbrename_4001_svc;
  117. break;
  119. case __DB_env_encrypt:
  120. _xdr_argument = (xdrproc_t) xdr___env_encrypt_msg;
  121. _xdr_result = (xdrproc_t) xdr___env_encrypt_reply;
  122. local = (char *(*)(char *, struct svc_req *)) __db_env_encrypt_4001_svc;
  123. break;
  125. case __DB_env_flags:
  126. _xdr_argument = (xdrproc_t) xdr___env_flags_msg;
  127. _xdr_result = (xdrproc_t) xdr___env_flags_reply;
  128. local = (char *(*)(char *, struct svc_req *)) __db_env_flags_4001_svc;
  129. break;
  131. case __DB_env_open:
  132. _xdr_argument = (xdrproc_t) xdr___env_open_msg;
  133. _xdr_result = (xdrproc_t) xdr___env_open_reply;
  134. local = (char *(*)(char *, struct svc_req *)) __db_env_open_4001_svc;
  135. break;
  137. case __DB_env_remove:
  138. _xdr_argument = (xdrproc_t) xdr___env_remove_msg;
  139. _xdr_result = (xdrproc_t) xdr___env_remove_reply;
  140. local = (char *(*)(char *, struct svc_req *)) __db_env_remove_4001_svc;
  141. break;
  143. case __DB_txn_abort:
  144. _xdr_argument = (xdrproc_t) xdr___txn_abort_msg;
  145. _xdr_result = (xdrproc_t) xdr___txn_abort_reply;
  146. local = (char *(*)(char *, struct svc_req *)) __db_txn_abort_4001_svc;
  147. break;
  149. case __DB_txn_begin:
  150. _xdr_argument = (xdrproc_t) xdr___txn_begin_msg;
  151. _xdr_result = (xdrproc_t) xdr___txn_begin_reply;
  152. local = (char *(*)(char *, struct svc_req *)) __db_txn_begin_4001_svc;
  153. break;
  155. case __DB_txn_commit:
  156. _xdr_argument = (xdrproc_t) xdr___txn_commit_msg;
  157. _xdr_result = (xdrproc_t) xdr___txn_commit_reply;
  158. local = (char *(*)(char *, struct svc_req *)) __db_txn_commit_4001_svc;
  159. break;
  161. case __DB_txn_discard:
  162. _xdr_argument = (xdrproc_t) xdr___txn_discard_msg;
  163. _xdr_result = (xdrproc_t) xdr___txn_discard_reply;
  164. local = (char *(*)(char *, struct svc_req *)) __db_txn_discard_4001_svc;
  165. break;
  167. case __DB_txn_prepare:
  168. _xdr_argument = (xdrproc_t) xdr___txn_prepare_msg;
  169. _xdr_result = (xdrproc_t) xdr___txn_prepare_reply;
  170. local = (char *(*)(char *, struct svc_req *)) __db_txn_prepare_4001_svc;
  171. break;
  173. case __DB_txn_recover:
  174. _xdr_argument = (xdrproc_t) xdr___txn_recover_msg;
  175. _xdr_result = (xdrproc_t) xdr___txn_recover_reply;
  176. local = (char *(*)(char *, struct svc_req *)) __db_txn_recover_4001_svc;
  177. break;
  179. case __DB_db_associate:
  180. _xdr_argument = (xdrproc_t) xdr___db_associate_msg;
  181. _xdr_result = (xdrproc_t) xdr___db_associate_reply;
  182. local = (char *(*)(char *, struct svc_req *)) __db_db_associate_4001_svc;
  183. break;
  185. case __DB_db_bt_maxkey:
  186. _xdr_argument = (xdrproc_t) xdr___db_bt_maxkey_msg;
  187. _xdr_result = (xdrproc_t) xdr___db_bt_maxkey_reply;
  188. local = (char *(*)(char *, struct svc_req *)) __db_db_bt_maxkey_4001_svc;
  189. break;
  191. case __DB_db_bt_minkey:
  192. _xdr_argument = (xdrproc_t) xdr___db_bt_minkey_msg;
  193. _xdr_result = (xdrproc_t) xdr___db_bt_minkey_reply;
  194. local = (char *(*)(char *, struct svc_req *)) __db_db_bt_minkey_4001_svc;
  195. break;
  197. case __DB_db_close:
  198. _xdr_argument = (xdrproc_t) xdr___db_close_msg;
  199. _xdr_result = (xdrproc_t) xdr___db_close_reply;
  200. local = (char *(*)(char *, struct svc_req *)) __db_db_close_4001_svc;
  201. break;
  203. case __DB_db_create:
  204. _xdr_argument = (xdrproc_t) xdr___db_create_msg;
  205. _xdr_result = (xdrproc_t) xdr___db_create_reply;
  206. local = (char *(*)(char *, struct svc_req *)) __db_db_create_4001_svc;
  207. break;
  209. case __DB_db_del:
  210. _xdr_argument = (xdrproc_t) xdr___db_del_msg;
  211. _xdr_result = (xdrproc_t) xdr___db_del_reply;
  212. local = (char *(*)(char *, struct svc_req *)) __db_db_del_4001_svc;
  213. break;
  215. case __DB_db_encrypt:
  216. _xdr_argument = (xdrproc_t) xdr___db_encrypt_msg;
  217. _xdr_result = (xdrproc_t) xdr___db_encrypt_reply;
  218. local = (char *(*)(char *, struct svc_req *)) __db_db_encrypt_4001_svc;
  219. break;
  221. case __DB_db_extentsize:
  222. _xdr_argument = (xdrproc_t) xdr___db_extentsize_msg;
  223. _xdr_result = (xdrproc_t) xdr___db_extentsize_reply;
  224. local = (char *(*)(char *, struct svc_req *)) __db_db_extentsize_4001_svc;
  225. break;
  227. case __DB_db_flags:
  228. _xdr_argument = (xdrproc_t) xdr___db_flags_msg;
  229. _xdr_result = (xdrproc_t) xdr___db_flags_reply;
  230. local = (char *(*)(char *, struct svc_req *)) __db_db_flags_4001_svc;
  231. break;
  233. case __DB_db_get:
  234. _xdr_argument = (xdrproc_t) xdr___db_get_msg;
  235. _xdr_result = (xdrproc_t) xdr___db_get_reply;
  236. local = (char *(*)(char *, struct svc_req *)) __db_db_get_4001_svc;
  237. break;
  239. case __DB_db_h_ffactor:
  240. _xdr_argument = (xdrproc_t) xdr___db_h_ffactor_msg;
  241. _xdr_result = (xdrproc_t) xdr___db_h_ffactor_reply;
  242. local = (char *(*)(char *, struct svc_req *)) __db_db_h_ffactor_4001_svc;
  243. break;
  245. case __DB_db_h_nelem:
  246. _xdr_argument = (xdrproc_t) xdr___db_h_nelem_msg;
  247. _xdr_result = (xdrproc_t) xdr___db_h_nelem_reply;
  248. local = (char *(*)(char *, struct svc_req *)) __db_db_h_nelem_4001_svc;
  249. break;
  251. case __DB_db_key_range:
  252. _xdr_argument = (xdrproc_t) xdr___db_key_range_msg;
  253. _xdr_result = (xdrproc_t) xdr___db_key_range_reply;
  254. local = (char *(*)(char *, struct svc_req *)) __db_db_key_range_4001_svc;
  255. break;
  257. case __DB_db_lorder:
  258. _xdr_argument = (xdrproc_t) xdr___db_lorder_msg;
  259. _xdr_result = (xdrproc_t) xdr___db_lorder_reply;
  260. local = (char *(*)(char *, struct svc_req *)) __db_db_lorder_4001_svc;
  261. break;
  263. case __DB_db_open:
  264. _xdr_argument = (xdrproc_t) xdr___db_open_msg;
  265. _xdr_result = (xdrproc_t) xdr___db_open_reply;
  266. local = (char *(*)(char *, struct svc_req *)) __db_db_open_4001_svc;
  267. break;
  269. case __DB_db_pagesize:
  270. _xdr_argument = (xdrproc_t) xdr___db_pagesize_msg;
  271. _xdr_result = (xdrproc_t) xdr___db_pagesize_reply;
  272. local = (char *(*)(char *, struct svc_req *)) __db_db_pagesize_4001_svc;
  273. break;
  275. case __DB_db_pget:
  276. _xdr_argument = (xdrproc_t) xdr___db_pget_msg;
  277. _xdr_result = (xdrproc_t) xdr___db_pget_reply;
  278. local = (char *(*)(char *, struct svc_req *)) __db_db_pget_4001_svc;
  279. break;
  281. case __DB_db_put:
  282. _xdr_argument = (xdrproc_t) xdr___db_put_msg;
  283. _xdr_result = (xdrproc_t) xdr___db_put_reply;
  284. local = (char *(*)(char *, struct svc_req *)) __db_db_put_4001_svc;
  285. break;
  287. case __DB_db_re_delim:
  288. _xdr_argument = (xdrproc_t) xdr___db_re_delim_msg;
  289. _xdr_result = (xdrproc_t) xdr___db_re_delim_reply;
  290. local = (char *(*)(char *, struct svc_req *)) __db_db_re_delim_4001_svc;
  291. break;
  293. case __DB_db_re_len:
  294. _xdr_argument = (xdrproc_t) xdr___db_re_len_msg;
  295. _xdr_result = (xdrproc_t) xdr___db_re_len_reply;
  296. local = (char *(*)(char *, struct svc_req *)) __db_db_re_len_4001_svc;
  297. break;
  299. case __DB_db_re_pad:
  300. _xdr_argument = (xdrproc_t) xdr___db_re_pad_msg;
  301. _xdr_result = (xdrproc_t) xdr___db_re_pad_reply;
  302. local = (char *(*)(char *, struct svc_req *)) __db_db_re_pad_4001_svc;
  303. break;
  305. case __DB_db_remove:
  306. _xdr_argument = (xdrproc_t) xdr___db_remove_msg;
  307. _xdr_result = (xdrproc_t) xdr___db_remove_reply;
  308. local = (char *(*)(char *, struct svc_req *)) __db_db_remove_4001_svc;
  309. break;
  311. case __DB_db_rename:
  312. _xdr_argument = (xdrproc_t) xdr___db_rename_msg;
  313. _xdr_result = (xdrproc_t) xdr___db_rename_reply;
  314. local = (char *(*)(char *, struct svc_req *)) __db_db_rename_4001_svc;
  315. break;
  317. case __DB_db_stat:
  318. _xdr_argument = (xdrproc_t) xdr___db_stat_msg;
  319. _xdr_result = (xdrproc_t) xdr___db_stat_reply;
  320. local = (char *(*)(char *, struct svc_req *)) __db_db_stat_4001_svc;
  321. break;
  323. case __DB_db_sync:
  324. _xdr_argument = (xdrproc_t) xdr___db_sync_msg;
  325. _xdr_result = (xdrproc_t) xdr___db_sync_reply;
  326. local = (char *(*)(char *, struct svc_req *)) __db_db_sync_4001_svc;
  327. break;
  329. case __DB_db_truncate:
  330. _xdr_argument = (xdrproc_t) xdr___db_truncate_msg;
  331. _xdr_result = (xdrproc_t) xdr___db_truncate_reply;
  332. local = (char *(*)(char *, struct svc_req *)) __db_db_truncate_4001_svc;
  333. break;
  335. case __DB_db_cursor:
  336. _xdr_argument = (xdrproc_t) xdr___db_cursor_msg;
  337. _xdr_result = (xdrproc_t) xdr___db_cursor_reply;
  338. local = (char *(*)(char *, struct svc_req *)) __db_db_cursor_4001_svc;
  339. break;
  341. case __DB_db_join:
  342. _xdr_argument = (xdrproc_t) xdr___db_join_msg;
  343. _xdr_result = (xdrproc_t) xdr___db_join_reply;
  344. local = (char *(*)(char *, struct svc_req *)) __db_db_join_4001_svc;
  345. break;
  347. case __DB_dbc_close:
  348. _xdr_argument = (xdrproc_t) xdr___dbc_close_msg;
  349. _xdr_result = (xdrproc_t) xdr___dbc_close_reply;
  350. local = (char *(*)(char *, struct svc_req *)) __db_dbc_close_4001_svc;
  351. break;
  353. case __DB_dbc_count:
  354. _xdr_argument = (xdrproc_t) xdr___dbc_count_msg;
  355. _xdr_result = (xdrproc_t) xdr___dbc_count_reply;
  356. local = (char *(*)(char *, struct svc_req *)) __db_dbc_count_4001_svc;
  357. break;
  359. case __DB_dbc_del:
  360. _xdr_argument = (xdrproc_t) xdr___dbc_del_msg;
  361. _xdr_result = (xdrproc_t) xdr___dbc_del_reply;
  362. local = (char *(*)(char *, struct svc_req *)) __db_dbc_del_4001_svc;
  363. break;
  365. case __DB_dbc_dup:
  366. _xdr_argument = (xdrproc_t) xdr___dbc_dup_msg;
  367. _xdr_result = (xdrproc_t) xdr___dbc_dup_reply;
  368. local = (char *(*)(char *, struct svc_req *)) __db_dbc_dup_4001_svc;
  369. break;
  371. case __DB_dbc_get:
  372. _xdr_argument = (xdrproc_t) xdr___dbc_get_msg;
  373. _xdr_result = (xdrproc_t) xdr___dbc_get_reply;
  374. local = (char *(*)(char *, struct svc_req *)) __db_dbc_get_4001_svc;
  375. break;
  377. case __DB_dbc_pget:
  378. _xdr_argument = (xdrproc_t) xdr___dbc_pget_msg;
  379. _xdr_result = (xdrproc_t) xdr___dbc_pget_reply;
  380. local = (char *(*)(char *, struct svc_req *)) __db_dbc_pget_4001_svc;
  381. break;
  383. case __DB_dbc_put:
  384. _xdr_argument = (xdrproc_t) xdr___dbc_put_msg;
  385. _xdr_result = (xdrproc_t) xdr___dbc_put_reply;
  386. local = (char *(*)(char *, struct svc_req *)) __db_dbc_put_4001_svc;
  387. break;
  389. default:
  390. svcerr_noproc (transp);
  391. return;
  392. }
  393. memset ((char *)&argument, 0, sizeof (argument));
  394. if (!svc_getargs (transp, (xdrproc_t) _xdr_argument, (caddr_t) &argument)) {
  395. svcerr_decode (transp);
  396. return;
  397. }
  398. result = (*local)((char *)&argument, rqstp);
  399. if (result != NULL && !svc_sendreply(transp, (xdrproc_t) _xdr_result, result)) {
  400. svcerr_systemerr (transp);
  401. }
  402. if (!svc_freeargs (transp, (xdrproc_t) _xdr_argument, (caddr_t) &argument)) {
  403. fprintf (stderr, "%s", "unable to free arguments");
  404. exit (1);
  405. }
  406. __dbsrv_timeout(0);
  407. return;
  408. }
  410. int
  411. void __dbsrv_main (int argc, char **argv)
  412. {
  413. register SVCXPRT *transp;
  415. pmap_unset (DB_RPC_SERVERPROG, DB_RPC_SERVERVERS);
  417. transp = svctcp_create(RPC_ANYSOCK, 0, 0);
  418. if (transp == NULL) {
  419. fprintf (stderr, "%s", "cannot create tcp service.");
  420. exit(1);
  421. }
  422. if (!svc_register(transp, DB_RPC_SERVERPROG, DB_RPC_SERVERVERS, db_rpc_serverprog_4001, IPPROTO_TCP)) {
  423. fprintf (stderr, "%s", "unable to register (DB_RPC_SERVERPROG, DB_RPC_SERVERVERS, tcp).");
  424. exit(1);
  425. }
  427. svc_run ();
  428. fprintf (stderr, "%s", "svc_run returned");
  429. exit (1);
  430. /* NOTREACHED */
  431. }