- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for donechan (0.16 sec)
-
test/fixedbugs/issue25727.go
package main import "net/http" var s = http.Server{} var _ = s.doneChan // ERROR "s.doneChan undefined .cannot refer to unexported field or method doneChan.$|unexported field or method|s.doneChan undefined" var _ = s.DoneChan // ERROR "s.DoneChan undefined .type http.Server has no field or method DoneChan.$|undefined field or method"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Feb 07 16:41:56 UTC 2024 - 1K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/sync/sync_test.go
tc.fake.logger = logger sync := New(&tc.fake, &tc.fake, &tc.fake, tc.mode, "node1", cidr) doneChan := make(chan struct{}) // Do a single step of the loop. go sync.Loop(logger, doneChan) sync.Update(tc.node) close(sync.opChan) <-doneChan tc.fake.dumpTrace() if !reflect.DeepEqual(tc.fake.events, tc.events) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 7.6K bytes - Viewed (0) -
pkg/client/tests/portfoward_test.go
pf, err := New(dialer, test.ports, stopChan, readyChan, os.Stdout, os.Stderr) if err != nil { t.Fatalf("%s: unexpected error calling New: %v", testName, err) } doneChan := make(chan error) go func() { doneChan <- pf.ForwardPorts() }() <-pf.Ready forwardedPorts, err := pf.GetPorts() if err != nil { t.Fatal(err) } remoteToLocalMap := map[int32]int32{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 05 06:08:18 UTC 2023 - 7.1K bytes - Viewed (0) -
src/runtime/race/output_test.go
{"simple", "run", "", "atexit_sleep_ms=0", ` package main import "time" var xptr *int var donechan chan bool func main() { done := make(chan bool) x := 0 startRacer(&x, done) store(&x, 43) <-done } func store(x *int, v int) { *x = v } func startRacer(x *int, done chan bool) { xptr = x donechan = done go racer() } func racer() { time.Sleep(10*time.Millisecond) store(xptr, 42)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 25 20:44:25 UTC 2023 - 9.3K bytes - Viewed (0) -
src/crypto/tls/handshake_client_test.go
if t.Failed() { t.Logf("OpenSSL output:\n\n%s", stdout.all) } }() } else { clientConn, serverConn = localPipe(t) } doneChan := make(chan bool) defer func() { clientConn.Close() <-doneChan }() go func() { defer close(doneChan) config := test.config if config == nil { config = testConfig } client := Client(clientConn, config) defer client.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 88.7K bytes - Viewed (0) -
internal/pubsub/pubsub_test.go
ch1 := make(chan Maskable, 1) ch2 := make(chan Maskable, 1) doneCh1 := make(chan struct{}) doneCh2 := make(chan struct{}) if err := ps.Subscribe(MaskAll, ch1, doneCh1, nil); err != nil { t.Fatalf("unexpected error: %v", err) } if err := ps.Subscribe(MaskAll, ch2, doneCh2, nil); err != nil { t.Fatalf("unexpected error: %v", err) } close(doneCh1) // Allow for the above statement to take effect.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 5.8K bytes - Viewed (0) -
internal/store/store.go
// Get next key. case <-doneCh: return } } } select { case <-retryTicker.C: case <-doneCh: return } } }() return keyCh } // sendItems - Reads items from the store and re-plays. func sendItems(target Target, keyCh <-chan Key, doneCh <-chan struct{}, logger logger) { retryTicker := time.NewTicker(retryInterval)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Mar 25 16:44:20 UTC 2024 - 3.5K bytes - Viewed (0) -
internal/pubsub/pubsub.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 16:57:30 UTC 2024 - 5.2K bytes - Viewed (0) -
pkg/config/mesh/watcher_test_utils.go
type TestWatcher struct { internalWatcher doneCh chan struct{} // used to implement a blocking Update method } func NewTestWatcher(meshConfig *meshconfig.MeshConfig) *TestWatcher { w := &TestWatcher{ internalWatcher: internalWatcher{}, } w.internalWatcher.MeshConfig.Store(meshConfig) w.doneCh = make(chan struct{}, 1) w.AddMeshHandler(func() { w.doneCh <- struct{}{} }) return w }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Nov 03 00:26:45 UTC 2023 - 1.5K bytes - Viewed (0) -
src/runtime/semasleep_test.go
} beforeStart := time.Now() if err := cmd.Start(); err != nil { t.Fatalf("Failed to start command: %v", err) } waiting := false doneCh := make(chan error, 1) t.Cleanup(func() { cmd.Process.Kill() if waiting { <-doneCh } else { cmd.Wait() } }) // Wait for After1 to close its stdout so that we know the runtime's SIGIO // handler is registered.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 06 17:48:24 UTC 2023 - 3.5K bytes - Viewed (0)