fix default value of is_ha_dag_net

This commit is contained in:
a1iive
2023-05-29 12:41:23 +00:00
committed by ob-robot
parent d137b298a0
commit 2529123af5
8 changed files with 8 additions and 1 deletions

View File

@ -475,7 +475,7 @@ public:
{
return OB_SUCCESS;
}
virtual bool is_ha_dag_net() const { return true; }
virtual bool is_ha_dag_net() const { return false; }
public:
friend class ObTenantDagScheduler;

View File

@ -110,6 +110,7 @@ class ObBackupDagNet : public share::ObIDagNet
public:
explicit ObBackupDagNet(const ObBackupDagNetSubType &sub_type);
virtual ~ObBackupDagNet();
bool is_ha_dag_net() const override { return true; }
ObBackupDagNetSubType get_sub_type() const { return sub_type_; };
INHERIT_TO_STRING_KV("ObIDagNet", ObIDagNet, K_(sub_type));
protected:

View File

@ -69,6 +69,7 @@ public:
int fill_comment(char *buf, const int64_t buf_len) const override;
int fill_dag_net_key(char *buf, const int64_t buf_len) const override;
bool is_valid() const override { return param_.is_valid(); }
bool is_ha_dag_net() const override { return true; }
ObLSBackupCleanDagNetInitParam &get_param() { return param_;}
INHERIT_TO_STRING_KV("share::ObIDagNet", share::ObIDagNet, K_(param));
private:

View File

@ -85,6 +85,7 @@ public:
virtual int fill_dag_net_key(char *buf, const int64_t buf_len) const override;
virtual int clear_dag_net_ctx() override;
virtual int deal_with_cancel() override;
bool is_ha_dag_net() const override { return true; }
ObLSCompleteMigrationCtx *get_ctx() { return &ctx_; }
const share::ObLSID &get_ls_id() const { return ctx_.arg_.ls_id_; }

View File

@ -131,6 +131,7 @@ public:
virtual int fill_dag_net_key(char *buf, const int64_t buf_len) const override;
virtual int clear_dag_net_ctx() override;
virtual int deal_with_cancel() override;
bool is_ha_dag_net() const override { return true; }
ObMigrationCtx *get_migration_ctx() { return ctx_; }
common::ObInOutBandwidthThrottle *get_bandwidth_throttle() { return bandwidth_throttle_; }

View File

@ -82,6 +82,7 @@ public:
virtual int fill_dag_net_key(char *buf, const int64_t buf_len) const override;
virtual int clear_dag_net_ctx() override;
virtual int deal_with_cancel() override;
bool is_ha_dag_net() const override { return true; }
ObLSPrepareMigrationCtx *get_ctx() { return &ctx_; }
const share::ObLSID &get_ls_id() const { return ctx_.arg_.ls_id_; }

View File

@ -99,6 +99,7 @@ public:
virtual int fill_dag_net_key(char *buf, const int64_t buf_len) const override;
virtual int clear_dag_net_ctx() override;
virtual int deal_with_cancel() override;
bool is_ha_dag_net() const override { return true; }
ObLSRestoreCtx *get_ls_restore_ctx() { return ctx_; }
common::ObInOutBandwidthThrottle *get_bandwidth_throttle() { return bandwidth_throttle_; }

View File

@ -143,6 +143,7 @@ public:
virtual int fill_dag_net_key(char *buf, const int64_t buf_len) const override;
virtual int clear_dag_net_ctx() override;
virtual int deal_with_cancel() override;
bool is_ha_dag_net() const override { return true; }
ObTabletGroupRestoreCtx *get_restore_ctx() { return ctx_; }
common::ObInOutBandwidthThrottle *get_bandwidth_throttle() { return bandwidth_throttle_; }