- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for Unlock (0.19 sec)
-
internal/event/targetlist.go
list.statLock.Lock() defer list.statLock.Unlock() stats, ok := list.targetStats[id] if !ok { // should not happen return } stats.currentSendCalls-- list.targetStats[id] = stats return } func (list *TargetList) incFailedEvents(id TargetID) { list.statLock.Lock() defer list.statLock.Unlock() stats, ok := list.targetStats[id] if !ok {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
cmd/metacache-bucket.go
logger.Info("bucketMetacache.findCache: bucket %s does not match this bucket %s", o.Bucket, b.bucket) debug.PrintStack() return metacache{} } // Grab a write lock, since we create one if we cannot find one. b.mu.Lock() defer b.mu.Unlock() // Check if exists already. if c, ok := b.caches[o.ID]; ok { c.lastHandout = time.Now() b.caches[o.ID] = c b.debugf("returning existing %v", o.ID) return c
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.6K bytes - Viewed (0) -
internal/logger/logonce.go
if err == nil { return } nerr := unwrapErrs(err) l.Lock() shouldLog := true prev, ok := l.IDMap[id] if !ok { l.IDMap[id] = onceErr{ Err: nerr, Count: 1, } } else if prev.Err.Error() == nerr.Error() { // if errors are equal do not log. prev.Count++ l.IDMap[id] = prev shouldLog = false } l.Unlock() if shouldLog { consoleLogIf(ctx, subsystem, err, errKind...) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.8K 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 {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
internal/grid/muxserver.go
} func (m *muxServer) send(msg message) { m.sendMu.Lock() defer m.sendMu.Unlock() msg.MuxID = m.ID msg.Seq = m.SendSeq m.SendSeq++ if debugPrint { fmt.Printf("Mux %d, Sending %+v\n", m.ID, msg) } gridLogIf(m.ctx, m.parent.queueMsg(msg, nil)) } func (m *muxServer) close() { m.cancel() m.recvMu.Lock() defer m.recvMu.Unlock() if m.inbound != nil { xioutil.SafeClose(m.inbound)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
cmd/untar.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/event-notification.go
func (evnot *EventNotifier) RemoveNotification(bucketName string) { evnot.Lock() defer evnot.Unlock() delete(evnot.bucketRulesMap, bucketName) } // RemoveAllBucketTargets - closes and removes all notification targets. func (evnot *EventNotifier) RemoveAllBucketTargets() { evnot.Lock() defer evnot.Unlock() targetIDSet := event.NewTargetIDSet() for k := range evnot.targetList.TargetMap() {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.8K 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 Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.4K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
if clnt.gridConn.State() != grid.StateConnected { mu.Lock() offlineEndpoints = append(offlineEndpoints, fmt.Errorf("%s is unreachable: %w", clnt, grid.ErrDisconnected)) mu.Unlock() return } ctx, cancel := context.WithTimeout(ctx, 2*time.Second) defer cancel() err := clnt.Verify(ctx, srcCfg) mu.Lock() if err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 7.5K bytes - Viewed (0) -
internal/config/drive/drive.go
// Update - updates the config with latest values func (c *Config) Update(new Config) error { configLk.Lock() defer configLk.Unlock() c.MaxTimeout = getMaxTimeout(new.MaxTimeout) return nil } // GetMaxTimeout - returns the max timeout value. func (c *Config) GetMaxTimeout() time.Duration { configLk.RLock() defer configLk.RUnlock() return getMaxTimeout(c.MaxTimeout) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 2.5K bytes - Viewed (0)