- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for sendZero (0.27 sec)
-
src/encoding/gob/encgen.go
slice, ok := v.Interface().([]%[1]s) if !ok { // It is kind %[1]s but not type %[1]s. TODO: We can handle this unsafely. return false } for _, x := range slice { if x != %[3]s || state.sendZero { %[4]s } } return true }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 22 16:39:09 UTC 2024 - 3.8K bytes - Viewed (0) -
src/crypto/internal/hpke/hpke.go
if err != nil { return nil, nil, err } return encapsulatedKey, &Sender{ kem: kem, aead: aead, sharedSecret: sharedSecret, suiteID: suiteID, key: key, baseNonce: baseNonce, exporterSecret: exporterSecret, }, nil } func (s *Sender) nextNonce() []byte { nonce := s.seqNum.bytes()[16-s.aead.NonceSize():]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:33:33 UTC 2024 - 7K bytes - Viewed (0) -
src/runtime/sigqueue.go
for i := uint32(0); i < _NSIG; i++ { if sig.recv[i/32]&(1<<(i&31)) != 0 { sig.recv[i/32] &^= 1 << (i & 31) return i } } // Wait for updates to be available from signal sender. Receive: for { switch sig.state.Load() { default: throw("signal_recv: inconsistent state") case sigIdle: if sig.state.CompareAndSwap(sigIdle, sigReceiving) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 7.6K bytes - Viewed (0) -
pilot/pkg/features/xds.go
).Get() // UseRemoteAddress sets useRemoteAddress to true for sidecar outbound listeners so that it picks up the localhost // address of the sender, which is an internal address, so that trusted headers are not sanitized. UseRemoteAddress = env.Register( "PILOT_SIDECAR_USE_REMOTE_ADDRESS", false,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 24 06:18:36 UTC 2024 - 3.4K bytes - Viewed (0) -
src/net/http/main_test.go
"created by net/http/httptest.(*Server).Start": "an httptest.Server", "timeoutHandler": "a TimeoutHandler", "net.(*netFD).connect(": "a timing out dial", ").noteClientGone(": "a closenotifier sender", } var stacks string for i := 0; i < 2500; i++ { bad = "" stacks = strings.Join(interestingGoroutines(), "\n\n") for substr, what := range badSubstring { if strings.Contains(stacks, substr) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 03 22:49:46 UTC 2024 - 4.9K bytes - Viewed (0) -
internal/grid/muxserver.go
go func() { wg.Wait() defer xioutil.SafeClose(send) err := m.handleRequests(ctx, msg, send, handler, handlerIn) if err != nil { handlerErr.Store(err) } }() // Response sender goroutine... go func(outBlock <-chan struct{}) { wg.Wait() defer m.parent.deleteMux(true, m.ID) m.sendResponses(ctx, send, c, &handlerErr, outBlock) }(m.outBlock) // Remote aliveness check if needed.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0)