Method run

src/server/ffplaydummy.cpp:271–331

--- RUN ---

// --- RUN ---
void FfplayDummy::run() {
	buf = (uint8_t*) malloc(buf_size);
	
	read_size = start_size;
	
	// Start main loop.
	// This loop waits until it is triggered, at which point there should either be a URL to
	// stream from, or a file to stream via the DataBuffer.
	running = true;
	playerStarted = false;
	std::mutex playbackMtx;
	while (running) {
		// Wait in condition variable until triggered. Ensure an event is waiting to deal with
		// spurious wake-ups.
		std::unique_lock<std::mutex> lk(playbackMtx);
		using namespace std::chrono_literals;
		dumbplaybackCv.wait(lk);
		
		if (!running) {
			std::cout << "Terminating AV thread..." << std::endl;
			break;
		}
		
		// Intercept spurious wake-ups.
		if (!playingTrack && !castingUrl) { continue; }
		
		// Start playback.
		playerStarted = true;
		
		// Update clients with status update.
		sendGlobalStatusUpdate();
		
		// Start dummy playback:
		// - Request a 32 kB data block every N milliseconds.
		// - Once EOF is returned, wait N milliseconds, then quit.
		ct.setCallback(FfplayDummy::triggerRead, 0);
		ct.setStopCallback(FfplayDummy::cleanUp);
		ct.start(50);	// Trigger time in milliseconds.
	
		// Wait here until playback has finished.
		// The read thread in StreamHandler will signal this condition variable.
		dummyMutex.lock();
		dummyCon.wait(dummyMutex);
		dummyMutex.unlock();
		
		ct.stop();
		
		DataBuffer::reset();	// Clears the data buffer (file data buffer).
		finishPlayback();		// Calls handler for post-playback steps.
		
		// Clean up.
		free(buf);
	
		playerStarted = false;
		playingTrack = false;
		castingUrl = false;
		
		// Update clients with status update.