- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 938 for rwmutex (0.12 sec)
-
src/sync/map_reference_test.go
Clear() } var ( _ mapInterface = &RWMutexMap{} _ mapInterface = &DeepCopyMap{} ) // RWMutexMap is an implementation of mapInterface using a sync.RWMutex. type RWMutexMap struct { mu sync.RWMutex dirty map[any]any } func (m *RWMutexMap) Load(key any) (value any, ok bool) { m.mu.RLock() value, ok = m.dirty[key] m.mu.RUnlock() return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 01 15:34:22 UTC 2024 - 5.6K bytes - Viewed (0) -
cmd/object-api-common.go
deletedBucketsPrefix = ".deleted" // ETag (hex encoded md5sum) of empty string. emptyETag = "d41d8cd98f00b204e9800998ecf8427e" ) // Global object layer mutex, used for safely updating object layer. var globalObjLayerMutex sync.RWMutex // Global object layer, only accessed by globalObjectAPI. var globalObjectAPI ObjectLayer type storageOpts struct { cleanUp bool healthCheck bool }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 2.1K bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/timeoututils.go
UpgradeManifests: &metav1.Duration{Duration: constants.UpgradeManifestsTimeout}, } } var ( activeTimeouts *Timeouts = nil timeoutMutex = &sync.RWMutex{} ) func init() { SetDefaultTimeouts(&activeTimeouts) } // GetActiveTimeouts gets the active timeouts structure. func GetActiveTimeouts() *Timeouts { timeoutMutex.RLock() defer timeoutMutex.RUnlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/waitgroup/waitgroup.go
limitations under the License. */ package waitgroup import ( "fmt" "sync" ) // SafeWaitGroup must not be copied after first use. type SafeWaitGroup struct { wg sync.WaitGroup mu sync.RWMutex // wait indicate whether Wait is called, if true, // then any Add with positive delta will return error. wait bool } // Add adds delta, which may be negative, similar to sync.WaitGroup.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 11 03:04:14 UTC 2018 - 1.5K bytes - Viewed (0) -
pilot/pkg/util/informermetric/informerutil.go
) var ( clusterLabel = monitoring.CreateLabel("cluster") errorMetric = monitoring.NewSum( "controller_sync_errors_total", "Total number of errorMetric syncing controllers.", ) mu sync.RWMutex handlers = map[cluster.ID]cache.WatchErrorHandler{} ) // ErrorHandlerForCluster fetches or creates an ErrorHandler that emits a metric
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 1.6K bytes - Viewed (0) -
cmd/ilm-config.go
"github.com/minio/minio/internal/config/ilm" ) var globalILMConfig = ilmConfig{ cfg: ilm.Config{ ExpirationWorkers: 100, TransitionWorkers: 100, }, } type ilmConfig struct { mu sync.RWMutex cfg ilm.Config } func (c *ilmConfig) getExpirationWorkers() int { c.mu.RLock() defer c.mu.RUnlock() return c.cfg.ExpirationWorkers } func (c *ilmConfig) getTransitionWorkers() int {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Mar 05 02:50:24 UTC 2024 - 1.3K bytes - Viewed (0) -
cmd/bootstrap-messages.go
package cmd import ( "context" "sync" "github.com/minio/madmin-go/v3" "github.com/minio/minio/internal/pubsub" ) const bootstrapTraceLimit = 4 << 10 type bootstrapTracer struct { mu sync.RWMutex info []madmin.TraceInfo } var globalBootstrapTracer = &bootstrapTracer{} func (bs *bootstrapTracer) Record(info madmin.TraceInfo) { bs.mu.Lock() defer bs.mu.Unlock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Aug 23 10:07:06 UTC 2023 - 1.7K bytes - Viewed (0) -
security/pkg/credentialfetcher/plugin/mock.go
return nil, err } return ms, nil } func (ms *MetadataServer) setToken(t string) { ms.mutex.Lock() defer ms.mutex.Unlock() ms.credential = t } // NumGetTokenCall returns the number of token fetching request. func (ms *MetadataServer) NumGetTokenCall() int { ms.mutex.RLock() defer ms.mutex.RUnlock() return ms.numGetTokenCall } // Reset resets members to default values.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/max_seats.go
SetMaxSeats(priorityLevelName string, maxSeats uint64) // ForgetPriorityLevel removes max seats tracking for a priority level. ForgetPriorityLevel(priorityLevelName string) } type maxSeatsTracker struct { sync.RWMutex maxSeats map[string]uint64 } func NewMaxSeatsTracker() MaxSeatsTracker { return &maxSeatsTracker{ maxSeats: make(map[string]uint64), } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:26:52 UTC 2023 - 1.7K bytes - Viewed (0) -
pilot/pkg/keycertbundle/watcher.go
func (w *Watcher) AddWatcher() (int32, chan struct{}) { ch := make(chan struct{}, 1) w.mutex.Lock() defer w.mutex.Unlock() id := w.watcherID w.watchers[id] = ch w.watcherID++ return id, ch } // RemoveWatcher removes the given watcher. func (w *Watcher) RemoveWatcher(id int32) { w.mutex.Lock() defer w.mutex.Unlock() ch := w.watchers[id] if ch != nil { close(ch) } delete(w.watchers, id)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 05 14:00:18 UTC 2023 - 2.6K bytes - Viewed (0)