Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for Hockin (0.17 sec)

  1. 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 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  2. README.md

    ## Container Installation
    
    Use the following commands to run a standalone MinIO server as a container.
    
    Standalone MinIO servers are best suited for early development and evaluation. Certain features such as versioning, object locking, and bucket replication
    require distributed deploying MinIO with Erasure Coding. For extended development and production, deploy MinIO with Erasure Coding enabled - specifically,
    Plain Text
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Feb 14 17:51:34 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  3. 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)
  4. 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 21 19:28:08 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  5. 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 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 41.3K bytes
    - Viewed (1)
  6. cmd/bucket-handlers.go

    	if s3Error != ErrNone {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    		return
    	}
    
    	if objectLockEnabled {
    		// Creating a bucket with locking requires the user having more permissions
    		for _, action := range []policy.Action{policy.PutBucketObjectLockConfigurationAction, policy.PutBucketVersioningAction} {
    			if !globalIAMSys.IsAllowed(policy.Args{
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 61.6K bytes
    - Viewed (0)
  7. 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)
  8. cmd/testdata/xl-meta-merge.zip

    PartASizes‘ÑJ©¤SizeÑJ©¥MTimeÓ ¹ô‡‰O/>§MetaSys ¼x-minio-internal-inline-dataÄ true§MetaUsr‚¬content-type­text/markdown¤etagÙ 4af243ccccbadaf12545¡vÎeçnÐÎÓ° , ¤nullÅ%u&vÎ e ( Š[ ðKšÔŽX·šØü… ‘ˆ*¨Š ÂWåion. Certain features such as versioning, object locking, and bucket replication require distributed deploying MinIO with Erasure Coding. For extended development and production, deploy MinIO with Erasure Coding enabled - specifically, with a *minimum* of 4 drives per MinIO server. See [MinIO Erasure Code...
    ZIP Archive
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Mar 08 17:50:48 GMT 2024
    - 30.2K bytes
    - Viewed (0)
  9. 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 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  10. 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 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 15 09:40:19 GMT 2024
    - 46.9K bytes
    - Viewed (0)
Back to top