- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for Hockin (0.17 sec)
-
internal/dsync/lock-args.go
Quorum int } // ResponseCode is the response code for a locking request. type ResponseCode uint8 // Response codes for a locking request. const ( RespOK ResponseCode = iota RespLockConflict RespLockNotInitialized RespLockNotFound RespErr ) // LockResp is a locking request response. type LockResp struct { Code ResponseCode Err string
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 04:34:26 GMT 2024 - 1.7K bytes - Viewed (0) -
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 Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K 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 Mar 24 19:28:08 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 13.2K 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 Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Feb 08 19:21:21 GMT 2024 - 16.5K 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 Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 14.2K 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 Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 46.7K bytes - Viewed (0) -
cmd/admin-handlers-users.go
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 17:09:09 GMT 2024 - 77.2K bytes - Viewed (0) -
cmd/ftp-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 } // GetFile implements ftpDriver
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 13.5K bytes - Viewed (0) -
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 Mar 24 19:28:08 GMT 2024 - Last Modified: Mon Feb 12 16:46:46 GMT 2024 - 61.8K bytes - Viewed (0) -
cmd/namespace-lock.go
nsMutex := nsLockMap{ isDistErasure: isDistErasure, } if isDistErasure { return &nsMutex } nsMutex.lockMap = make(map[string]*nsLock) return &nsMutex } // nsLock - provides primitives for locking critical namespace regions. type nsLock struct { ref int32 *lsync.LRWMutex } // nsLockMap - namespace lock map, provides primitives to Lock, // Unlock, RLock and RUnlock. type nsLockMap struct {
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0)