Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 34 for asyncId (1.5 sec)

  1. src/test/java/jcifs/internal/smb2/ServerMessageBlock2Test.java

                byte[] buffer = new byte[256];
                System.arraycopy(SMBUtil.SMB2_HEADER, 0, buffer, 0, 4);
                // Set up async message fields
                SMBUtil.writeInt4(ServerMessageBlock2.SMB2_FLAGS_ASYNC_COMMAND, buffer, 16); // flags with async
                SMBUtil.writeInt8(789L, buffer, 32); // async ID
                SMBUtil.writeInt8(456L, buffer, 40); // session ID
                return buffer;
            }
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  2. src/test/java/jcifs/internal/NotifyResponseTest.java

                return this.notifyInformation;
            }
    
            @Override
            public boolean isAsync() {
                return this.async;
            }
    
            public void setAsync(boolean async) {
                this.async = async;
            }
    
            @Override
            public CommonServerMessageBlockResponse getNextResponse() {
                return this.nextResponse;
            }
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 21.2K bytes
    - Viewed (0)
  3. src/test/java/jcifs/internal/CommonServerMessageBlockRequestTest.java

            when(request.allowChain(any())).thenReturn(true);
    
            // When
            boolean async = request.isResponseAsync();
            int size = request.size();
            Integer timeout = request.getOverrideTimeout();
            boolean canChain = request.allowChain(nextRequest);
    
            // Then
            assertTrue(async);
            assertEquals(100, size);
            assertEquals(3000, timeout);
            assertTrue(canChain);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  4. README.md

    ```java
    import org.codelibs.curl.Curl;
    
    Curl.post("https://api.example.com/items")
        .body("{\"name\":\"item1\"}")
        .header("Content-Type", "application/json")
        .execute(
            response -> System.out.println("Async status: " + response.getHttpStatusCode()),
            error -> error.printStackTrace());
    ```
    
    ## API Overview
    
    - `org.codelibs.curl.Curl`: entry point for HTTP methods (GET, POST, PUT, DELETE, HEAD, OPTIONS, CONNECT, TRACE).
    Registered: Sat Dec 20 09:13:53 UTC 2025
    - Last Modified: Thu Nov 20 13:34:13 UTC 2025
    - 2.5K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/web/base/login/FessLoginAssist.java

    import org.codelibs.fess.sso.SsoAuthenticator;
    import org.codelibs.fess.util.ComponentUtil;
    import org.dbflute.optional.OptionalEntity;
    import org.dbflute.optional.OptionalThing;
    import org.lastaflute.core.magic.async.AsyncManager;
    import org.lastaflute.core.time.TimeManager;
    import org.lastaflute.web.login.LoginHandlingResource;
    import org.lastaflute.web.login.PrimaryLoginManager;
    import org.lastaflute.web.login.TypicalLoginAssist;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/witness/WitnessRpcClient.java

                    }
                } else {
                    log.warn("Async notify failed: {}", message.getErrorMessage());
                }
    
                return null;
    
            } catch (Exception e) {
                throw new IOException("Witness async notify RPC failed", e);
            }
        }
    
        /**
         * Generates a registration ID from context handle and share name.
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  7. src/test/java/jcifs/internal/CommonServerMessageBlockResponseTest.java

            // Create a concrete implementation for comprehensive testing
            CommonServerMessageBlockResponse concreteResponse = new CommonServerMessageBlockResponse() {
                private boolean async = false;
                private CommonServerMessageBlockResponse next;
                private boolean received = false;
                private boolean error = false;
                private boolean verifyFailed = false;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 20.3K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/CommonServerMessageBlockResponse.java

     *
     * @author mbechler
     */
    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();
    
        /**
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java

    import org.codelibs.fess.util.RenderDataUtil;
    import org.codelibs.fess.util.ResourceUtil;
    import org.codelibs.fess.util.SearchEngineUtil;
    import org.dbflute.bhv.readable.EntityRowHandler;
    import org.lastaflute.core.magic.async.AsyncManager;
    import org.lastaflute.web.Execute;
    import org.lastaflute.web.response.ActionResponse;
    import org.lastaflute.web.response.HtmlResponse;
    import org.lastaflute.web.response.StreamResponse;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Mon Nov 24 02:07:40 UTC 2025
    - 32.1K bytes
    - Viewed (0)
  10. CLAUDE.md

    2. **Factory Pattern**: `Curl` class provides static factory methods for each HTTP method
    3. **Resource Management**: `CurlResponse` implements `Closeable` for try-with-resources
    4. **Async Support**: Both synchronous (`executeSync()`) and asynchronous (`execute()`) execution modes
    
    ## Technical Details
    
    - **Java Version**: 17+
    - **Dependencies**:
      - Apache Commons IO 2.19.0 (runtime)
    Registered: Sat Dec 20 09:13:53 UTC 2025
    - Last Modified: Mon Nov 24 03:10:07 UTC 2025
    - 3.2K bytes
    - Viewed (0)
Back to top