- Sort Score
- Num 10 results
- Language All
Results 271 - 280 of 415 for queued (0.04 seconds)
-
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) -
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) -
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) -
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 aboveCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Feb 10 11:51:21 GMT 2026 - 6.9K bytes - Click Count (0) -
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) -
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) -
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) -
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) -
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 notCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Mon Aug 25 14:34:10 GMT 2025 - 13.6K bytes - Click Count (0) -
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)