pdxx
/
libserverframe
mirror of https://github.com/happyfish100/libserverframe.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

bugfixed: add_to_flush_writer_queue MUST before deal function

connection_manager
YuQing 2021-01-21 10:43:39 +08:00
parent 1ece8a3389
commit 76f757f2bd
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/sf_binlog_writer.c
View File

@ -451,9 +451,10 @@ static int deal_binlog_records(SFBinlogWriterThread *thread,
thread->mblock, current);
} else {
current->writer->total_count++;
if ((result=deal_record_by_version(current)) == 0) {
add_to_flush_writer_queue(thread, current->writer);
} else {
add_to_flush_writer_queue(thread, current->writer);
/* NOTE: current maybe be released in the deal function */
if ((result=deal_record_by_version(current)) != 0) {
return result;
}
}