- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 938 for rwmutex (0.19 sec)
-
pilot/pkg/model/cluster_local.go
c.onMeshUpdated(e) return c } var _ ClusterLocalProvider = &clusterLocalProvider{} type clusterLocalProvider struct { mutex sync.RWMutex hosts ClusterLocalHosts } func (c *clusterLocalProvider) GetClusterLocalHosts() ClusterLocalHosts { c.mutex.RLock() out := c.hosts c.mutex.RUnlock() return out } func (c *clusterLocalProvider) onMeshUpdated(e *Environment) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 20 12:54:10 UTC 2023 - 4.4K bytes - Viewed (0) -
src/text/template/template.go
type common struct { tmpl map[string]*Template // Map from name to defined templates. muTmpl sync.RWMutex // protects tmpl option option // We use two maps, one for parsing and one for execution. // This separation makes the API cleaner since it doesn't // expose reflection to the client. muFuncs sync.RWMutex // protects parseFuncs and execFuncs parseFuncs FuncMap execFuncs map[string]reflect.Value }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 20:57:51 UTC 2024 - 7.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 07:56:39 UTC 2024 - 15.1K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/state/state_mem.go
See the License for the specific language governing permissions and limitations under the License. */ package state import ( "sync" "k8s.io/klog/v2" ) type stateMemory struct { sync.RWMutex assignments ContainerMemoryAssignments machineState NUMANodeMap } var _ State = &stateMemory{} // NewMemoryState creates new State for keeping track of cpu/pod assignment func NewMemoryState() State {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 15 19:51:19 UTC 2021 - 3.2K bytes - Viewed (0) -
src/syscall/env_unix.go
package syscall import ( "runtime" "sync" ) var ( // envOnce guards initialization by copyenv, which populates env. envOnce sync.Once // envLock guards env and envs. envLock sync.RWMutex // env maps from an environment variable to its first occurrence in envs. env map[string]int // envs is provided by the runtime. elements are expected to // be of the form "key=value". An empty string means deleted
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 06 20:58:35 UTC 2023 - 2.7K bytes - Viewed (0) -
pilot/pkg/model/controller.go
c.mutex.RLock() defer c.mutex.RUnlock() // Return a shallow copy of the array return c.serviceHandlers } func (c *ControllerHandlers) GetWorkloadHandlers() []func(*WorkloadInstance, Event) { c.mutex.RLock() defer c.mutex.RUnlock() // Return a shallow copy of the array return c.workloadHandlers } func (c *ControllerHandlers) NotifyServiceHandlers(prev, curr *Service, event Event) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 25 06:54:32 UTC 2023 - 4.7K bytes - Viewed (0) -
pkg/config/mesh/networks_watcher.go
if w == nil { return nil } w.mutex.RLock() defer w.mutex.RUnlock() return w.networks } // PrevNetworks returns the previous network configuration for the mesh. func (w *internalNetworkWatcher) PrevNetworks() *meshconfig.MeshNetworks { if w == nil { return nil } w.mutex.RLock() defer w.mutex.RUnlock() return w.prevNetworks }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 18:33:38 UTC 2023 - 4.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/examples/stateful/stateful.go
// This plugin is stateful. It receives arguments at initialization (NewMultipointPlugin) // and changes its state when it is executed. type MultipointExample struct { executionPoints []string mu sync.RWMutex } var _ framework.ReservePlugin = &MultipointExample{} var _ framework.PreBindPlugin = &MultipointExample{} // Name is the name of the plug used in Registry and configurations.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 03:43:17 UTC 2023 - 3.3K bytes - Viewed (0) -
pkg/kubelet/runtime.go
import ( "errors" "fmt" "sync" "time" utilerrors "k8s.io/apimachinery/pkg/util/errors" kubecontainer "k8s.io/kubernetes/pkg/kubelet/container" ) type runtimeState struct { sync.RWMutex lastBaseRuntimeSync time.Time baseRuntimeSyncThreshold time.Duration networkError error runtimeError error storageError error cidr string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 00:48:07 UTC 2024 - 3.6K bytes - Viewed (0) -
pkg/kubelet/prober/common_test.go
result probe.Result err error } func (p fakeExecProber) Probe(c exec.Cmd) (probe.Result, string, error) { return p.result, "", p.err } type syncExecProber struct { sync.RWMutex fakeExecProber } func (p *syncExecProber) set(result probe.Result, err error) { p.Lock() defer p.Unlock() p.result = result p.err = err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 12 16:57:26 UTC 2023 - 4.3K bytes - Viewed (0)