Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for reqchans (0.13 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top