- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 6,107 for ctan (0.06 sec)
-
src/net/http/transport_internal_test.go
func TestTransportPersistConnReadLoopEOF(t *testing.T) { ln := newLocalListener(t) defer ln.Close() connc := make(chan net.Conn, 1) go func() { defer close(connc) c, err := ln.Accept() if err != nil { t.Error(err) return } connc <- c }() tr := new(Transport) req, _ := NewRequest("GET", "http://"+ln.Addr().String(), nil) req = req.WithT(t)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 15:57:17 UTC 2024 - 6.2K bytes - Viewed (0) -
pilot/pkg/controllers/untaint/nodeuntainter_test.go
istiolog.Configure(opts) for _, scope := range istiolog.Scopes() { scope.SetOutputLevel(istiolog.DebugLevel) } } func newNodeUntainterTestServer(t *testing.T) *nodeTainterTestServer { stop := make(chan struct{}) t.Cleanup(func() { close(stop) }) client := kubelib.NewFakeClient() nodeUntainter := NewNodeUntainter(stop, client, systemNS, systemNS) go nodeUntainter.Run(stop) client.RunAndWait(stop)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 00:50:31 UTC 2024 - 6.1K bytes - Viewed (0) -
src/runtime/race/testdata/time_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 08 22:34:15 UTC 2024 - 1.3K bytes - Viewed (0) -
src/internal/types/testdata/fixedbugs/issue66878.go
// Copyright 2024 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 p func _[T bool](ch chan T) { var _, _ T = <-ch } // offending code snippets from issue func _[T ~bool](ch <-chan T) { var x, ok T = <-ch println(x, ok) } func _[T ~bool](m map[int]T) { var x, ok T = m[0] println(x, ok)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 17:42:47 UTC 2024 - 399 bytes - Viewed (0) -
src/go/types/builtins.go
if !check.hasCallOrRecv { mode = constant_ if t.len >= 0 { val = constant.MakeInt64(t.len) } else { val = constant.MakeUnknown() } } case *Slice, *Chan: mode = value case *Map: if id == _Len { mode = value } case *Interface: if !isTypeParam(x.typ) { break } if t.typeSet().underIs(func(t Type) bool {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 27.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/initializer/initializer.go
authorizer authorizer.Authorizer featureGates featuregate.FeatureGate stopCh <-chan struct{} restMapper meta.RESTMapper } // New creates an instance of admission plugins initializer. // This constructor is public with a long param list so that callers immediately know that new information can be expected // during compilation when they update a level. func New( extClientset kubernetes.Interface,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 3K bytes - Viewed (0) -
pkg/xds/server.go
stop chan struct{} // reqChan is used to receive discovery requests for this connection. reqChan chan *discovery.DiscoveryRequest // errorChan is used to process error during discovery request processing. errorChan chan error } func NewConnection(peerAddr string, stream DiscoveryStream) Connection { return Connection{ pushChannel: make(chan any), initialized: make(chan struct{}),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
internal/grid/muxserver.go
// Data inbound to the handler var handlerIn chan []byte if inboundCap > 0 { m.inbound = make(chan []byte, inboundCap) handlerIn = make(chan []byte, 1) go func(inbound chan []byte) { wg.Wait() defer xioutil.SafeClose(handlerIn) m.handleInbound(c, inbound, handlerIn) }(m.inbound) } // Fill outbound block. // Each token represents a message that can be sent to the client without blocking.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
type ElasticsearchTarget struct { initOnce once.Init id event.TargetID args ElasticsearchArgs client esClient store store.Store[event.Event] loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns target ID. func (target *ElasticsearchTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15K bytes - Viewed (0) -
cmd/erasure-server-pool.go
} }(resultIndex, erObj) } } updateCloser := make(chan chan struct{}) go func() { updateTicker := time.NewTicker(30 * time.Second) defer updateTicker.Stop() var lastUpdate time.Time // We need to merge since we will get the same buckets from each pool. // Therefore to get the exact bucket sizes we must merge before we can convert. var allMerged dataUsageCache update := func() {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 82.5K bytes - Viewed (0)