clustermessengeri.cpp

GiPS是一个面向数据密集型应用的分布式文件系统

#include "ClusterMessengerI.h"

using namespace std;
using namespace Cluster;

Ice::ObjectAdapterPtr Cluster::ClusterMessengerI::_adapter;

ClusterMessengerI::ClusterMessengerI(const Ice::CommunicatorPtr & ic, ClerkMap* clerkMap)
	: m_clerkMap(clerkMap)
{
	_adapter->add(this, ic->stringToIdentity("ClusterMessenger"));
}

void
ClusterMessengerI::clerkCallBackRegister(const ::std::string& clerkIP, const ::Cluster::ClerkCallBackPrx& clerkCallBack, const ::Ice::Current&)
{
	if (!clerkIP.empty()) {
		m_clerkMap->insert(ClerkMap::value_type(clerkIP, clerkCallBack));
		cout << clerkIP << " register successfully" << endl;
		
//		m_loadTable->push_back();
	}
}