set last_versions.done when binlog_writer_set_next_version
parent
cccb1c6d23
commit
b9b466c364
|
|
@ -38,6 +38,9 @@ static inline void binlog_writer_set_next_version(SFBinlogWriterInfo *writer,
|
|||
const uint64_t next_version)
|
||||
{
|
||||
writer->version_ctx.next = next_version;
|
||||
if (writer->fw.flags & SF_FILE_WRITER_FLAGS_WANT_DONE_VERSION) {
|
||||
writer->fw.last_versions.done = next_version - 1;
|
||||
}
|
||||
}
|
||||
|
||||
#define deal_binlog_one_record(wb) \
|
||||
|
|
|
|||
|
|
@ -19,6 +19,7 @@
|
|||
#define _SF_SERIALIZER_H
|
||||
|
||||
#include "fastcommon/common_define.h"
|
||||
#include "fastcommon/shared_func.h"
|
||||
#include "fastcommon/fast_buffer.h"
|
||||
#include "fastcommon/hash.h"
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue