- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 165 for ssender (0.28 sec)
-
src/cmd/compile/internal/syntax/testdata/map2.go
func (m *Map[K, V]) InOrder() *Iterator[K, V] { sender, receiver := chans_Ranger[keyValue[K, V]]() var f func(*node[K, V]) bool f = func(n *node[K, V]) bool { if n == nil { return true } // Stop sending values if sender.Send returns false, // meaning that nothing is listening at the receiver end. return f(n.left) && sender.Send(keyValue[K, V]{n.key, n.val}) && f(n.right) } go func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 01 12:49:49 UTC 2023 - 3.4K 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/race/testdata/chan_test.go
_ = data[i] } } // Test that sender synchronizes with receiver even if the sender was blocked. func TestNoRaceBlockedSendSync(t *testing.T) { c := make(chan *int, 1) c <- nil go func() { i := 42 c <- &i }() // Give the sender time to actually block. // This sleep is completely optional: race report must not be printed // regardless of whether the sender actually blocks or not.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 18 19:55:29 UTC 2023 - 11K bytes - Viewed (0) -
src/net/http/internal/chunked.go
if cr.err != nil { return } cr.n, cr.err = parseHexUint(line) if cr.err != nil { return } // A sender who sends one byte per chunk will send 5 bytes of overhead // for every byte of data. ("1\r\nX\r\n" to send "X".) // We want to allow this, since streaming a byte at a time can be legitimate. // // A sender can use chunk extensions to add arbitrary amounts of additional
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 7.8K bytes - Viewed (0) -
src/runtime/chan.go
} return true, false } // The channel has been closed, but the channel's buffer have data. } else { // Just found waiting sender with not closed. if sg := c.sendq.dequeue(); sg != nil { // Found a waiting sender. If buffer is size 0, receive value // directly from sender. Otherwise, receive from head of queue // and add sender's value to the tail of the queue (both map to
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0) -
cmd/admin-handlers-idp-ldap.go
} // Check if we are creating svc account for request sender. isSvcAccForRequestor := false if targetUser == requestorUser || targetUser == requestorParentUser { isSvcAccForRequestor = true } var ( targetGroups []string err error ) // If we are creating svc account for request sender, ensure that targetUser // is a real user (i.e. not derived credentials).
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 03 19:58:48 UTC 2024 - 14.1K bytes - Viewed (0) -
src/net/smtp/smtp_test.go
250-mx.google.com at your service 250 FEATURE ` var helloServer = []string{ "", "502 Not implemented\n", "250 User is valid\n", "235 Accepted\n", "250 Sender ok\n", "", "250 Reset ok\n", "221 Goodbye\n", "250 Sender ok\n", "250 ok\n", } var baseHelloClient = `EHLO customhost HELO customhost ` var helloClient = []string{ "", "STARTTLS\n",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 28.5K bytes - Viewed (0) -
.github/workflows/trusted-partners.yml
permissions: # Needed to attach tags into the PR issues: write contents: write pull-requests: write if: | github.event.pull_request.draft == false && github.event.sender.type == 'User' steps: - name: Checkout repo uses: actions/checkout@755da8c3cf115ac066823e79a1e1788f8940201b # v3.2.0 - name: Trusted-Partners-PR
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Sep 12 14:49:29 UTC 2023 - 2.4K bytes - Viewed (0) -
src/runtime/chan_test.go
// The way we try to induce this failure is to set up two // goroutines: a sender and a receiver that communicate across // a channel. We try to set up a situation where the sender // grows its stack temporarily then *fully* blocks on a channel // often. Meanwhile a GC is triggered so that we try to get a // mark worker to shrink the sender's stack and race with the // sender parking. // // Unfortunately the race window here is so small that we
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 31 20:47:35 UTC 2023 - 23.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/classpath/CallInterceptingMetaClass.java
} @Override public Object getProperty(Class sender, Object object, String name, boolean useSuper, boolean fromInsideClass) { if (useSuper || fromInsideClass) { return adaptee.getProperty(sender, object, name, useSuper, fromInsideClass); } else { return invokeIntercepted(object, GET_PROPERTY, name, NO_ARG, () -> adaptee.getProperty(sender, object, name, false, false)); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 13:46:35 UTC 2024 - 21.8K bytes - Viewed (0)