Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 37 for donechan (0.26 sec)

  1. 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)
  2. test/fixedbugs/issue31053.dir/main.go

    	}
    	f.doneChan = nil // ERROR "f.doneChan undefined .cannot refer to unexported field or method doneChan."
    	f.DoneChan = nil // ERROR "f.DoneChan undefined .type f1.Foo has no field or method DoneChan."
    	f.name = nil     // ERROR "f.name undefined .type f1.Foo has no field or method name, but does have Name."
    
    	_ = f.doneChan // ERROR "f.doneChan undefined .cannot refer to unexported field or method doneChan."
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Dec 28 07:44:07 UTC 2020
    - 2.7K bytes
    - Viewed (0)
  3. 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)
  4. test/fixedbugs/issue31053.dir/f1.go

    // Copyright 2019 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    package f1
    
    type Foo struct {
    	doneChan chan bool
    	Name     string
    	fOO      int
    	hook     func()
    }
    
    func (f *Foo) Exported() {
    }
    
    func (f *Foo) unexported() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 08 20:44:01 UTC 2020
    - 322 bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/promise/counting.go

    // - an optional initial value,
    // - an optional "done" channel,
    // - the value that is Set after the "done" channel becomes selectable.
    // Note that for this implementation, the reaction to `doneCh`
    // becoming selectable does not wait for a Get.
    // If `doneCh != nil` then the caller promises to close it reasonably promptly
    // (to the degree allowed by the Go runtime scheduler), and increment the
    // goroutine counter before that.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 10 14:37:53 UTC 2021
    - 3.3K bytes
    - Viewed (0)
Back to top