I2CP: Don't send multiple SetDate messages to sessions with subsessions
Some checks failed
Sync Primary Repository to GitHub Mirror / sync (push) Has been cancelled
Daily Workflow / daily-job (push) Has been cancelled
Daily Workflow / javadoc-latest (push) Has been cancelled
Daily Workflow / build-java7 (push) Has been cancelled
Java CI / build (push) Has been cancelled
Java CI / javadoc-latest (push) Has been cancelled
Java CI / build-java7 (push) Has been cancelled
Dockerhub / docker (push) Has been cancelled
Java with IzPack Snapshot Setup / setup (push) Has been cancelled
Some checks failed
Sync Primary Repository to GitHub Mirror / sync (push) Has been cancelled
Daily Workflow / daily-job (push) Has been cancelled
Daily Workflow / javadoc-latest (push) Has been cancelled
Daily Workflow / build-java7 (push) Has been cancelled
Java CI / build (push) Has been cancelled
Java CI / javadoc-latest (push) Has been cancelled
Java CI / build-java7 (push) Has been cancelled
Dockerhub / docker (push) Has been cancelled
Java with IzPack Snapshot Setup / setup (push) Has been cancelled
as reported by mareki2p
This commit is contained in:
@ -863,7 +863,13 @@ class ClientManager {
|
|||||||
public void timeReached() {
|
public void timeReached() {
|
||||||
if (!_isStarted)
|
if (!_isStarted)
|
||||||
return;
|
return;
|
||||||
for (ClientConnectionRunner runner : _runners.values()) {
|
if (_runners.isEmpty()) {
|
||||||
|
schedule(LOOP_TIME);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
// dedup subsessions
|
||||||
|
Set<ClientConnectionRunner> runners = new HashSet<ClientConnectionRunner>(_runners.values());
|
||||||
|
for (ClientConnectionRunner runner : runners) {
|
||||||
if (runner instanceof QueuedClientConnectionRunner)
|
if (runner instanceof QueuedClientConnectionRunner)
|
||||||
continue;
|
continue;
|
||||||
if (runner.isDead())
|
if (runner.isDead())
|
||||||
|
Reference in New Issue
Block a user