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

mds mvs rpc data version placehold in master.

Browse Source
This commit is contained in:
godyangfight
2024-05-25 03:58:07 +00:00
committed by ob-robot
parent e3510a5f8f
commit f0b3e0e7a7
2 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/storage/ob_storage_rpc.cpp
View File

@ -912,7 +912,8 @@ ObTransferTabletInfoArg::ObTransferTabletInfoArg()
: tenant_id_(OB_INVALID_ID), : tenant_id_(OB_INVALID_ID),
src_ls_id_(), src_ls_id_(),
dest_ls_id_(), dest_ls_id_(),
tablet_list_() tablet_list_(),
data_version_(0)
{ {
} }
@ -922,6 +923,7 @@ void ObTransferTabletInfoArg::reset()
src_ls_id_.reset(); src_ls_id_.reset();
dest_ls_id_.reset(); dest_ls_id_.reset();
tablet_list_.reset(); tablet_list_.reset();
data_version_ = 0;
} }
int ObTransferTabletInfoArg::assign(const ObTransferTabletInfoArg &other) int ObTransferTabletInfoArg::assign(const ObTransferTabletInfoArg &other)
@ -936,6 +938,7 @@ int ObTransferTabletInfoArg::assign(const ObTransferTabletInfoArg &other)
tenant_id_ = other.tenant_id_; tenant_id_ = other.tenant_id_;
src_ls_id_ = other.src_ls_id_; src_ls_id_ = other.src_ls_id_;
dest_ls_id_ = other.dest_ls_id_; dest_ls_id_ = other.dest_ls_id_;
data_version_ = other.data_version_;
} }
return ret; return ret;
} }
@ -948,7 +951,7 @@ bool ObTransferTabletInfoArg::is_valid() const
&& !tablet_list_.empty(); && !tablet_list_.empty();
} }
OB_SERIALIZE_MEMBER(ObTransferTabletInfoArg, tenant_id_, src_ls_id_, dest_ls_id_, tablet_list_); OB_SERIALIZE_MEMBER(ObTransferTabletInfoArg, tenant_id_, src_ls_id_, dest_ls_id_, tablet_list_, data_version_);
ObFetchLSReplayScnArg::ObFetchLSReplayScnArg() ObFetchLSReplayScnArg::ObFetchLSReplayScnArg()
: tenant_id_(OB_INVALID_ID), : tenant_id_(OB_INVALID_ID),

3
src/storage/ob_storage_rpc.h
View File

@ -546,11 +546,12 @@ public:
int assign(const ObTransferTabletInfoArg &other); int assign(const ObTransferTabletInfoArg &other);
void reset(); void reset();
TO_STRING_KV(K_(tenant_id), K_(src_ls_id), K_(dest_ls_id), K_(tablet_list)); TO_STRING_KV(K_(tenant_id), K_(src_ls_id), K_(dest_ls_id), K_(tablet_list), K_(data_version));
uint64_t tenant_id_; uint64_t tenant_id_;
share::ObLSID src_ls_id_; share::ObLSID src_ls_id_;
share::ObLSID dest_ls_id_; share::ObLSID dest_ls_id_;
common::ObSArray<share::ObTransferTabletInfo> tablet_list_; common::ObSArray<share::ObTransferTabletInfo> tablet_list_;
uint64_t data_version_;
private: private:
DISALLOW_COPY_AND_ASSIGN(ObTransferTabletInfoArg); DISALLOW_COPY_AND_ASSIGN(ObTransferTabletInfoArg);
}; };