- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of about 10,000 for ctan (0.08 sec)
-
internal/grid/stream.go
// All responses *must* be read by the caller until either an error is returned or the channel is closed. // Canceling the context will cause the context cancellation error to be returned. responses <-chan Response cancel context.CancelCauseFunc // Requests sent to the server. // If the handler is defined with 0 incoming capacity this will be nil. // Channel *must* be closed to signal the end of the stream.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 3.1K bytes - Viewed (0) -
test/convT2X.go
} // pp does not implement J. // Test that non-interface types can be used as ...interface{} arguments. if got := second(z, p, pp, u16, u32, u64, u128, f32, f64, c128, s, b, m, c); got != ip { println("second: got", got, "want", ip) panic("fail") } // Test that non-interface types can be sent on a chan interface{}. const n = 100 uc := make(chan interface{}) go func() { for i := 0; i < n; i++ { select {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jul 02 23:09:05 UTC 2012 - 3.3K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/executor.go
activeRequests *atomic.Uint64 stopCh chan struct{} } func newExecutor() *executor { e := &executor{ totalRequests: atomic.NewUint64(0), activeRequests: atomic.NewUint64(0), stopCh: make(chan struct{}), } return e } func (e *executor) ActiveRequests() uint64 { return e.activeRequests.Load() } // NewGroup creates a new group of tasks that can be managed collectively.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 10 18:09:08 UTC 2022 - 2K bytes - Viewed (0) -
src/net/mptcpsock_linux_test.go
defer ls.teardown() if g, w := ls.Listener.Addr().Network(), "tcp"; g != w { t.Fatalf("Network type mismatch: got %q, want %q", g, w) } genericCh := make(chan error) mptcpCh := make(chan error) handler := func(ls *localServer, ln Listener) { ls.transponder(ln, genericCh) postAcceptMPTCP(ls, mptcpCh) } if err := ls.buildup(handler); err != nil { t.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 11 00:36:57 UTC 2023 - 4.1K bytes - Viewed (0) -
src/cmd/go/testdata/script/test_chatty_parallel_success.txt
parallel := flag.Lookup("test.parallel").Value.(flag.Getter).Get().(int) // ready is a synchronization mechanism that causes subtests to execute // round robin. ready := make([]chan bool, parallel) for i := range ready { ready[i] = make(chan bool, 1) } ready[0] <- true for i := range ready { i := i t.Run(fmt.Sprintf("sub-%d", i), func(t *testing.T) { t.Parallel() for j := 0; j < 2; j++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 26 19:50:36 UTC 2022 - 1.9K bytes - Viewed (0) -
pkg/kubelet/config/apiserver.go
// NewSourceApiserver creates a config source that watches and pulls from the apiserver. func NewSourceApiserver(c clientset.Interface, nodeName types.NodeName, nodeHasSynced func() bool, updates chan<- interface{}) { lw := cache.NewListWatchFromClient(c.CoreV1().RESTClient(), "pods", metav1.NamespaceAll, fields.OneTermEqualSelector("spec.nodeName", string(nodeName)))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 21 19:46:27 UTC 2021 - 2.4K bytes - Viewed (0) -
src/runtime/testdata/testprogcgo/lockosthread.go
func LockOSThreadAlt() { // This is running locked to the main OS thread. var subThread C.pthread_t ready := make(chan bool, 1) C.threadExited = 0 go func() { // This goroutine must be running on a new thread. runtime.LockOSThread() subThread = C.pthread_self() // Register a pthread destructor so we can tell this // thread has exited. var key C.pthread_key_t
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 02 20:21:33 UTC 2023 - 2.5K bytes - Viewed (0) -
src/sync/atomic/example_test.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package atomic_test import ( "sync" "sync/atomic" "time" ) func loadConfig() map[string]string { return make(map[string]string) } func requests() chan int { return make(chan int) } // The following example shows how to use Value for periodic program config updates
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 18 23:58:54 UTC 2018 - 2.2K bytes - Viewed (0) -
src/internal/poll/fd_io_plan9.go
aio := &asyncIO{ res: make(chan result, 0), } aio.mu.Lock() go func() { // Lock the current goroutine to its process // and store the pid in io so that Cancel can // interrupt it. We ignore the "hangup" signal, // so the signal does not take down the entire // Go runtime. runtime.LockOSThread() runtime_ignoreHangup() aio.pid = syscall.Getpid() aio.mu.Unlock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Mar 14 17:56:50 UTC 2021 - 2.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/healthz_test.go
) func TestDelayedHealthCheck(t *testing.T) { t.Run("test that liveness check returns true until the delay has elapsed", func(t *testing.T) { t0 := time.Unix(0, 0) c := testingclock.NewFakeClock(t0) doneCh := make(chan struct{}) healthCheck := delayedHealthCheck(postStartHookHealthz{"test", doneCh}, c, time.Duration(10)*time.Second) err := healthCheck.Check(nil) if err != nil { t.Errorf("Got %v, expected no error", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 15 09:52:18 UTC 2021 - 2.2K bytes - Viewed (0)