- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for mies (0.14 sec)
-
cmd/server_test.go
getMD5 := getMD5Hash(getContent) // Compare putContent and getContent. c.Assert(putMD5, getMD5) } // TestGetPartialObjectMisAligned - tests get object partially miss-aligned. // create a large buffer of miss-aligned data and upload it. // then make partial range requests to while fetching it back and assert the response content. func (s *TestSuiteCommon) TestGetPartialObjectMisAligned(c *check) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
cmd/iam-etcd-store.go
usersSysType: usersSysType, } } func (ies *IAMEtcdStore) rlock() *iamCache { ies.RLock() return ies.iamCache } func (ies *IAMEtcdStore) runlock() { ies.RUnlock() } func (ies *IAMEtcdStore) lock() *iamCache { ies.Lock() return ies.iamCache } func (ies *IAMEtcdStore) unlock() { ies.Unlock() } func (ies *IAMEtcdStore) getUsersSysType() UsersSysType { return ies.usersSysType
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.6K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
if lcEvent.Action.DeleteRestored() { // delete locally restored copy of object or object version // from the source, while leaving metadata behind. The data on // transitioned tier lies untouched and still accessible opts.Transition.ExpireRestored = true _, err := objectAPI.DeleteObject(ctx, oi.Bucket, oi.Name, opts) if err == nil { // TODO consider including expiry of restored object to events we
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
internal/bucket/replication/replication_test.go
prefix: "miss/prefix", expectedNonRec: false, expectedRec: false, }, // case 2 - only one rule which matches prefix filter {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 32.5K bytes - Viewed (0) -
internal/pubsub/pubsub.go
subs []*Sub[T] sync.RWMutex } // Publish message to the subscribers. // Note that publish is always non-blocking send so that we don't block on slow receivers. // Hence receivers should use buffered channel so as not to miss the published events. func (ps *PubSub[T, M]) Publish(item T) { ps.RLock() defer ps.RUnlock() for _, sub := range ps.subs { if sub.types.Contains(Mask(item.Mask())) && (sub.filter == nil || sub.filter(item)) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Viewed (0) -
cmd/data-scanner-metric.go
func (p *scannerMetrics) getCurrentPaths() []string { var res []string prefix := globalLocalNodeName + "/" p.currentPaths.Range(func(key, value interface{}) bool { // We are a bit paranoid, but better miss an entry than crash. name, ok := key.(string) if !ok { return true } obj, ok := value.(*currentPathTracker) if !ok { return true } strptr := (*string)(atomic.LoadPointer(obj.name))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 25 05:15:31 GMT 2023 - 9.1K bytes - Viewed (0)