- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 682 for Flock (0.02 sec)
-
cmd/grid.go
var globalGrid atomic.Pointer[grid.Manager] // globalLockGrid is the global lock grid manager. var globalLockGrid atomic.Pointer[grid.Manager] // globalGridStart is a channel that will block startup of grid connections until closed. var globalGridStart = make(chan struct{}) // globalLockGridStart is a channel that will block startup of lock grid connections until closed. var globalLockGridStart = make(chan struct{})
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 3.7K bytes - Viewed (0) -
internal/grid/connection.go
if err != nil { if !xnet.IsNetworkOrHostDown(err, true) { gridLogIfNot(ctx, fmt.Errorf("ws read: %w", err), net.ErrClosed, io.EOF) } return } block := c.blockMessages.Load() if block != nil && *block != nil { <-*block } if c.incomingBytes != nil { c.incomingBytes(int64(len(msg))) } // Parse the received message var m message
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 46.7K bytes - Viewed (0) -
docs/site-replication/run-multi-site-ldap.sh
exit_1 fi ./mc mb --with-lock minio3/newbucket-olock sleep 5 enabled_minio2=$(./mc stat --json minio2/newbucket-olock | jq -r .ObjectLock.enabled) if [ $? -ne 0 ]; then echo "expected bucket to be mirrored with object-lock but not present, exiting..." exit_1 fi if [ "${enabled_minio2}" != "Enabled" ]; then echo "expected bucket to be mirrored with object-lock enabled, exiting..." exit_1 fi
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 08:03:58 UTC 2024 - 10.1K bytes - Viewed (0) -
internal/config/batch/batch.go
func (opts Config) ExpirationWait() time.Duration { configMu.RLock() defer configMu.RUnlock() return opts.ExpirationWorkersWait } // ReplicationWait returns the duration for which a batch replication worker // would wait before working on next object. func (opts Config) ReplicationWait() time.Duration { configMu.RLock() defer configMu.RUnlock() return opts.ReplicationWorkersWait }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.7K bytes - Viewed (0) -
cmd/ilm-config.go
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() c.cfg = cfg
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Mar 05 02:50:24 UTC 2024 - 1.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
outFinished: Boolean, inFinished: Boolean, headers: Headers?, ) { internal val lock: ReentrantLock = ReentrantLock() val condition: Condition = lock.newCondition() // Internal state is guarded by [lock]. No long-running or potentially blocking operations are // performed while the lock is held. /** The bytes consumed and acknowledged by the stream. */ val readBytes: WindowCounter = WindowCounter(id)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
cmd/metacache-walk.go
// Metadata has data stripped, if any. func (s *xlStorage) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) (err error) { legacyFS := !(s.fsType == xfs || s.fsType == ext4) s.RLock() legacy := s.formatLegacy s.RUnlock() // Verify if volume is valid and it exists. volumeDir, err := s.getVolDir(opts.Bucket) if err != nil { return err } if !skipAccessChecks(opts.Bucket) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Jun 01 05:17:37 UTC 2024 - 12.4K bytes - Viewed (0) -
cmd/metacache-set.go
return pathJoin(bucketMetaPrefix, bucket, metacachePrefix, id) } // objectPath returns the object path of the cache. func (o *listPathOptions) objectPath(block int) string { return pathJoin(metacachePrefixForID(o.Bucket, o.ID), "block-"+strconv.Itoa(block)+".s2") } func (o *listPathOptions) SetFilter() { switch { case metacacheSharePrefix: return case o.Prefix == o.BaseDir: // No additional prefix
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 30.7K bytes - Viewed (0) -
guava/javadoc-link/checker-framework/package-list
org.checkerframework.checker.interning org.checkerframework.checker.interning.qual org.checkerframework.checker.linear org.checkerframework.checker.linear.qual org.checkerframework.checker.lock org.checkerframework.checker.lock.qual org.checkerframework.checker.nullness org.checkerframework.checker.nullness.compatqual org.checkerframework.checker.nullness.qual org.checkerframework.checker.propkey
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Dec 07 19:00:31 UTC 2017 - 3.8K bytes - Viewed (0) -
docs/site-replication/run-multi-site-minio-idp.sh
if [ $? -eq 0 ]; then echo "expected file to be deleted, exiting.." exit_1 fi ./mc mb --with-lock minio3/newbucket-olock sleep 5 set -x enabled_minio2=$(./mc stat --json minio2/newbucket-olock | jq -r .ObjectLock.enabled) if [ $? -ne 0 ]; then echo "expected bucket to be mirrored with object-lock but not present, exiting..." exit_1 fi if [ "${enabled_minio2}" != "Enabled" ]; then
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 08:03:58 UTC 2024 - 12.1K bytes - Viewed (0)