- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for LoadInt32 (0.2 sec)
-
internal/http/server.go
requestCount int32 // counter holds no. of request in progress. } // GetRequestCount - returns number of request in progress. func (srv *Server) GetRequestCount() int { return int(atomic.LoadInt32(&srv.requestCount)) } // Init - init HTTP server func (srv *Server) Init(listenCtx context.Context, listenErrCallback func(listenAddr string, err error)) (serve func() error, err error) { // Take a copy of server fields.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
internal/pubsub/pubsub.go
types := Mask(atomic.LoadUint64(&ps.types)) if !types.Overlaps(Mask(mask.Mask())) { return 0 } return atomic.LoadInt32(&ps.numSubscribers) } // Subscribers returns the number of current subscribers for all types. func (ps *PubSub[T, M]) Subscribers() int32 { return atomic.LoadInt32(&ps.numSubscribers) } // New inits a PubSub system with a limit of maximum // subscribers unless zero is specified
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) -
internal/logger/target/http/http.go
} func (h *Target) String() string { return h.config.Name } // IsOnline returns true if the target is reachable using a cached value func (h *Target) IsOnline(ctx context.Context) bool { return atomic.LoadInt32(&h.status) == statusOnline } // Stats returns the target statistics. func (h *Target) Stats() types.TargetStats { h.logChMu.RLock() queueLength := len(h.logCh) h.logChMu.RUnlock()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0) -
cmd/http-stats.go
totalS34xxErrors HTTPAPIStats totalS35xxErrors HTTPAPIStats totalS3Canceled HTTPAPIStats } func (st *HTTPStats) loadRequestsInQueue() int32 { return atomic.LoadInt32(&st.s3RequestsInQueue) } func (st *HTTPStats) addRequestsInQueue(i int32) { atomic.AddInt32(&st.s3RequestsInQueue, i) } func (st *HTTPStats) incS3RequestsIncoming() {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 11.4K bytes - Viewed (0) -
internal/rest/client.go
// make connection pre-emptively. go clnt.HealthCheckFn() } return clnt } // IsOnline returns whether the client is likely to be online. func (c *Client) IsOnline() bool { return atomic.LoadInt32(&c.connected) == online } // LastConn returns when the disk was (re-)connected func (c *Client) LastConn() time.Time { return time.Unix(0, atomic.LoadInt64(&c.lastConn)) }
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/logger/target/kafka/kafka.go
atomic.StoreInt32(&h.status, statusOnline) } return nil } // IsOnline returns true if the target is online. func (h *Target) IsOnline(_ context.Context) bool { return atomic.LoadInt32(&h.status) == statusOnline } // Send log message 'e' to kafka target. func (h *Target) Send(ctx context.Context, entry interface{}) error { if h.store != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
cmd/bucket-replication.go
func (p *ReplicationPool) ActiveWorkers() int { return int(atomic.LoadInt32(&p.activeWorkers)) } // ActiveMRFWorkers returns the number of active workers handling replication failures. func (p *ReplicationPool) ActiveMRFWorkers() int { return int(atomic.LoadInt32(&p.activeMRFWorkers)) } // ResizeWorkers sets replication workers pool to new size.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 112K bytes - Viewed (1) -
cmd/xl-storage.go
info, err = s.diskInfoCache.Get() info.NRRequests = s.nrRequests info.Rotational = s.rotational info.MountPath = s.drivePath info.Endpoint = s.endpoint.String() info.Scanning = atomic.LoadInt32(&s.scanning) == 1 return info, err } // getVolDir - will convert incoming volume names to // corresponding valid volume names on the backend in a platform
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 82.4K bytes - Viewed (0) -
api/go1.txt
pkg sync/atomic, func CompareAndSwapUint64(*uint64, uint64, uint64) bool pkg sync/atomic, func CompareAndSwapUintptr(*uintptr, uintptr, uintptr) bool pkg sync/atomic, func LoadInt32(*int32) int32 pkg sync/atomic, func LoadInt64(*int64) int64 pkg sync/atomic, func LoadPointer(*unsafe.Pointer) unsafe.Pointer pkg sync/atomic, func LoadUint32(*uint32) uint32
Plain Text - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Wed Aug 14 18:58:28 GMT 2013 - 1.7M bytes - Viewed (1)