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

use libfastcommon V1.68

pull/6/head
YuQing 2023-07-05 18:09:53 +08:00
parent 5e8535db9c
commit 566c055f27
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/sf_ordered_writer.c
View File

@ -179,12 +179,18 @@ static int binlog_wbuffer_alloc_init(void *element, void *args)
return 0; return 0;
} }
static int compare_buffer_version(const SFOrderedWriterBuffer *entry1, static int push_compare_buffer_version(const SFOrderedWriterBuffer *entry1,
const SFOrderedWriterBuffer *entry2) const SFOrderedWriterBuffer *entry2)
{ {
return fc_compare_int64(entry1->version, entry2->version); return fc_compare_int64(entry1->version, entry2->version);
} }
static int pop_compare_buffer_version(const SFOrderedWriterBuffer *entry,
const SFOrderedWriterBuffer *less_equal, void *arg)
{
return fc_compare_int64(entry->version, less_equal->version);
}
static int sf_ordered_writer_init_thread(SFOrderedWriterContext *context, static int sf_ordered_writer_init_thread(SFOrderedWriterContext *context,
const char *name, const int max_record_size) const char *name, const int max_record_size)
{ {
@ -225,7 +231,9 @@ static int sf_ordered_writer_init_thread(SFOrderedWriterContext *context,
if ((result=sorted_queue_init(&thread->queues.buffer, (unsigned long) if ((result=sorted_queue_init(&thread->queues.buffer, (unsigned long)
(&((SFOrderedWriterBuffer *)NULL)->dlink), (&((SFOrderedWriterBuffer *)NULL)->dlink),
(int (*)(const void *, const void *)) (int (*)(const void *, const void *))
compare_buffer_version)) != 0) push_compare_buffer_version,
(int (*)(const void *, const void *, void *arg))
pop_compare_buffer_version, NULL)) != 0)
{ {
return result; return result;
} }