++

Author: Zainullin Damir

tests/performance/outputStorage/dummyReader.hpp

@@ -25,16 +25,17 @@ class DummyReader {
 	std::size_t readContainers() noexcept
 	{
 		// m_storage.registerReader(m_readerGroupIndex);
+		std::size_t printCounter{};
 		ipxp::output::OutputStorage::ReadHandler readHandler
 			= m_readerGroupHandler.getReaderHandler();
 		while (!readHandler.finished()) {
 			while (readHandler.getFlowRecord() != nullptr) {
-				if (std::chrono::steady_clock::now() - m_lastPrintTime > std::chrono::seconds(20)) {
+				if (counter++ % (1ULL << 35)) {
 					const std::string message = "Reader  "
 						+ std::to_string(readHandler.getReaderIndex()) + " read "
 						+ std::to_string(readHandler.readContainers()) + " containers so far.";
 					std::cout << message << std::endl;
-					m_lastPrintTime = std::chrono::steady_clock::now();
+					// m_lastPrintTime = std::chrono::steady_clock::now();
 				}
 			}
 		}
@@ -46,5 +47,5 @@ class DummyReader {
 	// std::size_t m_readerGroupIndex;
 	ipxp::output::OutputStorage::ReaderGroupHandler& m_readerGroupHandler;
 	bool m_immitateWork;
-	std::chrono::steady_clock::time_point m_lastPrintTime = std::chrono::steady_clock::now();
+	//std::chrono::steady_clock::time_point m_lastPrintTime = std::chrono::steady_clock::now();
 };