SharedVisualizationServer.cpp

/***********************************************************************
SharedVisualizationServer - Server for collaborative data exploration in
spatially distributed VR environments, implemented as a plug-in of the
Vrui remote collaboration infrastructure.
Copyright (c) 2009-2023 Oliver Kreylos

This file is part of the 3D Data Visualizer (Visualizer).

The 3D Data Visualizer is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License as published
by the Free Software Foundation; either version 2 of the License, or (at
your option) any later version.

The 3D Data Visualizer is distributed in the hope that it will be
useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
General Public License for more details.

You should have received a copy of the GNU General Public License along
with the 3D Data Visualizer; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
***********************************************************************/

#include "SharedVisualizationServer.h"

namespace Collab {

namespace Plugins {

/******************************************
Methods of class SharedVisualizationServer:
******************************************/

MessageContinuation* SharedVisualizationServer::connectRequestCallback(unsigned int messageId,unsigned int clientId,MessageContinuation* continuation)
	{
	/* Access the base client state object and its TCP socket: */
	Server::Client* client=server->getClient(clientId);
	NonBlockSocket& socket=client->getSocket();
	
	/* Read the layout of the client's dataset: */
	unsigned int clientNumScalarVariables=socket.read<VariableIndex>();
	unsigned int clientNumVectorVariables=socket.read<VariableIndex>();
	
	bool compatible;
	if(clientNumScalarVariables==numScalarVariables&&clientNumVectorVariables==numVectorVariables)
		compatible=true;
	else if(numScalarVariables==0&&numVectorVariables==0)
		{
		/* Adopt the client's dataset layout: */
		numScalarVariables=clientNumScalarVariables;
		colorMaps=new ColorMap*[numScalarVariables];
		for(unsigned int i=0;i<numScalarVariables;++i)
			colorMaps[i]=0;
		numVectorVariables=clientNumVectorVariables;
		
		compatible=true;
		}
	else
		compatible=false;
	
	/* Check if the client is compatible: */
	if(compatible)
		{
		/* Create a connect reply message: */
		ConnectReplyMsg connectReply;
		
		/* Send each already-defined color map to the new client: */
		for(unsigned int i=0;i<numScalarVariables;++i)
			if(colorMaps[i]!=0)
				{
				/* Add the color map to the connect reply message: */
				connectReply.colorMaps.push_back(ConnectReplyMsg::ColorMapListEntry(VariableIndex(i),*colorMaps[i]));
				}
		
		/* Send the connect reply message: */
		sendClientMessage(ConnectReply,&connectReply,client);
		}
	else
		{
		/* Send a connect reject message: */
		client->queueMessage(MessageBuffer::create(serverMessageBase+ConnectReject,0));
		}
	
	/* Done with message: */
	return 0;
	}

SharedVisualizationServer::SharedVisualizationServer(Server* sServer)
	:PluginServer(sServer),
	 numScalarVariables(0),colorMaps(0),
	 numVectorVariables(0)
	{
	}

SharedVisualizationServer::~SharedVisualizationServer(void)
	{
	/* Release all color maps: */
	for(unsigned int i=0;i<numScalarVariables;++i)
		delete[] colorMaps[i];
	delete[] colorMaps;
	}

const char* SharedVisualizationServer::getName(void) const
	{
	return protocolName;
	}

unsigned int SharedVisualizationServer::getVersion(void) const
	{
	return protocolVersion;
	}

unsigned int SharedVisualizationServer::getNumClientMessages(void) const
	{
	return NumClientMessages;
	}

unsigned int SharedVisualizationServer::getNumServerMessages(void) const
	{
	return NumServerMessages;
	}

void SharedVisualizationServer::setMessageBases(unsigned int newClientMessageBase,unsigned int newServerMessageBase)
	{
	/* Call the base class method: */
	PluginServer::setMessageBases(newClientMessageBase,newServerMessageBase);
	
	/* Register message handlers: */
	server->setMessageHandler(clientMessageBase+ConnectRequest,Server::wrapMethod<SharedVisualizationServer,&SharedVisualizationServer::connectRequestCallback>,this,getClientMsgSize(ConnectRequest));
	}

void SharedVisualizationServer::start(void)
	{
	}

void SharedVisualizationServer::clientConnected(unsigned int clientId)
	{
	}

void SharedVisualizationServer::clientDisconnected(unsigned int clientId)
	{
	}

/***********************
DSO loader entry points:
***********************/

extern "C" {

PluginServer* createObject(PluginServerLoader& objectLoader,Server* server)
	{
	return new SharedVisualizationServer(server);
	}

void destroyObject(PluginServer* object)
	{
	delete object;
	}

}

}

}