testSetUpCqSize() — netty Function Reference
Architecture documentation for the testSetUpCqSize() function in SubmissionQueueTest.java from the netty codebase.
Entity Profile
Dependency Diagram
graph TD c8a87734_2b6f_4c17_999d_32433d5239f9["testSetUpCqSize()"] fd25db8c_3569_d733_e052_a05bfd7b5f45["SubmissionQueueTest"] c8a87734_2b6f_4c17_999d_32433d5239f9 -->|defined in| fd25db8c_3569_d733_e052_a05bfd7b5f45 style c8a87734_2b6f_4c17_999d_32433d5239f9 fill:#6366f1,stroke:#818cf8,color:#fff
Relationship Graph
Source Code
transport-native-io_uring/src/test/java/io/netty/channel/uring/SubmissionQueueTest.java lines 101–126
@Test
@DisabledIf("setUpCQSizeUnavailable")
public void testSetUpCqSize() {
int cqSize = 8;
RingBuffer ringBuffer = Native.createRingBuffer(2, cqSize, Native.IORING_SETUP_CQSIZE);
try {
assertNotNull(ringBuffer);
ringBuffer.enable();
assertEquals(cqSize, ringBuffer.ioUringCompletionQueue().ringEntries);
int count = cqSize;
while (count > 0) {
assertThat(ringBuffer.ioUringSubmissionQueue().addNop((byte) 0, 1)).isNotZero();
count--;
if (ringBuffer.ioUringSubmissionQueue().remaining() == 0) {
ringBuffer.ioUringSubmissionQueue().submitAndGet();
}
}
ringBuffer.ioUringSubmissionQueue().submit();
assertEquals(cqSize, ringBuffer.ioUringCompletionQueue().count());
} finally {
ringBuffer.close();
}
}
Domain
Subdomains
Source
Frequently Asked Questions
What does testSetUpCqSize() do?
testSetUpCqSize() is a function in the netty codebase, defined in transport-native-io_uring/src/test/java/io/netty/channel/uring/SubmissionQueueTest.java.
Where is testSetUpCqSize() defined?
testSetUpCqSize() is defined in transport-native-io_uring/src/test/java/io/netty/channel/uring/SubmissionQueueTest.java at line 101.
Analyze Your Own Codebase
Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.
Try Supermodel Free