Kaladaran/briar
0
0
Fork 0
mirror of https://code.briarproject.org/briar/briar.git synced 2026-02-15 20:29:52 +01:00
Code Issues Projects Releases Wiki Activity

Flush the output stream before rather than after waiting for packets.

Browse Source 
See bug #27.
This commit is contained in:
akwizgran
2014-11-09 18:03:24 +00:00
parent 4b92de619c
commit ab467b3d3e
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
briar-core/src/org/briarproject/messaging/DuplexOutgoingSession.java
View File

@@ -106,11 +106,11 @@ class DuplexOutgoingSession implements MessagingSession, EventListener {
// Write packets until interrupted // Write packets until interrupted
try { try {
while(!interrupted) { while(!interrupted) {
// Flush the stream if it's going to be idle
if(writerTasks.isEmpty()) out.flush();
ThrowingRunnable<IOException> task = writerTasks.take(); ThrowingRunnable<IOException> task = writerTasks.take();
if(task == CLOSE) break; if(task == CLOSE) break;
task.run(); task.run();
// Flush the stream if it's going to be idle
if(writerTasks.isEmpty()) out.flush();
} }
out.flush(); out.flush();
} catch(InterruptedException e) { } catch(InterruptedException e) {