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

[CP] add lock for check ioability.is_valid()

Browse Source
This commit is contained in:
zhjc1124 2024-11-27 19:45:25 +00:00 committed by ob-robot
parent 1bf1415bb6
commit 45dc20eead
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/share/io/ob_io_calibration.h
View File

@ -76,6 +76,7 @@ private:
int find_item(const ObIOMode mode, const int64_t size, int64_t &item_idx) const; int find_item(const ObIOMode mode, const int64_t size, int64_t &item_idx) const;
private: private:
MeasureItemArray measure_items_[static_cast<int>(ObIOMode::MAX_MODE)]; MeasureItemArray measure_items_[static_cast<int>(ObIOMode::MAX_MODE)];
}; };
class ObIOBenchRunner : public lib::TGRunnable class ObIOBenchRunner : public lib::TGRunnable
@ -138,7 +139,7 @@ public:
int refresh(const bool only_refresh, const ObIArray<ObIOBenchResult> &items); int refresh(const bool only_refresh, const ObIArray<ObIOBenchResult> &items);
int execute_benchmark(); int execute_benchmark();
int get_benchmark_status(int64_t &start_ts, int64_t &finish_ts, int &ret_code); int get_benchmark_status(int64_t &start_ts, int64_t &finish_ts, int &ret_code);
bool is_valid() { return io_ability_.is_valid(); } bool is_valid() { DRWLock::RDLockGuard guard(lock_); return io_ability_.is_valid(); }
private: private:
ObIOCalibration(); ObIOCalibration();
~ObIOCalibration(); ~ObIOCalibration();