Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 271 - 280 of 351 for Queues (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java

                throw e;
            }
            saveInfo(messages -> messages.addSuccessStartedDataUpdate(GLOBAL));
            return redirect(getClass());
        }
    
        /**
         * Clears all crawler indices including queue, data, and filter indices.
         *
         * @param form the action form (validated but not used for configuration)
         * @return HTML response redirecting to the maintenance page
         */
        @Execute
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 23K bytes
    - Click Count (0)
  2. docs/es/docs/advanced/openapi-callbacks.md

    Observa que no estás pasando el router en sí (`invoices_callback_router`) a `callback=`, sino el atributo `.routes`, como en `invoices_callback_router.routes`.
    
    ///
    
    ### Revisa la documentación { #check-the-docs }
    
    Ahora puedes iniciar tu aplicación e ir a [http://127.0.0.1:8000/docs](http://127.0.0.1:8000/docs).
    
    Verás tu documentación incluyendo una sección de "Callbacks" para tu *path operation* que muestra cómo debería verse la *API externa*:
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 8K bytes
    - Click Count (0)
  3. src/main/java/jcifs/internal/smb2/rdma/RdmaConnection.java

        /** Available send credits for flow control */
        protected final AtomicInteger sendCredits;
        /** Available receive credits for flow control */
        protected final AtomicInteger receiveCredits;
        /** Queue of pending RDMA work requests */
        protected final BlockingQueue<RdmaWorkRequest> pendingRequests;
    
        // Connection state
        /** Current connection state */
        protected volatile RdmaConnectionState state;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 24 00:12:28 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/helper/CrawlerLogHelper.java

            }
        }
    
        /**
         * Stores a failure URL with error information for later analysis.
         *
         * @param crawlerContext the crawler context
         * @param urlQueue the URL queue containing the failed URL
         * @param errorName the name/type of the error
         * @param e the throwable that caused the failure
         * @return the stored FailureUrl entity
         */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 8.3K bytes
    - Click Count (0)
  5. android/guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.Iterator;
    import java.util.List;
    import java.util.ListIterator;
    import java.util.Locale;
    import java.util.Map;
    import java.util.NavigableMap;
    import java.util.NavigableSet;
    import java.util.Queue;
    import java.util.Random;
    import java.util.Set;
    import java.util.SortedMap;
    import java.util.SortedSet;
    import java.util.UUID;
    import java.util.concurrent.BlockingDeque;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 23 17:50:58 GMT 2025
    - 20.9K bytes
    - Click Count (0)
  6. internal/logger/logrotate.go

    	// or when files are being rotated.
    	f *os.File
    
    	pw *xioutil.PipeWriter
    	pr *xioutil.PipeReader
    }
    
    // Write writes p into the current file, rotating if necessary.
    // Write is non-blocking, if the writer's queue is not full.
    // Write is blocking otherwise.
    func (w *Writer) Write(p []byte) (n int, err error) {
    	return w.pw.Write(p)
    }
    
    // Close closes the writer.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  7. src/main/webapp/css/admin/respond.min.js

    a.ActiveXObject("Microsoft.XMLHTTP")}return function(){return b}}(),f=function(a,b){var c=e();c&&(c.open("GET",a,!0),c.onreadystatechange=function(){4!==c.readyState||200!==c.status&&304!==c.status||b(c.responseText)},4!==c.readyState&&c.send(null))};if(c.ajax=f,c.queue=d,c.regex={media:/@media[^\{]+\{([^\{\}]*\{[^\}\{]*\})+/gi,keyframes:/@(?:\-(?:o|moz|webkit)\-)?keyframes[^\{]+\{(?:[^\{\}]*\{[^\}\{]*\})+[^\}]*\}/gi,urls:/(url\()['"]?([^\/\)'"][^:\)'"]+)['"]?(\))/g,findStyles:/@media *([^\{]+)\{([\S\s]+?)$/,only...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Oct 08 12:14:13 GMT 2015
    - 4.3K bytes
    - Click Count (0)
  8. CODE_OF_CONDUCT.md

    
    ## Conflict Resolution
    
    Conflicts in an open source project can take many forms, from someone having a bad day and using harsh and hurtful language in the issue queue, to more serious instances such as sexist/racist statements or threats of violence, and everything in between.
    
    If the behavior is threatening or harassing, or for other reasons requires immediate escalation, please see below.
    
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Fri Feb 05 18:43:16 GMT 2021
    - 5.2K bytes
    - Click Count (0)
  9. internal/event/target/mqtt.go

    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			return nil, fmt.Errorf("unable to initialize the queue store of MQTT `%s`: %w", id, err)
    		}
    	}
    
    	target := &MQTTTarget{
    		id:         event.TargetID{ID: id, Name: "mqtt"},
    		args:       args,
    		store:      queueStore,
    		quitCh:     make(chan struct{}),
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 8.2K bytes
    - Click Count (0)
  10. internal/grid/grid.go

    	// This is the assumed size of bigger buffers and allocation size.
    	biggerBufMin = 32 << 10
    
    	// This is the maximum size of bigger buffers.
    	biggerBufMax = maxBufferSize
    
    	// If there is a queue, merge up to this many messages.
    	maxMergeMessages = 50
    
    	// clientPingInterval will ping the remote handler every 15 seconds.
    	// Clients disconnect when we exceed 2 intervals.
    	clientPingInterval = 15 * time.Second
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 7K bytes
    - Click Count (0)
Back to Top