add tag for debug

connection_manager
YuQing 2021-01-07 20:19:13 +08:00
parent e459a0c255
commit 0014cfa154
2 changed files with 4 additions and 2 deletions

View File

@ -366,9 +366,10 @@ static int deal_record_by_version(SFBinlogWriterBuffer *wb)
} else if (distance < 0) { } else if (distance < 0) {
logError("file: "__FILE__", line: %d, subdir_name: %s, " logError("file: "__FILE__", line: %d, subdir_name: %s, "
"current version: %"PRId64" is too small which " "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->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); fast_mblock_free_object(&writer->thread->mblock, wb);
return EINVAL; return EINVAL;
} }

View File

@ -46,6 +46,7 @@ struct sf_binlog_writer_info;
typedef struct sf_binlog_writer_buffer { typedef struct sf_binlog_writer_buffer {
SFVersionRange version; SFVersionRange version;
BufferInfo bf; BufferInfo bf;
int tag;
int type; //for versioned writer int type; //for versioned writer
struct sf_binlog_writer_info *writer; struct sf_binlog_writer_info *writer;
struct sf_binlog_writer_buffer *next; struct sf_binlog_writer_buffer *next;