diff --git a/src/share/scheduler/ob_dag_scheduler.h b/src/share/scheduler/ob_dag_scheduler.h index c40829f635..7abb1f2440 100644 --- a/src/share/scheduler/ob_dag_scheduler.h +++ b/src/share/scheduler/ob_dag_scheduler.h @@ -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; diff --git a/src/storage/backup/ob_backup_task.h b/src/storage/backup/ob_backup_task.h index e5865523c0..079afa0643 100644 --- a/src/storage/backup/ob_backup_task.h +++ b/src/storage/backup/ob_backup_task.h @@ -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: diff --git a/src/storage/backup/ob_ls_backup_clean_mgr.h b/src/storage/backup/ob_ls_backup_clean_mgr.h index 98c52c587f..bac9a0bb31 100644 --- a/src/storage/backup/ob_ls_backup_clean_mgr.h +++ b/src/storage/backup/ob_ls_backup_clean_mgr.h @@ -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: diff --git a/src/storage/high_availability/ob_ls_complete_migration.h b/src/storage/high_availability/ob_ls_complete_migration.h index 19f08918a7..cb2ada9450 100644 --- a/src/storage/high_availability/ob_ls_complete_migration.h +++ b/src/storage/high_availability/ob_ls_complete_migration.h @@ -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_; } diff --git a/src/storage/high_availability/ob_ls_migration.h b/src/storage/high_availability/ob_ls_migration.h index 69f14eb36a..4419ec6ab8 100644 --- a/src/storage/high_availability/ob_ls_migration.h +++ b/src/storage/high_availability/ob_ls_migration.h @@ -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_; } diff --git a/src/storage/high_availability/ob_ls_prepare_migration.h b/src/storage/high_availability/ob_ls_prepare_migration.h index b0db7eb277..082634596b 100644 --- a/src/storage/high_availability/ob_ls_prepare_migration.h +++ b/src/storage/high_availability/ob_ls_prepare_migration.h @@ -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_; } diff --git a/src/storage/high_availability/ob_ls_restore.h b/src/storage/high_availability/ob_ls_restore.h index 7d6362df27..848e1aaa21 100644 --- a/src/storage/high_availability/ob_ls_restore.h +++ b/src/storage/high_availability/ob_ls_restore.h @@ -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_; } diff --git a/src/storage/high_availability/ob_tablet_group_restore.h b/src/storage/high_availability/ob_tablet_group_restore.h index 58928f1a68..e0e1988963 100644 --- a/src/storage/high_availability/ob_tablet_group_restore.h +++ b/src/storage/high_availability/ob_tablet_group_restore.h @@ -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_; }