aboutsummaryrefslogtreecommitdiff
path: root/test
diff options
context:
space:
mode:
Diffstat (limited to 'test')
-rw-r--r--test/CMakeLists.txt3
-rw-r--r--test/test_concurrent_queue.cpp68
2 files changed, 0 insertions, 71 deletions
diff --git a/test/CMakeLists.txt b/test/CMakeLists.txt
index e4c7a1b..f8796d0 100644
--- a/test/CMakeLists.txt
+++ b/test/CMakeLists.txt
@@ -4,6 +4,3 @@ include_directories(../src/
add_executable(test_secp256k1 test_secp256k1.cpp)
target_link_libraries(test_secp256k1 hotstuff_static)
-
-add_executable(test_concurrent_queue test_concurrent_queue.cpp)
-target_link_libraries(test_concurrent_queue salticidae_static pthread)
diff --git a/test/test_concurrent_queue.cpp b/test/test_concurrent_queue.cpp
deleted file mode 100644
index 7412213..0000000
--- a/test/test_concurrent_queue.cpp
+++ /dev/null
@@ -1,68 +0,0 @@
-#include "salticidae/event.h"
-#include "concurrentqueue/blockingconcurrentqueue.h"
-#include <thread>
-#include <unistd.h>
-
-class VeriPool {
- int fin_fd[2];
- moodycamel::BlockingConcurrentQueue<int> in_queue;
- moodycamel::BlockingConcurrentQueue<int> out_queue;
- std::thread notifier;
- std::vector<std::thread> workers;
- public:
- VeriPool(size_t nworker) {
- pipe(fin_fd);
- // finish notifier thread
- notifier = std::thread([this]() {
- while (true)
- {
- int item;
- out_queue.wait_dequeue(item);
- write(fin_fd[1], &item, sizeof(item));
- }
- });
- for (size_t i = 0; i < nworker; i++)
- {
- workers.push_back(std::thread([this]() {
- while (true)
- {
- int item;
- in_queue.wait_dequeue(item);
- fprintf(stderr, "%lu working on %d\n", std::this_thread::get_id(), item);
- out_queue.enqueue(item * 1000);
- }
- }));
- }
- }
-
- ~VeriPool() {
- notifier.detach();
- for (auto &w: workers) w.detach();
- close(fin_fd[0]);
- close(fin_fd[1]);
- }
-
- void submit(int item) {
- in_queue.enqueue(item);
- }
-
- int get_fd() {
- return fin_fd[0];
- }
-};
-
-int main() {
- VeriPool p(2);
- salticidae::EventContext ec;
- salticidae::Event ev;
- ev = salticidae::Event(ec, p.get_fd(), EV_READ, [&ev](int fd, short) {
- int item;
- read(fd, &item, sizeof(item));
- printf("finished %d\n", item);
- ev.add();
- });
- for (int i = 0; i < 10000; i++)
- p.submit(i);
- ev.add();
- ec.dispatch();
-}