From 90e144920a676251fda9279248e1b18f62d22d77 Mon Sep 17 00:00:00 2001 From: YuQing <384681@qq.com> Date: Thu, 4 May 2023 20:07:23 +0800 Subject: [PATCH] use new sorted queue with double link chain for quick push --- src/sf_ordered_writer.c | 2 +- src/sf_ordered_writer.h | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/sf_ordered_writer.c b/src/sf_ordered_writer.c index 49c653f..8ce72d3 100644 --- a/src/sf_ordered_writer.c +++ b/src/sf_ordered_writer.c @@ -223,7 +223,7 @@ static int sf_ordered_writer_init_thread(SFOrderedWriterContext *context, } if ((result=sorted_queue_init(&thread->queues.buffer, (unsigned long) - (&((SFOrderedWriterBuffer *)NULL)->next), + (&((SFOrderedWriterBuffer *)NULL)->dlink), (int (*)(const void *, const void *)) compare_buffer_version)) != 0) { diff --git a/src/sf_ordered_writer.h b/src/sf_ordered_writer.h index 2ca1c43..7f85b41 100644 --- a/src/sf_ordered_writer.h +++ b/src/sf_ordered_writer.h @@ -29,7 +29,7 @@ typedef struct sf_writer_version_entry { typedef struct sf_ordered_writer_buffer { int64_t version; BufferInfo bf; - struct sf_ordered_writer_buffer *next; + struct fc_list_head dlink; } SFOrderedWriterBuffer; typedef struct sf_orderd_writer_thread {