MySQL 5.0.9 Beta: com::sleepycat::db::rpcserver::DbDispatcher Class Reference

00037         {
00038                 super();
00039         }

00044         {
00045                 __db_associate_reply reply = new __db_associate_reply();
00046                 RpcDb rdb = getDb(args.dbpcl_id);
00047                 if (rdb == null)
00048                         reply.status = Db.DB_NOSERVER_ID;
00049                 else
00050                         rdb.associate(this, args, reply);
00051                 return reply;
00052         }

00055         {
00056                 __db_bt_maxkey_reply reply = new __db_bt_maxkey_reply();
00057                 RpcDb rdb = getDb(args.dbpcl_id);
00058                 if (rdb == null)
00059                         reply.status = Db.DB_NOSERVER_ID;
00060                 else
00061                         rdb.set_bt_maxkey(this, args, reply);
00062                 return reply;
00063         }

00066         {
00067                 __db_bt_minkey_reply reply = new __db_bt_minkey_reply();
00068                 RpcDb rdb = getDb(args.dbpcl_id);
00069                 if (rdb == null)
00070                         reply.status = Db.DB_NOSERVER_ID;
00071                 else
00072                         rdb.set_bt_minkey(this, args, reply);
00073                 return reply;
00074         }

00077         {
00078                 __db_close_reply reply = new __db_close_reply();
00079                 RpcDb rdb = getDb(args.dbpcl_id);
00080                 if (rdb == null)
00081                         reply.status = Db.DB_NOSERVER_ID;
00082                 else
00083                         rdb.close(this, args, reply);
00084                 return reply;
00085         }

00088         {
00089                 __db_create_reply reply = new __db_create_reply();
00090                 RpcDb rdb = new RpcDb(getEnv(args.dbenvcl_id));
00091                 if (rdb == null)
00092                         reply.status = Db.DB_NOSERVER_ID;
00093                 else
00094                         rdb.create(this, args, reply);
00095                 return reply;
00096         }

00099         {
00100                 __db_cursor_reply reply = new __db_cursor_reply();
00101                 RpcDb rdb = getDb(args.dbpcl_id);
00102                 if (rdb == null)
00103                         reply.status = Db.DB_NOSERVER_ID;
00104                 else
00105                         rdb.cursor(this, args, reply);
00106                 return reply;
00107         }

00110         {
00111                 __db_del_reply reply = new __db_del_reply();
00112                 RpcDb rdb = getDb(args.dbpcl_id);
00113                 if (rdb == null)
00114                         reply.status = Db.DB_NOSERVER_ID;
00115                 else
00116                         rdb.del(this, args, reply);
00117                 return reply;
00118         }

00121         {
00122                 __db_encrypt_reply reply = new __db_encrypt_reply();
00123                 RpcDb rdb = getDb(args.dbpcl_id);
00124                 if (rdb == null)
00125                         reply.status = Db.DB_NOSERVER_ID;
00126                 else
00127                         rdb.set_encrypt(this, args, reply);
00128                 return reply;
00129         }

00132         {
00133                 __db_extentsize_reply reply = new __db_extentsize_reply();
00134                 RpcDb rdb = getDb(args.dbpcl_id);
00135                 if (rdb == null)
00136                         reply.status = Db.DB_NOSERVER_ID;
00137                 else
00138                         rdb.set_q_extentsize(this, args, reply);
00139                 return reply;
00140         }

00143         {
00144                 __db_flags_reply reply = new __db_flags_reply();
00145                 RpcDb rdb = getDb(args.dbpcl_id);
00146                 if (rdb == null)
00147                         reply.status = Db.DB_NOSERVER_ID;
00148                 else
00149                         rdb.set_flags(this, args, reply);
00150                 return reply;
00151         }

00154         {
00155                 __db_get_reply reply = new __db_get_reply();
00156                 RpcDb rdb = getDb(args.dbpcl_id);
00157                 if (rdb == null)
00158                         reply.status = Db.DB_NOSERVER_ID;
00159                 else
00160                         rdb.get(this, args, reply);
00161                 return reply;
00162         }

00165         {
00166                 __db_h_ffactor_reply reply = new __db_h_ffactor_reply();
00167                 RpcDb rdb = getDb(args.dbpcl_id);
00168                 if (rdb == null)
00169                         reply.status = Db.DB_NOSERVER_ID;
00170                 else
00171                         rdb.set_h_ffactor(this, args, reply);
00172                 return reply;
00173         }

