From 7d91b187fe8e54a79ae297da8298a26ed0bdad61 Mon Sep 17 00:00:00 2001
From: mutouyun <orz@orzz.org>
Date: Thu, 29 Nov 2018 00:14:37 +0800
Subject: [PATCH] fix bugs of circ_queue

---
 include/circ_queue.h | 4 +---
 test/test_circ.cpp   | 6 ++++--
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/include/circ_queue.h b/include/circ_queue.h
index 0230253..758905b 100644
--- a/include/circ_queue.h
+++ b/include/circ_queue.h
@@ -36,8 +36,6 @@ public:
         swap(rhs);
     }
 
-    ~queue(void) { detach(); }
-
     void swap(queue& rhs) {
         std::swap(elems_ , rhs.elems_ );
         std::swap(cursor_, rhs.cursor_);
@@ -96,7 +94,7 @@ public:
         while (cursor_ == elems_->cursor()) {
             std::this_thread::yield();
         }
-        auto item_ptr = static_cast<T*>(elems_->take(cursor_));
+        auto item_ptr = static_cast<T*>(elems_->take(cursor_++));
         T item = *item_ptr;
         elems_->put(item_ptr);
         return item;
diff --git a/test/test_circ.cpp b/test/test_circ.cpp
index a535335..0c1736c 100644
--- a/test/test_circ.cpp
+++ b/test/test_circ.cpp
@@ -88,7 +88,9 @@ struct test_confirm {
     int lcount_;
 
     test_confirm(int M) {
-        list_ = new std::remove_reference_t<decltype(*list_)>[lcount_ = M];
+        list_ = new std::remove_reference_t<decltype(*list_)>[
+                    static_cast<std::size_t>(lcount_ = M)
+                ];
     }
 
     ~test_confirm(void) {
@@ -315,7 +317,7 @@ void Unit::test_queue(void) {
     queue.attch(cq);
     QVERIFY(queue.detach() != nullptr);
 
-    test_prod_cons<1, 1>((ipc::circ::queue<msg_t>*)nullptr);
+    test_prod_cons<1, 3>((ipc::circ::queue<msg_t>*)nullptr);
 }
 
 } // internal-linkage