Function receiveDataMaster

src/server/NymphCastServer.cpp:626–660

--- RECEIVE DATA MASTER --- Receives data chunks for playback. uint8 receiveDataMaster(blob data)

// Receives data chunks for playback.
// uint8 receiveDataMaster(blob data)
NymphMessage* receiveDataMaster(int session, NymphMessage* msg, void* data) {
	NymphMessage* returnMsg = msg->getReplyMessage();
	
	// Extract data blob and add it to the buffer.
	NymphType* mediaData = msg->parameters()[0];
	bool done = msg->parameters()[1]->getBool();
	int64_t when = msg->parameters()[2]->getInt64();
	
	// Write string into buffer.
	DataBuffer::write(mediaData->getChar(), mediaData->string_length());
	
	if (!ffplay.playbackActive()) {
		// Start the player when the delay in 'when' has been reached.
		std::condition_variable cv;
		std::mutex cv_m;
		std::unique_lock<std::mutex> lk(cv_m);
		//std::chrono::system_clock::time_point then = std::chrono::system_clock::from_time_t(when);
		std::chrono::microseconds dur(when);
		std::chrono::time_point<std::chrono::system_clock> then(dur);
		//while (cv.wait_until(lk, then) != std::cv_status::timeout) { }
		while (cv.wait_for(lk, dur) != std::cv_status::timeout) { }
		
		// Start player.
		ffplay.playTrack();
	}
	
	if (done) {
		DataBuffer::setEof(done);
	}
	
	msg->discard();
	
	returnMsg->setResultValue(new NymphType((uint8_t) 0));
	return returnMsg;
}


// Client disconnects from server.