Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 254 for chanOf (0.34 sec)

  1. pkg/apis/storage/validation/validation_test.go

    		name   string
    		modify func(new *storage.CSIDriver)
    	}{{
    		name:   "no change",
    		modify: func(new *storage.CSIDriver) {},
    	}, {
    		name: "change TokenRequests",
    		modify: func(new *storage.CSIDriver) {
    			new.Spec.TokenRequests = []storage.TokenRequest{{Audience: gcp}}
    		},
    	}, {
    		name: "change RequiresRepublish",
    		modify: func(new *storage.CSIDriver) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 69.7K bytes
    - Viewed (0)
  2. src/crypto/tls/handshake_client_test.go

    // when certain messages are seen.
    type opensslOutputSink struct {
    	handshakeComplete chan struct{}
    	readKeyUpdate     chan struct{}
    	all               []byte
    	line              []byte
    }
    
    func newOpensslOutputSink() *opensslOutputSink {
    	return &opensslOutputSink{make(chan struct{}), make(chan struct{}), nil, nil}
    }
    
    // opensslEndOfHandshake is a message that the “openssl s_server” tool will
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 88.7K bytes
    - Viewed (0)
  3. src/crypto/tls/tls_test.go

    	}
    	return nil
    }
    
    func TestTLSUniqueMatches(t *testing.T) {
    	ln := newLocalListener(t)
    	defer ln.Close()
    
    	serverTLSUniques := make(chan []byte)
    	parentDone := make(chan struct{})
    	childDone := make(chan struct{})
    	defer close(parentDone)
    	go func() {
    		defer close(childDone)
    		for i := 0; i < 2; i++ {
    			sconn, err := ln.Accept()
    			if err != nil {
    				t.Error(err)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 60.5K bytes
    - Viewed (0)
  4. pkg/controller/replicaset/replica_set_test.go

    	fakePodControl := controller.FakePodControl{}
    	stopCh := make(chan struct{})
    	defer close(stopCh)
    	manager, informers := testNewReplicaSetControllerFromClient(t, client, stopCh, BurstReplicas)
    	manager.podControl = &fakePodControl
    
    	received := make(chan string)
    	manager.syncHandler = func(ctx context.Context, key string) error {
    		received <- key
    		return nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 69.2K bytes
    - Viewed (0)
  5. src/cmd/go/internal/modget/get.go

    			// packages imported by the main module does not change, and the query
    			// result for the module containing each such package also does not change
    			// (it is always relative to the initial build list, before applying
    			// queries). So the only way that the result of an "all" query can change
    			// is if some matching package moves from one module in the build list
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 18:26:32 UTC 2024
    - 66.5K bytes
    - Viewed (0)
  6. src/runtime/pprof/pprof_test.go

    	}
    }
    
    func func1(c chan int) { <-c }
    func func2(c chan int) { <-c }
    func func3(c chan int) { <-c }
    func func4(c chan int) { <-c }
    
    func TestGoroutineCounts(t *testing.T) {
    	// Setting GOMAXPROCS to 1 ensures we can force all goroutines to the
    	// desired blocking point.
    	defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(1))
    
    	c := make(chan int)
    	for i := 0; i < 100; i++ {
    		switch {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 18:42:28 UTC 2024
    - 68.8K bytes
    - Viewed (0)
  7. src/runtime/mgc.go

    	// Kick off sweeping and scavenging.
    	c := make(chan int, 2)
    	go bgsweep(c)
    	go bgscavenge(c)
    	<-c
    	<-c
    	memstats.enablegc = true // now that runtime is initialized, GC is okay
    }
    
    // Garbage collector phase.
    // Indicates to write barrier and synchronization task to perform.
    var gcphase uint32
    
    // The compiler knows about this variable.
    // If you change it, you must change builtin/runtime.go, too.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62K bytes
    - Viewed (0)
  8. cmd/xl-storage_test.go

    			t.Fatalf("Unable to change permission to temporary directory %v. %v", permDeniedDir, err)
    		}
    
    		xlStorageNew, err := newLocalXLStorage(permDeniedDir)
    		if err != nil {
    			t.Fatalf("Unable to initialize xlStorage, %s", err)
    		}
    
    		// change backend permissions for MakeVol error.
    		if err = os.Chmod(permDeniedDir, 0o400); err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Apr 11 17:45:28 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  9. pilot/pkg/model/push_context.go

    	ServiceUpdate TriggerReason = "service"
    	// ProxyUpdate describes a push triggered by a change to an individual proxy (such as label change)
    	ProxyUpdate TriggerReason = "proxy"
    	// GlobalUpdate describes a push triggered by a change to global config, such as mesh config
    	GlobalUpdate TriggerReason = "global"
    	// AmbientUpdate describes a push triggered by a change to ambient mesh config
    	AmbientUpdate TriggerReason = "ambient"
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 09:02:11 UTC 2024
    - 91.8K bytes
    - Viewed (0)
  10. src/runtime/map.go

    	// us to eliminate padding which would be needed for, e.g., map[int64]int8.
    	// Followed by an overflow pointer.
    }
    
    // A hash iteration structure.
    // If you modify hiter, also change cmd/compile/internal/reflectdata/reflect.go
    // and reflect/value.go to match the layout of this structure.
    type hiter struct {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 57.6K bytes
    - Viewed (0)
Back to top