00176         {
00177                 __db_h_nelem_reply reply = new __db_h_nelem_reply();
00178                 RpcDb rdb = getDb(args.dbpcl_id);
00179                 if (rdb == null)
00180                         reply.status = Db.DB_NOSERVER_ID;
00181                 else
00182                         rdb.set_h_nelem(this, args, reply);
00183                 return reply;
00184         }

00187         {
00188                 __db_join_reply reply = new __db_join_reply();
00189                 RpcDb rdb = getDb(args.dbpcl_id);
00190                 if (rdb == null)
00191                         reply.status = Db.DB_NOSERVER_ID;
00192                 else
00193                         rdb.join(this, args, reply);
00194                 return reply;
00195         }

00198         {
00199                 __db_key_range_reply reply = new __db_key_range_reply();
00200                 RpcDb rdb = getDb(args.dbpcl_id);
00201                 if (rdb == null)
00202                         reply.status = Db.DB_NOSERVER_ID;
00203                 else
00204                         rdb.key_range(this, args, reply);
00205                 return reply;
00206         }

00209         {
00210                 __db_lorder_reply reply = new __db_lorder_reply();
00211                 RpcDb rdb = getDb(args.dbpcl_id);
00212                 if (rdb == null)
00213                         reply.status = Db.DB_NOSERVER_ID;
00214                 else
00215                         rdb.set_lorder(this, args, reply);
00216                 return reply;
00217         }

00220         {
00221                 __db_open_reply reply = new __db_open_reply();
00222                 RpcDb rdb = getDb(args.dbpcl_id);
00223                 if (rdb == null)
00224                         reply.status = Db.DB_NOSERVER_ID;
00225                 else
00226                         rdb.open(this, args, reply);
00227                 return reply;
00228         }

00231         {
00232                 __db_pagesize_reply reply = new __db_pagesize_reply();
00233                 RpcDb rdb = getDb(args.dbpcl_id);
00234                 if (rdb == null)
00235                         reply.status = Db.DB_NOSERVER_ID;
00236                 else
00237                         rdb.set_pagesize(this, args, reply);
00238                 return reply;
00239         }

00242         {
00243                 __db_pget_reply reply = new __db_pget_reply();
00244                 RpcDb rdb = getDb(args.dbpcl_id);
00245                 if (rdb == null)
00246                         reply.status = Db.DB_NOSERVER_ID;
00247                 else
00248                         rdb.pget(this, args, reply);
00249                 return reply;
00250         }

00253         {
00254                 __db_put_reply reply = new __db_put_reply();
00255                 RpcDb rdb = getDb(args.dbpcl_id);
00256                 if (rdb == null)
00257                         reply.status = Db.DB_NOSERVER_ID;
00258                 else
00259                         rdb.put(this, args, reply);
00260                 return reply;
00261         }

00286         {
00287                 __db_re_delim_reply reply = new __db_re_delim_reply();
00288                 RpcDb rdb = getDb(args.dbpcl_id);
00289                 if (rdb == null)
00290                         reply.status = Db.DB_NOSERVER_ID;
00291                 else
00292                         rdb.set_re_delim(this, args, reply);
00293                 return reply;
00294         }

00297         {
00298                 __db_re_len_reply reply = new __db_re_len_reply();
00299                 RpcDb rdb = getDb(args.dbpcl_id);
00300                 if (rdb == null)
00301                         reply.status = Db.DB_NOSERVER_ID;
00302                 else
00303                         rdb.set_re_len(this, args, reply);
00304                 return reply;
00305         }

00308         {
00309                 __db_re_pad_reply reply = new __db_re_pad_reply();
00310                 RpcDb rdb = getDb(args.dbpcl_id);
00311                 if (rdb == null)
00312                         reply.status = Db.DB_NOSERVER_ID;
00313                 else
00314                         rdb.set_re_pad(this, args, reply);
00315                 return reply;
00316         }

00264         {
00265                 __db_remove_reply reply = new __db_remove_reply();
00266                 RpcDb rdb = getDb(args.dbpcl_id);
00267                 if (rdb == null)
00268                         reply.status = Db.DB_NOSERVER_ID;
00269                 else
00270                         rdb.remove(this, args, reply);
00271                 return reply;
00272         }

00275         {
00276                 __db_rename_reply reply = new __db_rename_reply();
00277                 RpcDb rdb = getDb(args.dbpcl_id);
00278                 if (rdb == null)
00279                         reply.status = Db.DB_NOSERVER_ID;
00280                 else
00281                         rdb.rename(this, args, reply);
00282                 return reply;
00283         }

