- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 191 for rlocked (0.03 sec)
-
docs/bucket/lifecycle/DESIGN.md
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 4.2K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
lc, err = globalLifecycleSys.Get(bucket) if err != nil && !errors.Is(err, BucketLifecycleNotFound{Bucket: bucket}) { return err } // Check if bucket is object locked. lr, err = globalBucketObjectLockSys.Get(bucket) if err != nil { return err } rcfg, err = getReplicationConfig(ctx, bucket) if err != nil { return err } }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 28.7K bytes - Viewed (0) -
internal/event/targetlist.go
if list == nil { return []Target{} } list.RLock() defer list.RUnlock() targets := []Target{} for _, tgt := range list.targets { targets = append(targets, tgt) } return targets } // List - returns available target IDs. func (list *TargetList) List() []TargetID { list.RLock() defer list.RUnlock() keys := []TargetID{}Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 9.2K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
* specified access policy. * * @param capacity the capacity of this queue * @param fair if {@code true} then queue accesses for threads blocked on insertion or removal, * are processed in FIFO order; if {@code false} the access order is unspecified. * @throws IllegalArgumentException if {@code capacity} is less than 1 */Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 22.4K bytes - Viewed (0) -
cmd/peer-s3-server.go
peerS3BucketForceDelete = "force-delete" ) func healBucketLocal(ctx context.Context, bucket string, opts madmin.HealOpts) (res madmin.HealResultItem, err error) { globalLocalDrivesMu.RLock() localDrives := cloneDrives(globalLocalDrivesMap) globalLocalDrivesMu.RUnlock() // Initialize sync waitgroup. g := errgroup.WithNErrs(len(localDrives)) // Disk states slices
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 8.2K bytes - Viewed (0) -
cmd/ilm-config.go
}, } type ilmConfig struct { mu sync.RWMutex cfg ilm.Config } func (c *ilmConfig) getExpirationWorkers() int { c.mu.RLock() defer c.mu.RUnlock() return c.cfg.ExpirationWorkers } func (c *ilmConfig) getTransitionWorkers() int { c.mu.RLock() defer c.mu.RUnlock() return c.cfg.TransitionWorkers } func (c *ilmConfig) update(cfg ilm.Config) { c.mu.Lock() defer c.mu.Unlock()Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Mar 05 02:50:24 UTC 2024 - 1.3K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/NtStatus.java
int NT_STATUS_PASSWORD_MUST_CHANGE = 0xC0000224; /** The object was not found */ int NT_STATUS_NOT_FOUND = 0xC0000225; /** The referenced account is currently locked out */ int NT_STATUS_ACCOUNT_LOCKED_OUT = 0xC0000234; /** The pathname does not traverse a DFS junction */ int NT_STATUS_PATH_NOT_COVERED = 0xC0000257; /** The IO operation on the reparse point failed */Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 13.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
List<LockGraphNode> acquiredLockList = requireNonNull(acquiredLocks.get()); LockGraphNode node = lock.getLockGraphNode(); // Iterate in reverse because locks are usually locked/unlocked in a // LIFO order. for (int i = acquiredLockList.size() - 1; i >= 0; i--) { if (acquiredLockList.get(i) == node) { acquiredLockList.remove(i); break; }
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Sep 11 17:06:34 UTC 2025 - 35.9K bytes - Viewed (0) -
internal/config/heal/heal.go
// - '> 0' interval duration between cycles func (opts Config) BitrotScanCycle() (d time.Duration) { configMutex.RLock() defer configMutex.RUnlock() return opts.cache.bitrotCycle } // Clone safely the heal configuration func (opts Config) Clone() (int, time.Duration, string) { configMutex.RLock() defer configMutex.RUnlock() return opts.IOCount, opts.Sleep, opts.Bitrot }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Nov 04 19:06:02 UTC 2024 - 4.9K bytes - Viewed (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/root/RootLocator.java
import org.apache.maven.api.annotations.Nonnull; import org.apache.maven.api.annotations.Nullable; /** * Interface used to locate the root directory for a given project. * * The root locator is usually looked up from the plexus container. * One notable exception is the computation of the early {@code session.rootDirectory} * property which happens very early. The implementation used in this caseRegistered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Tue Feb 25 08:27:34 UTC 2025 - 2.5K bytes - Viewed (0)