Changeset View

Standalone View

	Show First 20 Lines • Show All 950 Lines • ▼ Show 20 Lines
	BOOST_AUTO_TEST_CASE(destructor) {			BOOST_AUTO_TEST_CASE(destructor) {
	CScheduler s;			CScheduler s;
	boost::chrono::system_clock::time_point start, stop;			boost::chrono::system_clock::time_point start, stop;

	// Start the scheduler thread.			// Start the scheduler thread.
	std::thread schedulerThread(std::bind(&CScheduler::serviceQueue, &s));			std::thread schedulerThread(std::bind(&CScheduler::serviceQueue, &s));

	{			{
	AvalancheProcessor p(g_connman.get());			AvalancheProcessor p(m_node.connman.get());
	BOOST_CHECK(p.startEventLoop(s));			BOOST_CHECK(p.startEventLoop(s));
	BOOST_CHECK_EQUAL(s.getQueueInfo(start, stop), 1);			BOOST_CHECK_EQUAL(s.getQueueInfo(start, stop), 1);
	}			}

	// Now that avalanche is destroyed, there is no more scheduled tasks.			// Now that avalanche is destroyed, there is no more scheduled tasks.
	BOOST_CHECK_EQUAL(s.getQueueInfo(start, stop), 0);			BOOST_CHECK_EQUAL(s.getQueueInfo(start, stop), 0);

	// Wait for the scheduler to stop.			// Wait for the scheduler to stop.
	s.stop(true);			s.stop(true);
	schedulerThread.join();			schedulerThread.join();
	}			}

	BOOST_AUTO_TEST_SUITE_END()			BOOST_AUTO_TEST_SUITE_END()