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; }