- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 158 for Lock (0.18 sec)
-
internal/dsync/lock-args_gen_test.go
Klaus Post <******@****.***> 1700528975 -0800
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/dsync/lock-args_gen.go
Klaus Post <******@****.***> 1700528975 -0800
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 9.5K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
func (p *podNetnsCache) UpsertPodCacheWithNetns(uid string, workload WorkloadInfo) Netns { // lock current snapshot pod map p.mu.Lock() defer p.mu.Unlock() if existing := p.currentPodCache[uid]; existing.Netns != nil { if existing.Netns.Inode() == workload.Netns.Inode() { workload.Netns.Close()
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/admin-heal-ops.go
func (ahs *allHealState) setDiskHealingStatus(ep Endpoint, healing bool) { ahs.Lock() defer ahs.Unlock() ahs.healLocalDisks[ep] = healing } func (ahs *allHealState) pushHealLocalDisks(healLocalDisks ...Endpoint) { ahs.Lock() defer ahs.Unlock() for _, ep := range healLocalDisks { ahs.healLocalDisks[ep] = false } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cmd/bucket-replication-stats.go
func (r *ReplicationStats) Delete(bucket string) { if r == nil { return } r.Lock() defer r.Unlock() delete(r.Cache, bucket) } // UpdateReplicaStat updates in-memory replica statistics with new values. func (r *ReplicationStats) UpdateReplicaStat(bucket string, n int64) { if r == nil { return } r.Lock() defer r.Unlock() bs, ok := r.Cache[bucket] if !ok {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0) -
internal/grid/connection.go
} cancel(ErrDisconnected) c.connChange.L.Lock() if atomic.CompareAndSwapUint32((*uint32)(&c.state), StateConnected, StateConnectionError) { c.connChange.Broadcast() } c.disconnected() c.connChange.L.Unlock() conn.Close() c.handleMsgWg.Done() }() c.connMu.Lock() connPingInterval := c.connPingInterval c.connMu.Unlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/site-replication-metrics.go
Endpoint string `json:"-"` // Secure is true if the replication target endpoint is secure Secure bool `json:"-"` } func (sr *SRStats) update(st replStat, dID string) { sr.lock.Lock() defer sr.lock.Unlock() srs, ok := sr.M[dID] if !ok { srs = &SRStatus{ XferRateLrg: newXferStats(), XferRateSml: newXferStats(), } } srs.Endpoint = st.Endpoint srs.Secure = st.Secure
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 8.2K bytes - Viewed (0) -
internal/cachevalue/cache.go
go func() { defer t.updating.Unlock() t.update() }() } return v.v, v.e } // Get lock. Either we get it or we wait for it. t.updating.Lock() if time.Since(time.UnixMilli(t.lastUpdateMs.Load())) < ttl { // There is a new value, release lock and return it. v = t.valErr.Load() t.updating.Unlock() return v.v, v.e } t.update() v = t.valErr.Load()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 16:00:42 GMT 2024 - 4.2K bytes - Viewed (0) -
internal/logger/reqinfo.go
if r == nil { return nil } r.Lock() defer r.Unlock() r.tags = append(r.tags, KeyVal{key, val}) return r } // SetTags - sets key/val to ReqInfo.tags func (r *ReqInfo) SetTags(key string, val interface{}) *ReqInfo { if r == nil { return nil } r.Lock() defer r.Unlock() // Search of tag key already exists in tags var updated bool
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) -
internal/store/batch.go
func (b *Batch[K, T]) GetByKey(key K) (T, bool) { b.Lock() defer b.Unlock() item, ok := b.items[key] return item, ok } // Len returns the no of items in the batch func (b *Batch[K, T]) Len() int { b.Lock() defer b.Unlock() return len(b.keys) } // IsFull checks if the batch is full or not func (b *Batch[K, T]) IsFull() bool { b.Lock() defer b.Unlock() return b.isFull() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 2.5K bytes - Viewed (0)