testAcquireBoundQueue() — netty Function Reference
Architecture documentation for the testAcquireBoundQueue() function in FixedChannelPoolTest.java from the netty codebase.
Entity Profile
Dependency Diagram
graph TD 82019ee6_5d4f_c4b5_7480_632eda0746a8["testAcquireBoundQueue()"] 92761f16_3144_6791_29c9_00f65a091a8f["FixedChannelPoolTest"] 82019ee6_5d4f_c4b5_7480_632eda0746a8 -->|defined in| 92761f16_3144_6791_29c9_00f65a091a8f style 82019ee6_5d4f_c4b5_7480_632eda0746a8 fill:#6366f1,stroke:#818cf8,color:#fff
Relationship Graph
Source Code
transport/src/test/java/io/netty/channel/pool/FixedChannelPoolTest.java lines 174–196
@Test
public void testAcquireBoundQueue() throws Exception {
Tuple t = bootstrap();
// Start server
Channel sc = t.sb.bind(t.address).syncUninterruptibly().channel();
ChannelPoolHandler handler = new TestChannelPoolHandler();
final ChannelPool pool = new FixedChannelPool(t.cb, handler, 1, 1);
Channel channel = pool.acquire().syncUninterruptibly().getNow();
Future<Channel> future = pool.acquire();
assertFalse(future.isDone());
assertThrows(IllegalStateException.class, new Executable() {
@Override
public void execute() throws Throwable {
pool.acquire().syncUninterruptibly();
}
});
sc.close().syncUninterruptibly();
channel.close().syncUninterruptibly();
pool.close();
}
Domain
Subdomains
Source
Frequently Asked Questions
What does testAcquireBoundQueue() do?
testAcquireBoundQueue() is a function in the netty codebase, defined in transport/src/test/java/io/netty/channel/pool/FixedChannelPoolTest.java.
Where is testAcquireBoundQueue() defined?
testAcquireBoundQueue() is defined in transport/src/test/java/io/netty/channel/pool/FixedChannelPoolTest.java at line 174.
Analyze Your Own Codebase
Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.
Try Supermodel Free