- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for Hockin (0.18 sec)
-
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 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.3K 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 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/lock/lock.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. // Package lock - implements filesystem locking wrappers around an // open file descriptor. package lock import ( "errors" "os" "sync" ) // ErrAlreadyLocked is returned if the underlying fd is already locked.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 2.5K bytes - Viewed (0) -
cmd/api-errors.go
}, ErrInvalidLifecycleWithObjectLock: { Code: "InvalidLifecycleWithObjectLock", Description: "The lifecycle configuration containing MaxNoncurrentVersions is not supported with object locking", HTTPStatusCode: http.StatusBadRequest, }, ErrNoSuchBucketSSEConfig: { Code: "ServerSideEncryptionConfigurationNotFoundError", Description: "The server side encryption configuration was not found",
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Apr 06 05:26:02 GMT 2024 - 90.2K bytes - Viewed (6) -
cmd/object-handlers.go
} rcfg, _ := globalBucketObjectLockSys.Get(bucket) if rcfg.LockEnabled && opts.DeletePrefix { apiErr := toAPIError(ctx, errInvalidArgument) apiErr.Description = "force-delete is forbidden on Object Locking enabled buckets" writeErrorResponse(ctx, w, apiErr, r.URL) return } os := newObjSweeper(bucket, object).WithVersion(opts.VersionID).WithVersioning(opts.Versioned, opts.VersionSuspended)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 05 11:39:31 GMT 2024 - 124.7K 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 Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0) -
internal/dsync/dsync_test.go
func TestFailedRefreshLock(t *testing.T) { if testing.Short() { t.Skip("skipping test in short mode.") } // Simulate Refresh response to return no locking found for i := range lockServers[:3] { lockServers[i].setRefreshReply(false) defer lockServers[i].setRefreshReply(true) } dm := NewDRWMutex(ds, "aap") dm.refreshInterval = 500 * time.Millisecond
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0)