- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 10 for locked (0.04 seconds)
-
internal/bucket/lifecycle/lifecycle_test.go
</LifecycleConfiguration>`, expectedParsingErr: nil, expectedValidationErr: errLifecycleBucketLocked, lr: lock.Retention{ LockEnabled: true, }, }, { // Using DelMarkerExpiration action with an object locked bucket inputConfig: `<LifecycleConfiguration> <Rule>Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 55.5K bytes - Click Count (0) -
cmd/iam-store.go
type IAMStorageAPI interface { // The role of the read-write lock is to prevent go routines from // concurrently reading and writing the IAM storage. The (r)lock() // functions return the iamCache. The cache can be safely written to // only when returned by `lock()`. lock() *iamCache unlock() rlock() *iamCache runlock() getUsersSysType() UsersSysTypeCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 87.1K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildPlanExecutor.java
executeStep(step); if (nextIsPlanning) { lock.writeLock().lock(); try { plan(); } finally { lock.writeLock().unlock(); } } executePlan();
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Thu Oct 16 06:12:36 GMT 2025 - 55.1K bytes - Click Count (0) -
cmd/xl-storage.go
if err == nil { cache.Info.replication = replicationConfig{ Config: rcfg, remotes: tgts, } } } } // Check if bucket is object locked. lr, err := globalBucketObjectLockSys.Get(cache.Info.Name) if err != nil { scannerLogOnceIf(ctx, err, cache.Info.Name) return cache, err } vcfg, _ := globalBucketVersioningSys.Get(cache.Info.Name)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/admin-handlers-users.go
return } targetUser = lookupResult.NormDN opts.claims[ldapUser] = targetUser // username DN opts.claims[ldapActualUser] = lookupResult.ActualDN // Add LDAP attributes that were looked up into the claims. for attribKey, attribValue := range lookupResult.Attributes { opts.claims[ldapAttribPrefix+attribKey] = attribValue } // NOTE: if not using LDAP, then internal IDP or open ID is
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 90.6K bytes - Click Count (0) -
.bazelrc
# TODO(rostam): Remove when `cc_shared_library` is enabled by default common --experimental_cc_shared_library # cc_shared_library ensures no library is linked statically more than once. common --experimental_link_static_libraries_once=false # Prevent regressions on those two incompatible changes # TODO: remove those flags when they are flipped in the default Bazel version TF uses.
Created: Tue Dec 30 12:39:10 GMT 2025 - Last Modified: Fri Dec 26 23:20:26 GMT 2025 - 56.8K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/project/MavenProject.java
* project. In spite of the 'throws' declaration on this API, this method has never thrown an exception since Maven * 3.0.x. Historically, it logged and ignored a second addition of the same g/a/v/c/t. Now it replaces the file for * the artifact, so that plugins (e.g. shade) can change the pathname of the file for a particular set of * coordinates. *
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Aug 29 12:47:20 GMT 2025 - 67K bytes - Click Count (0) -
tensorflow/c/c_api_test.cc
} void NoOpDeallocator(void* data, size_t, void*) {} TEST(CAPI, MalformedTensor) { // See https://github.com/tensorflow/tensorflow/issues/7394 // num_dims = 0 implies a scalar, so should be backed by at least 4 bytes of // data. TF_Tensor* t = TF_NewTensor(TF_FLOAT, nullptr, 0, nullptr, 0, &NoOpDeallocator, nullptr); ASSERT_TRUE(t == nullptr); } TEST(CAPI, AllocateTensor) {
Created: Tue Dec 30 12:39:10 GMT 2025 - Last Modified: Mon Nov 17 00:00:38 GMT 2025 - 97K bytes - Click Count (0) -
cmd/erasure-object.go
nsUnlocker() } }() // Acquire lock if !opts.NoLock { lock := er.NewNSLock(bucket, object) lkctx, err := lock.GetRLock(ctx, globalOperationTimeout) if err != nil { return nil, err } ctx = lkctx.Context() // Release lock when the metadata is verified, and reader // is ready to be read. // // This is possible to be lock free because
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 80.4K bytes - Click Count (0) -
docs/bucket/notifications/README.md
## Publish MinIO events via AMQP Install RabbitMQ from [here](https://www.rabbitmq.com/). ### Step 1: Add AMQP endpoint to MinIO The AMQP configuration is located under the sub-system `notify_amqp` top-level key. Create a configuration key-value pair here for your AMQP instance. The key is a name for your AMQP endpoint, and the value is a collection of key-value parameters described in the table below.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 84.2K bytes - Click Count (0)