Remove message_buffer_manager tests

nanocurrency · Feb 18, 2023 · ef49f99 · ef49f99
1 parent 94fc8bd
commit ef49f99
Showing 1 changed file with 0 additions and 148 deletions.
diff --git a/nano/core_test/network.cpp b/nano/core_test/network.cpp
@@ -700,154 +700,6 @@ TEST (node, port_mapping)
 	}
 }
 
-TEST (message_buffer_manager, one_buffer)
-{
-	nano::stats stats;
-	nano::message_buffer_manager buffer (stats, 512, 1);
-	auto buffer1 (buffer.allocate ());
-	ASSERT_NE (nullptr, buffer1);
-	buffer.enqueue (buffer1);
-	auto buffer2 (buffer.dequeue ());
-	ASSERT_EQ (buffer1, buffer2);
-	buffer.release (buffer2);
-	auto buffer3 (buffer.allocate ());
-	ASSERT_EQ (buffer1, buffer3);
-}
-
-TEST (message_buffer_manager, two_buffers)
-{
-	nano::stats stats;
-	nano::message_buffer_manager buffer (stats, 512, 2);
-	auto buffer1 (buffer.allocate ());
-	ASSERT_NE (nullptr, buffer1);
-	auto buffer2 (buffer.allocate ());
-	ASSERT_NE (nullptr, buffer2);
-	ASSERT_NE (buffer1, buffer2);
-	buffer.enqueue (buffer2);
-	buffer.enqueue (buffer1);
-	auto buffer3 (buffer.dequeue ());
-	ASSERT_EQ (buffer2, buffer3);
-	auto buffer4 (buffer.dequeue ());
-	ASSERT_EQ (buffer1, buffer4);
-	buffer.release (buffer3);
-	buffer.release (buffer4);
-	auto buffer5 (buffer.allocate ());
-	ASSERT_EQ (buffer2, buffer5);
-	auto buffer6 (buffer.allocate ());
-	ASSERT_EQ (buffer1, buffer6);
-}
-
-TEST (message_buffer_manager, one_overflow)
-{
-	nano::stats stats;
-	nano::message_buffer_manager buffer (stats, 512, 1);
-	auto buffer1 (buffer.allocate ());
-	ASSERT_NE (nullptr, buffer1);
-	buffer.enqueue (buffer1);
-	auto buffer2 (buffer.allocate ());
-	ASSERT_EQ (buffer1, buffer2);
-}
-
-TEST (message_buffer_manager, two_overflow)
-{
-	nano::stats stats;
-	nano::message_buffer_manager buffer (stats, 512, 2);
-	auto buffer1 (buffer.allocate ());
-	ASSERT_NE (nullptr, buffer1);
-	buffer.enqueue (buffer1);
-	auto buffer2 (buffer.allocate ());
-	ASSERT_NE (nullptr, buffer2);
-	ASSERT_NE (buffer1, buffer2);
-	buffer.enqueue (buffer2);
-	auto buffer3 (buffer.allocate ());
-	ASSERT_EQ (buffer1, buffer3);
-	auto buffer4 (buffer.allocate ());
-	ASSERT_EQ (buffer2, buffer4);
-}
-
-TEST (message_buffer_manager, one_buffer_multithreaded)
-{
-	nano::stats stats;
-	nano::message_buffer_manager buffer (stats, 512, 1);
-	boost::thread thread ([&buffer] () {
-		auto done (false);
-		while (!done)
-		{
-			auto item (buffer.dequeue ());
-			done = item == nullptr;
-			if (item != nullptr)
-			{
-				buffer.release (item);
-			}
-		}
-	});
-	auto buffer1 (buffer.allocate ());
-	ASSERT_NE (nullptr, buffer1);
-	buffer.enqueue (buffer1);
-	auto buffer2 (buffer.allocate ());
-	ASSERT_EQ (buffer1, buffer2);
-	buffer.stop ();
-	thread.join ();
-}
-
-TEST (message_buffer_manager, many_buffers_multithreaded)
-{
-	nano::stats stats;
-	nano::message_buffer_manager buffer (stats, 512, 16);
-	std::vector<boost::thread> threads;
-	for (auto i (0); i < 4; ++i)
-	{
-		threads.push_back (boost::thread ([&buffer] () {
-			auto done (false);
-			while (!done)
-			{
-				auto item (buffer.dequeue ());
-				done = item == nullptr;
-				if (item != nullptr)
-				{
-					buffer.release (item);
-				}
-			}
-		}));
-	}
-	std::atomic_int count (0);
-	for (auto i (0); i < 4; ++i)
-	{
-		threads.push_back (boost::thread ([&buffer, &count] () {
-			auto done (false);
-			for (auto i (0); !done && i < 1000; ++i)
-			{
-				auto item (buffer.allocate ());
-				done = item == nullptr;
-				if (item != nullptr)
-				{
-					buffer.enqueue (item);
-					++count;
-					if (count > 3000)
-					{
-						buffer.stop ();
-					}
-				}
-			}
-		}));
-	}
-	buffer.stop ();
-	for (auto & i : threads)
-	{
-		i.join ();
-	}
-}
-
-TEST (message_buffer_manager, stats)
-{
-	nano::stats stats;
-	nano::message_buffer_manager buffer (stats, 512, 1);
-	auto buffer1 (buffer.allocate ());
-	buffer.enqueue (buffer1);
-	buffer.allocate ();
-	ASSERT_EQ (1, stats.count (nano::stat::type::udp, nano::stat::detail::overflow));
-}
-
 TEST (tcp_listener, tcp_node_id_handshake)
 {
 	nano::test::system system (1);