- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 115 for Hockin (0.34 sec)
-
internal/bucket/object/lock/lock.go
"github.com/minio/minio/internal/logger" "github.com/minio/pkg/v2/env" ) const ( logSubsys = "locking" ) func lockLogIf(ctx context.Context, err error) { logger.LogIf(ctx, logSubsys, err) } // Enabled indicates object locking is enabled const Enabled = "Enabled" // RetMode - object retention mode. type RetMode string const ( // RetGovernance - governance mode.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 17.1K bytes - Viewed (0) -
.teamcity/performance-test-durations.json
"durations" : [ { "testProject" : "excludeRuleMergingBuild", "linux" : 205 } ] }, { "scenario" : "org.gradle.performance.regression.corefeature.LargeDependencyGraphPerformanceTest.resolve large dependency graph (parallel = false, locking = true)", "durations" : [ { "testProject" : "excludeRuleMergingBuild",
Json - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Mon Feb 19 11:22:56 GMT 2024 - 26.3K bytes - Viewed (1) -
cni/pkg/nodeagent/pod_cache.go
func closeNetns(netns NetnsCloser) { netns.Close() } func (p *podNetnsCache) ReadCurrentPodSnapshot() map[string]WorkloadInfo { p.mu.RLock() defer p.mu.RUnlock() // snapshot the cache to avoid long locking return maps.Clone(p.currentPodCache) } // Remove and return the Netns for the given uid // No need to return NetnsCloser here it will be closed automatically on GC.
Go - Registered: Wed Apr 17 22:53:10 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
cmd/bucket-object-lock.go
} logger.CriticalIf(context.Background(), err) return r, err } return config.ToRetention(), nil } // enforceRetentionForDeletion checks if it is appropriate to remove an // object according to locking configuration when this is lifecycle/ bucket quota asking. func enforceRetentionForDeletion(ctx context.Context, objInfo ObjectInfo) (locked bool) { if objInfo.DeleteMarker { return false }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.3K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
exec.awaitTermination(100, MILLISECONDS); } /** * Tests that all listeners complete, even if they were added before or after the future was * finishing. Also acts as a concurrency test to make sure the locking is done correctly when a * future is finishing so that no listeners can be lost. */ public void testAllListenersCompleteSuccessfully() throws InterruptedException, ExecutionException {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0) -
cmd/service.go
} // freezeServices will freeze all incoming S3 API calls. // For each call, unfreezeServices must be called once. func freezeServices() { // Use atomics for globalServiceFreeze, so we can read without locking. // We need a lock since we are need the 2 atomic values to remain in sync. globalServiceFreezeMu.Lock() // If multiple calls, first one creates channel. globalServiceFreezeCnt++ if globalServiceFreezeCnt == 1 {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K bytes - Viewed (0) -
docs/bucket/lifecycle/DESIGN.md
An object that is in transition tier will be deleted once the object hits expiry date or if removed via `mc rm` (`mc rm --vid` in the case of delete of a specific object version). Other rules specific to legal hold and object locking precede any lifecycle rules. ### Additional notes Tiering and lifecycle transition are applicable only to erasure/distributed MinIO. ## Explore Further
Plain Text - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 4.3K bytes - Viewed (0) -
.teamcity/performance-tests-ci.json
"groups" : [ { "testProject" : "excludeRuleMergingBuild", "coverage" : { "per_commit" : [ "linux" ] } } ] }, { "testId" : "org.gradle.performance.regression.corefeature.LargeDependencyGraphPerformanceTest.resolve large dependency graph (parallel = false, locking = true)", "groups" : [ {
Json - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Mon Apr 01 17:23:34 GMT 2024 - 35.6K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
* MoreExecutors#newDirectExecutorService} and subject to the same constraints. * * <p>Although all tasks are immediately executed in the thread that submitted the task, this * {@code ExecutorService} imposes a small locking overhead on each task submission in order to * implement shutdown and termination behavior. * * <p>Because of the nature of single-thread execution, the methods {@code scheduleAtFixedRate}
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Fri May 26 22:04:00 GMT 2023 - 6.7K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
exec.awaitTermination(100, MILLISECONDS); } /** * Tests that all listeners complete, even if they were added before or after the future was * finishing. Also acts as a concurrency test to make sure the locking is done correctly when a * future is finishing so that no listeners can be lost. */ public void testAllListenersCompleteSuccessfully() throws InterruptedException, ExecutionException {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0)