- Sort Score
- Num 10 results
- Language All
Results 381 - 390 of 642 for differ (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/cachevalue/cache.go
if t.opts.NoWait && v != nil && tNow-vTime < ttl.Milliseconds()*2 { if t.updating.TryLock() { go func() { defer t.updating.Unlock() t.update(context.Background()) }() } return *v, nil } // Get lock. Either we get it or we wait for it. t.updating.Lock() defer t.updating.Unlock() if time.Since(time.UnixMilli(t.lastUpdateMs.Load())) < ttl {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 24 12:50:46 GMT 2024 - 4.4K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ImmutableSortedMultiset.java
/* * If we make these calls inline inside toImmutableSortedMultiset, we get an Animal Sniffer error, * despite the @IgnoreJRERequirement annotation there. My assumption is that, because javac * generates a synthetic method for the body of the lambda, the actual method calls that Animal * Sniffer is flagging don't appear inside toImmutableSortedMultiset but rather inside that
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 35.2K bytes - Click Count (0) -
internal/event/target/amqp.go
return false, err } return target.isActive() } func (target *AMQPTarget) isActive() (bool, error) { ch, _, err := target.channel() if err != nil { return false, err } defer func() { ch.Close() }() return true, nil } func (target *AMQPTarget) channel() (*amqp091.Channel, chan amqp091.Confirmation, error) { var err error var conn *amqp091.Connection
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Aug 21 04:25:07 GMT 2025 - 10K bytes - Click Count (0) -
src/builtin/builtin.go
// specified number of elements. The size may be omitted, in which case // a small starting size is allocated. // - Channel: The channel's buffer is initialized with the specified // buffer capacity. If zero, or the size is omitted, the channel is // unbuffered. func make(t Type, size ...IntegerType) Type // The max built-in function returns the largest value of a fixed number of
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Dec 30 23:59:23 GMT 2024 - 12.8K bytes - Click Count (0) -
cmd/update_test.go
httpServer1 := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {})) defer httpServer1.Close() httpServer2 := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { fmt.Fprintln(w, "fbe246edbd382902db9a4035df7dce8cb441357d minio.RELEASE.2016-10-07T01-16-39Z") })) defer httpServer2.Close()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 10.4K bytes - Click Count (0) -
cmd/data-usage-cache.go
} buf := bytebufferpool.Get() defer func() { <-maxConcurrentScannerSaves buf.Reset() bytebufferpool.Put(buf) }() if err := d.serializeTo(buf); err != nil { return err } save := func(name string, timeout time.Duration) error { // Abandon if more than a minute, so we don't hold up scanner. ctx, cancel := context.WithTimeout(ctx, timeout) defer cancel()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 34.7K bytes - Click Count (0) -
cmd/bucket-lifecycle-handlers.go
// https://docs.aws.amazon.com/AmazonS3/latest/dev/object-lifecycle-mgmt.html func (api objectAPIHandlers) PutBucketLifecycleHandler(w http.ResponseWriter, r *http.Request) { ctx := newContext(r, w, "PutBucketLifecycle") defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r)) objAPI := api.ObjectAPI() if objAPI == nil { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL) return }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Jan 20 14:49:07 GMT 2025 - 7K bytes - Click Count (0) -
internal/config/lambda/target/webhook.go
// Send - sends an event to the webhook. func (target *WebhookTarget) Send(eventData event.Event) (resp *http.Response, err error) { atomic.AddInt64(&target.activeRequests, 1) defer atomic.AddInt64(&target.activeRequests, -1) atomic.AddInt64(&target.totalRequests, 1) defer func() { if err != nil { atomic.AddInt64(&target.failedRequests, 1) } }() if err = target.init(); err != nil { return nil, err }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Jul 08 21:39:49 GMT 2024 - 6.7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocket.kt
* Attempts to enqueue `text` to be UTF-8 encoded and sent as a the data of a text (type `0x1`) * message. * * This method returns true if the message was enqueued. Messages that would overflow the outgoing * message buffer will be rejected and trigger a [graceful shutdown][close] of this web socket. * This method returns false in that case, and in any other case where this web socket is closing, * closed, or canceled. *
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 5.3K bytes - Click Count (0) -
internal/kms/context.go
// is based on the un-escaped keys. It never returns an error. func (c Context) MarshalText() ([]byte, error) { if len(c) == 0 { return []byte{'{', '}'}, nil } // Pre-allocate a buffer - 128 bytes is an arbitrary // heuristic value that seems like a good starting size. b := bytes.NewBuffer(make([]byte, 0, 128)) if len(c) == 1 { for k, v := range c { b.WriteString(`{"`) escapeStringJSON(b, k)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 6K bytes - Click Count (0)