- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for count (0.14 sec)
-
cni/pkg/nodeagent/server_test.go
} } } func (wg *WaitGroup) Add(i int32) { select { case <-wg.done: panic("use of an already closed WaitGroup") default: } atomic.AddInt32(&wg.count, i) } func (wg *WaitGroup) Done() { i := atomic.AddInt32(&wg.count, -1) if i == 0 { close(wg.done) } } func (wg *WaitGroup) C() <-chan struct{} { return wg.done
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
} for i, l := range gotLogs { // For each line, there should be two level string, e.g. // "2021-07-09T03:26:08.984951Z debug debug log" if got, want := strings.Count(l, wantLevels[i]), 2; want != got { t.Errorf("Number of log level string want %v, got %v", want, got) } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
cni/pkg/repair/netns.go
// /var/run/netns/<name>. However, this pattern is not ubiquitous. Some platforms bind mount to other places. As we run // in a pod, we cannot just access any arbitrary file they happen to bind mount in, as we don't know ahead of time where // it might be. // // Instead, we rely directly on the procfs. // This rules out two possible methods:
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 4.8K bytes - Viewed (0) -
istioctl/pkg/wait/wait.go
countVersions(versionCount, configVersion.ListenerVersion) countVersions(versionCount, configVersion.EndpointVersion) } } for version, count := range versionCount { if slices.Contains(acceptedVersions, version) { present += count } else { notpresent += count } } return present, notpresent, sdcnum, nil } // getAndWatchResource ensures that Generations always contains
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 17 12:24:17 GMT 2024 - 10.1K bytes - Viewed (0) -
istioctl/pkg/injector/injector-list.go
} func renderCounts(injectedRevision string, counts revisionCount) string { if counts.pods == 0 { return "<no pods>" } podText := strconv.Itoa(counts.pods) if counts.disabled > 0 { podText += fmt.Sprintf(" (injection disabled: %d)", counts.disabled) } if counts.needsRestart > 0 { podText += fmt.Sprintf(" NEEDS RESTART: %d", counts.needsRestart) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jan 04 03:08:06 GMT 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/config/config.go
type InstallConfig struct { // Location of the CNI config files in the host's filesystem CNINetDir string // Location of the CNI config files in the container's filesystem (mount location of the CNINetDir) MountedCNINetDir string // Name of the CNI config file CNIConfName string // Whether to install CNI plugin as a chained or standalone ChainedCNIPlugin bool // CNI config template file
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 5.5K bytes - Viewed (0) -
cni/pkg/constants/constants.go
// Exposed for testing constants var ( CNIBinDir = "/opt/cni/bin" HostCNIBinDir = "/host/opt/cni/bin" ServiceAccountPath = "/var/run/secrets/kubernetes.io/serviceaccount" // Well-known subpath we will mount any needed host-mounts under, // to preclude shadowing or breaking any pod-internal mounts HostMountsPath = "/host"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 2.7K bytes - Viewed (0)