From 0014cfa154aa517d1f29d4603a743484ef31fe09 Mon Sep 17 00:00:00 2001 From: YuQing <384681@qq.com> Date: Thu, 7 Jan 2021 20:19:13 +0800 Subject: [PATCH] add tag for debug --- src/sf_binlog_writer.c | 5 +++-- src/sf_binlog_writer.h | 1 + 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/src/sf_binlog_writer.c b/src/sf_binlog_writer.c index c6241a6..16b066d 100644 --- a/src/sf_binlog_writer.c +++ b/src/sf_binlog_writer.c @@ -366,9 +366,10 @@ static int deal_record_by_version(SFBinlogWriterBuffer *wb) } else if (distance < 0) { logError("file: "__FILE__", line: %d, subdir_name: %s, " "current version: %"PRId64" is too small which " - "less than %"PRId64, __LINE__, + "less than %"PRId64", tag: %d, buffer(%d): %.*s", __LINE__, writer->cfg.subdir_name, wb->version.first, - writer->version_ctx.next); + writer->version_ctx.next, wb->tag, wb->bf.length, + wb->bf.length, wb->bf.buff); fast_mblock_free_object(&writer->thread->mblock, wb); return EINVAL; } diff --git a/src/sf_binlog_writer.h b/src/sf_binlog_writer.h index eb43fb9..0293960 100644 --- a/src/sf_binlog_writer.h +++ b/src/sf_binlog_writer.h @@ -46,6 +46,7 @@ struct sf_binlog_writer_info; typedef struct sf_binlog_writer_buffer { SFVersionRange version; BufferInfo bf; + int tag; int type; //for versioned writer struct sf_binlog_writer_info *writer; struct sf_binlog_writer_buffer *next;