- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 3,491 for ctan (0.05 sec)
-
pkg/istio-agent/xds_proxy.go
conID uint32 upstreamError chan error downstreamError chan error requestsChan *channels.Unbounded[*discovery.DiscoveryRequest] responsesChan chan *discovery.DiscoveryResponse deltaRequestsChan *channels.Unbounded[*discovery.DeltaDiscoveryRequest] deltaResponsesChan chan *discovery.DeltaDiscoveryResponse stopChan chan struct{} downstream adsStream
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
src/cmd/trace/testdata/testprog/main.go
for i := 0; i < runtime.GOMAXPROCS(0); i++ { wg2.Add(1) go func() { defer wg2.Done() cpuHog(50 * time.Millisecond) }() } wg2.Wait() // checkSyscalls relies on this. done := make(chan error) go blockingSyscall(50*time.Millisecond, done) if err := <-done; err != nil { log.Fatal(err) } // checkNetworkUnblock relies on this. ln, err := net.Listen("tcp", "127.0.0.1:0") if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 17:15:58 UTC 2024 - 2.5K bytes - Viewed (0) -
pkg/revisions/tag_watcher.go
"istio.io/istio/pkg/kube/kclient" "istio.io/istio/pkg/kube/kubetypes" "istio.io/istio/pkg/util/sets" ) // TagWatcher keeps track of the current tags and can notify watchers // when the tags change. type TagWatcher interface { Run(stopCh <-chan struct{}) HasSynced() bool AddHandler(handler TagHandler) GetMyTags() sets.String } // TagHandler is a callback for when the tags revision change.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 3.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go
} type inFlightRequest struct { blockedCh, startedCh chan struct{} resultCh chan result url string } func setupInFlightNonLongRunningRequestHandler(s *GenericAPIServer) *inFlightRequest { inflight := &inFlightRequest{ blockedCh: make(chan struct{}), startedCh: make(chan struct{}), resultCh: make(chan result), url: "/in-flight-non-long-running-request-as-designed",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 38.3K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/cgo-callback.go
} func main() { // Start tracing. if err := trace.Start(os.Stdout); err != nil { log.Fatalf("failed to start tracing: %v", err) } // Do a whole bunch of cgocallbacks. const n = 10 done := make(chan bool) for i := 0; i < n; i++ { go func() { C.foo() done <- true }() } for i := 0; i < n; i++ { <-done } // Do something to steal back any Ps from the Ms, just // for coverage.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.3K bytes - Viewed (0) -
src/net/http/transport.go
pconn = &persistConn{ t: t, cacheKey: cm.key(), reqch: make(chan requestAndChan, 1), writech: make(chan writeRequest, 1), closech: make(chan struct{}), writeErrCh: make(chan error, 1), writeLoopDone: make(chan struct{}), } trace := httptrace.ContextClientTrace(ctx) wrapErr := func(err error) error { if cm.proxyURL != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
src/syscall/syscall_linux_test.go
} } // launches per fns member. const launches = 11 question := make(chan uintptr) response := make(chan uintptr) defer close(question) routines := 0 for i, v := range fns { for j := 0; j < launches; j++ { // Add another goroutine - the closest thing // we can do to encourage more OS thread // creation - while the test is running. The
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 23K bytes - Viewed (0) -
src/internal/fmtsort/sort_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 6.9K 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/unique/handle_test.go
}) } // drainMaps ensures that the internal maps are drained. func drainMaps(t *testing.T) { t.Helper() wait := make(chan struct{}, 1) // Set up a one-time notification for the next time the cleanup runs. // Note: this will only run if there's no other active cleanup, so // we can be sure that the next time cleanup runs, it'll see the new // notification. cleanupMu.Lock() cleanupNotify = append(cleanupNotify, func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 18:14:07 UTC 2024 - 2.5K bytes - Viewed (0)