- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 3,491 for ctan (0.07 sec)
-
src/internal/reflectlite/value.go
//go:noescape func maplen(unsafe.Pointer) int // Len returns v's length. // It panics if v's Kind is not Array, Chan, Map, Slice, or String. func (v Value) Len() int { k := v.kind() switch k { case abi.Array: tt := (*arrayType)(unsafe.Pointer(v.typ())) return int(tt.Len) case abi.Chan: return chanlen(v.pointer()) case abi.Map: return maplen(v.pointer()) case abi.Slice:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 07 17:01:54 UTC 2024 - 13.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
// ResultChan implements Interface func (w emptyWatch) ResultChan() <-chan Event { return chan Event(w) } // FakeWatcher lets you test anything that consumes a watch.Interface; threadsafe. type FakeWatcher struct { result chan Event stopped bool sync.Mutex } func NewFake() *FakeWatcher { return &FakeWatcher{ result: make(chan Event), } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
pilot/pkg/serviceregistry/kube/controller/multicluster.go
m.s.RunComponentAsyncAndWait("auto serviceexport controller", func(_ <-chan struct{}) error { leaderelection. NewLeaderElectionMulticluster(options.SystemNamespace, m.serverID, leaderelection.ServiceExportController, m.revision, !configCluster, client). AddRunFunction(func(leaderStop <-chan struct{}) { serviceExportController := newAutoServiceExportController(autoServiceExportOptions{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
src/reflect/value.go
} haveDefault = true if c.Chan.IsValid() { panic("reflect.Select: default case has Chan value") } if c.Send.IsValid() { panic("reflect.Select: default case has Send value") } case SelectSend: ch := c.Chan if !ch.IsValid() { break } ch.mustBe(Chan) ch.mustBeExported() tt := (*chanType)(unsafe.Pointer(ch.typ()))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 119.9K bytes - Viewed (0) -
src/cmd/gofmt/gofmt.go
prev <-chan *reporterState // 1-buffered } // newSequencer returns a sequencer that allows concurrent tasks up to maxWeight // and writes tasks' output to out and err. func newSequencer(maxWeight int64, out, err io.Writer) *sequencer { sem := semaphore.NewWeighted(maxWeight) prev := make(chan *reporterState, 1) prev <- &reporterState{out: out, err: err}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 19:41:17 UTC 2024 - 15.1K bytes - Viewed (0) -
pilot/pkg/xds/discovery_test.go
c := make(chan struct{}) go func() { wg.Wait() c <- struct{}{} }() select { case <-c: return true case <-time.After(timeout): return false } } func TestSendPushesManyPushes(t *testing.T) { stopCh := make(chan struct{}) defer close(stopCh) semaphore := make(chan struct{}, 2) queue := NewPushQueue() defer queue.ShutDown()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 9.2K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/stress.go
var wg sync.WaitGroup done := make(chan bool) // Create a goroutine blocked before tracing. wg.Add(1) go func() { <-done wg.Done() }() // Create a goroutine blocked in syscall before tracing. rp, wp, err := os.Pipe() if err != nil { log.Fatalf("failed to create pipe: %v", err) } defer func() { rp.Close() wp.Close() }() wg.Add(1) go func() { var tmp [1]byte
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/hooks.go
// this is programmer error, but it can be hard to debug return fmt.Errorf("unable to add %q because it was already registered by: %s", name, postStartHook.originatingStack) } // done is closed when the poststarthook is finished. This is used by the health check to be able to indicate // that the poststarthook is finished done := make(chan struct{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 8K bytes - Viewed (0) -
internal/grid/connection.go
if handler == nil { return nil, ErrUnknownHandler } var requests chan []byte var responses chan Response if handler.InCapacity > 0 { requests = make(chan []byte, handler.InCapacity) } if handler.OutCapacity > 0 { responses = make(chan Response, handler.OutCapacity) } else { responses = make(chan Response, 1) } cl, err := c.newMuxClient(ctx) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
src/internal/abi/type.go
} return 0 } func (t *Type) Common() *Type { return t } type ChanDir int const ( RecvDir ChanDir = 1 << iota // <-chan SendDir // chan<- BothDir = RecvDir | SendDir // chan InvalidDir ChanDir = 0 ) // ChanType represents a channel type type ChanType struct { Type Elem *Type Dir ChanDir }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:09:59 UTC 2024 - 21.8K bytes - Viewed (0)