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

write inc direct load macro block sync

Browse Source
This commit is contained in:
coolfishchen
2024-06-18 12:41:43 +00:00
committed by ob-robot
parent 8d3e2c2e76
commit e63b69a7b6
5 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/storage/blocksstable/ob_imacro_block_flush_callback.h
View File

@ -27,7 +27,7 @@ class ObIMacroBlockFlushCallback
public: public:
ObIMacroBlockFlushCallback() {} ObIMacroBlockFlushCallback() {}
virtual ~ObIMacroBlockFlushCallback() {} virtual ~ObIMacroBlockFlushCallback() {}
virtual int write(const ObMacroBlockHandle &macro_handle, virtual int write(ObMacroBlockHandle &macro_handle,
const ObLogicMacroBlockId &logic_id, const ObLogicMacroBlockId &logic_id,
char *buf, char *buf,
const int64_t buf_len, const int64_t buf_len,

4
src/storage/ddl/ob_ddl_inc_redo_log_writer.cpp
View File

@ -711,7 +711,7 @@ void ObDDLIncRedoLogWriterCallback::reset()
} }
int ObDDLIncRedoLogWriterCallback::write( int ObDDLIncRedoLogWriterCallback::write(
const ObMacroBlockHandle &macro_handle, ObMacroBlockHandle &macro_handle,
const ObLogicMacroBlockId &logic_id, const ObLogicMacroBlockId &logic_id,
char *buf, char *buf,
const int64_t buf_len, const int64_t buf_len,
@ -724,6 +724,8 @@ int ObDDLIncRedoLogWriterCallback::write(
} else if (OB_UNLIKELY(!macro_handle.is_valid() || !logic_id.is_valid() || nullptr == buf || row_count <= 0)) { } else if (OB_UNLIKELY(!macro_handle.is_valid() || !logic_id.is_valid() || nullptr == buf || row_count <= 0)) {
ret = OB_INVALID_ARGUMENT; ret = OB_INVALID_ARGUMENT;
LOG_WARN("invalid argument", K(ret), K(macro_handle), K(logic_id), KP(buf), K(row_count)); LOG_WARN("invalid argument", K(ret), K(macro_handle), K(logic_id), KP(buf), K(row_count));
} else if (OB_FAIL(macro_handle.wait())) {
STORAGE_LOG(WARN, "macro block writer fail to wait io finish", K(ret));
} else { } else {
macro_block_id_ = macro_handle.get_macro_id(); macro_block_id_ = macro_handle.get_macro_id();
redo_info_.table_key_ = table_key_; redo_info_.table_key_ = table_key_;

2
src/storage/ddl/ob_ddl_inc_redo_log_writer.h
View File

@ -129,7 +129,7 @@ public:
const transaction::ObTransID &trans_id); const transaction::ObTransID &trans_id);
void reset(); void reset();
int write( int write(
const blocksstable::ObMacroBlockHandle &macro_handle, blocksstable::ObMacroBlockHandle &macro_handle,
const blocksstable::ObLogicMacroBlockId &logic_id, const blocksstable::ObLogicMacroBlockId &logic_id,
char *buf, char *buf,
const int64_t buf_len, const int64_t buf_len,

2
src/storage/ddl/ob_ddl_redo_log_writer.cpp
View File

@ -1574,7 +1574,7 @@ bool ObDDLRedoLogWriterCallback::is_column_group_info_valid() const
return table_key_.is_column_store_sstable() && row_id_offset_ >= 0; return table_key_.is_column_store_sstable() && row_id_offset_ >= 0;
} }
int ObDDLRedoLogWriterCallback::write(const ObMacroBlockHandle &macro_handle, int ObDDLRedoLogWriterCallback::write(ObMacroBlockHandle &macro_handle,
const ObLogicMacroBlockId &logic_id, const ObLogicMacroBlockId &logic_id,
char *buf, char *buf,
const int64_t buf_len, const int64_t buf_len,

2
src/storage/ddl/ob_ddl_redo_log_writer.h
View File

@ -378,7 +378,7 @@ public:
const int64_t row_id_offset = -1); const int64_t row_id_offset = -1);
void reset(); void reset();
int write( int write(
const blocksstable::ObMacroBlockHandle &macro_handle, blocksstable::ObMacroBlockHandle &macro_handle,
const blocksstable::ObLogicMacroBlockId &logic_id, const blocksstable::ObLogicMacroBlockId &logic_id,
char *buf, char *buf,
const int64_t buf_len, const int64_t buf_len,