Function session_start

src/server/NymphCastServer.cpp:708–804

Client starts a session. Return value: OK (0), ERROR (1). int session_start(struct fileInfo)

// Return value: OK (0), ERROR (1).
// int session_start(struct fileInfo)
NymphMessage* session_start(int session, NymphMessage* msg, void* data) {
	NymphMessage* returnMsg = msg->getReplyMessage();
	
	// Set up a new 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;
	}
	
	// Obtain the filesize from the client, which we use with the buffer management.
	NymphType* fileInfo = msg->parameters()[0];
	NymphType* num = 0;
	if (!fileInfo->getStructValue("filesize", num)) {
		NYMPH_LOG_FATAL("Didn't find entry 'filesize'. Aborting...");
		returnMsg->setResultValue(new NymphType((uint8_t) 1));
		msg->discard();
		
		return returnMsg;
	}
	
	it->second.filesize = num->getUint32();
	
	// Check whether we're already playing or not. If we continue here, this will forcefully 
	// end current playback.
	//	FIXME:	=> this likely happens due to a status update glitch. Fix by sending back status update
	// 			along with error?
	if (ffplay.playbackActive()) {
		NYMPH_LOG_ERROR("Trying to start a new session with session already active. Abort.");
		returnMsg->setResultValue(new NymphType((uint8_t) 1));
		msg->discard();
		
		return returnMsg;
	}
	
	// If the AV thread is currently running, we wait until it's quit.
	//if (avThread.joinable()) { avThread.join(); } // FIXME: C++11 version
	/* if (avThread.isRunning()) {
		std::cout << "AV thread active: waiting for join..." << std::endl;
		bool ret = avThread.tryJoin(100);
		if (!ret) {
			// Player thread is still running, meaning we cannot proceed. Error out.
			std::cerr << "Joining failed: aborting new session..." << std::endl;
			returnMsg->setResultValue(new NymphType((uint8_t) 1));
			msg->discard();

			return returnMsg;
		}
	} */
	
	NYMPH_LOG_INFORMATION("Starting new session for file with size: " +
							Poco::NumberFormatter::format(it->second.filesize));
	
	DataBuffer::setFileSize(it->second.filesize);
	DataBuffer::setSessionHandle(session);