Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 4 of 4 for InFlight (0.06 seconds)

  1. 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();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  2. docs/compression/README.md

    # Compression Guide [![Slack](https://slack.min.io/slack?type=svg)](https://slack.min.io)
    
    MinIO server allows streaming compression to ensure efficient disk space usage.
    Compression happens inflight, i.e objects are compressed before being written to disk(s).
    MinIO uses [`klauspost/compress/s2`](https://github.com/klauspost/compress/tree/master/s2)
    streaming compression due to its stability and performance.
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/ListenableFuture.java

     *
     * {@snippet :
     * final String name = ...;
     * inFlight.add(name);
     * ListenableFuture<Result> future = service.query(name);
     * future.addListener(new Runnable() {
     *   public void run() {
     *     processedCount.incrementAndGet();
     *     inFlight.remove(name);
     *     lastProcessed.set(name);
     *     logger.info("Done with {0}", name);
     *   }
     * }, executor);
     * }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 8K bytes
    - Click Count (0)
  4. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

     *
     * {@snippet :
     * final String name = ...;
     * inFlight.add(name);
     * ListenableFuture<Result> future = service.query(name);
     * future.addListener(new Runnable() {
     *   public void run() {
     *     processedCount.incrementAndGet();
     *     inFlight.remove(name);
     *     lastProcessed.set(name);
     *     logger.info("Done with {0}", name);
     *   }
     * }, executor);
     * }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 8K bytes
    - Click Count (0)
Back to Top