- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 64 for gotSock (0.16 sec)
-
pkg/kubelet/metrics/collectors/resource_metrics_test.go
limitations under the License. */ package collectors import ( "context" "fmt" "strings" "testing" "time" "go.uber.org/mock/gomock" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/component-base/metrics/testutil" statsapi "k8s.io/kubelet/pkg/apis/stats/v1alpha1" summaryprovidertest "k8s.io/kubernetes/pkg/kubelet/server/stats/testing" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 15.3K bytes - Viewed (1) -
cmd/erasure-multipart.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 44.8K bytes - Viewed (0) -
cmd/metacache-entries_test.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 31.6K bytes - Viewed (0) -
cmd/erasure-server-pool.go
return BucketNameInvalid{Bucket: bucket} } if !opts.NoLock { // Lock the bucket name before creating. lk := z.NewNSLock(minioMetaTmpBucket, bucket+".lck") lkctx, err := lk.GetLock(ctx, globalOperationTimeout) if err != nil { return err } ctx = lkctx.Context() defer lk.Unlock(lkctx) } } if err := z.s3Peer.MakeBucket(ctx, bucket, opts); err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 82.5K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_gc_test.go
limitations under the License. */ package kuberuntime import ( "context" "os" "path/filepath" "testing" "time" "github.com/stretchr/testify/assert" "go.uber.org/mock/gomock" v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/types" runtimeapi "k8s.io/cri-api/pkg/apis/runtime/v1" kubecontainer "k8s.io/kubernetes/pkg/kubelet/container"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 20.6K bytes - Viewed (0) -
internal/dsync/drwmutex.go
Timeout time.Duration RetryInterval time.Duration } // GetLock tries to get a write lock on dm before the timeout elapses. // // If the lock is already in use, the calling go routine // blocks until either the mutex becomes available and return success or // more time has passed than the timeout value and return false.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.7K bytes - Viewed (0) -
cmd/erasure-object.go
if !srcInfo.metadataOnly { return oi, NotImplemented{} } if !dstOpts.NoLock { lk := er.NewNSLock(dstBucket, dstObject) lkctx, err := lk.GetLock(ctx, globalOperationTimeout) if err != nil { return oi, err } ctx = lkctx.Context() defer lk.Unlock(lkctx) } // Read metadata associated with the object from all disks. storageDisks := er.getDisks()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 78.6K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
z.rebalMeta.PoolStats = append(z.rebalMeta.PoolStats, &rebalanceStats{}) ok = true } } if ok { lock := z.serverPools[0].NewNSLock(minioMetaBucket, rebalMetaName) lkCtx, err := lock.GetLock(ctx, globalOperationTimeout) if err != nil { rebalanceLogIf(ctx, fmt.Errorf("failed to acquire write lock on %s/%s: %w", minioMetaBucket, rebalMetaName, err)) return err } defer lock.Unlock(lkCtx)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 03 15:45:54 UTC 2024 - 27.3K bytes - Viewed (0) -
cmd/batch-rotate.go
versionSuspended := globalBucketVersioningSys.PrefixSuspended(srcBucket, srcObject) lock := api.NewNSLock(r.Bucket, objInfo.Name) lkctx, err := lock.GetLock(ctx, globalOperationTimeout) if err != nil { return err } ctx = lkctx.Context() defer lock.Unlock(lkctx) opts := ObjectOptions{ VersionID: objInfo.VersionID,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.3K bytes - Viewed (0) -
src/cmd/go/internal/fsys/fsys_test.go
{"subdir5", "subdir5", false}, {"subdir5/deleted.txt", "", true}, } for _, tc := range testCases { gotPath, gotOK := OverlayPath(tc.path) if gotPath != tc.wantPath || gotOK != tc.wantOK { t.Errorf("OverlayPath(%q): got %v, %v; want %v, %v", tc.path, gotPath, gotOK, tc.wantPath, tc.wantOK) } } } func TestOpen(t *testing.T) { initOverlay(t, ` { "Replace": {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 20 18:52:11 UTC 2023 - 29.1K bytes - Viewed (0)