From 0825cfc5fef538015201de7e312d9126727b7459 Mon Sep 17 00:00:00 2001 From: YuQing <384681@qq.com> Date: Wed, 6 Jan 2021 18:45:26 +0800 Subject: [PATCH] fast_mblock_free_object writer buffer --- src/sf_binlog_writer.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/sf_binlog_writer.c b/src/sf_binlog_writer.c index 62963ff..c6241a6 100644 --- a/src/sf_binlog_writer.c +++ b/src/sf_binlog_writer.c @@ -272,8 +272,7 @@ static inline int deal_binlog_one_record(SFBinlogWriterBuffer *wb) } } - return check_write_to_file(wb->writer, - wb->bf.buff, wb->bf.length); + return check_write_to_file(wb->writer, wb->bf.buff, wb->bf.length); } if (wb->writer->file.size + SF_BINLOG_BUFFER_LENGTH(wb->writer-> @@ -370,6 +369,7 @@ static int deal_record_by_version(SFBinlogWriterBuffer *wb) "less than %"PRId64, __LINE__, writer->cfg.subdir_name, wb->version.first, writer->version_ctx.next); + fast_mblock_free_object(&writer->thread->mblock, wb); return EINVAL; }