Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for queueSize (0.04 seconds)

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

         */
        public SimplexTransferListener(
                TransferListener delegate, int queueSize, int batchMaxSize, boolean blockOnLastEvent) {
            this.delegate = requireNonNull(delegate);
            if (queueSize < 1 || batchMaxSize < 1) {
                throw new IllegalArgumentException("Queue and batch sizes must be greater than 1");
            }
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Nov 08 08:49:11 GMT 2024
    - 8.4K bytes
    - Click Count (0)
  2. impl/maven-cli/src/main/java/org/apache/maven/cling/transfer/SimplexTransferListener.java

         */
        public SimplexTransferListener(
                TransferListener delegate, int queueSize, int batchMaxSize, boolean blockOnLastEvent) {
            this.delegate = requireNonNull(delegate);
            if (queueSize < 1 || batchMaxSize < 1) {
                throw new IllegalArgumentException("Queue and batch sizes must be greater than 1");
            }
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Thu Feb 06 11:28:05 GMT 2025
    - 8.7K bytes
    - Click Count (0)
  3. 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,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Sep 11 22:20:42 GMT 2024
    - 7.4K bytes
    - Click Count (0)
  4. 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);
        }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocket.kt

     * thrown and no [WebSocketListener.onFailure] callback is triggered, so callers should always check
     * the return value of `send()`.
     *
     * Use [queueSize] to monitor backpressure before sending. For large payloads, consider breaking
     * them into smaller messages or using HTTP requests instead.
     */
    interface WebSocket {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Mar 10 21:45:14 GMT 2026
    - 6.1K bytes
    - Click Count (0)
Back to Top