- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for getInflightRequests (0.45 sec)
-
src/test/java/jcifs/smb/SmbTransportInternalTest.java
@ParameterizedTest @DisplayName("getInflightRequests returns various counts") @ValueSource(ints = { 0, 1, 42, 1000 }) void getInflightRequests_counts(int count) { when(transport.getInflightRequests()).thenReturn(count); assertEquals(count, transport.getInflightRequests()); verify(transport).getInflightRequests(); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 12.1K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaTransport.java
} @Override public boolean isSMB2() throws SmbException { return delegate.isSMB2(); } @Override public int getInflightRequests() { return delegate.getInflightRequests(); } @Override public CIFSContext getContext() { return delegate.getContext(); } @Override @SuppressWarnings("unchecked")
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 8.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportInternal.java
*/ boolean isSMB2() throws SmbException; /** * Gets the number of currently pending requests. * * @return number of inflight requests */ int getInflightRequests();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 4.5K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbTransportImplTest.java
void basicGetters() { assertEquals(address, transport.getRemoteAddress()); assertNull(transport.getRemoteHostName(), "tconHostName starts null"); assertEquals(0, transport.getInflightRequests()); assertEquals(0, transport.getNumSessions()); } @Test @DisplayName("isDisconnected / isFailed reflect socket and state") void connectionStateChecks() throws Exception {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 17.6K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
/** * * @return number of sessions on this transport */ public int getNumSessions() { return this.sessions.size(); } @Override public int getInflightRequests() { return this.response_map.size(); } @Override public boolean isDisconnected() { final Socket s = this.socket;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 69.8K bytes - Viewed (0)