chore: use helio MPSCIntrusiveQueue queue (#2573)

dragonflydb · Feb 12, 2024 · 9802f2c · 9802f2c
1 parent e66e670
commit 9802f2c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 95 deletions.
diff --git a/src/core/mpsc_intrusive_queue.h b/src/core/mpsc_intrusive_queue.h
diff --git a/src/server/rdb_load.h b/src/server/rdb_load.h
@@ -11,9 +11,9 @@ extern "C" {
 }
 
 #include "base/io_buf.h"
+#include "base/mpsc_intrusive_queue.h"
 #include "base/pod_array.h"
 #include "core/json_object.h"
-#include "core/mpsc_intrusive_queue.h"
 #include "io/io.h"
 #include "redis/rdb.h"
 #include "server/common.h"
@@ -263,7 +263,7 @@ class RdbLoader : protected RdbLoaderBase {
   // Callback when receiving RDB_OPCODE_FULLSYNC_END
   std::function<void()> full_sync_cut_cb;
 
-  detail::MPSCIntrusiveQueue<Item> item_queue_;
+  base::MPSCIntrusiveQueue<Item> item_queue_;
 };
 
 }  // namespace dfly