- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 3,491 for ctan (0.15 sec)
-
pilot/pkg/xds/discovery.go
func (s *DiscoveryServer) handleUpdates(stopCh <-chan struct{}) { debounce(s.pushChannel, stopCh, s.DebounceOptions, s.Push, s.CommittedUpdates) } // The debounce helper function is implemented to enable mocking func debounce(ch chan *model.PushRequest, stopCh <-chan struct{}, opts DebounceOptions, pushFn func(req *model.PushRequest), updateSent *atomic.Int64) { var timeChan <-chan time.Time var startDebounce time.Time
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0) -
src/go/types/unify.go
if y, ok := y.(*Map); ok { return u.nify(x.key, y.key, emode, p) && u.nify(x.elem, y.elem, emode, p) } case *Chan: // Two channel types unify if their value types unify // and if they have the same direction. // The channel direction is ignored for inexact unification. if y, ok := y.(*Chan); ok { return (mode&exact == 0 || x.dir == y.dir) && u.nify(x.elem, y.elem, emode, p) } case *Named:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 16:24:39 UTC 2024 - 27.9K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/futile-wakeup.go
) func main() { if err := trace.Start(os.Stdout); err != nil { log.Fatalf("failed to start tracing: %v", err) } defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(8)) c0 := make(chan int, 1) c1 := make(chan int, 1) c2 := make(chan int, 1) const procs = 2 var done sync.WaitGroup done.Add(4 * procs) for p := 0; p < procs; p++ { const iters = 1e3 go func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.8K bytes - Viewed (0) -
src/database/sql/sql.go
// Used to signal the need for new connections // a goroutine running connectionOpener() reads on this chan and // maybeOpenNewConnections sends on the chan (one send per needed connection) // It is closed during db.Close(). The close tells the connectionOpener // goroutine to exit. openerCh chan struct{} closed bool dep map[finalCloser]depSet
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K bytes - Viewed (0) -
src/time/tick_test.go
done := make(chan bool) AfterFunc(60*Second, func() { close(done) }) // Set up a queuing goroutine to ping pong through the scheduler. inQ := make(chan func()) outQ := make(chan func()) defer close(inQ) wg.Add(1) go func() { defer wg.Done() defer close(outQ) var q []func() for { var sendTo chan func() var send func() if len(q) > 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/testdata/issue20789.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 326 bytes - Viewed (0) -
src/internal/trace/testdata/testprog/stacks.go
go func() { // func1 select {} }() go func() { // func2 var c chan int c <- 0 }() go func() { // func3 var c chan int <-c }() done1 := make(chan bool) go func() { // func4 <-done1 }() done2 := make(chan bool) go func() { // func5 done2 <- true }() c1 := make(chan int) c2 := make(chan int) go func() { // func6 select { case <-c1: case <-c2: }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.4K bytes - Viewed (0) -
cmd/kube-apiserver/app/testing/testserver.go
return result, err } s.Authentication.RequestHeader.ClientCAFile = proxyCACertFile // give the kube api server an "identity" it can use to for request header auth // so that aggregated api servers can understand who the calling user is s.Authentication.RequestHeader.AllowedNames = []string{"ash", "misty", "brock"} // create private key
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 17.6K bytes - Viewed (0) -
test/fixedbugs/issue20789.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Make sure this doesn't crash the compiler. // (This test should be part of the internal/syntax // package, but we don't have a general test framework // there yet, so put it here for now. See also #20800.) package e
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 449 bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/typeparams/coretype.go
return U } ch, ok := U.(*types.Chan) if !ok { return nil // no core type as identical < len(terms) and U is not a channel. } // https://go.dev/ref/spec#Core_types // "the type chan E if T contains only bidirectional channels, or the type chan<- E or // <-chan E depending on the direction of the directional channels present."
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 5.3K bytes - Viewed (0)