- Sort Score
- Result 10 results
- Languages All
Results 11 - 15 of 15 for getLoc (0.17 sec)
-
cmd/admin-handlers.go
writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL) return } nsLock := objectAPI.NewNSLock(minioMetaBucket, "site-net-perf") lkctx, err := nsLock.GetLock(ctx, globalOperationTimeout) if err != nil { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(toAPIErrorCode(ctx, err)), r.URL) return } ctx = lkctx.Context() defer nsLock.Unlock(lkctx)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
cmd/bucket-replication.go
} // Lock the object name before starting replication operation. // Use separate lock that doesn't collide with regular objects. lk := objectAPI.NewNSLock(bucket, "/[replicate]/"+dobj.ObjectName) lkctx, err := lk.GetLock(ctx, globalOperationTimeout) if err != nil { globalReplicationPool.queueMRFSave(dobj.ToMRFEntry()) sendEvent(eventArgs{ BucketName: bucket, Object: ObjectInfo{ Bucket: bucket,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
if err := om.createPodTracker.incWithOptionalError(); err != nil { return err } pod.SetUID(types.UID(pod.Name + "-uid")) return om.podsIndexer.Update(pod) } func (om *fakeObjectManager) GetPod(namespace, podName string) (*v1.Pod, error) { return om.podsLister.Pods(namespace).Get(podName) } func (om *fakeObjectManager) UpdatePod(pod *v1.Pod) error { defer om.updatePodTracker.trackParallelRequests()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0) -
cmd/site-replication.go
} } return nil } const siteHealTimeInterval = 30 * time.Second func (c *SiteReplicationSys) startHealRoutine(ctx context.Context, objAPI ObjectLayer) { ctx, cancel := globalLeaderLock.GetLock(ctx) defer cancel() healTimer := time.NewTimer(siteHealTimeInterval) defer healTimer.Stop() var maxRefreshDurationSecondsForLog float64 = 10 // 10 seconds.. for { select {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0) -
testing/architecture-test/src/changes/archunit-store/public-api-mutable-properties.txt
Method <org.gradle.api.publish.maven.MavenPublication.getGroupId()> does not have raw return type assignable to org.gradle.api.provider.Property in (MavenPublication.java:0) Method <org.gradle.api.publish.maven.MavenPublication.getPom()> does not have raw return type assignable to org.gradle.api.provider.Provider in (MavenPublication.java:0)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 22:42:49 UTC 2024 - 160.5K bytes - Viewed (0)