Differential D7554 Diff 23771 src/avalanche/test/processor_tests.cpp

Changeset View

Standalone View

Show First 20 Lines • Show All 950 Lines • ▼ Show 20 Lines	BOOST_AUTO_TEST_CASE(event_loop) {

connman->ClearNodes();		connman->ClearNodes();
}		}

BOOST_AUTO_TEST_CASE(destructor) {		BOOST_AUTO_TEST_CASE(destructor) {
CScheduler s;		CScheduler s;
std::chrono::system_clock::time_point start, stop;		std::chrono::system_clock::time_point start, stop;

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

{		{
Processor p(m_node.connman.get());		Processor 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);

		// Start the service thread after the queue size check to prevent a
		// race condition where the thread may be processing the event loop
		// task during the check.
		schedulerThread = std::thread(std::bind(&CScheduler::serviceQueue, &s));
}		}

// 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()