Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

dispatch from the timer thread to iterate 

Signed-off-by: Ludovic Orban <lorban@bitronix.be>
This commit is contained in:
Ludovic Orban 2021-03-30 16:47:01 +02:00 committed by Simone Bordet
parent 2244be64ef
commit 5424f67132
1 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
jetty-http3/http3-common/src/main/java/org/eclipse/jetty/http3/common/QuicSession.java
View File

@ -157,14 +157,17 @@ public abstract class QuicSession
List<Long> writableStreamIds = quicheConnection.writableStreamIds();
if (LOG.isDebugEnabled())
LOG.debug("writable stream ids: {}", writableStreamIds);
Runnable onWritable = () ->
if (!writableStreamIds.isEmpty())
{
for (Long writableStreamId : writableStreamIds)
Runnable onWritable = () ->
{
onWritable(writableStreamId);
}
};
dispatch(onWritable);
for (Long writableStreamId : writableStreamIds)
{
onWritable(writableStreamId);
}
};
dispatch(onWritable);
}
List<Long> readableStreamIds = quicheConnection.readableStreamIds();
if (LOG.isDebugEnabled())
@ -281,8 +284,9 @@ public abstract class QuicSession
LOG.debug("quiche timeout callback");
quicheConnection.onTimeout();
if (LOG.isDebugEnabled())
LOG.debug("re-iterating quiche after timeout");
iterate();
LOG.debug("re-iterating quiche after timeout cid={}", quicheConnectionId);
// do not use the timer thread to iterate
dispatch(() -> iterate());
}
};
}