hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Added placeholder for serialization of topnsql rpc parameters

Browse Source
This commit is contained in:
AntiTopQuark
2024-06-27 12:53:02 +00:00
committed by ob-robot
parent 6fab5b64e6
commit 69db0f75ee
2 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/share/wr/ob_wr_snapshot_rpc_processor.cpp
View File

@ -89,12 +89,12 @@ DEF_TO_STRING(ObWrUserModifySettingsArg)
J_COLON(); J_COLON();
pos += ObWrSnapshotArg::to_string(buf + pos, buf_len - pos); pos += ObWrSnapshotArg::to_string(buf + pos, buf_len - pos);
J_COMMA(); J_COMMA();
J_KV(K_(tenant_id), K_(retention), K_(interval)); J_KV(K_(tenant_id), K_(retention), K_(interval), K_(topnsql));
J_OBJ_END(); J_OBJ_END();
return pos; return pos;
} }
OB_SERIALIZE_MEMBER( OB_SERIALIZE_MEMBER(
(ObWrUserModifySettingsArg, ObWrSnapshotArg), tenant_id_, retention_, interval_); (ObWrUserModifySettingsArg, ObWrSnapshotArg), tenant_id_, retention_, interval_, topnsql_);
template <obrpc::ObRpcPacketCode pcode> template <obrpc::ObRpcPacketCode pcode>
int ObWrBaseSnapshotTaskP<pcode>::init() int ObWrBaseSnapshotTaskP<pcode>::init()

8
src/share/wr/ob_wr_snapshot_rpc_processor.h
View File

@ -214,13 +214,15 @@ public:
: ObWrSnapshotArg(WrTaskType::USER_MODIFY_SETTINGS), : ObWrSnapshotArg(WrTaskType::USER_MODIFY_SETTINGS),
tenant_id_(tenant_id), tenant_id_(tenant_id),
retention_(retention), retention_(retention),
interval_(interval) interval_(interval),
topnsql_(0)
{} {}
ObWrUserModifySettingsArg() ObWrUserModifySettingsArg()
: ObWrSnapshotArg(WrTaskType::USER_MODIFY_SETTINGS), : ObWrSnapshotArg(WrTaskType::USER_MODIFY_SETTINGS),
tenant_id_(0), tenant_id_(0),
retention_(0), retention_(0),
interval_(0) interval_(0),
topnsql_(0)
{} {}
~ObWrUserModifySettingsArg() = default; ~ObWrUserModifySettingsArg() = default;
inline int64_t get_tenant_id() const inline int64_t get_tenant_id() const
@ -241,6 +243,7 @@ public:
tenant_id_ = other.tenant_id_; tenant_id_ = other.tenant_id_;
retention_ = other.retention_; retention_ = other.retention_;
interval_ = other.interval_; interval_ = other.interval_;
topnsql_ = topnsql_;
if (OB_FAIL(ObWrSnapshotArg::assign(other))) { if (OB_FAIL(ObWrSnapshotArg::assign(other))) {
SHARE_LOG(WARN, "fail to assign wr snapshot arg", KR(ret)); SHARE_LOG(WARN, "fail to assign wr snapshot arg", KR(ret));
} else { /*do nothing*/ } else { /*do nothing*/
@ -254,6 +257,7 @@ private:
int64_t tenant_id_; int64_t tenant_id_;
int64_t retention_; int64_t retention_;
int64_t interval_; int64_t interval_;
int64_t topnsql_;
}; };
class ObWrUserSubmitSnapResp { class ObWrUserSubmitSnapResp {