📄 gen_client.c
字号:
/* * PUBLIC: int __dbcl_set_tas_spins __P((DB_ENV *, u_int32_t)); */int__dbcl_set_tas_spins(dbenv, tas_spins) DB_ENV * dbenv; u_int32_t tas_spins;{ COMPQUIET(tas_spins, 0); return (__dbcl_rpc_illegal(dbenv, "set_tas_spins"));}/* * PUBLIC: int __dbcl_set_timeout __P((DB_ENV *, u_int32_t, u_int32_t)); */int__dbcl_set_timeout(dbenv, timeout, flags) DB_ENV * dbenv; u_int32_t timeout; u_int32_t flags;{ COMPQUIET(timeout, 0); COMPQUIET(flags, 0); return (__dbcl_rpc_illegal(dbenv, "set_timeout"));}/* * PUBLIC: int __dbcl_set_tmp_dir __P((DB_ENV *, const char *)); */int__dbcl_set_tmp_dir(dbenv, dir) DB_ENV * dbenv; const char * dir;{ COMPQUIET(dir, NULL); return (__dbcl_rpc_illegal(dbenv, "set_tmp_dir"));}/* * PUBLIC: int __dbcl_set_tx_max __P((DB_ENV *, u_int32_t)); */int__dbcl_set_tx_max(dbenv, max) DB_ENV * dbenv; u_int32_t max;{ COMPQUIET(max, 0); return (__dbcl_rpc_illegal(dbenv, "set_tx_max"));}/* * PUBLIC: int __dbcl_set_tx_timestamp __P((DB_ENV *, time_t *)); */int__dbcl_set_tx_timestamp(dbenv, max) DB_ENV * dbenv; time_t * max;{ COMPQUIET(max, 0); return (__dbcl_rpc_illegal(dbenv, "set_tx_timestamp"));}/* * PUBLIC: int __dbcl_set_verbose __P((DB_ENV *, u_int32_t, int)); */int__dbcl_set_verbose(dbenv, which, onoff) DB_ENV * dbenv; u_int32_t which; int onoff;{ COMPQUIET(which, 0); COMPQUIET(onoff, 0); return (__dbcl_rpc_illegal(dbenv, "set_verbose"));}/* * PUBLIC: int __dbcl_txn_abort __P((DB_TXN *)); */int__dbcl_txn_abort(txnp) DB_TXN * txnp;{ CLIENT *cl; __txn_abort_msg msg; __txn_abort_reply *replyp = NULL; int ret; DB_ENV *dbenv; ret = 0; dbenv = txnp->mgrp->dbenv; if (dbenv == NULL || !RPC_ON(dbenv)) return (__dbcl_noserver(NULL)); cl = (CLIENT *)dbenv->cl_handle; if (txnp == NULL) msg.txnpcl_id = 0; else msg.txnpcl_id = txnp->txnid; replyp = __db_txn_abort_4001(&msg, cl); if (replyp == NULL) { __db_err(dbenv, clnt_sperror(cl, "Berkeley DB")); ret = DB_NOSERVER; goto out; } ret = __dbcl_txn_abort_ret(txnp, replyp);out: if (replyp != NULL) xdr_free((xdrproc_t)xdr___txn_abort_reply, (void *)replyp); return (ret);}/* * PUBLIC: int __dbcl_txn_begin __P((DB_ENV *, DB_TXN *, DB_TXN **, * PUBLIC: u_int32_t)); */int__dbcl_txn_begin(dbenv, parent, txnpp, flags) DB_ENV * dbenv; DB_TXN * parent; DB_TXN ** txnpp; u_int32_t flags;{ CLIENT *cl; __txn_begin_msg msg; __txn_begin_reply *replyp = NULL; int ret; ret = 0; if (dbenv == NULL || !RPC_ON(dbenv)) return (__dbcl_noserver(dbenv)); cl = (CLIENT *)dbenv->cl_handle; if (dbenv == NULL) msg.dbenvcl_id = 0; else msg.dbenvcl_id = dbenv->cl_id; if (parent == NULL) msg.parentcl_id = 0; else msg.parentcl_id = parent->txnid; msg.flags = flags; replyp = __db_txn_begin_4001(&msg, cl); if (replyp == NULL) { __db_err(dbenv, clnt_sperror(cl, "Berkeley DB")); ret = DB_NOSERVER; goto out; } ret = __dbcl_txn_begin_ret(dbenv, parent, txnpp, flags, replyp);out: if (replyp != NULL) xdr_free((xdrproc_t)xdr___txn_begin_reply, (void *)replyp); return (ret);}/* * PUBLIC: int __dbcl_txn_checkpoint __P((DB_ENV *, u_int32_t, u_int32_t, * PUBLIC: u_int32_t)); */int__dbcl_txn_checkpoint(dbenv, kbyte, min, flags) DB_ENV * dbenv; u_int32_t kbyte; u_int32_t min; u_int32_t flags;{ COMPQUIET(kbyte, 0); COMPQUIET(min, 0); COMPQUIET(flags, 0); return (__dbcl_rpc_illegal(dbenv, "txn_checkpoint"));}/* * PUBLIC: int __dbcl_txn_commit __P((DB_TXN *, u_int32_t)); */int__dbcl_txn_commit(txnp, flags) DB_TXN * txnp; u_int32_t flags;{ CLIENT *cl; __txn_commit_msg msg; __txn_commit_reply *replyp = NULL; int ret; DB_ENV *dbenv; ret = 0; dbenv = txnp->mgrp->dbenv; if (dbenv == NULL || !RPC_ON(dbenv)) return (__dbcl_noserver(NULL)); cl = (CLIENT *)dbenv->cl_handle; if (txnp == NULL) msg.txnpcl_id = 0; else msg.txnpcl_id = txnp->txnid; msg.flags = flags; replyp = __db_txn_commit_4001(&msg, cl); if (replyp == NULL) { __db_err(dbenv, clnt_sperror(cl, "Berkeley DB")); ret = DB_NOSERVER; goto out; } ret = __dbcl_txn_commit_ret(txnp, flags, replyp);out: if (replyp != NULL) xdr_free((xdrproc_t)xdr___txn_commit_reply, (void *)replyp); return (ret);}/* * PUBLIC: int __dbcl_txn_discard __P((DB_TXN *, u_int32_t)); */int__dbcl_txn_discard(txnp, flags) DB_TXN * txnp; u_int32_t flags;{ CLIENT *cl; __txn_discard_msg msg; __txn_discard_reply *replyp = NULL; int ret; DB_ENV *dbenv; ret = 0; dbenv = txnp->mgrp->dbenv; if (dbenv == NULL || !RPC_ON(dbenv)) return (__dbcl_noserver(NULL)); cl = (CLIENT *)dbenv->cl_handle; if (txnp == NULL) msg.txnpcl_id = 0; else msg.txnpcl_id = txnp->txnid; msg.flags = flags; replyp = __db_txn_discard_4001(&msg, cl); if (replyp == NULL) { __db_err(dbenv, clnt_sperror(cl, "Berkeley DB")); ret = DB_NOSERVER; goto out; } ret = __dbcl_txn_discard_ret(txnp, flags, replyp);out: if (replyp != NULL) xdr_free((xdrproc_t)xdr___txn_discard_reply, (void *)replyp); return (ret);}/* * PUBLIC: int __dbcl_txn_prepare __P((DB_TXN *, u_int8_t *)); */int__dbcl_txn_prepare(txnp, gid) DB_TXN * txnp; u_int8_t * gid;{ CLIENT *cl; __txn_prepare_msg msg; __txn_prepare_reply *replyp = NULL; int ret; DB_ENV *dbenv; ret = 0; dbenv = txnp->mgrp->dbenv; if (dbenv == NULL || !RPC_ON(dbenv)) return (__dbcl_noserver(NULL)); cl = (CLIENT *)dbenv->cl_handle; if (txnp == NULL) msg.txnpcl_id = 0; else msg.txnpcl_id = txnp->txnid; memcpy(msg.gid, gid, 128); replyp = __db_txn_prepare_4001(&msg, cl); if (replyp == NULL) { __db_err(dbenv, clnt_sperror(cl, "Berkeley DB")); ret = DB_NOSERVER; goto out; } ret = replyp->status;out: if (replyp != NULL) xdr_free((xdrproc_t)xdr___txn_prepare_reply, (void *)replyp); return (ret);}/* * PUBLIC: int __dbcl_txn_recover __P((DB_ENV *, DB_PREPLIST *, long, long *, * PUBLIC: u_int32_t)); */int__dbcl_txn_recover(dbenv, preplist, count, retp, flags) DB_ENV * dbenv; DB_PREPLIST * preplist; long count; long * retp; u_int32_t flags;{ CLIENT *cl; __txn_recover_msg msg; __txn_recover_reply *replyp = NULL; int ret; ret = 0; if (dbenv == NULL || !RPC_ON(dbenv)) return (__dbcl_noserver(dbenv)); cl = (CLIENT *)dbenv->cl_handle; if (dbenv == NULL) msg.dbenvcl_id = 0; else msg.dbenvcl_id = dbenv->cl_id; msg.count = count; msg.flags = flags; replyp = __db_txn_recover_4001(&msg, cl); if (replyp == NULL) { __db_err(dbenv, clnt_sperror(cl, "Berkeley DB")); ret = DB_NOSERVER; goto out; } ret = __dbcl_txn_recover_ret(dbenv, preplist, count, retp, flags, replyp);out: if (replyp != NULL) xdr_free((xdrproc_t)xdr___txn_recover_reply, (void *)replyp); return (ret);}/* * PUBLIC: int __dbcl_txn_stat __P((DB_ENV *, DB_TXN_STAT **, u_int32_t)); */int__dbcl_txn_stat(dbenv, statp, flags) DB_ENV * dbenv; DB_TXN_STAT ** statp; u_int32_t flags;{ COMPQUIET(statp, 0); COMPQUIET(flags, 0); return (__dbcl_rpc_illegal(dbenv, "txn_stat"));}/* * PUBLIC: int __dbcl_txn_timeout __P((DB_TXN *, u_int32_t, u_int32_t)); */int__dbcl_txn_timeout(txnp, timeout, flags) DB_TXN * txnp; u_int32_t timeout; u_int32_t flags;{ DB_ENV *dbenv; dbenv = txnp->mgrp->dbenv; COMPQUIET(timeout, 0); COMPQUIET(flags, 0); return (__dbcl_rpc_illegal(dbenv, "txn_timeout"));}/* * PUBLIC: int __dbcl_rep_elect __P((DB_ENV *, int, int, u_int32_t, int *)); */int__dbcl_rep_elect(dbenv, nsites, pri, timeout, idp) DB_ENV * dbenv; int nsites; int pri; u_int32_t timeout; int * idp;{ COMPQUIET(nsites, 0); COMPQUIET(pri, 0); COMPQUIET(timeout, 0); COMPQUIET(idp, 0); return (__dbcl_rpc_illegal(dbenv, "rep_elect"));}/* * PUBLIC: int __dbcl_rep_flush __P((DB_ENV *)); */int__dbcl_rep_flush(dbenv) DB_ENV * dbenv;{ return (__dbcl_rpc_illegal(dbenv, "rep_flush"));}/* * PUBLIC: int __dbcl_rep_process_message __P((DB_ENV *, DBT *, DBT *, int *)); */int__dbcl_rep_process_message(dbenv, rec, control, idp) DB_ENV * dbenv; DBT * rec; DBT * control; int * idp;{ COMPQUIET(rec, NULL); COMPQUIET(control, NULL); COMPQUIET(idp, 0); return (__dbcl_rpc_illegal(dbenv, "rep_process_message"));}/* * PUBLIC: int __dbcl_rep_set_limit __P((DB_ENV *, u_int32_t, u_int32_t)); */int__dbcl_rep_set_limit(dbenv, mbytes, bytes) DB_ENV * dbenv; u_int32_t mbytes; u_int32_t bytes;{ COMPQUIET(mbytes, 0); COMPQUIET(bytes, 0); return (__dbcl_rpc_illegal(dbenv, "rep_set_limit"));}/* * PUBLIC: int __dbcl_rep_set_request __P((DB_ENV *, u_int32_t, u_int32_t)); */int__dbcl_rep_set_request(dbenv, min, max) DB_ENV * dbenv; u_int32_t min; u_int32_t max;{ COMPQUIET(min, 0); COMPQUIET(max, 0); return (__dbcl_rpc_illegal(dbenv, "rep_set_request"));}/* * PUBLIC: int __dbcl_rep_set_rep_transport __P((DB_ENV *, int, * PUBLIC: int (*)(DB_ENV *, const DBT *, const DBT *, int, u_int32_t))); */int__dbcl_rep_set_rep_transport(dbenv, id, func0) DB_ENV * dbenv; int id; int (*func0) __P((DB_ENV *, const DBT *, const DBT *, int, u_int32_t));{ COMPQUIET(id, 0); COMPQUIET(func0, 0); return (__dbcl_rpc_illegal(dbenv, "rep_set_rep_transport"));}/* * PUBLIC: int __dbcl_rep_start __P((DB_ENV *, DBT *, u_int32_t)); */int__dbcl_rep_start(dbenv, cdata, flags) DB_ENV * dbenv; DBT * cdata; u_int32_t flags;{ COMPQUIET(cdata, NULL); COMPQUIET(flags, 0); return (__dbcl_rpc_illegal(dbenv, "rep_start"));}/* * PUBLIC: int __dbcl_rep_stat __P((DB_ENV *, DB_REP_STAT **, u_int32_t)); */int__dbcl_rep_stat(dbenv, statp, flags) DB_ENV * dbenv; DB_REP_STAT ** statp; u_int32_t flags;{ COMPQUIET(statp, 0); COMPQUIET(flags, 0); return (__dbcl_rpc_illegal(dbenv, "rep_stat"));}/* * PUBLIC: int __dbcl_db_alloc __P((DB *, void *(*)(size_t), void *(*)(void *, * PUBLIC: size_t), void (*)(void *))); */int__dbcl_db_alloc(dbp, func0, func1, func2) DB * dbp; void *(*func0) __P((size_t)); void *(*func1) __P((void *, size_t)); void (*func2) __P((void *));{ DB_ENV *dbenv; dbenv = dbp->dbenv; COMPQUIET(func0, 0); COMPQUIET(func1, 0); COMPQUIET(func2, 0); return (__dbcl_rpc_illegal(dbenv, "db_alloc"));}/* * PUBLIC: int __dbcl_db_associate __P((DB *, DB_TXN *, DB *, int (*)(DB *, * PUBLIC: const DBT *, const DBT *, DBT *), u_int32_t)); */int__dbcl_db_associate(dbp, txnp, sdbp, func0, flags) DB * dbp; DB_TXN * txnp; DB * sdbp; int (*func0) __P((DB *, const DBT *, const DBT *, DBT *)); u_int32_t flags;{ CLIENT *cl; __db_associate_msg msg; __db_associate_reply *replyp = NULL; int ret; DB_ENV *dbenv; ret = 0; dbenv = dbp->dbenv; if (dbenv == NULL || !RPC_ON(dbenv)) return (__dbcl_noserver(NULL)); cl = (CLIENT *)dbenv->cl_handle; if (func0 != NULL) { __db_err(dbenv, "User functions not supported in RPC"); return (EINVAL); } if (dbp == NULL) msg.dbpcl_id = 0; else msg.dbpcl_id = dbp->cl_id; if (txnp == NULL) msg.txnpcl_id = 0; else msg.txnpcl_id = txnp->txnid; if (sdbp == NULL) msg.sdbpcl_id = 0; else msg.sdbpcl_id = sdbp->cl_id; msg.flags = flags; replyp = __db_db_associate_4001(&msg, cl); if (replyp == NULL) { __db_err(dbenv, clnt_sperror(cl, "Berkeley DB")); ret = DB_NOSERVER; goto out; } ret = replyp->status;out: if (replyp != NULL) xdr_free((xdrproc_t)xdr___db_associate_reply, (void *)replyp); return (ret);}/* * PUBLIC: int __dbcl_db_bt_compare __P((DB *, int (*)(DB *, const DBT *, * PUBLIC: const DBT *))); */int__dbcl_db_bt_compare(dbp, func0) DB * dbp; int (*func0) __P((DB *, const DBT *, const DBT *));{ DB_ENV *dbenv; dbenv = dbp->dbenv; COMPQUIET(func0, 0); return (__dbcl_rpc_illegal(dbenv, "db_bt_compare"));}/* * PUBLIC: int __dbcl_db_bt_maxkey __P((DB *, u_int32_t)); */int__dbcl_db_bt_maxkey(dbp, maxkey) DB * dbp; u_int32_t maxkey;{ CLIENT *cl; __db_bt_maxkey_msg msg; __db_bt_maxkey_reply *replyp = NULL; int ret; DB_ENV *dbenv; ret = 0; dbenv = dbp->dbenv; if (dbenv == NULL || !RPC_ON(dbenv)) return (__dbcl_noserver(NULL)); cl = (CLIENT *)dbenv->cl_handle; if (dbp == NULL) msg.dbpcl_id = 0; else msg.dbpcl_id = dbp->cl_id; msg.maxkey = maxkey; replyp = __db_db_bt_maxkey_4001(&msg, cl); if (replyp == NULL) { __db_err(dbenv, clnt_sperror(cl, "Berkeley DB")); ret = DB_NOSERVER; goto out; } ret = replyp->status;out: if (replyp != NULL) xdr_free((xdrproc_t)xdr___db_bt_maxkey_reply, (void *)replyp); return (ret);}/* * PUBLIC: int __dbcl_db_bt_minkey __P((DB *, u_int32_t)); */int__dbcl_db_bt_minkey(dbp, minkey) DB * dbp; u_int32_t minkey;{ CLIENT *cl; __db_bt_minkey_msg msg; __db_bt_minkey_reply *replyp = NULL; int ret; DB_ENV *dbenv; ret = 0; dbenv = dbp->dbenv; if (dbenv == NULL || !RPC_ON(dbenv)) return (__dbcl_noserver(NULL)); cl = (CLIENT *)dbenv->cl_handle; if (dbp == NULL) msg.dbpcl_id = 0; else msg.dbpcl_id = dbp->cl_id; msg.minkey = minkey; replyp = __db_db_bt_minkey_4001(&msg, cl); if (replyp == NULL) { __db_err(dbenv, clnt_sperror(cl, "Berkeley DB")); ret = DB_NOSERVER; goto out; } ret = replyp->status;
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -