/*-
 * See the file LICENSE for redistribution information.
 *
 * Copyright (c) 2001-2004
 *	Sleepycat Software.  All rights reserved.
 *
 * $Id: Dispatcher.java,v 1.1 2004/04/06 20:43:41 mjc Exp $
 */

package com.sleepycat.db.rpcserver;

import com.sleepycat.db.*;
import com.sleepycat.db.internal.DbConstants;
import java.io.IOException;
import org.acplt.oncrpc.OncRpcException;

/**
 * Dispatcher for RPC messages for the Java RPC server.
 * These are hooks that translate between RPC msg/reply structures and
 * DB calls, which keeps the real implementation code in Rpc* classes cleaner.
 */
public abstract class Dispatcher extends ServerStubs {
    abstract int addEnv(RpcDbEnv rdbenv);
    abstract int addDatabase(RpcDb rdb);
    abstract int addTxn(RpcDbTxn rtxn);
    abstract int addCursor(RpcDbc rdbc);
    abstract void delEnv(RpcDbEnv rdbenv, boolean dispose);
    abstract void delDatabase(RpcDb rdb, boolean dispose);
    abstract void delTxn(RpcDbTxn rtxn, boolean dispose);
    abstract void delCursor(RpcDbc rdbc, boolean dispose);
    abstract RpcDbEnv getEnv(int envid);
    abstract RpcDb getDatabase(int dbid);
    abstract RpcDbTxn getTxn(int txnbid);
    abstract RpcDbc getCursor(int dbcid);

    public Dispatcher() throws IOException, OncRpcException {
        super();
    }

    //// Database methods

    public  __db_associate_reply __DB_db_associate_4003(__db_associate_msg args) {
        __db_associate_reply reply = new __db_associate_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.associate(this, args, reply);
        return reply;
    }

    public  __db_bt_maxkey_reply __DB_db_bt_maxkey_4003(__db_bt_maxkey_msg args) {
        __db_bt_maxkey_reply reply = new __db_bt_maxkey_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.set_bt_maxkey(this, args, reply);
        return reply;
    }

    public __db_get_bt_minkey_reply __DB_db_get_bt_minkey_4003(__db_get_bt_minkey_msg args) {
        __db_get_bt_minkey_reply reply = new __db_get_bt_minkey_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.get_bt_minkey(this, args, reply);
        return reply;
    }

    public  __db_bt_minkey_reply __DB_db_bt_minkey_4003(__db_bt_minkey_msg args) {
        __db_bt_minkey_reply reply = new __db_bt_minkey_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.set_bt_minkey(this, args, reply);
        return reply;
    }

    public  __db_close_reply __DB_db_close_4003(__db_close_msg args)  {
        __db_close_reply reply = new __db_close_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.close(this, args, reply);
        return reply;
    }

    public  __db_create_reply __DB_db_create_4003(__db_create_msg args) {
        __db_create_reply reply = new __db_create_reply();
        RpcDb rdb = new RpcDb(getEnv(args.dbenvcl_id));
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.create(this, args, reply);
        return reply;
    }

    public  __db_cursor_reply __DB_db_cursor_4003(__db_cursor_msg args) {
        __db_cursor_reply reply = new __db_cursor_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.cursor(this, args, reply);
        return reply;
    }

    public  __db_del_reply __DB_db_del_4003(__db_del_msg args) {
        __db_del_reply reply = new __db_del_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.del(this, args, reply);
        return reply;
    }

    public __db_get_encrypt_flags_reply __DB_db_get_encrypt_flags_4003(__db_get_encrypt_flags_msg args) {
        __db_get_encrypt_flags_reply reply = new __db_get_encrypt_flags_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.get_encrypt_flags(this, args, reply);
        return reply;
    }

    public  __db_encrypt_reply __DB_db_encrypt_4003(__db_encrypt_msg args) {
        __db_encrypt_reply reply = new __db_encrypt_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.set_encrypt(this, args, reply);
        return reply;
    }

    public __db_get_extentsize_reply __DB_db_get_extentsize_4003(__db_get_extentsize_msg args) {
        __db_get_extentsize_reply reply = new __db_get_extentsize_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.get_q_extentsize(this, args, reply);
        return reply;
    }

    public  __db_extentsize_reply __DB_db_extentsize_4003(__db_extentsize_msg args) {
        __db_extentsize_reply reply = new __db_extentsize_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.set_q_extentsize(this, args, reply);
        return reply;
    }

    public __db_get_flags_reply __DB_db_get_flags_4003(__db_get_flags_msg args) {
        __db_get_flags_reply reply = new __db_get_flags_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.get_flags(this, args, reply);
        return reply;
    }

