From 566c055f270335c199056739359b3b4f2bd948cd Mon Sep 17 00:00:00 2001
From: YuQing <384681@qq.com>
Date: Wed, 5 Jul 2023 18:09:53 +0800
Subject: [PATCH] use libfastcommon V1.68

---
 src/sf_ordered_writer.c | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/src/sf_ordered_writer.c b/src/sf_ordered_writer.c
index eadfed1..4635c5b 100644
--- a/src/sf_ordered_writer.c
+++ b/src/sf_ordered_writer.c
@@ -179,12 +179,18 @@ static int binlog_wbuffer_alloc_init(void *element, void *args)
     return 0;
 }
 
-static int compare_buffer_version(const SFOrderedWriterBuffer *entry1,
+static int push_compare_buffer_version(const SFOrderedWriterBuffer *entry1,
         const SFOrderedWriterBuffer *entry2)
 {
     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,
         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)
                     (&((SFOrderedWriterBuffer *)NULL)->dlink),
                     (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;
     }