- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for reqchans (0.13 sec)
-
src/runtime/stack_test.go
const ( R = 4 G = 200 S = 5 ) for i := 0; i < R; i++ { var reqchans [G]chan int done := make(chan struct{}) for j := 0; j < G; j++ { reqchans[j] = make(chan int) go growing(reqchans[j], done) } for s := 0; s < S; s++ { for j := 0; j < G; j++ { reqchans[j] <- 1 << uint(s) } for j := 0; j < G; j++ { <-done } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 23.1K bytes - Viewed (0) -
pkg/xds/server.go
initialized chan struct{} // stop can be used to end the connection manually via debug endpoints. Only to be used for testing. stop chan struct{} // reqChan is used to receive discovery requests for this connection. reqChan chan *discovery.DiscoveryRequest // errorChan is used to process error during discovery request processing. errorChan chan error }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
cluster/addons/calico-policy-controller/felixconfigurations-crd.yaml
type: string interfaceRefreshInterval: description: InterfaceRefreshInterval is the period at which Felix rescans local interfaces to verify their state. The rescan can be disabled by setting the interval to 0. type: string ipipEnabled: type: boolean
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 07 20:48:43 UTC 2021 - 29.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
Predicate: storage.Everything, }) if err != nil { t.Fatalf("Failed to create watch: %v", err) } defer w.Stop() received := 0 resChan := w.ResultChan() for event := range resChan { received++ t.Logf("event type: %v, events received so far: %d", event.Type, received) if event.Type != watch.Added {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi_util.go
b.plugin.targetLocks.LockKey(b.Iqn) defer b.plugin.targetLocks.UnlockKey(b.Iqn) // Build a map of SCSI hosts for each target portal. We will need this to // issue the bus rescans. portalHostMap, err := b.deviceUtil.GetISCSIPortalHostMapForTarget(b.Iqn) if err != nil { return "", err } klog.V(4).Infof("AttachDisk portal->host map for %s is %v", b.Iqn, portalHostMap)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 22 12:53:01 UTC 2022 - 34.1K bytes - Viewed (0) -
prow/config/calico.yaml
type: string interfaceRefreshInterval: description: InterfaceRefreshInterval is the period at which Felix rescans local interfaces to verify their state. The rescan can be disabled by setting the interval to 0. pattern: ^([0-9]+(\\.[0-9]+)?(ms|s|m|h))*$ type: string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 246.5K bytes - Viewed (0)