- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 3,396 for ctan (0.04 sec)
-
staging/src/k8s.io/apiserver/pkg/server/healthz/healthz_test.go
// that simply returns the value passed during stub initialization. func (s cacheSyncWaiterStub) WaitForCacheSync(_ <-chan struct{}) map[reflect.Type]bool { return s.startedByInformerType } func TestInstallPathHandlerWithHealthyFunc(t *testing.T) { mux := http.NewServeMux() readyzCh := make(chan struct{}) hasBeenReadyCounter := 0 hasBeenReadyFn := func() { hasBeenReadyCounter++ }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 15 20:43:16 UTC 2023 - 11.4K bytes - Viewed (0) -
src/runtime/runtime-gdb.py
yield str(cnt + 1), v cnt += 2 bp = b['overflow'] class ChanTypePrinter: """Pretty print chan[T] types. Chan-typed go variables are really pointers. dereference them in gdb to inspect their contents with this pretty printer. """ pattern = re.compile(r'^chan ') def __init__(self, val): self.val = val def display_hint(self): return 'array'
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 10 12:59:20 UTC 2023 - 15.4K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller_test.go
func (t *testController) ConfigClusterHandler() testHandler { return t.component.clusters["config"] } func (t *testController) Run(stop chan struct{}) { assert.NoError(t.t, t.controller.Run(stop)) t.client.RunAndWait(stop) } func TestListRemoteClusters(t *testing.T) { stop := make(chan struct{}) c := buildTestController(t, false) c.AddSecret("s0", "c0") c.AddSecret("s1", "c1") c.Run(stop) // before sync
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 17.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/backoff.go
// // Until is syntactic sugar on top of JitterUntil with zero jitter factor and // with sliding = true (which means the timer for period starts after the f // completes). func Until(f func(), period time.Duration, stopCh <-chan struct{}) { JitterUntil(f, period, 0.0, true, stopCh) } // UntilWithContext loops until context is done, running f every period. // // UntilWithContext is syntactic sugar on top of JitterUntilWithContext
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 16.5K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/typesinternal/errorcode.go
// InvalidChanAssign occurs when a chan assignment is invalid. // // Per the spec, a value x is assignable to a channel type T if: // "x is a bidirectional channel value, T is a channel type, x's type V and // T have identical element types, and at least one of V or T is not a // defined type." // // Example: // type T1 chan int // type T2 chan int // // var x T1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 02:38:00 UTC 2024 - 34K bytes - Viewed (0) -
src/crypto/tls/conn_test.go
clientConn, serverConn := localPipe(t) serverConfig := config.Clone() serverConfig.DynamicRecordSizingDisabled = false tlsConn := Server(serverConn, serverConfig) handshakeDone := make(chan struct{}) recordSizesChan := make(chan []int, 1) defer func() { <-recordSizesChan }() // wait for the goroutine to exit go func() { // This goroutine performs a TLS handshake over clientConn and
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 24 21:35:01 UTC 2023 - 10.5K bytes - Viewed (0) -
src/vendor/golang.org/x/net/nettest/conntest.go
} // testBasicIO tests that the data sent on c1 is properly received on c2. func testBasicIO(t *testing.T, c1, c2 net.Conn) { want := make([]byte, 1<<20) rand.New(rand.NewSource(0)).Read(want) dataCh := make(chan []byte) go func() { rd := bytes.NewReader(want) if err := chunkedCopy(c1, rd); err != nil { t.Errorf("unexpected c1.Write error: %v", err) } if err := c1.Close(); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 12.2K bytes - Viewed (0) -
src/go/types/predicates.go
if y, ok := y.(*Map); ok { return c.identical(x.key, y.key, p) && c.identical(x.elem, y.elem, p) } case *Chan: // Two channel types are identical if they have identical value types // and the same direction. if y, ok := y.(*Chan); ok { return x.dir == y.dir && c.identical(x.elem, y.elem, p) } case *Named: // Two named types are identical if their type names originate
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:01:18 UTC 2024 - 17.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/apiserver.go
go finalizingController.Run(5, context.StopCh) discoverySyncedCh := make(chan struct{}) go discoveryController.Run(context.StopCh, discoverySyncedCh) select { case <-context.StopCh: case <-discoverySyncedCh: } return nil }) // we don't want to report healthy until we can handle all CRDs that have already been registered. Waiting for the informer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 14:31:43 UTC 2023 - 11.5K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/go/types/objectpath/objectpath.go
// function fails. func (enc *Encoder) concreteMethod(meth *types.Func) (Path, bool) { // Concrete methods can only be declared on package-scoped named types. For // that reason we can skip the expensive walk over the package scope: the // path will always be package -> named type -> method. We can trivially get // the type name from the receiver, and only have to look over the type's // methods to find the method index. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 23.1K bytes - Viewed (0)