Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for queue_size (0.03 sec)

  1. compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java

         */
        public SimplexTransferListener(TransferListener delegate) {
            this(delegate, QUEUE_SIZE, BATCH_MAX_SIZE, true);
        }
    
        /**
         * Constructor that may alter behaviour of this listener.
         *
         * @param delegate The delegate that should run on single thread.
         * @param queueSize The event queue size (default {@code 1024}).
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Nov 08 08:49:11 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. impl/maven-cli/src/main/java/org/apache/maven/cling/transfer/SimplexTransferListener.java

         */
        public SimplexTransferListener(TransferListener delegate) {
            this(delegate, QUEUE_SIZE, BATCH_MAX_SIZE, true);
        }
    
        /**
         * Constructor that may alter behaviour of this listener.
         *
         * @param delegate The delegate that should run on single thread.
         * @param queueSize The event queue size (default {@code 1024}).
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Thu Feb 06 11:28:05 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/smb1/BufferCache.java

            return String.format("BufferCache: queued=%d, max=%d, utilization=%.1f%%", queueSize.get(), MAX_BUFFERS,
                    (queueSize.get() * 100.0 / MAX_BUFFERS));
        }
    
        /**
         * Clear all cached buffers (for testing or cleanup)
         */
        public static void clearCache() {
            bufferQueue.clear();
            queueSize.set(0);
        }
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  4. internal/logger/help.go

    		},
    		config.HelpKV{
    			Key:         BatchSize,
    			Description: "Number of events per HTTP send to webhook target",
    			Optional:    true,
    			Type:        "number",
    		},
    		config.HelpKV{
    			Key:         QueueSize,
    			Description: "configure channel queue size for webhook targets",
    			Optional:    true,
    			Type:        "number",
    		},
    		config.HelpKV{
    			Key:         QueueDir,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocket.kt

       * queue. If may return a nonzero value after the web socket has been canceled; this indicates
       * that enqueued messages were not transmitted.
       */
      fun queueSize(): Long
    
      /**
       * Attempts to enqueue `text` to be UTF-8 encoded and sent as a the data of a text (type `0x1`)
       * message.
       *
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5.3K bytes
    - Viewed (0)
Back to top