- Sort Score
- Result 10 results
- Languages All
Results 311 - 320 of 361 for Background (0.06 sec)
-
src/main/java/jcifs/smb1/http/NetworkExplorer.java
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Wed Jan 22 03:57:31 UTC 2020 - 19.7K bytes - Viewed (0) -
internal/rest/client.go
return } if c.HealthCheckFn() { if atomic.CompareAndSwapInt32(&c.connected, offline, online) { now := time.Now() disconnected := now.Sub(c.LastConn()) logger.Event(context.Background(), "healthcheck", "Client '%s' re-connected in %s", c.url.String(), disconnected) atomic.StoreInt64(&c.lastConn, now.UnixNano()) } return } attempt++ time.Sleep(backOff(attempt))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 26 12:55:01 UTC 2024 - 14.7K bytes - Viewed (0) -
cmd/bucket-handlers.go
writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } if err = globalDNSConfig.Put(bucket); err != nil { objectAPI.DeleteBucket(context.Background(), bucket, DeleteBucketOptions{ Force: true, SRDeleteOp: getSRBucketDeleteOp(globalSiteReplicationSys.isEnabled()), }) writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 12:24:04 UTC 2024 - 63.4K bytes - Viewed (0) -
istioctl/pkg/analyze/analyze.go
if err != nil { return nil, err } clients = append(clients, remoteClients...) return clients, nil } secrets, err := client.Kube().CoreV1().Secrets(ctx.IstioNamespace()).List(context.Background(), metav1.ListOptions{ LabelSelector: fmt.Sprintf("%s=%s", multicluster.MultiClusterSecretLabel, "true"), }) if err != nil { return nil, err } for _, s := range secrets.Items {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Oct 31 06:53:50 UTC 2024 - 17.6K bytes - Viewed (0) -
cmd/storage-rest-client.go
healthClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken()) healthClient.NoMetrics = true restClient.HealthCheckFn = func() bool { ctx, cancel := context.WithTimeout(context.Background(), restClient.HealthCheckTimeout) defer cancel() respBody, err := healthClient.Call(ctx, storageRESTMethodHealth, nil, nil, -1) xhttp.DrainBody(respBody) return toStorageErr(err) != errDiskNotFound }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Oct 13 13:07:21 UTC 2024 - 30.2K bytes - Viewed (0) -
cmd/metacache-stream_test.go
r := loadMetacacheSample(t) defer r.Close() var readErr error objs := make(chan metaCacheEntry, 1) var wg sync.WaitGroup wg.Add(1) go func() { readErr = r.readAll(context.Background(), objs) wg.Done() }() want := loadMetacacheSampleNames i := 0 for entry := range objs { if entry.name != want[i] { t.Errorf("entry %d, want %q, got %q", i, want[i], entry.name) } i++
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 15K bytes - Viewed (0) -
guava/src/com/google/common/base/Throwables.java
* directly, or use a combination of {@link #throwIfUnchecked} and {@code throw new * RuntimeException(e)}. But consider whether users would be better off if your API threw a * different type of exception. For background on the deprecation, read <a * href="https://github.com/google/guava/wiki/Why-we-deprecated-Throwables.propagate">Why we * deprecated {@code Throwables.propagate}</a>. */ @CanIgnoreReturnValue
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Jul 19 16:02:36 UTC 2024 - 20.7K bytes - Viewed (0) -
architecture/ambient/ztunnel.md
# Ztunnel This document provides an overview of the architecture and design decisions around Ztunnel, the node-proxy component in ambient mode. ## Background and motivation Motivations to implement ztunnel generally came from two areas. First, and most importantly, it serves as a means to implement the real goal: waypoints.
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Jul 17 23:10:17 UTC 2024 - 16.8K bytes - Viewed (0) -
cmd/erasure-multipart.go
// Delete the temporary object part. If PutObjectPart succeeds there would be nothing to delete. defer func() { if countOnlineDisks(onlineDisks) != len(onlineDisks) { er.deleteAll(context.Background(), minioMetaTmpBucket, tmpPart) } }() erasure, err := NewErasure(ctx, fi.Erasure.DataBlocks, fi.Erasure.ParityBlocks, fi.Erasure.BlockSize) if err != nil { return pi, toObjectErr(err, bucket, object)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 44.7K bytes - Viewed (0) -
cmd/erasure-server-pool.go
if opts.SRDeleteOp == MarkDelete { z.s3Peer.MakeBucket(context.Background(), pathJoin(minioMetaBucket, bucketMetaPrefix, deletedBucketsPrefix, bucket), MakeBucketOptions{}) } } if err == nil { // Purge the entire bucket metadata entirely. z.deleteAll(context.Background(), minioMetaBucket, pathJoin(bucketMetaPrefix, bucket)) } return toObjectErr(err, bucket) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 89.8K bytes - Viewed (0)