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

Use larger buffer in test connections to prevent deadlock.

Browse Source
This commit is contained in:
akwizgran
2019-06-03 17:07:24 +01:00
parent f95bb9b28e
commit 0b764a01dd
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
bramble-core/src/test/java/org/briarproject/bramble/test/TestDuplexTransportConnection.java
View File

@@ -21,6 +21,7 @@ public class TestDuplexTransportConnection
private final TransportConnectionReader reader; private final TransportConnectionReader reader;
private final TransportConnectionWriter writer; private final TransportConnectionWriter writer;
@SuppressWarnings("WeakerAccess")
public TestDuplexTransportConnection(InputStream in, OutputStream out) { public TestDuplexTransportConnection(InputStream in, OutputStream out) {
reader = new TestTransportConnectionReader(in); reader = new TestTransportConnectionReader(in);
writer = new TestTransportConnectionWriter(out); writer = new TestTransportConnectionWriter(out);
@@ -42,8 +43,9 @@ public class TestDuplexTransportConnection
*/ */
public static TestDuplexTransportConnection[] createPair() public static TestDuplexTransportConnection[] createPair()
throws IOException { throws IOException {
PipedInputStream aliceIn = new PipedInputStream(); // Use 64k buffers to prevent deadlock
PipedInputStream bobIn = new PipedInputStream(); PipedInputStream aliceIn = new PipedInputStream(1 << 16);
PipedInputStream bobIn = new PipedInputStream(1 << 16);
PipedOutputStream aliceOut = new PipedOutputStream(bobIn); PipedOutputStream aliceOut = new PipedOutputStream(bobIn);
PipedOutputStream bobOut = new PipedOutputStream(aliceIn); PipedOutputStream bobOut = new PipedOutputStream(aliceIn);
TestDuplexTransportConnection alice = TestDuplexTransportConnection alice =