lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2021-01-09 15:41:35 +08:00
parent f154292cb5
commit 3e408e535c
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/org/redkale/net/http/WebSocketRunner.java
View File

@@ -302,9 +302,9 @@ class WebSocketRunner implements Runnable {
if (t != null && context.getLogger().isLoggable(Level.FINER)) { if (t != null && context.getLogger().isLoggable(Level.FINER)) {
context.getLogger().log(Level.FINER, "WebSocket sendMessage abort, force to close channel, live " + (System.currentTimeMillis() - webSocket.getCreatetime()) / 1000 + " seconds", t); context.getLogger().log(Level.FINER, "WebSocket sendMessage abort, force to close channel, live " + (System.currentTimeMillis() - webSocket.getCreatetime()) / 1000 + " seconds", t);
} }
} }
return futureResult.whenComplete((r, t) -> { int ts = webSocket._channel.getWriteTimeoutSeconds();
return futureResult.orTimeout(ts > 0 ? ts : 6, TimeUnit.SECONDS).whenComplete((r, t) -> {
WriteEntry entry = writeQueue.poll(); WriteEntry entry = writeQueue.poll();
if (entry != null) { if (entry != null) {
webSocket._channel.write(entry.writeBuffers, entry.writeBuffers, entry.writeHandler); webSocket._channel.write(entry.writeBuffers, entry.writeBuffers, entry.writeHandler);