Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 271 - 280 of 415 for queued (0.04 seconds)

  1. compat/maven-model-builder/src/main/java/org/apache/maven/model/building/ModelCacheTag.java

         */
        T intoCache(T data);
    
        /**
         * Creates a copy of the data suitable for retrieval from the cache. The retrieved data can be mutated after the
         * cache is queried but the state of the cache must not change so we need to make a copy.
         *
         * @param data The data to retrieve from the cache, must not be {@code null}.
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Feb 25 08:27:34 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  2. internal/s3select/sql/parser.go

    type ObjectKey struct {
    	Lit *LiteralString `parser:" \"[\" @LitString \"]\""`
    	ID  *Identifier    `parser:"| \".\" @@"`
    }
    
    // QuotedIdentifier is a type for parsed strings that are double
    // quoted.
    type QuotedIdentifier string
    
    // Capture interface used by participle
    func (qi *QuotedIdentifier) Capture(values []string) error {
    	// Remove enclosing quotes
    	n := len(values[0])
    	r := values[0][1 : n-1]
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 12.9K bytes
    - Click Count (0)
  3. internal/event/target/mqtt.go

    	}
    
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    		queueDir := filepath.Join(args.QueueDir, storePrefix+"-mqtt-"+id)
    		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{
    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)
  4. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

        // contract.
        // This is somewhat annoying, but turns out to be very fast in practice. Alternatively, we could
        // drop the contract on the method that enforces this queue like behavior since depending on it
        // is likely to be a bug anyway.
    
        // N.B. All writes to the list and the next pointers must have happened before the above
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 6.9K bytes
    - Click Count (0)
  5. internal/s3select/errors.go

    	}
    }
    
    func errInvalidCompression(err error, t CompressionType) *s3Error {
    	return &s3Error{
    		code:       "InvalidCompressionFormat",
    		message:    strings.ToUpper(string(t)) + " is not applicable to the queried object. Please correct the request and try again.",
    		statusCode: 400,
    		cause:      err,
    	}
    }
    
    func errInvalidDataSource(err error) *s3Error {
    	return &s3Error{
    		code:       "InvalidDataSource",
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Mar 14 16:48:36 GMT 2022
    - 4.3K bytes
    - Click Count (0)
  6. 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)
  7. statement.go

    }
    
    // WriteByte write byte
    func (stmt *Statement) WriteByte(c byte) error {
    	return stmt.SQL.WriteByte(c)
    }
    
    // WriteQuoted write quoted value
    func (stmt *Statement) WriteQuoted(value interface{}) {
    	stmt.QuoteTo(&stmt.SQL, value)
    }
    
    // QuoteTo write quoted value to writer
    func (stmt *Statement) QuoteTo(writer clause.Writer, field interface{}) {
    	write := func(raw bool, str string) {
    		if raw {
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Fri Sep 12 04:33:27 GMT 2025
    - 20.9K bytes
    - Click Count (0)
  8. docs/es/docs/tutorial/cookie-param-models.md

    ///
    
    ## Prohibir Cookies Extra { #forbid-extra-cookies }
    
    En algunos casos de uso especiales (probablemente no muy comunes), podrías querer **restringir** las cookies que deseas recibir.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Feb 13 13:41:41 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  9. src/main/java/jcifs/smb/SIDCacheImpl.java

         * expired because under normal circumstances SID information never changes.
         *
         * @param authorityServerName
         *            The hostname of the server that should be queried. For maximum efficiency this should be the hostname
         *            of a domain controller however a member server will work as well and a domain controller may not
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Mon Aug 25 14:34:10 GMT 2025
    - 13.6K bytes
    - Click Count (0)
  10. docs/fr/docs/async.md

    ///
    
    ---
    
    Imaginez que vous êtes l'ordinateur / le programme 🤖 dans cette histoire.
    
    Pendant que vous faites la queue, vous être simplement inactif 😴, attendant votre tour, ne faisant rien de « productif ». Mais la queue est rapide car le serveur 💁 prend seulement les commandes (et ne les prépare pas), donc tout va bien.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 27.3K bytes
    - Click Count (0)
Back to Top