Method processUniverseFlags

source/game/StarUniverseServer.cpp:601–639

}

void UniverseServer::processUniverseFlags() {
  RecursiveMutexLocker locker(m_mainLock);
  ReadLocker clientsLocker(m_clientsLock);

  if (auto actions = m_universeSettings->pullPendingFlagActions()) {
    for (auto action : *actions) {
      if (action.is<PlaceDungeonFlagAction>()) {
        auto placeDungeonAction = action.get<PlaceDungeonFlagAction>();
        if (instanceWorldStoredOrActive(placeDungeonAction.targetInstance)) {
          auto worldId = InstanceWorldId(placeDungeonAction.targetInstance);
          m_pendingFlagActions.append(pair<WorldId, UniverseFlagAction>{worldId, placeDungeonAction});
        }
      }
    }
  }

  eraseWhere(m_pendingFlagActions, [&](pair<WorldId, UniverseFlagAction> const& p) {
      if (p.first.is<InstanceWorldId>() && instanceWorldStoredOrActive(p.first.get<InstanceWorldId>())) {
        // world is stored or active; perform flag actions once it loads
        if (auto maybeTargetWorld = triggerWorldCreation(p.first)) {
          if (auto targetWorld = maybeTargetWorld.value()) {
            if (p.second.is<PlaceDungeonFlagAction>()) {
              auto placeDungeonAction = p.second.get<PlaceDungeonFlagAction>();
              locker.unlock();
              targetWorld->executeAction([&](WorldServerThread*, WorldServer* worldServer) {
                worldServer->placeDungeon(placeDungeonAction.dungeonId, placeDungeonAction.targetPosition, 0);
              });
              locker.lock();
            }
            return true;
          }
        }
        return false;
      } else {
        // world hasn't yet been created; flag actions will be handled by normal creation
        return true;
      }
    });
}

void UniverseServer::sendPendingChat() {
  RecursiveMutexLocker locker(m_mainLock);