- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 938 for rwmutex (0.14 sec)
-
pkg/kube/kclient/crdwatcher.go
} // Run starts the controller. This must be called. func (c *crdWatcher) Run(stop <-chan struct{}) { c.mutex.Lock() if c.stop != nil { // Run already called. Because we call this from client.RunAndWait this isn't uncommon c.mutex.Unlock() return } c.stop = stop c.mutex.Unlock() kube.WaitForCacheSync("crd watcher", stop, c.crds.HasSynced) c.queue.Run(stop) c.crds.ShutdownHandlers() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 5.7K bytes - Viewed (0) -
src/runtime/export_test.go
lock(&deadlock) } type RWMutex struct { rw rwmutex } func (rw *RWMutex) Init() { rw.rw.init(lockRankTestR, lockRankTestRInternal, lockRankTestW) } func (rw *RWMutex) RLock() { rw.rw.rlock() } func (rw *RWMutex) RUnlock() { rw.rw.runlock() } func (rw *RWMutex) Lock() { rw.rw.lock() } func (rw *RWMutex) Unlock() { rw.rw.unlock() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:50:53 UTC 2024 - 46.1K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/reconciler/reconciler.go
loopSleepDuration time.Duration desiredStateOfWorld cache.DesiredStateOfWorld actualStateOfWorld cache.ActualStateOfWorld handlers map[string]cache.PluginHandler sync.RWMutex } var _ Reconciler = &reconciler{} func (rc *reconciler) Run(stopCh <-chan struct{}) { wait.Until(func() { rc.reconcile() }, rc.loopSleepDuration, stopCh) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 6.2K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
// if we don't know the netns, the pod will still be here with a nil netns. type podNetnsCache struct { openNetns func(nspath string) (NetnsCloser, error) currentPodCache map[string]WorkloadInfo mu sync.RWMutex } type WorkloadInfo struct { Workload *zdsapi.WorkloadInfo Netns NetnsCloser } var _ PodNetnsCache = &podNetnsCache{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 17:18:11 UTC 2024 - 4.3K bytes - Viewed (0) -
internal/config/browser/browser.go
Value: config.EnableOff, }, config.KV{ Key: browserReferrerPolicy, Value: "strict-origin-when-cross-origin", }, } ) // configLock is a global lock for browser config var configLock sync.RWMutex // Config storage class configuration type Config struct { CSPPolicy string `json:"csp_policy"` HSTSSeconds int `json:"hsts_seconds"`
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.8K bytes - Viewed (1) -
cmd/bucket-replication-metrics.go
Curr: qm.Curr.add(o.Curr), Avg: qm.Avg.add(o.Avg), Max: qm.Max.add(o.Max), } } type queueCache struct { srQueueStats InQueueStats bucketStats map[string]InQueueStats sync.RWMutex // mutex for queue stats } func newQueueCache(r metrics.Registry) queueCache { return queueCache{ bucketStats: make(map[string]InQueueStats), srQueueStats: newInQueueStats(r, "site"), } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 14.2K bytes - Viewed (0) -
internal/config/heal/heal.go
EnvBitrot = "MINIO_HEAL_BITROTSCAN" EnvSleep = "MINIO_HEAL_MAX_SLEEP" EnvIOCount = "MINIO_HEAL_MAX_IO" EnvDriveWorkers = "MINIO_HEAL_DRIVE_WORKERS" ) var configMutex sync.RWMutex // Config represents the heal settings. type Config struct { // Bitrot will perform bitrot scan on local disk when checking objects. Bitrot string `json:"bitrotscan"`
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.9K bytes - Viewed (0) -
api/go1.18.txt
pkg strings, func Clone(string) string pkg strings, func Cut(string, string) (string, string, bool) pkg strings, func Title //deprecated pkg sync, method (*Mutex) TryLock() bool pkg sync, method (*RWMutex) TryLock() bool pkg sync, method (*RWMutex) TryRLock() bool pkg syscall (freebsd-386), type SysProcAttr struct, Pdeathsig Signal pkg syscall (freebsd-386-cgo), type SysProcAttr struct, Pdeathsig Signal
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 17 20:31:46 UTC 2023 - 13K bytes - Viewed (0) -
pkg/test/framework/components/istio/configmap.go
ic.mu.Lock() ic.injectConfig = nil ic.mu.Unlock() errG := multierror.Group{} origCfg := map[string]string{} mu := sync.RWMutex{} for _, c := range ic.ctx.AllClusters() { c := c errG.Go(func() error { cfgMap, err := ic.getConfigMap(c, ic.configMapName()) if err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 12.8K bytes - Viewed (0) -
cmd/consolelogger.go
const defaultLogBufferCount = 10000 // HTTPConsoleLoggerSys holds global console logger state type HTTPConsoleLoggerSys struct { totalMessages int64 failedMessages int64 sync.RWMutex pubsub *pubsub.PubSub[log.Info, madmin.LogMask] console *console.Target nodeName string logBuf *ring.Ring } // NewConsoleLogger - creates new HTTPConsoleLoggerSys with all nodes subscribed to
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0)