- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 12 for isAsync (0.04 seconds)
-
src/test/java/jcifs/internal/CommonServerMessageBlockResponseTest.java
} @Test @DisplayName("Test isAsync method returning true") void testIsAsyncTrue() { // Given when(response.isAsync()).thenReturn(true); // When boolean isAsync = response.isAsync(); // Then assertTrue(isAsync); verify(response).isAsync(); } @Test @DisplayName("Test isAsync method returning false") void testIsAsyncFalse() {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 20.3K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/ServerMessageBlock2Response.java
this.received = false; } /** * {@inheritDoc} * * @see jcifs.util.transport.Response#received() */ @Override public final void received() { if (isAsync() && getStatus() == NtStatus.NT_STATUS_PENDING) { synchronized (this) { notifyAll(); } return; } this.received = true;Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 8.1K bytes - Click Count (0) -
src/main/java/jcifs/internal/CommonServerMessageBlockResponse.java
public interface CommonServerMessageBlockResponse extends CommonServerMessageBlock, Response { /** * Checks if this is an asynchronous response. * * @return is an async response */ boolean isAsync(); /** * * @return the next response */ @Override CommonServerMessageBlockResponse getNextResponse(); /** * Prepares this response for the next request. *Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 1.6K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/Smb2CancelRequestTest.java
void testIsResponseAsync() { // Given Smb2CancelRequest request = new Smb2CancelRequest(mockConfig, 1L, 0L); // When boolean isAsync = request.isResponseAsync(); // Then assertFalse(isAsync, "Cancel requests should not expect async responses"); } @Test @DisplayName("Test getNext returns null") void testGetNext() { // Given
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 9.8K bytes - Click Count (0) -
src/test/java/jcifs/internal/RequestTest.java
private CommonServerMessageBlockResponse response; private int command = 0; private byte[] rawPayload; private boolean retainPayload = false; @Override public boolean isAsync() { return async; } @Override public CommonServerMessageBlockResponse getNextResponse() { return nextResponse; } @OverrideCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 14.5K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/ServerMessageBlock2ResponseTest.java
flagsField.set(this, flags); } catch (Exception e) { throw new RuntimeException(e); } } @Override public boolean isAsync() { return async; } public void setAsync(boolean async) { this.async = async; } @Override public boolean isRetainPayload() {
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 19.3K bytes - Click Count (0) -
src/test/java/jcifs/internal/NotifyResponseTest.java
MockNotifyResponse response = new MockNotifyResponse(Collections.emptyList()); // Test async property assertFalse(response.isAsync()); response.setAsync(true); assertTrue(response.isAsync()); // Test next response property assertNull(response.getNextResponse()); MockNotifyResponse nextResponse = new MockNotifyResponse(Collections.emptyList());
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 21.2K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb1/ServerMessageBlock.java
*/ @Override public int size() { return 0; } /** * {@inheritDoc} * * @see jcifs.internal.CommonServerMessageBlockResponse#isAsync() */ @Override public boolean isAsync() { return false; } /** * {@inheritDoc} * * @see jcifs.internal.CommonServerMessageBlockRequest#isResponseAsync() */ @OverrideCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 38.9K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/ServerMessageBlock2.java
this.readSize = readSize; } /** * Checks whether this message is an asynchronous message. * * @return the async */ public boolean isAsync() { return this.async; } /** * @param command * the command to set */ @Override public final void setCommand(final int command) {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 24K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
synchronized (resp) { if (resp.isAsync() && !resp.isAsyncHandled() && resp.getStatus() == NtStatus.NT_STATUS_PENDING && resp.getAsyncId() != 0) { resp.setAsyncHandled(true); final boolean first = !req.isAsync(); req.setAsyncId(resp.getAsyncId()); final Long exp = resp.getExpiration();
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 69.8K bytes - Click Count (0)