    public  __db_flags_reply __DB_db_flags_4003(__db_flags_msg args) {
        __db_flags_reply reply = new __db_flags_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.set_flags(this, args, reply);
        return reply;
    }

    public  __db_get_reply __DB_db_get_4003(__db_get_msg args) {
        __db_get_reply reply = new __db_get_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.get(this, args, reply);
        return reply;
    }

    public __db_get_h_ffactor_reply __DB_db_get_h_ffactor_4003(__db_get_h_ffactor_msg args) {
        __db_get_h_ffactor_reply reply = new __db_get_h_ffactor_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.get_h_ffactor(this, args, reply);
        return reply;
    }

    public  __db_h_ffactor_reply __DB_db_h_ffactor_4003(__db_h_ffactor_msg args) {
        __db_h_ffactor_reply reply = new __db_h_ffactor_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.set_h_ffactor(this, args, reply);
        return reply;
    }

    public __db_get_h_nelem_reply __DB_db_get_h_nelem_4003(__db_get_h_nelem_msg args) {
        __db_get_h_nelem_reply reply = new __db_get_h_nelem_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.get_h_nelem(this, args, reply);
        return reply;
    }

    public  __db_h_nelem_reply __DB_db_h_nelem_4003(__db_h_nelem_msg args) {
        __db_h_nelem_reply reply = new __db_h_nelem_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.set_h_nelem(this, args, reply);
        return reply;
    }

    public  __db_join_reply __DB_db_join_4003(__db_join_msg args) {
        __db_join_reply reply = new __db_join_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.join(this, args, reply);
        return reply;
    }

    public  __db_key_range_reply __DB_db_key_range_4003(__db_key_range_msg args) {
        __db_key_range_reply reply = new __db_key_range_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.key_range(this, args, reply);
        return reply;
    }

    public __db_get_lorder_reply __DB_db_get_lorder_4003(__db_get_lorder_msg args) {
        __db_get_lorder_reply reply = new __db_get_lorder_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.get_lorder(this, args, reply);
        return reply;
    }

    public  __db_lorder_reply __DB_db_lorder_4003(__db_lorder_msg args) {
        __db_lorder_reply reply = new __db_lorder_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.set_lorder(this, args, reply);
        return reply;
    }

    public __db_get_name_reply __DB_db_get_name_4003(__db_get_name_msg args) {
        __db_get_name_reply reply = new __db_get_name_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.get_name(this, args, reply);
        return reply;
    }

    public __db_get_open_flags_reply __DB_db_get_open_flags_4003(__db_get_open_flags_msg args) {
        __db_get_open_flags_reply reply = new __db_get_open_flags_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.get_open_flags(this, args, reply);
        return reply;
    }

    public  __db_open_reply __DB_db_open_4003(__db_open_msg args) {
        __db_open_reply reply = new __db_open_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.open(this, args, reply);
        return reply;
    }

    public __db_get_pagesize_reply __DB_db_get_pagesize_4003(__db_get_pagesize_msg args) {
        __db_get_pagesize_reply reply = new __db_get_pagesize_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.get_pagesize(this, args, reply);
        return reply;
    }

    public  __db_pagesize_reply __DB_db_pagesize_4003(__db_pagesize_msg args) {
        __db_pagesize_reply reply = new __db_pagesize_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.set_pagesize(this, args, reply);
        return reply;
    }

    public  __db_pget_reply __DB_db_pget_4003(__db_pget_msg args) {
        __db_pget_reply reply = new __db_pget_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.pget(this, args, reply);
        return reply;
    }

    public  __db_put_reply __DB_db_put_4003(__db_put_msg args) {
        __db_put_reply reply = new __db_put_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.put(this, args, reply);
        return reply;
    }

    public  __db_remove_reply __DB_db_remove_4003(__db_remove_msg args) {
        __db_remove_reply reply = new __db_remove_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.remove(this, args, reply);
        return reply;
    }

    public  __db_rename_reply __DB_db_rename_4003(__db_rename_msg args) {
        __db_rename_reply reply = new __db_rename_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.rename(this, args, reply);
        return reply;
    }

    public __db_get_re_delim_reply __DB_db_get_re_delim_4003(__db_get_re_delim_msg args) {
        __db_get_re_delim_reply reply = new __db_get_re_delim_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.get_re_delim(this, args, reply);
        return reply;
    }

    public  __db_re_delim_reply __DB_db_re_delim_4003(__db_re_delim_msg args) {
        __db_re_delim_reply reply = new __db_re_delim_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.set_re_delim(this, args, reply);
        return reply;
    }

    public __db_get_re_len_reply __DB_db_get_re_len_4003(__db_get_re_len_msg args) {
        __db_get_re_len_reply reply = new __db_get_re_len_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.get_re_len(this, args, reply);
        return reply;
    }

