TorqueGameEngines/Torque3D
1
0
Fork 0
mirror of https://github.com/TorqueGameEngines/Torque3D.git synced 2026-03-31 01:55:15 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #1548 from Azaezel/alpha41/eventManagerSafeties

Browse source 
reformulation of subscriber message consumer
This commit is contained in:
Areloch 2025-09-12 00:46:56 -05:00 • committed by GitHub
commit d7d64fdd9f
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 26 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

30
Engine/source/util/messaging/eventManager.cpp
View file

@ -79,24 +79,26 @@ bool EventManagerListener::onMessageReceived( StringTableEntry queue, const char
if( subscribers == NULL )
return true;
for( Vector<Subscriber>::iterator iter = subscribers->begin(); iter != subscribers->end(); iter++ )
for (U32 i = 0; i < subscribers->size(); i++)
{
if( iter->listener == NULL )
Subscriber* itter = &((*subscribers)[i]);
if (itter->listener == NULL)
{
subscribers->erase_fast( iter -- );
continue;
(*subscribers).erase(i);
}
else if (!itter->removeFlag)
{
itter->callDepth++;
Con::executef(itter->listener, itter->callback, data);
itter->callDepth--;
if (itter->removeFlag && itter->callDepth == 0)
{
(*subscribers).erase(i);
}
}
if (!iter->removeFlag)
{
iter->callDepth++;
Con::executef( iter->listener, iter->callback, data );
iter->callDepth--;
if (iter->removeFlag && iter->callDepth==0)
{
subscribers->erase_fast(iter--);
}
}
if (subscribers->size() == 0)
return true;
}
return true;

15
Templates/BaseGame/game/core/clientServer/scripts/server/connectionToClient.tscript
View file

@ -136,8 +136,6 @@ function GameConnectionListener::onSetSpawnObjectTypeComplete( %this, %client )
return; //continue to wait
%client.GetEventManager().remove( %client.listener, "setSpawnObjectTypeComplete" );
%client.GetEventManager().remove( %client.listener, "setSpawnObjectTypeFailed" );
%client.GetEventManager().subscribe( %client.listener, "setSpawnPointComplete" );
%client.GetEventManager().subscribe( %client.listener, "setSpawnPointFailed" );
if (isObject(%client.player))
{
@ -177,7 +175,11 @@ function GameConnection::setSpawnPoint( %this )
%this.numModsNeedingLoaded = getNumCanCallOnObjectList("setSpawnPoint", %modulesIDList);
if (%this.numModsNeedingLoaded)
callOnObjectList("setSpawnPoint", %modulesIdList, %this);
{
%this.GetEventManager().subscribe( %this.listener, "setSpawnPointComplete" );
%this.GetEventManager().subscribe( %this.listener, "setSpawnPointFailed" );
callOnObjectList("setSpawnPoint", %modulesIdList, %this);
}
else
%this.listener.onSetSpawnPointComplete(%this);
}
@ -189,8 +191,7 @@ function GameConnectionListener::onSetSpawnPointComplete( %this, %client )
return; //continue to wait
%client.GetEventManager().remove( %client.listener, "setSpawnPointComplete" );
%client.GetEventManager().remove( %client.listener, "setSpawnPointFailed" );
%client.GetEventManager().subscribe( %client.listener, "postSpawnComplete" );
%client.GetEventManager().remove( %client.listener, "setSpawnPointFailed" );
%client.spawnProperties = "position =\""@ getWords(%client.spawnLocation,0,2) @"\";" @ %client.spawnProperties;
@ -280,9 +281,13 @@ function GameConnection::onPostSpawn( %this )
%this.numModsNeedingLoaded = getNumCanCallOnObjectList("onPostSpawn", %modulesIDList);
if (%this.numModsNeedingLoaded)
{
%this.GetEventManager().subscribe( %this.listener, "postSpawnComplete" );
callOnObjectList("onPostSpawn", %modulesIdList, %this);
}
else
%this.listener.onPostSpawnComplete(%this);
if (isObject(%this.player.getDatablock().controlMap))
commandToClient(%this, 'setMoveMap', %this.player.getDatablock().controlMap);
}