Function session_data

src/server/NymphCastServer.cpp:929–1036

Client sends a chunk of track data. Returns: OK (0), ERROR (1). int session_data(string buffer, boolean done)

// Returns: OK (0), ERROR (1).
// int session_data(string buffer, boolean done)
NymphMessage* session_data(int session, NymphMessage* msg, void* data) {
	NymphMessage* returnMsg = msg->getReplyMessage();
	
	// Get iterator to the session instance for the client.
	std::map<int, CastClient>::iterator it;
	it = clients.find(session);
	if (it == clients.end()) {
		returnMsg->setResultValue(new NymphType((uint8_t) 1));
		msg->discard();
		return returnMsg;
	}
	
	// Safely write the data for this session to the buffer.
	NymphType* mediaData = msg->parameters()[0];
	bool done = msg->parameters()[1]->getBool();
	
	// Update EOF status.
	DataBuffer::setEof(done);
	
	// Write string into buffer.
	DataBuffer::write(mediaData->getChar(), mediaData->string_length());
	
	// If passing the message through to slave remotes, add the timestamp to the message.
	// This timestamp is the current time plus the largest master-slave latency times 2.
	int64_t then = 0;
	if (serverMode == NCS_MODE_MASTER) {
		Poco::Timestamp ts;
		int64_t now = (int64_t) ts.epochMicroseconds();
		//then = now + (slaveLatencyMax * 2);
		
		// Timing: 	Multiply the max slave latency by the number of slaves. After sending this delay
		// 			to the first slave (minus half its recorded latency), 
		// 			subtract the time it took to send to this slave from the
		//			first delay, then send this new delay to the second slave, and so on.
		int64_t countdown = slaveLatencyMax * slave_remotes.size();
		
		for (int i = 0; i < slave_remotes.size(); ++i) {
			NymphCastSlaveRemote& rm = slave_remotes[i];
			//then = slaveLatencyMax - rm.delay;
			then = countdown - (rm.delay / 2);
			
			int64_t send = (int64_t) ts.epochMicroseconds();
		
			// Prepare data vector.
			NymphType* media = new NymphType((char*) mediaData->getChar(), mediaData->string_length());
			NymphType* doneBool = new NymphType(done);
			std::vector<NymphType*> values;
			values.push_back(media);
			values.push_back(doneBool);
			values.push_back(new NymphType(then));
			
			std::string result;
			NymphType* returnValue = 0;
			if (!NymphRemoteServer::callMethod(rm.handle, "receiveDataMaster", values, returnValue, result)) {
				// TODO:
			}
			
			delete returnValue;