diff --git a/code/ryzom/server/src/mirror_service/data_set_ms.cpp b/code/ryzom/server/src/mirror_service/data_set_ms.cpp index 9c12fc6a1..994b45e5b 100644 --- a/code/ryzom/server/src/mirror_service/data_set_ms.cpp +++ b/code/ryzom/server/src/mirror_service/data_set_ms.cpp @@ -91,8 +91,8 @@ void CDataSetMS::readdAllocatedTrackers( NLNET::CMessage& msgin, TServiceId s TSelfPropTrackers::const_iterator ipt; for ( ipt=selfPropTrackers.begin(); ipt!=selfPropTrackers.end(); ++ipt ) { - smidpool.reacquireId( (*ipt).smid() ); - mutidpool.reacquireId( (*ipt).mutid() ); + smidpool.reacquireId( (*ipt).smid() & 0xFFF ); + mutidpool.reacquireId( (*ipt).mutid() & 0xFFF ); _SubscribersByProperty[(*ipt).propIndex()].push_back( CChangeTrackerMS( serviceId, true, @@ -107,15 +107,15 @@ void CDataSetMS::readdAllocatedTrackers( NLNET::CMessage& msgin, TServiceId s // Entity trackers CChangeTrackerClient selfAddingTracker; msgin.serial( selfAddingTracker ); - smidpool.reacquireId( selfAddingTracker.smid() ); - mutidpool.reacquireId( selfAddingTracker.mutid() ); + smidpool.reacquireId( selfAddingTracker.smid() & 0xFFF ); + mutidpool.reacquireId( selfAddingTracker.mutid() & 0xFFF ); _EntityTrackers[ADDING].push_back( CChangeTrackerMS( serviceId, true ) ); _EntityTrackers[ADDING].back().reaccess( selfAddingTracker.smid() ); _EntityTrackers[ADDING].back().createMutex( selfAddingTracker.mutid(), false ); CChangeTrackerClient selfRemovingTracker; msgin.serial( selfRemovingTracker ); - smidpool.reacquireId( selfRemovingTracker.smid() ); - mutidpool.reacquireId( selfRemovingTracker.mutid() ); + smidpool.reacquireId( selfRemovingTracker.smid() & 0xFFF ); + mutidpool.reacquireId( selfRemovingTracker.mutid() & 0xFFF ); _EntityTrackers[REMOVING].push_back( CChangeTrackerMS( serviceId, true ) ); _EntityTrackers[REMOVING].back().reaccess( selfRemovingTracker.smid() ); _EntityTrackers[REMOVING].back().createMutex( selfRemovingTracker.mutid(), false ); diff --git a/code/ryzom/server/src/mirror_service/mirror_service.cpp b/code/ryzom/server/src/mirror_service/mirror_service.cpp index 3f0154b31..9b7ae4077 100644 --- a/code/ryzom/server/src/mirror_service/mirror_service.cpp +++ b/code/ryzom/server/src/mirror_service/mirror_service.cpp @@ -166,6 +166,15 @@ void CMirrorService::init() _IsPureReceiver = true; nlinfo( "\tThis MS is in pure receiver mode" ); } + CConfigFile::CVar *varS = ConfigFile.getVarPtr("ShardId"); + if (varS) + { + m_ShardId = varS->asInt(); + if ((m_ShardId & 0xFFF) != m_ShardId) + nlwarning("\tConfigured ShardId %u is too large", (unsigned int)m_ShardId); + m_ShardId &= 0xFFF; + nlinfo("\tShardId for shared memory namespace is %u", (unsigned int)m_ShardId); + } // Register to ServiceUp and ServiceDown CUnifiedNetwork::getInstance()->setServiceUpCallback( "*", cbServiceUp, 0 ); @@ -540,8 +549,8 @@ void CMirrorService::deleteTracker( CChangeTrackerMS& tracker, std::vectorallocate( smid, ds->maxNbRows() ) ) smid = InvalidSMId; } @@ -3283,7 +3301,7 @@ void CMirrorService::receiveSyncMirrorInformation( CMessage& msgin, TServiceId s if ( ! propInfo.allocated() ) { // Reaccess shared memory - _SMIdPool.reacquireId( propInfoClient.SMId ); + _SMIdPool.reacquireId( propInfoClient.SMId & 0xFFF ); _PropertiesInMirror[propName].reaccess( propInfoClient.SMId ); // Set property pointers but don't init values diff --git a/code/ryzom/server/src/mirror_service/mirror_service.h b/code/ryzom/server/src/mirror_service/mirror_service.h index 5d7104bd0..552afa1a3 100644 --- a/code/ryzom/server/src/mirror_service/mirror_service.h +++ b/code/ryzom/server/src/mirror_service/mirror_service.h @@ -695,7 +695,7 @@ public: /// Constructor CMirrorService() : - _NumberOfOnlineMS(1), + m_ShardId(DEFAULT_SHARD_ID), _NumberOfOnlineMS(1), _RangeManagerReady(false), _MirrorsOnline(false), _DeltaSent(false), _BlockedAwaitingATAck(false), _EmittedKBytesPerSecond(0.0f), _EmittedBytesPartialSum(0), _TimeOfLatestEmittedBytesAvg(0), _NbDeltaUpdatesReceived(0), _NbExpectedDeltaUpdates(0), _IsPureReceiver(false) @@ -1054,6 +1054,9 @@ private: /// Properties in the local mirror TPropertiesInMirrorMS _PropertiesInMirror; + /// Shard id as in the config file, DEFAULT_SHARD_ID otherwise. Used for pool namespacing + uint32 m_ShardId; + /// Shared memory id pool, to generate new ids CSMIdPool _SMIdPool;