- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for StoreUint64 (0.2 sec)
-
internal/pubsub/pubsub.go
combined.Merge(Mask(mask.Mask())) atomic.StoreUint64(&ps.types, uint64(combined)) go func() { <-doneCh ps.Lock() defer ps.Unlock() var remainTypes Mask for i, s := range ps.subs { if s == sub { ps.subs = append(ps.subs[:i], ps.subs[i+1:]...) } else { remainTypes.Merge(s.types) } } atomic.StoreUint64(&ps.types, uint64(remainTypes))
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Viewed (0) -
cmd/perf-tests.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 11.3K bytes - Viewed (0) -
cmd/iam.go
if err != nil { atomic.AddUint64(&sys.TotalRefreshFailures, 1) return err } loadDuration := time.Since(loadStartTime) atomic.StoreUint64(&sys.LastRefreshDurationMilliseconds, uint64(loadDuration.Milliseconds())) atomic.StoreUint64(&sys.LastRefreshTimeUnixNano, uint64(loadStartTime.Add(loadDuration).UnixNano())) atomic.AddUint64(&sys.TotalRefreshSuccesses, 1) if !globalSiteReplicatorCred.IsValid() {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
cmd/bucket-replication.go
} } // save mrf entries to nodenamehex.bin func (p *ReplicationPool) saveMRFEntries(ctx context.Context, entries map[string]MRFReplicateEntry) { if !p.initialized() { return } atomic.StoreUint64(&globalReplicationStats.mrfStats.LastFailedCount, uint64(len(entries))) if len(entries) == 0 { return } v := MRFReplicateEntries{ Entries: entries, Version: mrfMetaVersion, }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/dynamic-timeouts.go
// Make copy on stack in order to call adjust() logCopy := [dynamicTimeoutLogSize]time.Duration{} copy(logCopy[:], dt.log[:]) // reset log entries atomic.StoreInt64(&dt.entries, 0) dt.mutex.Unlock() dt.adjust(logCopy) return } dt.mutex.Unlock() } } // adjust changes the value of the dynamic timeout based on the // previous results
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Aug 19 23:21:05 GMT 2022 - 4.5K bytes - Viewed (0) -
internal/rest/rpc-stats.go
var dialStart, dialEnd int64 trace := &httptrace.ClientTrace{ ConnectStart: func(network, addr string) { atomic.StoreInt64(&dialStart, time.Now().UnixNano()) }, ConnectDone: func(network, addr string, err error) { if err == nil { atomic.StoreInt64(&dialEnd, time.Now().UnixNano()) } }, } return req.WithContext(httptrace.WithClientTrace(req.Context(), trace)), func() {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Sep 29 16:27:58 GMT 2022 - 2.3K bytes - Viewed (0) -
internal/grid/muxclient.go
} }() var pingTimer <-chan time.Time if m.deadline == 0 || m.deadline > clientPingInterval { ticker := time.NewTicker(clientPingInterval) defer ticker.Stop() pingTimer = ticker.C atomic.StoreInt64(&m.LastPong, time.Now().Unix()) } defer m.parent.deleteMux(false, m.MuxID) for { select { case <-m.ctx.Done(): if debugPrint { fmt.Println("Client sending disconnect to mux", m.MuxID) }
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) -
cmd/xl-storage-disk-id-check.go
func (e *lockedLastMinuteLatency) addSize(value time.Duration, sz int64) { // alloc on every call, so we have a clean entry to swap in. t := time.Now().Unix() e.init.Do(func() { e.cached.Store(&AccElem{}) atomic.StoreInt64(&e.cachedSec, t) }) acc := e.cached.Load() if lastT := atomic.LoadInt64(&e.cachedSec); lastT != t { // Check if lastT was changed by someone else. if atomic.CompareAndSwapInt64(&e.cachedSec, lastT, t) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
internal/rest/client.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14K bytes - Viewed (0) -
internal/grid/muxserver.go
return pongMsg{Err: &msg} } select { case <-m.ctx.Done(): err := context.Cause(m.ctx).Error() return pongMsg{Err: &err} default: atomic.StoreInt64(&m.LastPing, time.Now().Unix()) return pongMsg{} } } func (m *muxServer) disconnect(msg string) { if debugPrint { fmt.Println("Mux", m.ID, "disconnecting. Reason:", msg) } if msg != "" {
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)