- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 248 for chanOf (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)