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

modify the way that slog flush thread gets start ts

Browse Source
This commit is contained in:
obdev
2023-03-02 17:44:22 +00:00
committed by ob-robot
parent f1d066b4bd
commit 49809d219c
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/share/redolog/ob_log_file_handler.cpp
View File

@ -11,7 +11,6 @@
*/ */
#define USING_LOG_PREFIX COMMON #define USING_LOG_PREFIX COMMON
#include "common/ob_clock_generator.h"
#include "lib/allocator/ob_malloc.h" #include "lib/allocator/ob_malloc.h"
#include "lib/oblog/ob_log.h" #include "lib/oblog/ob_log.h"
#include "lib/utility/ob_tracepoint.h" #include "lib/utility/ob_tracepoint.h"
@ -393,7 +392,7 @@ int ObLogFileHandler::normal_retry_write(void *buf, int64_t size, int64_t offset
} else { } else {
int64_t retry_cnt = 0; int64_t retry_cnt = 0;
int64_t write_size = 0; int64_t write_size = 0;
const int64_t start_ts = ObClockGenerator::getClock(); const int64_t start_ts = ObTimeUtility::current_time();
ATOMIC_STORE(&pwrite_ts_, start_ts); ATOMIC_STORE(&pwrite_ts_, start_ts);
do { do {
if (OB_FAIL(THE_IO_DEVICE->pwrite(io_fd_, offset, size, buf, write_size))) { if (OB_FAIL(THE_IO_DEVICE->pwrite(io_fd_, offset, size, buf, write_size))) {