- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for Hockin (0.21 sec)
-
internal/dsync/drwmutex.go
var wg sync.WaitGroup for lockID := range restClnts { wg.Add(1) go func(lockID int) { defer wg.Done() if sendRelease(ctx, ds, restClnts[lockID], owner, (*locks)[lockID], isReadLock, names...) { (*locks)[lockID] = "" } }(lockID) } wg.Wait() // Return true if releaseAll was successful, otherwise we return 'false'
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/bucket-metadata.go
return b.LockEnabled || (b.versioningConfig != nil && b.versioningConfig.Enabled()) || (b.objectLockConfig != nil && b.objectLockConfig.Enabled()) } // ObjectLocking returns true if object locking is enabled func (b BucketMetadata) ObjectLocking() bool { return b.LockEnabled || (b.objectLockConfig != nil && b.objectLockConfig.Enabled()) }
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 16.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 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.3K bytes - Viewed (0) -
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 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 17.1K bytes - Viewed (0) -
cmd/data-scanner.go
} toDel := make([]ObjectToDelete, 0, len(overflowVersions)) for _, fi := range overflowVersions { obj := fi.ToObjectInfo(i.bucket, i.objectPath(), versioned) // skip versions with object locking enabled if rcfg.LockEnabled && enforceRetentionForDeletion(ctx, obj) { if i.debug { if obj.VersionID != "" {
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Mon Apr 08 17:45:03 GMT 2024 - 47.8K bytes - Viewed (0) -
internal/grid/muxclient.go
m.closeLocked() return false } } func (m *muxClient) close() { if debugPrint { fmt.Println("closing outgoing mux", m.MuxID) } if !m.respMu.TryLock() { // Cancel before locking - will unblock any pending sends. if m.cancelFn != nil { m.cancelFn(context.Canceled) } // Wait for senders to release. m.respMu.Lock() } defer m.respMu.Unlock() m.closeLocked() }
Go - Registered: Sun Apr 07 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/sftp-server-driver.go
} dirPath := buildMinioDir(prefix) _, err = clnt.PutObject(context.Background(), bucket, dirPath, bytes.NewReader([]byte("")), 0, // Always send Content-MD5 to succeed with bucket with // locking enabled. There is no performance hit since // this is always an empty object minio.PutObjectOptions{SendContentMd5: true}, ) return err } return NotImplemented{} }
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13K bytes - Viewed (0) -
cmd/object-api-interface.go
func (o *ObjectOptions) SetEvalRetentionBypassFn(f EvalRetentionBypassFn) { o.EvalRetentionBypassFn = f } // ObjectLayer implements primitives for object API layer. type ObjectLayer interface { // Locking operations on object. NewNSLock(bucket string, objects ...string) RWLocker // Storage operations. Shutdown(context.Context) error
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 16.9K bytes - Viewed (0) -
cmd/data-usage-cache.go
} // load the cache content with name from minioMetaBackgroundOpsBucket. // Only backend errors are returned as errors. // The loader is optimistic and has no locking, but tries 5 times before giving up. // If the object is not found, a nil error with empty data usage cache is returned. func (d *dataUsageCache) load(ctx context.Context, store objectIO, name string) error {
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 41.3K bytes - Viewed (1) -
misc/go_android_exec/main.go
// This wrapper uses syscall.Flock to prevent concurrent adb commands, // so for now it only builds on platforms that support that system call. // TODO(#33974): use a more portable library for file locking. //go:build darwin || dragonfly || freebsd || illumos || linux || netbsd || openbsd // This program can be used as go_android_GOARCH_exec by the Go tool. // It executes binaries on an android device using adb.
Go - Registered: Tue Apr 16 11:13:10 GMT 2024 - Last Modified: Mon Aug 21 17:46:57 GMT 2023 - 15.3K bytes - Viewed (0)