- Sort Score
- Result 10 results
- Languages All
Results 31 - 37 of 37 for donechan (0.12 sec)
-
internal/http/listener.go
func (listener *httpListener) start() { // Closure to send acceptResult to acceptCh. // It returns true if the result is sent else false if returns when doneCh is closed. send := func(result acceptResult) bool { select { case listener.acceptCh <- result: // Successfully written to acceptCh return true case <-listener.ctx.Done(): return false } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 5.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go
type signalInterceptingTestStep struct { doneCh chan struct{} } func (ts signalInterceptingTestStep) done() <-chan struct{} { return ts.doneCh } func (ts signalInterceptingTestStep) execute(fn func()) { defer close(ts.doneCh) fn() } func newSignalInterceptingTestStep() *signalInterceptingTestStep { return &signalInterceptingTestStep{ doneCh: make(chan struct{}), } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 38.3K bytes - Viewed (0) -
src/crypto/tls/handshake_server_test.go
cmd.Stderr = &output if err := cmd.Start(); err != nil { return nil, nil, err } connChan := make(chan any, 1) go func() { tcpConn, err := l.Accept() if err != nil { connChan <- err return } connChan <- tcpConn }() var tcpConn net.Conn select { case connOrError := <-connChan: if err, ok := connOrError.(error); ok { return nil, nil, err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 64.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cached_token_authenticator.go
doneAuthenticating(true) return record } // Record cache miss doneBlocking := stats.blocking(ctx) defer doneBlocking() defer doneAuthenticating(false) c := a.group.DoChan(key, func() (val interface{}, _ error) { // always use one place to read and write the output of AuthenticateToken record := &cacheRecord{} doneFetching := stats.fetching(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 9.8K bytes - Viewed (0) -
src/net/lookup.go
lookupGroupCtx, lookupGroupCancel := context.WithCancel(withUnexpiredValuesPreserved(ctx)) lookupKey := network + "\000" + host dnsWaitGroup.Add(1) ch := r.getLookupGroup().DoChan(lookupKey, func() (any, error) { return testHookLookupIP(lookupGroupCtx, resolverFunc, network, host) }) dnsWaitGroupDone := func(ch <-chan singleflight.Result, cancelFn context.CancelFunc) { <-ch
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 28.6K bytes - Viewed (0) -
src/net/http/transport_test.go
// Start 3 outstanding requests and wait for the server to get them. // Their responses will hang until we write to resch, though. donech := make(chan bool) doReq := func() { defer func() { select { case <-stop: return case donech <- t.Failed(): } }() resp, err := c.Get(ts.URL) if err != nil { t.Error(err) return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
okhttp/src/test/resources/okhttp3/internal/publicsuffix/public_suffix_list.dat
nsw.edu.au nt.edu.au qld.edu.au sa.edu.au tas.edu.au vic.edu.au wa.edu.au // act.gov.au Bug 984824 - Removed at request of Greg Tankard // nsw.gov.au Bug 547985 - Removed at request of <Shae.Donelan@services.nsw.gov.au> // nt.gov.au Bug 940478 - Removed at request of Greg Connors <******@****.***> qld.gov.au sa.gov.au tas.gov.au vic.gov.au wa.gov.au // 4LDs
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 240.3K bytes - Viewed (1)