- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 3,491 for ctan (0.09 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) -
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) -
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) -
src/runtime/signal_unix.go
// the signal handler is currently set to the Go signal handler or not. // This is uint32 rather than bool so that we can use atomic instructions. var handlingSig [_NSIG]uint32 // channels for synchronizing signal mask updates with the signal mask // thread var ( disableSigChan chan uint32 enableSigChan chan uint32 maskUpdatedChan chan struct{} ) func init() { // _NSIG is the number of signals on this operating system.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 16:04:54 UTC 2024 - 45K bytes - Viewed (0) -
src/net/lookup_test.go
defer cancel() ctxTimeout, cancel := context.WithTimeout(context.Background(), timeout) defer cancel() c := make(chan error, 2*N) for i := 0; i < N; i++ { name := fmt.Sprintf("%d.net-test.golang.org", i) go func() { _, err := DefaultResolver.LookupIPAddr(ctxHalfTimeout, name) c <- err }() go func() { _, err := DefaultResolver.LookupIPAddr(ctxTimeout, name)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 41.4K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/iter-pull.go
for { _, ok := i.next() if !ok { break } } // Try bouncing the pull iterator between two goroutines. var wg sync.WaitGroup var iterChans [2]chan intIter wg.Add(2) iterChans[0] = make(chan intIter) iterChans[1] = make(chan intIter) go func() { defer wg.Done() iter := pullRange(100) iterChans[1] <- iter for i := range iterChans[0] { _, ok := i.next() if !ok {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.4K bytes - Viewed (0)