DBMS_SPM.LOAD_PLANS_FROM_CURSOR_CACHE need return correct baseline number load from plan cache

This commit is contained in:
obdev
2023-07-11 04:48:16 +00:00
committed by ob-robot
parent ceeb9e31f6
commit b4511b899d
4 changed files with 26 additions and 0 deletions

View File

@ -569,6 +569,8 @@ PCODE_DEF(OB_DTL_SEND, 0x5C0)
PCODE_DEF(OB_DTL_FETCH, 0x5C1) PCODE_DEF(OB_DTL_FETCH, 0x5C1)
PCODE_DEF(OB_DTL_BC_SEND, 0x5C2) PCODE_DEF(OB_DTL_BC_SEND, 0x5C2)
PCODE_DEF(OB_PX_SEND_BLOOM_FILTER, 0x5C3) PCODE_DEF(OB_PX_SEND_BLOOM_FILTER, 0x5C3)
PCODE_DEF(OB_LOAD_BASELINE_V2, 0x5C4)
PCODE_DEF(OB_ADMIN_LOAD_BASELINE_V2, 0x5C5)
// election // election
PCODE_DEF(OB_ELECTION, 0x601) PCODE_DEF(OB_ELECTION, 0x601)
PCODE_DEF(OB_ELECTION_RESPONSE, 0x602) PCODE_DEF(OB_ELECTION_RESPONSE, 0x602)

View File

@ -136,6 +136,7 @@ public:
RPC_S(PR5 accept_plan_baseline, obrpc::OB_RS_ACCEPT_PLAN_BASELINE, (ObModifyPlanBaselineArg)); RPC_S(PR5 accept_plan_baseline, obrpc::OB_RS_ACCEPT_PLAN_BASELINE, (ObModifyPlanBaselineArg));
RPC_S(PRD cancel_evolve_task, obrpc::OB_RS_CANCEL_EVOLVE_TASK, (ObModifyPlanBaselineArg)); RPC_S(PRD cancel_evolve_task, obrpc::OB_RS_CANCEL_EVOLVE_TASK, (ObModifyPlanBaselineArg));
RPC_S(PR5 admin_load_baseline, obrpc::OB_ADMIN_LOAD_BASELINE, (ObLoadPlanBaselineArg)); RPC_S(PR5 admin_load_baseline, obrpc::OB_ADMIN_LOAD_BASELINE, (ObLoadPlanBaselineArg));
RPC_S(PR5 admin_load_baseline_v2, obrpc::OB_ADMIN_LOAD_BASELINE_V2, (ObLoadPlanBaselineArg), ObLoadBaselineRes);
// RPC_S(PRD drop_plan_baseline, obrpc::OB_DROP_PLAN_BASELINE, (ObDropPlanBaselineArg)); // RPC_S(PRD drop_plan_baseline, obrpc::OB_DROP_PLAN_BASELINE, (ObDropPlanBaselineArg));
//----End of definitions for managing plan_baselines---- //----End of definitions for managing plan_baselines----

View File

@ -8592,5 +8592,16 @@ int ObBroadcastConsensusVersionArg::assign(const ObBroadcastConsensusVersionArg
} }
OB_SERIALIZE_MEMBER(ObBroadcastConsensusVersionRes, ret_); OB_SERIALIZE_MEMBER(ObBroadcastConsensusVersionRes, ret_);
int ObLoadBaselineRes::assign(const ObLoadBaselineRes &other)
{
int ret = OB_SUCCESS;
if (this != &other) {
load_count_ = other.load_count_;
}
return ret;
}
OB_SERIALIZE_MEMBER(ObLoadBaselineRes, load_count_);
}//end namespace obrpc }//end namespace obrpc
}//end namepsace oceanbase }//end namepsace oceanbase

View File

@ -9322,6 +9322,18 @@ private:
int ret_; int ret_;
}; };
struct ObLoadBaselineRes
{
OB_UNIS_VERSION(1);
public:
ObLoadBaselineRes()
: load_count_(0)
{}
int assign(const ObLoadBaselineRes &other);
TO_STRING_KV(K_(load_count));
uint64_t load_count_;
};
}//end namespace obrpc }//end namespace obrpc
}//end namespace oceanbase }//end namespace oceanbase
#endif #endif