- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 938 for rwmutex (0.28 sec)
-
pkg/filewatcher/filewatcher.go
Remove(path string) error Close() error Events(path string) chan fsnotify.Event Errors(path string) chan error } type fileWatcher struct { mu sync.RWMutex // The watcher maintain a map of workers, // keyed by watched dir (parent dir of watched files). workers map[string]*workerState funcs *patchTable } type workerState struct { worker *worker
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 4.3K bytes - Viewed (0) -
src/internal/trace/parser.go
EvGoBlockRecv = 23 // goroutine blocks on chan recv [timestamp, stack] EvGoBlockSelect = 24 // goroutine blocks on select [timestamp, stack] EvGoBlockSync = 25 // goroutine blocks on Mutex/RWMutex [timestamp, stack] EvGoBlockCond = 26 // goroutine blocks on Cond [timestamp, stack] EvGoBlockNet = 27 // goroutine blocks on network [timestamp, stack] EvGoSysCall = 28 // syscall enter [timestamp, stack]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:31:04 UTC 2024 - 4.7K bytes - Viewed (0) -
pkg/kube/multicluster/component.go
"istio.io/istio/pkg/maps" "istio.io/istio/pkg/slices" ) type ComponentConstraint interface { Close() HasSynced() bool } type Component[T ComponentConstraint] struct { mu sync.RWMutex constructor func(cluster *Cluster) T clusters map[cluster.ID]T } func (m *Component[T]) ForCluster(clusterID cluster.ID) *T { m.mu.RLock() defer m.mu.RUnlock() t, f := m.clusters[clusterID] if !f {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 3.4K bytes - Viewed (0) -
pkg/kubelet/status/state/state_mem.go
limitations under the License. */ package state import ( "sync" "k8s.io/api/core/v1" "k8s.io/klog/v2" ) type stateMemory struct { sync.RWMutex podAllocation PodResourceAllocation podResizeStatus PodResizeStatus } var _ State = &stateMemory{} // NewStateMemory creates new State to track resources allocated to pods func NewStateMemory() State {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 24 18:21:21 UTC 2023 - 4K bytes - Viewed (0) -
pkg/test/failer.go
// test context, which will cause the test to panic. The Wrap function handles this automatically type errorWrapper struct { mu sync.RWMutex failed error cleanup func() } // Wrap executes a function with a fake Failer, and returns an error if the test failed. This allows
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Jul 15 23:58:50 UTC 2023 - 3.5K bytes - Viewed (0) -
internal/config/batch/batch.go
EnvKeyRotationWorkersWait = "MINIO_BATCH_KEYROTATION_WORKERS_WAIT" EnvKeyExpirationWorkersWait = "MINIO_BATCH_EXPIRATION_WORKERS_WAIT" ) var configMu sync.RWMutex // Config represents the batch job settings. type Config struct { ReplicationWorkersWait time.Duration `json:"replicationWorkersWait"` KeyRotationWorkersWait time.Duration `json:"keyRotationWorkersWait"`
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.7K bytes - Viewed (0) -
src/sync/cond.go
"unsafe" ) // Cond implements a condition variable, a rendezvous point // for goroutines waiting for or announcing the occurrence // of an event. // // Each Cond has an associated Locker L (often a [*Mutex] or [*RWMutex]), // which must be held when changing the condition and // when calling the [Cond.Wait] method. // // A Cond must not be copied after first use. // // In the terminology of [the Go memory model], Cond arranges that
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/root.go
addresses Addresses serializer runtime.NegotiatedSerializer // Map storing information about all groups to be exposed in discovery response. // The map is from name to the group. lock sync.RWMutex apiGroups map[string]metav1.APIGroup // apiGroupNames preserves insertion order apiGroupNames []string } func NewRootAPIsHandler(addresses Addresses, serializer runtime.NegotiatedSerializer) *rootAPIsHandler {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 22:44:49 UTC 2022 - 4.3K bytes - Viewed (0) -
pkg/controller/job/tracking_utils.go
} // uidSet holds a key and a set of UIDs. Used by the // uidTrackingExpectations to remember which UID it has seen/still waiting for. type uidSet struct { sync.RWMutex set sets.Set[string] key string } // uidTrackingExpectations tracks the UIDs of Pods the controller is waiting to // observe tracking finalizer deletions. type uidTrackingExpectations struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 14 05:40:02 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/plugin_manager_test.go
"k8s.io/kubernetes/pkg/kubelet/pluginmanager/pluginwatcher" ) var ( socketDir string supportedVersions = []string{"v1beta1", "v1beta2"} ) type fakePluginHandler struct { events []string sync.RWMutex } func newFakePluginHandler() *fakePluginHandler { return &fakePluginHandler{} } // ValidatePlugin is a fake method
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 4.4K bytes - Viewed (0)