00319         {
00320                 __db_stat_reply reply = new __db_stat_reply();
00321                 RpcDb rdb = getDb(args.dbpcl_id);
00322                 if (rdb == null)
00323                         reply.status = Db.DB_NOSERVER_ID;
00324                 else
00325                         rdb.stat(this, args, reply);
00326                 return reply;
00327         }

00330         {
00331                 __db_sync_reply reply = new __db_sync_reply();
00332                 RpcDb rdb = getDb(args.dbpcl_id);
00333                 if (rdb == null)
00334                         reply.status = Db.DB_NOSERVER_ID;
00335                 else
00336                         rdb.sync(this, args, reply);
00337                 return reply;
00338         }

00341         {
00342                 __db_truncate_reply reply = new __db_truncate_reply();
00343                 RpcDb rdb = getDb(args.dbpcl_id);
00344                 if (rdb == null)
00345                         reply.status = Db.DB_NOSERVER_ID;
00346                 else
00347                         rdb.truncate(this, args, reply);
00348                 return reply;
00349         }

00354         {
00355                 __dbc_close_reply reply = new __dbc_close_reply();
00356                 RpcDbc rdbc = getCursor(args.dbccl_id);
00357                 if (rdbc == null)
00358                         reply.status = Db.DB_NOSERVER_ID;
00359                 else
00360                         rdbc.close(this, args, reply);
00361                 return reply;
00362         }

00365         {
00366                 __dbc_count_reply reply = new __dbc_count_reply();
00367                 RpcDbc rdbc = getCursor(args.dbccl_id);
00368                 if (rdbc == null)
00369                         reply.status = Db.DB_NOSERVER_ID;
00370                 else
00371                         rdbc.count(this, args, reply);
00372                 return reply;
00373         }

00376         {
00377                 __dbc_del_reply reply = new __dbc_del_reply();
00378                 RpcDbc rdbc = getCursor(args.dbccl_id);
00379                 if (rdbc == null)
00380                         reply.status = Db.DB_NOSERVER_ID;
00381                 else
00382                         rdbc.del(this, args, reply);
00383                 return reply;
00384         }

00387         {
00388                 __dbc_dup_reply reply = new __dbc_dup_reply();
00389                 RpcDbc rdbc = getCursor(args.dbccl_id);
00390                 if (rdbc == null)
00391                         reply.status = Db.DB_NOSERVER_ID;
00392                 else
00393                         rdbc.dup(this, args, reply);
00394                 return reply;
00395         }

00398         {
00399                 __dbc_get_reply reply = new __dbc_get_reply();
00400                 RpcDbc rdbc = getCursor(args.dbccl_id);
00401                 if (rdbc == null)
00402                         reply.status = Db.DB_NOSERVER_ID;
00403                 else
00404                         rdbc.get(this, args, reply);
00405                 return reply;
00406         }

00408                                                                          {
00409                 __dbc_pget_reply reply = new __dbc_pget_reply();
00410                 RpcDbc rdbc = getCursor(args.dbccl_id);
00411                 if (rdbc == null)
00412                         reply.status = Db.DB_NOSERVER_ID;
00413                 else
00414                         rdbc.pget(this, args, reply);
00415                 return reply;
00416         }

00418                                                                       {
00419                 __dbc_put_reply reply = new __dbc_put_reply();
00420                 RpcDbc rdbc = getCursor(args.dbccl_id);
00421                 if (rdbc == null)
00422                         reply.status = Db.DB_NOSERVER_ID;
00423                 else
00424                         rdbc.put(this, args, reply);
00425                 return reply;
00426         }

00431         {
00432                 __env_cachesize_reply reply = new __env_cachesize_reply();
00433                 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00434                 if (rdbenv == null)
00435                         reply.status = Db.DB_NOSERVER_ID;
00436                 else
00437                         rdbenv.set_cachesize(this, args, reply);
00438                 return reply;
00439         }

00442         {
00443                 __env_close_reply reply = new __env_close_reply();
00444                 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00445                 if (rdbenv == null)
00446                         reply.status = Db.DB_NOSERVER_ID;
00447                 else
00448                         rdbenv.close(this, args, reply);
00449                 return reply;
00450         }

00453         {
00454                 __env_create_reply reply = new __env_create_reply();
00455                 RpcDbEnv rdbenv = new RpcDbEnv();
00456                 rdbenv.create(this, args, reply);
00457                 return reply;
00458         }

00461         {
00462                 __env_dbremove_reply reply = new __env_dbremove_reply();
00463                 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00464                 if (rdbenv == null)
00465                         reply.status = Db.DB_NOSERVER_ID;
00466                 else
00467                         rdbenv.dbremove(this, args, reply);
00468                 return reply;
00469         }

