Function dataRequestFunction

src/test/test_databuffer_multi_port.cpp:79–117

--- DATA REQUEST FUNCTION --- This function can be signalled with the condition variable to request data from the client.

// --- DATA REQUEST FUNCTION ---
// This function can be signalled with the condition variable to request data from the client.
void dataRequestFunction() {
	// Create and share condition variable with DataBuffer class.
	DataBuffer::setDataRequestCondition(&dataRequestCv);
	
	while (running) {
		// Wait for the condition to be signalled.
		std::unique_lock<std::mutex> lk(dataRequestMtx);
		using namespace std::chrono_literals;
		dataRequestCv.wait(lk);
		
		if (!running) {
			std::cout << "Shutting down data request function..." << std::endl;
			break;
		}
		
		// Set data request as pending.
		DataBuffer::dataRequestPending = true;
		
		//std::cout << "Asking for data..." << std::endl;
	
		// Write into buffer after a brief delay.
		std::this_thread::sleep_for(std::chrono::milliseconds(1));
		
		// Create fresh chunk using counter.
		for (uint32_t i = 0; i < chunk_size; ++i) {
			chunk[i] = writeCnt++;
		}
		
		DataBuffer::write(chunk, chunk_size);
		
		if (!playerRunning) {
			// Start playback locally.
			ffplay.playTrack();
			playerRunning = true;
			
			DataBuffer::startBufferAhead();
		}
	}
}


// --- SEEKING HANDLER ---