- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 130 for mutex (0.13 sec)
-
cmd/bucket-replication-metrics.go
) // rateMeasurement captures the transfer details for one bucket/target //msgp:ignore rateMeasurement type rateMeasurement struct { lock sync.Mutex bytesSinceLastWindow uint64 // Total bytes since last window was processed startTime time.Time // Start time for window expMovingAvg float64 // Previously calculated exponential moving average }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/grid/muxserver.go
BaseFlags Flags ctx context.Context cancel context.CancelFunc inbound chan []byte parent *Connection sendMu sync.Mutex recvMu sync.Mutex outBlock chan struct{} } func newMuxStateless(ctx context.Context, msg message, c *Connection, handler StatelessHandler) *muxServer { var cancel context.CancelFunc
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
misc/linkcheck/linkcheck.go
var urlq = make(chan string) // URLs to crawl // urlFrag is a URL and its optional #fragment (without the #) type urlFrag struct { url, frag string } var ( mu sync.Mutex crawled = make(map[string]bool) // URL without fragment -> true neededFrags = make(map[urlFrag][]string) // URL#frag -> who needs it ) var aRx = regexp.MustCompile(`<a href=['"]?(/[^\s'">]+)`)
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Oct 06 15:53:04 GMT 2021 - 3.9K bytes - Viewed (0) -
cmd/erasure-common.go
"math/rand" "sync" "time" "github.com/minio/pkg/v2/sync/errgroup" ) func (er erasureObjects) getOnlineDisks() (newDisks []StorageAPI) { disks := er.getDisks() var wg sync.WaitGroup var mu sync.Mutex r := rand.New(rand.NewSource(time.Now().UnixNano())) for _, i := range r.Perm(len(disks)) { i := i wg.Add(1) go func() { defer wg.Done() if disks[i] == nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 4.6K bytes - Viewed (0) -
internal/store/batch.go
type key interface { string | int | int64 } // Batch represents an ordered batch type Batch[K key, T any] struct { keys []K items map[K]T limit uint32 sync.Mutex } // Add adds the item to the batch func (b *Batch[K, T]) Add(key K, item T) error { b.Lock() defer b.Unlock() if b.isFull() { return ErrBatchFull } if _, ok := b.items[key]; !ok {
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) -
tensorflow/c/experimental/filesystem/plugins/gcs/expiring_lru_cache.h
#include <functional> #include <list> #include <map> #include <memory> #include <string> #include "absl/base/thread_annotations.h" #include "absl/synchronization/mutex.h" #include "tensorflow/c/env.h" #include "tensorflow/c/tf_status.h" namespace tf_gcs_filesystem { /// \brief An LRU cache of string keys and arbitrary values, with configurable
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Jul 09 19:31:22 GMT 2020 - 6.3K bytes - Viewed (0) -
internal/cachevalue/cache.go
// Should be set before calling Get(). Once sync.Once // Managed values. valErr atomic.Pointer[struct { v T e error }] lastUpdateMs atomic.Int64 updating sync.Mutex } // New allocates a new cached value instance. Tt must be initialized with // `.TnitOnce`. func New[T any]() *Cache[T] { return &Cache[T]{} }
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/config/identity/openid/provider/keycloak.go
AccessToken string `json:"access_token"` Expiry int `json:"expires_in"` } // KeycloakProvider implements Provider interface for KeyCloak Identity Provider. type KeycloakProvider struct { sync.Mutex oeConfig DiscoveryDoc client http.Client adminURL string realm string // internal value refreshed accessToken Token }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 29 01:27:09 GMT 2022 - 4.6K bytes - Viewed (0) -
cni/pkg/log/uds.go
"istio.io/istio/pkg/log" "istio.io/istio/pkg/network" "istio.io/istio/pkg/uds" ) var pluginLog = log.RegisterScope("cni", "CNI network plugin") type UDSLogger struct { mu sync.Mutex loggingServer *http.Server } type cniLog struct { Level string `json:"level"` Time time.Time `json:"time"` Msg string `json:"msg"` } func NewUDSLogger() *UDSLogger { l := &UDSLogger{}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0) -
cmd/config.go
if err != nil { return err } bootstrapTraceMsg("lookup the configuration") // Override any values from ENVs. lookupConfigs(srvCfg, objAPI) // hold the mutex lock before a new config is assigned. globalServerConfigMu.Lock() globalServerConfig = srvCfg globalServerConfigMu.Unlock() return nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Aug 23 10:07:06 GMT 2023 - 6K bytes - Viewed (0)