00472         {
00473                 __env_dbrename_reply reply = new __env_dbrename_reply();
00474                 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00475                 if (rdbenv == null)
00476                         reply.status = Db.DB_NOSERVER_ID;
00477                 else
00478                         rdbenv.dbrename(this, args, reply);
00479                 return reply;
00480         }

00483         {
00484                 __env_encrypt_reply reply = new __env_encrypt_reply();
00485                 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00486                 if (rdbenv == null)
00487                         reply.status = Db.DB_NOSERVER_ID;
00488                 else
00489                         rdbenv.set_encrypt(this, args, reply);
00490                 return reply;
00491         }

00494         {
00495                 __env_flags_reply reply = new __env_flags_reply();
00496                 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00497                 if (rdbenv == null)
00498                         reply.status = Db.DB_NOSERVER_ID;
00499                 else
00500                         rdbenv.set_flags(this, args, reply);
00501                 return reply;
00502         }

00505         {
00506                 __env_open_reply reply = new __env_open_reply();
00507                 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00508                 if (rdbenv == null)
00509                         reply.status = Db.DB_NOSERVER_ID;
00510                 else
00511                         rdbenv.open(this, args, reply);
00512                 return reply;
00513         }

00516         {
00517                 __env_remove_reply reply = new __env_remove_reply();
00518                 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00519                 if (rdbenv == null)
00520                         reply.status = Db.DB_NOSERVER_ID;
00521                 else
00522                         rdbenv.remove(this, args, reply);
00523                 return reply;
00524         }

00529         {
00530                 __txn_abort_reply reply = new __txn_abort_reply();
00531                 RpcDbTxn rdbtxn = getTxn(args.txnpcl_id);
00532                 if (rdbtxn == null)
00533                         reply.status = Db.DB_NOSERVER_ID;
00534                 else
00535                         rdbtxn.abort(this, args, reply);
00536                 return reply;
00537         }

00540         {
00541                 __txn_begin_reply reply = new __txn_begin_reply();
00542                 RpcDbTxn rdbtxn = new RpcDbTxn(getEnv(args.dbenvcl_id), null);
00543                 rdbtxn.begin(this, args, reply);
00544                 return reply;
00545         }

00548         {
00549                 __txn_commit_reply reply = new __txn_commit_reply();
00550                 RpcDbTxn rdbtxn = getTxn(args.txnpcl_id);
00551                 if (rdbtxn == null)
00552                         reply.status = Db.DB_NOSERVER_ID;
00553                 else
00554                         rdbtxn.commit(this, args, reply);
00555                 return reply;
00556         }

00559         {
00560                 __txn_discard_reply reply = new __txn_discard_reply();
00561                 RpcDbTxn rdbtxn = getTxn(args.txnpcl_id);
00562                 if (rdbtxn == null)
00563                         reply.status = Db.DB_NOSERVER_ID;
00564                 else
00565                         rdbtxn.discard(this, args, reply);
00566                 return reply;
00567         }

00570         {
00571                 __txn_prepare_reply reply = new __txn_prepare_reply();
00572                 RpcDbTxn rdbtxn = getTxn(args.txnpcl_id);
00573                 if (rdbtxn == null)
00574                         reply.status = Db.DB_NOSERVER_ID;
00575                 else
00576                         rdbtxn.prepare(this, args, reply);
00577                 return reply;
00578         }

00581         {
00582                 __txn_recover_reply reply = new __txn_recover_reply();
00583                 RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
00584                 if (rdbenv == null)
00585                         reply.status = Db.DB_NOSERVER_ID;
00586                 else
00587                         rdbenv.txn_recover(this, args, reply);
00588                 return reply;
00589         }


