- Sort Score
- Num 10 results
- Language All
Results 261 - 270 of 761 for refer (0.03 seconds)
-
internal/grid/benchmark_test.go
b.Run("bytes", func(b *testing.B) { for par := 1; par <= 32; par *= 2 { b.Run("par="+strconv.Itoa(par*runtime.GOMAXPROCS(0)), func(b *testing.B) { defer timeout(60 * time.Second)() ctx, cancel := context.WithTimeout(b.Context(), 30*time.Second) defer cancel() b.ReportAllocs() b.SetBytes(int64(len(payload) * 2)) b.ResetTimer() t := time.Now() var ops int64 var lat int64
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 15.5K bytes - Click Count (0) -
cmd/xl-storage.go
atomic.AddInt32(&s.scanning, 1) defer atomic.AddInt32(&s.scanning, -1) var err error stopFn := globalScannerMetrics.log(scannerMetricScanBucketDrive, s.drivePath, cache.Info.Name) defer func() { res := make(map[string]string) if err != nil { res["err"] = err.Error() } stopFn(res) }() // Updates must be closed before we return. defer xioutil.SafeClose(updates)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 91.7K bytes - Click Count (0) -
cmd/erasure-multipart-conditional_test.go
func TestNewMultipartUploadConditionalWithReadQuorumFailure(t *testing.T) { ctx := context.Background() obj, fsDirs, err := prepareErasure16(ctx) if err != nil { t.Fatal(err) } defer obj.Shutdown(context.Background()) defer removeRoots(fsDirs) z := obj.(*erasureServerPools) xl := z.serverPools[0].sets[0] bucket := "test-bucket" object := "test-object"
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 6.9K bytes - Click Count (0) -
cmd/etcd.go
timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() _, err := client.Delete(timeoutCtx, key) etcdLogIf(ctx, err) return etcdErrToErr(err, client.Endpoints()) } func readKeyEtcd(ctx context.Context, client *etcd.Client, key string) ([]byte, error) { timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() resp, err := client.Get(timeoutCtx, key) if err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 2.9K bytes - Click Count (0) -
internal/event/target/elasticsearch.go
return false, err } return target.isActive() } func (target *ElasticsearchTarget) isActive() (bool, error) { ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) defer cancel() err := target.checkAndInitClient(ctx) if err != nil { return false, err } return target.client.ping(ctx, target.args) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 15K bytes - Click Count (0) -
guava/src/com/google/common/base/Predicates.java
* * @author Kevin Bourrillion * @since 2.0 */ @GwtCompatible public final class Predicates { /** * Returns a predicate that always evaluates to {@code true}. * * <p><b>Discouraged:</b> Prefer using {@code x -> true}, but note that lambdas do not have * human-readable {@link #toString()} representations and are not serializable. */ public static <T extends @Nullable Object> Predicate<T> alwaysTrue() {Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 26.6K bytes - Click Count (0) -
internal/grid/muxclient.go
// respHandler func (m *muxClient) handleOneWayStream(respHandler chan<- Response, respServer <-chan Response) { if debugPrint { start := time.Now() defer func() { fmt.Println("Mux", m.MuxID, "Request took", time.Since(start).Round(time.Millisecond)) }() } defer func() { // addErrorNonBlockingClose will close the response channel // - maybe async, so we shouldn't do it here. if m.respErr.Load() == nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 15.9K bytes - Click Count (0) -
cmd/callhome.go
// cycle back return 'true' return true } ctx = lkctx.Context() defer locker.Unlock(lkctx) // Perform callhome once and then keep running it at regular intervals. performCallhome(ctx) callhomeTimer := time.NewTimer(globalCallhomeConfig.FrequencyDur()) defer callhomeTimer.Stop() for { if !globalCallhomeConfig.Enabled() { // Stop the processing as callhome got disabled
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.3K bytes - Click Count (0) -
cmd/http-tracer_test.go
var wg sync.WaitGroup for i := range numGoroutines { wg.Add(1) go func(id int) { defer wg.Done() for j := 0; j < opsPerGoroutine; j++ { stats.Inc("TestAPI") } }(i) } for i := range numGoroutines / 2 { wg.Add(1) go func(id int) { defer wg.Done() for range opsPerGoroutine / 2 { _ = stats.Load(false) } }(i) } wg.Wait()Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/ConnectionSpec.kt
* if it is present on the connection spec. The same policy also applies to cipher suites. * * Use [Builder.allEnabledTlsVersions] and [Builder.allEnabledCipherSuites] to defer all feature * selection to the underlying SSL socket. * * The configuration of each spec changes with each OkHttp release. This is annoying: upgrading
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 13.4K bytes - Click Count (0)