Method pullRequests

source/game/StarCelestialDatabase.cpp:646–674

}

List<CelestialRequest> CelestialSlaveDatabase::pullRequests() {
  RecursiveMutexLocker locker(m_mutex);

  List<CelestialRequest> requests;

  auto chunkIt = makeSMutableMapIterator(m_pendingChunkRequests);
  while (chunkIt.hasNext()) {
    auto& pair = chunkIt.next();
    if (!pair.second.running()) {
      requests.append(makeLeft(pair.first));
      pair.second.restart(m_requestTimeout);
    } else if (pair.second.timeUp()) {
      chunkIt.remove();
    }
  }

  auto systemIt = makeSMutableMapIterator(m_pendingSystemRequests);
  while (systemIt.hasNext()) {
    auto& pair = systemIt.next();
    if (!pair.second.running()) {
      requests.append(makeRight(pair.first));
      pair.second.restart(m_requestTimeout);
    } else if (pair.second.timeUp()) {
      systemIt.remove();
    }
  }

  return requests;
}

void CelestialSlaveDatabase::pushResponses(List<CelestialResponse> responses) {
  RecursiveMutexLocker locker(m_mutex);