Public Member Functions
__db_associate_reply	__DB_db_associate_4001 (__db_associate_msg args)
__db_bt_maxkey_reply	__DB_db_bt_maxkey_4001 (__db_bt_maxkey_msg args)
__db_bt_minkey_reply	__DB_db_bt_minkey_4001 (__db_bt_minkey_msg args)
__db_close_reply	__DB_db_close_4001 (__db_close_msg args)
__db_create_reply	__DB_db_create_4001 (__db_create_msg args)
__db_cursor_reply	__DB_db_cursor_4001 (__db_cursor_msg args)
__db_del_reply	__DB_db_del_4001 (__db_del_msg args)
__db_encrypt_reply	__DB_db_encrypt_4001 (__db_encrypt_msg args)
__db_extentsize_reply	__DB_db_extentsize_4001 (__db_extentsize_msg args)
__db_flags_reply	__DB_db_flags_4001 (__db_flags_msg args)
__db_get_reply	__DB_db_get_4001 (__db_get_msg args)
__db_h_ffactor_reply	__DB_db_h_ffactor_4001 (__db_h_ffactor_msg args)
__db_h_nelem_reply	__DB_db_h_nelem_4001 (__db_h_nelem_msg args)
__db_join_reply	__DB_db_join_4001 (__db_join_msg args)
__db_key_range_reply	__DB_db_key_range_4001 (__db_key_range_msg args)
__db_lorder_reply	__DB_db_lorder_4001 (__db_lorder_msg args)
__db_open_reply	__DB_db_open_4001 (__db_open_msg args)
__db_pagesize_reply	__DB_db_pagesize_4001 (__db_pagesize_msg args)
__db_pget_reply	__DB_db_pget_4001 (__db_pget_msg args)
__db_put_reply	__DB_db_put_4001 (__db_put_msg args)
__db_re_delim_reply	__DB_db_re_delim_4001 (__db_re_delim_msg args)
__db_re_len_reply	__DB_db_re_len_4001 (__db_re_len_msg args)
__db_re_pad_reply	__DB_db_re_pad_4001 (__db_re_pad_msg args)
__db_remove_reply	__DB_db_remove_4001 (__db_remove_msg args)
__db_rename_reply	__DB_db_rename_4001 (__db_rename_msg args)
__db_stat_reply	__DB_db_stat_4001 (__db_stat_msg args)
__db_sync_reply	__DB_db_sync_4001 (__db_sync_msg args)
__db_truncate_reply	__DB_db_truncate_4001 (__db_truncate_msg args)
__dbc_close_reply	__DB_dbc_close_4001 (__dbc_close_msg args)
__dbc_count_reply	__DB_dbc_count_4001 (__dbc_count_msg args)
__dbc_del_reply	__DB_dbc_del_4001 (__dbc_del_msg args)
__dbc_dup_reply	__DB_dbc_dup_4001 (__dbc_dup_msg args)
__dbc_get_reply	__DB_dbc_get_4001 (__dbc_get_msg args)
__dbc_pget_reply	__DB_dbc_pget_4001 (__dbc_pget_msg args)
__dbc_put_reply	__DB_dbc_put_4001 (__dbc_put_msg args)
__env_cachesize_reply	__DB_env_cachesize_4001 (__env_cachesize_msg args)
__env_close_reply	__DB_env_close_4001 (__env_close_msg args)
__env_create_reply	__DB_env_create_4001 (__env_create_msg args)
__env_dbremove_reply	__DB_env_dbremove_4001 (__env_dbremove_msg args)
__env_dbrename_reply	__DB_env_dbrename_4001 (__env_dbrename_msg args)
__env_encrypt_reply	__DB_env_encrypt_4001 (__env_encrypt_msg args)
__env_flags_reply	__DB_env_flags_4001 (__env_flags_msg args)
__env_open_reply	__DB_env_open_4001 (__env_open_msg args)
__env_remove_reply	__DB_env_remove_4001 (__env_remove_msg args)
__txn_abort_reply	__DB_txn_abort_4001 (__txn_abort_msg args)
__txn_begin_reply	__DB_txn_begin_4001 (__txn_begin_msg args)
__txn_commit_reply	__DB_txn_commit_4001 (__txn_commit_msg args)
__txn_discard_reply	__DB_txn_discard_4001 (__txn_discard_msg args)
__txn_prepare_reply	__DB_txn_prepare_4001 (__txn_prepare_msg args)
__txn_recover_reply	__DB_txn_recover_4001 (__txn_recover_msg args)
	DbDispatcher () throws IOException, OncRpcException
Package Functions
abstract int	addCursor (RpcDbc rdbc)
abstract int	addDb (RpcDb rdb)
abstract int	addEnv (RpcDbEnv rdbenv)
abstract int	addTxn (RpcDbTxn rtxn)
abstract void	delCursor (RpcDbc rdbc)
abstract void	delDb (RpcDb rdb)
abstract void	delEnv (RpcDbEnv rdbenv)
abstract void	delTxn (RpcDbTxn rtxn)
abstract RpcDbc	getCursor (int dbcid)
abstract RpcDb	getDb (int dbid)
abstract RpcDbEnv	getEnv (int envid)
abstract RpcDbTxn	getTxn (int txnbid)

com::sleepycat::db::rpcserver::DbDispatcher Class Reference

Detailed Description

Public Member Functions

Package Functions

Constructor & Destructor Documentation

Member Function Documentation