    public  __db_re_len_reply __DB_db_re_len_4003(__db_re_len_msg args) {
        __db_re_len_reply reply = new __db_re_len_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.set_re_len(this, args, reply);
        return reply;
    }

    public __db_get_re_pad_reply __DB_db_get_re_pad_4003(__db_get_re_pad_msg args) {
        __db_get_re_pad_reply reply = new __db_get_re_pad_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.get_re_pad(this, args, reply);
        return reply;
    }

    public  __db_re_pad_reply __DB_db_re_pad_4003(__db_re_pad_msg args) {
        __db_re_pad_reply reply = new __db_re_pad_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.set_re_pad(this, args, reply);
        return reply;
    }

    public  __db_stat_reply __DB_db_stat_4003(__db_stat_msg args) {
        __db_stat_reply reply = new __db_stat_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.stat(this, args, reply);
        return reply;
    }

    public  __db_sync_reply __DB_db_sync_4003(__db_sync_msg args) {
        __db_sync_reply reply = new __db_sync_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.sync(this, args, reply);
        return reply;
    }

    public  __db_truncate_reply __DB_db_truncate_4003(__db_truncate_msg args) {
        __db_truncate_reply reply = new __db_truncate_reply();
        RpcDb rdb = getDatabase(args.dbpcl_id);
        if (rdb == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdb.truncate(this, args, reply);
        return reply;
    }

    //// Cursor methods

    public  __dbc_close_reply __DB_dbc_close_4003(__dbc_close_msg args) {
        __dbc_close_reply reply = new __dbc_close_reply();
        RpcDbc rdbc = getCursor(args.dbccl_id);
        if (rdbc == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbc.close(this, args, reply);
        return reply;
    }

    public  __dbc_count_reply __DB_dbc_count_4003(__dbc_count_msg args) {
        __dbc_count_reply reply = new __dbc_count_reply();
        RpcDbc rdbc = getCursor(args.dbccl_id);
        if (rdbc == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbc.count(this, args, reply);
        return reply;
    }

    public  __dbc_del_reply __DB_dbc_del_4003(__dbc_del_msg args) {
        __dbc_del_reply reply = new __dbc_del_reply();
        RpcDbc rdbc = getCursor(args.dbccl_id);
        if (rdbc == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbc.del(this, args, reply);
        return reply;
    }

    public  __dbc_dup_reply __DB_dbc_dup_4003(__dbc_dup_msg args) {
        __dbc_dup_reply reply = new __dbc_dup_reply();
        RpcDbc rdbc = getCursor(args.dbccl_id);
        if (rdbc == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbc.dup(this, args, reply);
        return reply;
    }

    public  __dbc_get_reply __DB_dbc_get_4003(__dbc_get_msg args) {
        __dbc_get_reply reply = new __dbc_get_reply();
        RpcDbc rdbc = getCursor(args.dbccl_id);
        if (rdbc == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbc.get(this, args, reply);
        return reply;
    }

    public  __dbc_pget_reply __DB_dbc_pget_4003(__dbc_pget_msg args) {
        __dbc_pget_reply reply = new __dbc_pget_reply();
        RpcDbc rdbc = getCursor(args.dbccl_id);
        if (rdbc == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbc.pget(this, args, reply);
        return reply;
    }

    public  __dbc_put_reply __DB_dbc_put_4003(__dbc_put_msg args) {
        __dbc_put_reply reply = new __dbc_put_reply();
        RpcDbc rdbc = getCursor(args.dbccl_id);
        if (rdbc == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbc.put(this, args, reply);
        return reply;
    }

    //// Environment methods

    public __env_get_cachesize_reply __DB_env_get_cachesize_4003(__env_get_cachesize_msg args) {
        __env_get_cachesize_reply reply = new __env_get_cachesize_reply();
        RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
        if (rdbenv == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbenv.get_cachesize(this, args, reply);
        return reply;
    }

    public  __env_cachesize_reply __DB_env_cachesize_4003(__env_cachesize_msg args) {
        __env_cachesize_reply reply = new __env_cachesize_reply();
        RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
        if (rdbenv == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbenv.set_cachesize(this, args, reply);
        return reply;
    }

    public  __env_close_reply __DB_env_close_4003(__env_close_msg args) {
        __env_close_reply reply = new __env_close_reply();
        RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
        if (rdbenv == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbenv.close(this, args, reply);
        return reply;
    }

    public  __env_create_reply __DB_env_create_4003(__env_create_msg args) {
        __env_create_reply reply = new __env_create_reply();
        RpcDbEnv rdbenv = new RpcDbEnv();
        rdbenv.create(this, args, reply);
        return reply;
    }

    public  __env_dbremove_reply __DB_env_dbremove_4003(__env_dbremove_msg args) {
        __env_dbremove_reply reply = new __env_dbremove_reply();
        RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
        if (rdbenv == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbenv.dbremove(this, args, reply);
        return reply;
    }

    public  __env_dbrename_reply __DB_env_dbrename_4003(__env_dbrename_msg args) {
        __env_dbrename_reply reply = new __env_dbrename_reply();
        RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
        if (rdbenv == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbenv.dbrename(this, args, reply);
        return reply;
    }

    public __env_get_encrypt_flags_reply __DB_env_get_encrypt_flags_4003(__env_get_encrypt_flags_msg args) {
        __env_get_encrypt_flags_reply reply = new __env_get_encrypt_flags_reply();
        RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
        if (rdbenv == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbenv.get_encrypt_flags(this, args, reply);
        return reply;
    }

    public  __env_encrypt_reply __DB_env_encrypt_4003(__env_encrypt_msg args) {
        __env_encrypt_reply reply = new __env_encrypt_reply();
        RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
        if (rdbenv == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbenv.set_encrypt(this, args, reply);
        return reply;
    }

    public __env_get_flags_reply __DB_env_get_flags_4003(__env_get_flags_msg args) {
        __env_get_flags_reply reply = new __env_get_flags_reply();
        RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
        if (rdbenv == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbenv.get_flags(this, args, reply);
        return reply;
    }

    public  __env_flags_reply __DB_env_flags_4003(__env_flags_msg args) {
        __env_flags_reply reply = new __env_flags_reply();
        RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
        if (rdbenv == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbenv.set_flags(this, args, reply);
        return reply;
    }

    public __env_get_home_reply __DB_env_get_home_4003(__env_get_home_msg args) {
        __env_get_home_reply reply = new __env_get_home_reply();
        RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
        if (rdbenv == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbenv.get_home(this, args, reply);
        return reply;
    }

    public __env_get_open_flags_reply __DB_env_get_open_flags_4003(__env_get_open_flags_msg args) {
        __env_get_open_flags_reply reply = new __env_get_open_flags_reply();
        RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
        if (rdbenv == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbenv.get_open_flags(this, args, reply);
        return reply;
    }

    public  __env_open_reply __DB_env_open_4003(__env_open_msg args) {
        __env_open_reply reply = new __env_open_reply();
        RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
        if (rdbenv == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbenv.open(this, args, reply);
        return reply;
    }

    public  __env_remove_reply __DB_env_remove_4003(__env_remove_msg args) {
        __env_remove_reply reply = new __env_remove_reply();
        RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
        if (rdbenv == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbenv.remove(this, args, reply);
        return reply;
    }

    //// Transaction methods

    public  __txn_abort_reply __DB_txn_abort_4003(__txn_abort_msg args) {
        __txn_abort_reply reply = new __txn_abort_reply();
        RpcDbTxn rdbtxn = getTxn(args.txnpcl_id);
        if (rdbtxn == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbtxn.abort(this, args, reply);
        return reply;
    }

    public  __txn_begin_reply __DB_txn_begin_4003(__txn_begin_msg args) {
        __txn_begin_reply reply = new __txn_begin_reply();
        RpcDbTxn rdbtxn = new RpcDbTxn(getEnv(args.dbenvcl_id), null);
        rdbtxn.begin(this, args, reply);
        return reply;
    }

    public  __txn_commit_reply __DB_txn_commit_4003(__txn_commit_msg args) {
        __txn_commit_reply reply = new __txn_commit_reply();
        RpcDbTxn rdbtxn = getTxn(args.txnpcl_id);
        if (rdbtxn == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbtxn.commit(this, args, reply);
        return reply;
    }

    public  __txn_discard_reply __DB_txn_discard_4003(__txn_discard_msg args) {
        __txn_discard_reply reply = new __txn_discard_reply();
        RpcDbTxn rdbtxn = getTxn(args.txnpcl_id);
        if (rdbtxn == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbtxn.discard(this, args, reply);
        return reply;
    }

    public  __txn_prepare_reply __DB_txn_prepare_4003(__txn_prepare_msg args) {
        __txn_prepare_reply reply = new __txn_prepare_reply();
        RpcDbTxn rdbtxn = getTxn(args.txnpcl_id);
        if (rdbtxn == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbtxn.prepare(this, args, reply);
        return reply;
    }

    public  __txn_recover_reply __DB_txn_recover_4003(__txn_recover_msg args) {
        __txn_recover_reply reply = new __txn_recover_reply();
        RpcDbEnv rdbenv = getEnv(args.dbenvcl_id);
        if (rdbenv == null)
            reply.status = DbConstants.DB_NOSERVER_ID;
        else
            rdbenv.txn_recover(this, args, reply);
        return reply;
    }
}