- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 587 for rake (0.12 sec)
-
internal/dsync/dsync_test.go
ctx, cancel := context.WithCancel(context.Background()) if !dm.GetLock(ctx, cancel, id, source, Options{Timeout: 5 * time.Minute}) { t.Fatal("GetLock() should be successful") } // Make it run twice. timer := time.NewTimer(testDrwMutexRefreshInterval * 2) select { case <-ctx.Done(): t.Fatal("Lock context canceled which is not expected") case <-timer.C: }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
cmd/object-api-utils.go
if len(md5sumCurr) == 0 { // md5sumCurr is only empty when we are running // in non-compatibility mode. md5sumCurr = make([]byte, 16) rand.Read(md5sumCurr) appendHyphen = true } if p.sealMD5Fn != nil { md5sumCurr = p.sealMD5Fn(md5sumCurr) } if appendHyphen { // Make sure to return etag string upto 32 length, for SSE // requests ETag might be longer and the code decrypting the
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
cmd/bucket-policy.go
} // NewPolicySys - creates new policy system. func NewPolicySys() *PolicySys { return &PolicySys{} } func getSTSConditionValues(r *http.Request, lc string, cred auth.Credentials) map[string][]string { m := make(map[string][]string) if d := r.Form.Get("DurationSeconds"); d != "" { m["DurationSeconds"] = []string{d} } return m }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 8K bytes - Viewed (0) -
cmd/tier_gen.go
case "Tiers": var zb0002 uint32 zb0002, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err, "Tiers") return } if z.Tiers == nil { z.Tiers = make(map[string]madmin.TierConfig, zb0002) } else if len(z.Tiers) > 0 { for key := range z.Tiers { delete(z.Tiers, key) } } for zb0002 > 0 { zb0002-- var za0001 string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 20 00:53:08 GMT 2023 - 4K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
func (p *podNetnsCache) Get(uid string) Netns { // lock current snapshot pod map p.mu.RLock() defer p.mu.RUnlock() if info, f := p.currentPodCache[uid]; f { return info.Netns } return nil } // make sure uid is in the cache, even if we don't have a netns func (p *podNetnsCache) Ensure(uid string) { p.mu.Lock() defer p.mu.Unlock() if _, ok := p.currentPodCache[uid]; !ok { p.currentPodCache[uid] = WorkloadInfo{}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
cmd/namespace-lock.go
// newNSLock - return a new name space lock map. func newNSLock(isDistErasure bool) *nsLockMap { 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 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0) -
internal/dsync/lock-args_gen_test.go
v := LockArgs{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgLockArgs(b *testing.B) { v := LockArgs{} bts := make([]byte, 0, v.Msgsize()) bts, _ = v.MarshalMsg(bts[0:0]) b.SetBytes(int64(len(bts))) b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { bts, _ = v.MarshalMsg(bts[0:0]) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 4.4K bytes - Viewed (0) -
internal/logger/reqinfo.go
if r == nil { return nil } r.RLock() defer r.RUnlock() return append(make([]KeyVal, 0, len(r.tags)), r.tags...) } // GetTagsMap - returns the user defined tags in a map structure func (r *ReqInfo) GetTagsMap() map[string]interface{} { if r == nil { return nil } r.RLock() defer r.RUnlock() m := make(map[string]interface{}, len(r.tags)) for _, t := range r.tags { m[t.Key] = t.Val }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.4K bytes - Viewed (0) -
src/cmd/cgo/internal/test/issue26430.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. //go:build cgo // Issue 26430: incomplete typedef leads to inconsistent typedefs error. // No runtime test; just make sure it compiles. package cgotest
Go - Registered: Tue Mar 26 11:13:08 GMT 2024 - Last Modified: Fri May 12 12:00:02 GMT 2023 - 359 bytes - Viewed (1) -
cmd/local-locker_gen.go
func (z *localLockMap) DecodeMsg(dc *msgp.Reader) (err error) { var zb0004 uint32 zb0004, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } if (*z) == nil { (*z) = make(localLockMap, zb0004) } else if len((*z)) > 0 { for key := range *z { delete((*z), key) } } var field []byte _ = field for zb0004 > 0 { zb0004-- var zb0001 string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 13.8K bytes - Viewed (0)