Function session_add_slave

src/server/NymphCastServer.cpp:825–923

--- SESSION ADD SLAVE --- Client sends list of slave server which this server instance should control. Returns: OK (0), ERROR (1). int session_add_slave(array servers);

// Returns: OK (0), ERROR (1).
// int session_add_slave(array servers);
NymphMessage* session_add_slave(int session, NymphMessage* msg, void* data) {
	NymphMessage* returnMsg = msg->getReplyMessage();
	
	// Extract the array.
	std::vector<NymphType*>* remotes = msg->parameters()[0]->getArray();
	for (int i = 0; i < (*remotes).size(); ++i) {
		std::map<std::string, NymphPair>* pairs = (*remotes)[i]->getStruct();
		NymphCastSlaveRemote remote;
		NymphType* value = 0;
		(*remotes)[i]->getStructValue("name", value);
		remote.name = std::string(value->getChar(), value->string_length());
		
		(*remotes)[i]->getStructValue("ipv4", value);
		remote.ipv4 = std::string(value->getChar(), value->string_length());
		
		(*remotes)[i]->getStructValue("ipv6", value);
		remote.ipv6 = std::string(value->getChar(), value->string_length());
		
		(*remotes)[i]->getStructValue("port", value);
		remote.port = value->getUint16();
		remote.handle = 0;
		remote.delay = 0;
	
		slave_remotes.push_back(remote);
	}
	
	// Validate that each slave remote is accessible and determine latency.
	for (int i = 0; i < slave_remotes.size(); ++i) {
		// Establish RPC connection to remote. Starts the PTP-like handshake.
		NymphCastSlaveRemote& rm = slave_remotes[i];
		std::string result;
		if (!NymphRemoteServer::connect(rm.ipv4, 4004, rm.handle, 0, result)) {
			// Failed to connect, error out. Disconnect from any already connected slaves.
			NYMPH_LOG_ERROR("Slave connection error: " + result);
			for (; i >= 0; --i) {
				NymphCastSlaveRemote& drm = slave_remotes[i];
				NymphRemoteServer::disconnect(drm.handle, result);
			}
			
			returnMsg->setResultValue(new NymphType((uint8_t) 1));
			msg->discard();
			
			return returnMsg;
		}
		
		// Attempt to start slave mode on the remote.
		// Send the current timestamp to the slave remote as part of the latency determination.
		Poco::Timestamp ts;
		int64_t now = (int64_t) ts.epochMicroseconds();
		std::vector<NymphType*> values;
		values.push_back(new NymphType(now));
		NymphType* returnValue = 0;
		if (!NymphRemoteServer::callMethod(rm.handle, "connectMaster", values, returnValue, result)) {
			NYMPH_LOG_ERROR("Slave connect master failed: " + result);
			// TODO: disconnect from slave remotes.
			returnMsg->setResultValue(new NymphType((uint8_t) 1));
			msg->discard();