00001
00002
00003
00004
00005
00006
00007
00008
00009
00010 package com.sleepycat.db.rpcserver;
00011
00012 import com.sleepycat.db.*;
00013 import com.sleepycat.db.internal.DbConstants;
00014 import java.io.IOException;
00015 import org.acplt.oncrpc.OncRpcException;
00016
00022 public abstract class Dispatcher extends ServerStubs {
00023 abstract int addEnv(RpcDbEnv rdbenv);
00024 abstract int addDatabase(RpcDb rdb);
00025 abstract int addTxn(RpcDbTxn rtxn);
00026 abstract int addCursor(RpcDbc rdbc);
00027 abstract void delEnv(RpcDbEnv rdbenv, boolean dispose);
00028 abstract void delDatabase(RpcDb rdb, boolean dispose);
00029 abstract void delTxn(RpcDbTxn rtxn, boolean dispose);
00030 abstract void delCursor(RpcDbc rdbc, boolean dispose);
00031 abstract RpcDbEnv getEnv(int envid);
00032 abstract RpcDb getDatabase(int dbid);
00033 abstract RpcDbTxn getTxn(int txnbid);
00034 abstract RpcDbc getCursor(int dbcid);
00035
00036 public Dispatcher() throws IOException, OncRpcException {
00037 super();
00038 }
00039
00041
00042 public __db_associate_reply __DB_db_associate_4004(__db_associate_msg args) {
00043 __db_associate_reply reply = new __db_associate_reply();
00044 RpcDb rdb = getDatabase(args.dbpcl_id);
00045 if (rdb == null)
00046 reply.status = DbConstants.DB_NOSERVER_ID;
00047 else
00048 rdb.associate(this, args, reply);
00049 return reply;
00050 }
00051
00052 public __db_get_bt_minkey_reply __DB_db_get_bt_minkey_4004(__db_get_bt_minkey_msg args) {
00053 __db_get_bt_minkey_reply reply = new __db_get_bt_minkey_reply();
00054 RpcDb rdb = getDatabase(args.dbpcl_id);
00055 if (rdb == null)
00056 reply.status = DbConstants.DB_NOSERVER_ID;
00057 else
00058 rdb.get_bt_minkey(this, args, reply);
00059 return reply;
00060 }
00061
00062 public __db_set_bt_minkey_reply __DB_db_set_bt_minkey_4004(__db_set_bt_minkey_msg args) {
00063 __db_set_bt_minkey_reply reply = new __db_set_bt_minkey_reply();
00064 RpcDb rdb = getDatabase(args.dbpcl_id);
00065 if (rdb == null)
00066 reply.status = DbConstants.DB_NOSERVER_ID;
00067 else
00068 rdb.set_bt_minkey(this, args, reply);
00069 return reply;
00070 }
00071
00072 public __db_close_reply __DB_db_close_4004(__db_close_msg args) {
00073 __db_close_reply reply = new __db_close_reply();
00074 RpcDb rdb = getDatabase(args.dbpcl_id);
00075 if (rdb == null)
00076 reply.status = DbConstants.DB_NOSERVER_ID;
00077 else
00078 rdb.close(this, args, reply);
00079 return reply;
00080 }
00081
00082 public __db_create_reply __DB_db_create_4004(__db_create_msg args) {
00083 __db_create_reply reply = new __db_create_reply();
00084 RpcDb rdb = new RpcDb(getEnv(args.dbenvcl_id));
00085 if (rdb == null)
00086 reply.status = DbConstants.DB_NOSERVER_ID;
00087 else
00088 rdb.create(this, args, reply);
00089 return reply;
00090 }
00091
00092 public __db_cursor_reply __DB_db_cursor_4004(__db_cursor_msg args) {
00093 __db_cursor_reply reply = new __db_cursor_reply();
00094 RpcDb rdb = getDatabase(args.dbpcl_id);
00095 if (rdb == null)
00096 reply.status = DbConstants.DB_NOSERVER_ID;
00097 else
00098 rdb.cursor(this, args, reply);
00099 return reply;
00100 }
00101
00102 public __db_del_reply __DB_db_del_4004(__db_del_msg args) {
00103 __db_del_reply reply = new __db_del_reply();
00104 RpcDb rdb = getDatabase(args.dbpcl_id);
00105 if (rdb == null)
00106 reply.status = DbConstants.DB_NOSERVER_ID;
00107 else
00108 rdb.del(this, args, reply);
00109 return reply;
00110 }
00111
00112 public __db_get_encrypt_flags_reply __DB_db_get_encrypt_flags_4004(__db_get_encrypt_flags_msg args) {
00113 __db_get_encrypt_flags_reply reply = new __db_get_encrypt_flags_reply();
00114 RpcDb rdb = getDatabase(args.dbpcl_id);
00115 if (rdb == null)
00116 reply.status = DbConstants.DB_NOSERVER_ID;
00117 else
00118 rdb.get_encrypt_flags(this, args, reply);
00119 return reply;
00120 }
00121
00122 public __db_set_encrypt_reply __DB_db_set_encrypt_4004(__db_set_encrypt_msg args) {
00123 __db_set_encrypt_reply reply = new __db_set_encrypt_reply();
00124 RpcDb rdb = getDatabase(args.dbpcl_id);
00125 if (rdb == null)
00126 reply.status = DbConstants.DB_NOSERVER_ID;
00127 else
00128 rdb.set_encrypt(this, args, reply);
00129 return reply;
00130 }
00131
00132 public __db_get_q_extentsize_reply __DB_db_get_q_extentsize_4004(__db_get_q_extentsize_msg args) {
00133 __db_get_q_extentsize_reply reply = new __db_get_q_extentsize_reply();
00134 RpcDb rdb = getDatabase(args.dbpcl_id);
00135 if (rdb == null)
00136 reply.status = DbConstants.DB_NOSERVER_ID;
00137 else
00138 rdb.get_q_extentsize(this, args, reply);
00139 return reply;
00140 }
00141
00142 public __db_set_q_extentsize_reply __DB_db_set_q_extentsize_4004(__db_set_q_extentsize_msg args) {
00143 __db_set_q_extentsize_reply reply = new __db_set_q_extentsize_reply();
00144 RpcDb rdb = getDatabase(args.dbpcl_id);
00145 if (rdb == null)
00146 reply.status = DbConstants.DB_NOSERVER_ID;
00147 else
00148 rdb.set_q_extentsize(this, args, reply);
00149 return reply;
00150 }
00151
00152 public __db_get_flags_reply __DB_db_get_flags_4004(__db_get_flags_msg args) {
00153 __db_get_flags_reply reply = new __db_get_flags_reply();
00154 RpcDb rdb = getDatabase(args.dbpcl_id);
00155 if (rdb == null)
00156 reply.status = DbConstants.DB_NOSERVER_ID;
00157 else
00158 rdb.get_flags(this, args, reply);
00159 return reply;
00160 }
00161
00162 public __db_set_flags_reply __DB_db_set_flags_4004(__db_set_flags_msg args) {
00163 __db_set_flags_reply reply = new __db_set_flags_reply();
00164 RpcDb rdb = getDatabase(args.dbpcl_id);
00165 if (rdb == null)
00166 reply.status = DbConstants.DB_NOSERVER_ID;
00167 else
00168 rdb.set_flags(this, args, reply);
00169 return reply;
00170 }
00171
00172 public __db_get_reply __DB_db_get_4004(__db_get_msg args) {
00173 __db_get_reply reply = new __db_get_reply();
00174 RpcDb rdb = getDatabase(args.dbpcl_id);
00175 if (rdb == null)
00176 reply.status = DbConstants.DB_NOSERVER_ID;
00177 else
00178 rdb.get(this, args, reply);
00179 return reply;
00180 }
00181
00182 public __db_get_h_ffactor_reply __DB_db_get_h_ffactor_4004(__db_get_h_ffactor_msg args) {
00183 __db_get_h_ffactor_reply reply = new __db_get_h_ffactor_reply();
00184 RpcDb rdb = getDatabase(args.dbpcl_id);
00185 if (rdb == null)
00186 reply.status = DbConstants.DB_NOSERVER_ID;
00187 else
00188 rdb.get_h_ffactor(this, args, reply);
00189 return reply;
00190 }
00191
00192 public __db_set_h_ffactor_reply __DB_db_set_h_ffactor_4004(__db_set_h_ffactor_msg args) {
00193 __db_set_h_ffactor_reply reply = new __db_set_h_ffactor_reply();
00194 RpcDb rdb = getDatabase(args.dbpcl_id);
00195 if (rdb == null)
00196 reply.status = DbConstants.DB_NOSERVER_ID;
00197 else
00198 rdb.set_h_ffactor(this, args, reply);
00199 return reply;
00200 }
00201
00202 public __db_get_h_nelem_reply __DB_db_get_h_nelem_4004(__db_get_h_nelem_msg args) {
00203 __db_get_h_nelem_reply reply = new __db_get_h_nelem_reply();
00204 RpcDb rdb = getDatabase(args.dbpcl_id);
00205 if (rdb == null)
00206 reply.status = DbConstants.DB_NOSERVER_ID;
00207 else
00208 rdb.get_h_nelem(this, args, reply);
00209 return reply;
00210 }
00211
00212 public __db_set_h_nelem_reply __DB_db_set_h_nelem_4004(__db_set_h_nelem_msg args) {
00213 __db_set_h_nelem_reply reply = new __db_set_h_nelem_reply();
00214 RpcDb rdb = getDatabase(args.dbpcl_id);
00215 if (rdb == null)
00216 reply.status = DbConstants.DB_NOSERVER_ID;
00217 else
00218 rdb.set_h_nelem(this, args, reply);
00219 return reply;
00220 }
00221
00222 public __db_join_reply __DB_db_join_4004(__db_join_msg args) {
00223 __db_join_reply reply = new __db_join_reply();
00224 RpcDb rdb = getDatabase(args.dbpcl_id);
00225 if (rdb == null)
00226 reply.status = DbConstants.DB_NOSERVER_ID;
00227 else
00228 rdb.join(this, args, reply);
00229 return reply;
00230 }
00231
00232 public __db_key_range_reply __DB_db_key_range_4004(__db_key_range_msg args) {
00233 __db_key_range_reply reply = new __db_key_range_reply();
00234 RpcDb rdb = getDatabase(args.dbpcl_id);
00235 if (rdb == null)
00236 reply.status = DbConstants.DB_NOSERVER_ID;
00237 else
00238 rdb.key_range(this, args, reply);
00239 return reply;
00240 }
00241
00242 public __db_get_lorder_reply __DB_db_get_lorder_4004(__db_get_lorder_msg args) {
00243 __db_get_lorder_reply reply = new __db_get_lorder_reply();
00244 RpcDb rdb = getDatabase(args.dbpcl_id);
00245 if (rdb == null)
00246 reply.status = DbConstants.DB_NOSERVER_ID;
00247 else
00248 rdb.get_lorder(this, args, reply);
00249 return reply;
00250 }
00251
00252 public __db_set_lorder_reply __DB_db_set_lorder_4004(__db_set_lorder_msg args) {
00253 __db_set_lorder_reply reply = new __db_set_lorder_reply();
00254 RpcDb rdb = getDatabase(args.dbpcl_id);
00255 if (rdb == null)
00256 reply.status = DbConstants.DB_NOSERVER_ID;
00257 else
00258 rdb.set_lorder(this, args, reply);
00259 return reply;
00260 }
00261
00262 public __db_get_dbname_reply __DB_db_get_dbname_4004(__db_get_dbname_msg args) {
00263 __db_get_dbname_reply reply = new __db_get_dbname_reply();
00264 RpcDb rdb = getDatabase(args.dbpcl_id);
00265 if (rdb == null)
00266 reply.status = DbConstants.DB_NOSERVER_ID;
00267 else
00268 rdb.get_dbname(this, args, reply);
00269 return reply;
00270 }
00271
00272 public __db_get_open_flags_reply __DB_db_get_open_flags_4004(__db_get_open_flags_msg args) {
00273 __db_get_open_flags_reply reply = new __db_get_open_flags_reply();
00274 RpcDb rdb = getDatabase(args.dbpcl_id);
00275 if (rdb == null)
00276 reply.status = DbConstants.DB_NOSERVER_ID;
00277 else
00278 rdb.get_open_flags(this, args, reply);
00279 return reply;
00280 }
00281
00282 public __db_open_reply __DB_db_open_4004(__db_open_msg args) {
00283 __db_open_reply reply = new __db_open_reply();
00284 RpcDb rdb = getDatabase(args.dbpcl_id);
00285 if (rdb == null)
00286 reply.status = DbConstants.DB_NOSERVER_ID;
00287 else
00288 rdb.open(this, args, reply);
00289 return reply;
00290 }
00291
00292 public __db_get_pagesize_reply __DB_db_get_pagesize_4004(__db_get_pagesize_msg args) {
00293 __db_get_pagesize_reply reply = new __db_get_pagesize_reply();
00294 RpcDb rdb = getDatabase(args.dbpcl_id);
00295 if (rdb == null)
00296 reply.status = DbConstants.DB_NOSERVER_ID;
00297 else
00298 rdb.get_pagesize(this, args, reply);
00299 return reply;
00300 }
00301
00302 public __db_set_pagesize_reply __DB_db_set_pagesize_4004(__db_set_pagesize_msg args) {
00303 __db_set_pagesize_reply reply = new __db_set_pagesize_reply();
00304 RpcDb rdb = getDatabase(args.dbpcl_id);
00305 if (rdb == null)
00306 reply.status = DbConstants.DB_NOSERVER_ID;
00307 else
00308 rdb.set_pagesize(this, args, reply);
00309 return reply;
00310 }
00311
00312 public __db_pget_reply __DB_db_pget_4004(__db_pget_msg args) {
00313 __db_pget_reply reply = new __db_pget_reply();
00314 RpcDb rdb = getDatabase(args.dbpcl_id);
00315 if (rdb == null)
00316 reply.status = DbConstants.DB_NOSERVER_ID;
00317 else
00318 rdb.pget(this, args, reply);
00319 return reply;
00320 }
00321
00322 public __db_put_reply __DB_db_put_4004(__db_put_msg args) {
00323 __db_put_reply reply = new __db_put_reply();
00324 RpcDb rdb = getDatabase(args.dbpcl_id);
00325 if (rdb == null)
00326 reply.status = DbConstants.DB_NOSERVER_ID;
00327 else
00328 rdb.put(this, args, reply);
00329 return reply;
00330 }
00331
00332 public __db_remove_reply __DB_db_remove_4004(__db_remove_msg args) {
00333 __db_remove_reply reply = new __db_remove_reply();
00334 RpcDb rdb = getDatabase(args.dbpcl_id);
00335 if (rdb == null)
00336 reply.status = DbConstants.DB_NOSERVER_ID;
00337 else
00338 rdb.remove(this, args, reply);
00339 return reply;
00340 }
00341
00342 public __db_rename_reply __DB_db_rename_4004(__db_rename_msg args) {
00343 __db_rename_reply reply = new __db_rename_reply();
00344 RpcDb rdb = getDatabase(args.dbpcl_id);
00345 if (rdb == null)
00346 reply.status = DbConstants.DB_NOSERVER_ID;
00347 else
00348 rdb.rename(this, args, reply);
00349 return reply;
00350 }
00351
00352 public __db_get_re_delim_reply __DB_db_get_re_delim_4004(__db_get_re_delim_msg args) {
00353 __db_get_re_delim_reply reply = new __db_get_re_delim_reply();
00354 RpcDb rdb = getDatabase(args.dbpcl_id);
00355 if (rdb == null)
00356 reply.status = DbConstants.DB_NOSERVER_ID;
00357 else
00358 rdb.get_re_delim(this, args, reply);
00359 return reply;
00360 }
00361
00362 public __db_set_re_delim_reply __DB_db_set_re_delim_4004(__db_set_re_delim_msg args) {
00363 __db_set_re_delim_reply reply = new __db_set_re_delim_reply();
00364 RpcDb rdb = getDatabase(args.dbpcl_id);
00365 if (rdb == null)
00366 reply.status = DbConstants.DB_NOSERVER_ID;
00367 else
00368 rdb.set_re_delim(this, args, reply);
00369 return reply;
00370 }
00371
00372 public __db_get_re_len_reply __DB_db_get_re_len_4004(__db_get_re_len_msg args) {
00373 __db_get_re_len_reply reply = new __db_get_re_len_reply();
00374 RpcDb rdb = getDatabase(args.dbpcl_id);
00375 if (rdb == null)
00376 reply.status = DbConstants.DB_NOSERVER_ID;
00377 else
00378 rdb.get_re_len(this, args, reply);
00379 return reply;
00380 }
00381
00382 public __db_set_re_len_reply __DB_db_set_re_len_4004(__db_set_re_len_msg args) {
00383 __db_set_re_len_reply reply = new __db_set_re_len_reply();
00384 RpcDb rdb = getDatabase(args.dbpcl_id);
00385 if (rdb == null)
00386 reply.status = DbConstants.DB_NOSERVER_ID;
00387 else
00388 rdb.set_re_len(this, args, reply);
00389 return reply;
00390 }
00391
00392 public __db_get_re_pad_reply __DB_db_get_re_pad_4004(__db_get_re_pad_msg args) {
00393 __db_get_re_pad_reply reply = new __db_get_re_pad_reply();
00394 RpcDb rdb = getDatabase(args.dbpcl_id);
00395 if (rdb == null)
00396 reply.status = DbConstants.DB_NOSERVER_ID;
00397 else
00398 rdb.get_re_pad(this, args, reply);
00399 return reply;
00400 }
00401
00402 public __db_set_re_pad_reply __DB_db_set_re_pad_4004(__db_set_re_pad_msg args) {
00403 __db_set_re_pad_reply reply = new __db_set_re_pad_reply();
00404 RpcDb rdb = getDatabase(args.dbpcl_id);
00405 if (rdb == null)
00406 reply.status = DbConstants.DB_NOSERVER_ID;
00407 else
00408 rdb.set_re_pad(this, args, reply);
00409 return reply;
00410 }
00411
00412 public __db_stat_reply __DB_db_stat_4004(__db_stat_msg args) {
00413 __db_stat_reply reply = new __db_stat_reply();
00414 RpcDb rdb = getDatabase(args.dbpcl_id);
00415 if (rdb == null)
00416 reply.status = DbConstants.DB_NOSERVER_ID;
00417 else
00418 rdb.stat(this, args, reply);
00419 return reply;
00420 }
00421
00422 public __db_sync_reply __DB_db_sync_4004(__db_sync_msg args) {
00423 __db_sync_reply reply = new __db_sync_reply();
00424 RpcDb rdb = getDatabase(args.dbpcl_id);
00425 if (rdb == null)
00426 reply.status = DbConstants.DB_NOSERVER_ID;
00427 else
00428 rdb.sync(this, args, reply);
00429 return reply;
00430 }
00431
00432 public __db_truncate_reply __DB_db_truncate_4004(__db_truncate_msg args) {
00433 __db_truncate_reply reply = new __db_truncate_reply();
00434 RpcDb rdb = getDatabase(args.dbpcl_id);
00435 if (rdb == null)
00436 reply.status = DbConstants.DB_NOSERVER_ID;
00437 else
00438 rdb.truncate(this, args, reply);
00439 return reply;
00440 }
00441
00443
00444 public __dbc_c_close_reply __DB_dbc_c_close_4004(__dbc_c_close_msg args) {
00445 __dbc_c_close_reply reply = new __dbc_c_close_reply();
00446 RpcDbc rdbc = getCursor(args.dbccl_id);
00447 if (rdbc == null)
00448 reply.status = DbConstants.DB_NOSERVER_ID;
00449 else
00450 rdbc.close(this, args, reply);
00451 return reply;
00452 }
00453
00454 public __dbc_c_count_reply __DB_dbc_c_count_4004(__dbc_c_count_msg args) {
00455 __dbc_c_count_reply reply = new __dbc_c_count_reply();
00456 RpcDbc rdbc = getCursor(args.dbccl_id);
00457 if (rdbc == null)
00458 reply.status = DbConstants.DB_NOSERVER_ID;
00459 else
00460 rdbc.count(this, args, reply);
00461 return reply;
00462 }
00463
00464 public __dbc_c_del_reply __DB_dbc_c_del_4004(__dbc_c_del_msg args) {
00465 __dbc_c_del_reply reply = new __dbc_c_del_reply();
00466 RpcDbc rdbc = getCursor(args.dbccl_id);
00467 if (rdbc == null)
00468 reply.status = DbConstants.DB_NOSERVER_ID;
00469 else
00470 rdbc.del(this, args, reply);
00471 return reply;
00472 }
00473
00474 public __dbc_c_dup_reply __DB_dbc_c_dup_4004(__dbc_c_dup_msg args) {
00475 __dbc_c_dup_reply reply = new __dbc_c_dup_reply();
00476 RpcDbc rdbc = getCursor(args.dbccl_id);
00477 if (rdbc == null)
00478 reply.status = DbConstants.DB_NOSERVER_ID;
00479 else
00480 rdbc.dup(this, args, reply);
00481 return reply;
00482 }
00483
00484 public __dbc_c_get_reply __DB_dbc_c_get_4004(__dbc_c_get_msg args) {
00485 __dbc_c_get_reply reply = new __dbc_c_get_reply();
00486 RpcDbc rdbc = getCursor(args.dbccl_id);
00487 if (rdbc == null)
00488 reply.status = DbConstants.DB_NOSERVER_ID;
00489 else
00490 rdbc.get(this, args, reply);
00491 return reply;
00492 }
00493
00494 public __dbc_c_pget_reply __DB_dbc_c_pget_4004(__dbc_c_pget_msg args) {
00495 __dbc_c_pget_reply reply = new __dbc_c_pget_reply();
00496 RpcDbc rdbc = getCursor(args.dbccl_id);
00497 if (rdbc == null)
00498 reply.status = DbConstants.DB_NOSERVER_ID;
00499 else
00500 rdbc.pget(this, args, reply);
00501 return reply;
00502 }
00503
00504 public __dbc_c_put_reply __DB_dbc_c_put_4004(__dbc_c_put_msg args) {
00505 __dbc_c_put_reply reply = new __dbc_c_put_reply();
00506 RpcDbc rdbc = getCursor(args.dbccl_id);
00507 if (rdbc == null)
00508 reply.status = DbConstants.DB_NOSERVER_ID;
00509 else
00510 rdbc.put(this, args, reply);
00511 return reply;
00512 }
00513
00515
00516 public __env_get_cachesize_reply __DB_env_get_cachesize_4004(__env_get_cachesize_msg args) {
00517 __env_get_cachesize_reply reply = new __env_get_cachesize_reply();
00518 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00519 if (rdbenv == null)
00520 reply.status = DbConstants.DB_NOSERVER_ID;
00521 else
00522 rdbenv.get_cachesize(this, args, reply);
00523 return reply;
00524 }
00525
00526 public __env_set_cachesize_reply __DB_env_set_cachesize_4004(__env_set_cachesize_msg args) {
00527 __env_set_cachesize_reply reply = new __env_set_cachesize_reply();
00528 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00529 if (rdbenv == null)
00530 reply.status = DbConstants.DB_NOSERVER_ID;
00531 else
00532 rdbenv.set_cachesize(this, args, reply);
00533 return reply;
00534 }
00535
00536 public __env_close_reply __DB_env_close_4004(__env_close_msg args) {
00537 __env_close_reply reply = new __env_close_reply();
00538 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00539 if (rdbenv == null)
00540 reply.status = DbConstants.DB_NOSERVER_ID;
00541 else
00542 rdbenv.close(this, args, reply);
00543 return reply;
00544 }
00545
00546 public __env_create_reply __DB_env_create_4004(__env_create_msg args) {
00547 __env_create_reply reply = new __env_create_reply();
00548 RpcDbEnv rdbenv = new RpcDbEnv();
00549 rdbenv.create(this, args, reply);
00550 return reply;
00551 }
00552
00553 public __env_dbremove_reply __DB_env_dbremove_4004(__env_dbremove_msg args) {
00554 __env_dbremove_reply reply = new __env_dbremove_reply();
00555 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00556 if (rdbenv == null)
00557 reply.status = DbConstants.DB_NOSERVER_ID;
00558 else
00559 rdbenv.dbremove(this, args, reply);
00560 return reply;
00561 }
00562
00563 public __env_dbrename_reply __DB_env_dbrename_4004(__env_dbrename_msg args) {
00564 __env_dbrename_reply reply = new __env_dbrename_reply();
00565 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00566 if (rdbenv == null)
00567 reply.status = DbConstants.DB_NOSERVER_ID;
00568 else
00569 rdbenv.dbrename(this, args, reply);
00570 return reply;
00571 }
00572
00573 public __env_get_encrypt_flags_reply __DB_env_get_encrypt_flags_4004(__env_get_encrypt_flags_msg args) {
00574 __env_get_encrypt_flags_reply reply = new __env_get_encrypt_flags_reply();
00575 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00576 if (rdbenv == null)
00577 reply.status = DbConstants.DB_NOSERVER_ID;
00578 else
00579 rdbenv.get_encrypt_flags(this, args, reply);
00580 return reply;
00581 }
00582
00583 public __env_set_encrypt_reply __DB_env_set_encrypt_4004(__env_set_encrypt_msg args) {
00584 __env_set_encrypt_reply reply = new __env_set_encrypt_reply();
00585 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00586 if (rdbenv == null)
00587 reply.status = DbConstants.DB_NOSERVER_ID;
00588 else
00589 rdbenv.set_encrypt(this, args, reply);
00590 return reply;
00591 }
00592
00593 public __env_get_flags_reply __DB_env_get_flags_4004(__env_get_flags_msg args) {
00594 __env_get_flags_reply reply = new __env_get_flags_reply();
00595 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00596 if (rdbenv == null)
00597 reply.status = DbConstants.DB_NOSERVER_ID;
00598 else
00599 rdbenv.get_flags(this, args, reply);
00600 return reply;
00601 }
00602
00603 public __env_set_flags_reply __DB_env_set_flags_4004(__env_set_flags_msg args) {
00604 __env_set_flags_reply reply = new __env_set_flags_reply();
00605 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00606 if (rdbenv == null)
00607 reply.status = DbConstants.DB_NOSERVER_ID;
00608 else
00609 rdbenv.set_flags(this, args, reply);
00610 return reply;
00611 }
00612
00613 public __env_get_home_reply __DB_env_get_home_4004(__env_get_home_msg args) {
00614 __env_get_home_reply reply = new __env_get_home_reply();
00615 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00616 if (rdbenv == null)
00617 reply.status = DbConstants.DB_NOSERVER_ID;
00618 else
00619 rdbenv.get_home(this, args, reply);
00620 return reply;
00621 }
00622
00623 public __env_get_open_flags_reply __DB_env_get_open_flags_4004(__env_get_open_flags_msg args) {
00624 __env_get_open_flags_reply reply = new __env_get_open_flags_reply();
00625 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00626 if (rdbenv == null)
00627 reply.status = DbConstants.DB_NOSERVER_ID;
00628 else
00629 rdbenv.get_open_flags(this, args, reply);
00630 return reply;
00631 }
00632
00633 public __env_open_reply __DB_env_open_4004(__env_open_msg args) {
00634 __env_open_reply reply = new __env_open_reply();
00635 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00636 if (rdbenv == null)
00637 reply.status = DbConstants.DB_NOSERVER_ID;
00638 else
00639 rdbenv.open(this, args, reply);
00640 return reply;
00641 }
00642
00643 public __env_remove_reply __DB_env_remove_4004(__env_remove_msg args) {
00644 __env_remove_reply reply = new __env_remove_reply();
00645 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00646 if (rdbenv == null)
00647 reply.status = DbConstants.DB_NOSERVER_ID;
00648 else
00649 rdbenv.remove(this, args, reply);
00650 return reply;
00651 }
00652
00654
00655 public __txn_abort_reply __DB_txn_abort_4004(__txn_abort_msg args) {
00656 __txn_abort_reply reply = new __txn_abort_reply();
00657 RpcDbTxn rdbtxn = getTxn(args.txnpcl_id);
00658 if (rdbtxn == null)
00659 reply.status = DbConstants.DB_NOSERVER_ID;
00660 else
00661 rdbtxn.abort(this, args, reply);
00662 return reply;
00663 }
00664
00665 public __env_txn_begin_reply __DB_env_txn_begin_4004(__env_txn_begin_msg args) {
00666 __env_txn_begin_reply reply = new __env_txn_begin_reply();
00667 RpcDbTxn rdbtxn = new RpcDbTxn(getEnv(args.dbenvcl_id), null);
00668 rdbtxn.begin(this, args, reply);
00669 return reply;
00670 }
00671
00672 public __txn_commit_reply __DB_txn_commit_4004(__txn_commit_msg args) {
00673 __txn_commit_reply reply = new __txn_commit_reply();
00674 RpcDbTxn rdbtxn = getTxn(args.txnpcl_id);
00675 if (rdbtxn == null)
00676 reply.status = DbConstants.DB_NOSERVER_ID;
00677 else
00678 rdbtxn.commit(this, args, reply);
00679 return reply;
00680 }
00681
00682 public __txn_discard_reply __DB_txn_discard_4004(__txn_discard_msg args) {
00683 __txn_discard_reply reply = new __txn_discard_reply();
00684 RpcDbTxn rdbtxn = getTxn(args.txnpcl_id);
00685 if (rdbtxn == null)
00686 reply.status = DbConstants.DB_NOSERVER_ID;
00687 else
00688 rdbtxn.discard(this, args, reply);
00689 return reply;
00690 }
00691
00692 public __txn_prepare_reply __DB_txn_prepare_4004(__txn_prepare_msg args) {
00693 __txn_prepare_reply reply = new __txn_prepare_reply();
00694 RpcDbTxn rdbtxn = getTxn(args.txnpcl_id);
00695 if (rdbtxn == null)
00696 reply.status = DbConstants.DB_NOSERVER_ID;
00697 else
00698 rdbtxn.prepare(this, args, reply);
00699 return reply;
00700 }
00701
00702 public __env_txn_recover_reply __DB_env_txn_recover_4004(__env_txn_recover_msg args) {
00703 __env_txn_recover_reply reply = new __env_txn_recover_reply();
00704 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00705 if (rdbenv == null)
00706 reply.status = DbConstants.DB_NOSERVER_ID;
00707 else
00708 rdbenv.txn_recover(this, args, reply);
00709 return reply;
00710 }
00711 }
