use new sorted queue with double link chain for quick push
parent
c5d64a0d54
commit
90e144920a
|
|
@ -223,7 +223,7 @@ 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)->next),
|
(&((SFOrderedWriterBuffer *)NULL)->dlink),
|
||||||
(int (*)(const void *, const void *))
|
(int (*)(const void *, const void *))
|
||||||
compare_buffer_version)) != 0)
|
compare_buffer_version)) != 0)
|
||||||
{
|
{
|
||||||
|
|
|
||||||
|
|
@ -29,7 +29,7 @@ typedef struct sf_writer_version_entry {
|
||||||
typedef struct sf_ordered_writer_buffer {
|
typedef struct sf_ordered_writer_buffer {
|
||||||
int64_t version;
|
int64_t version;
|
||||||
BufferInfo bf;
|
BufferInfo bf;
|
||||||
struct sf_ordered_writer_buffer *next;
|
struct fc_list_head dlink;
|
||||||
} SFOrderedWriterBuffer;
|
} SFOrderedWriterBuffer;
|
||||||
|
|
||||||
typedef struct sf_orderd_writer_thread {
|
typedef struct sf_orderd_writer_thread {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue