- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for sendErr (0.17 sec)
-
internal/event/targetlist_test.go
package event import ( "context" "crypto/rand" "errors" "reflect" "testing" "time" "github.com/minio/minio/internal/store" ) type ExampleTarget struct { id TargetID sendErr bool closeErr bool } func (target ExampleTarget) ID() TargetID { return target.id } // Save - Sends event directly without persisting. func (target ExampleTarget) Save(eventData Event) error {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Dec 05 10:16:33 UTC 2023 - 6.1K bytes - Viewed (0) -
src/crypto/rand/rand_plan9.go
_, r.seedErr = io.ReadFull(entropy, r.key[:]) }) if r.seedErr != nil { return 0, r.seedErr } r.mu.Lock() blockCipher, err := aes.NewCipher(r.key[:]) if err != nil { r.mu.Unlock() return 0, err } var ( counter uint64 block [aes.BlockSize]byte ) inc := func() { counter++ if counter == 0 { panic("crypto/rand counter wrapped") } byteorder.LePutUint64(block[:], counter) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 18:57:38 UTC 2024 - 1.8K bytes - Viewed (0) -
src/cmd/cgo/internal/testsanitizers/testdata/tsan15.go
go_callback(); return 0; } static void *sendthr(void *arg) { pthread_t th = *(pthread_t*)arg; while (1) { int r = pthread_kill(th, SIGWINCH); if (r < 0) break; } return 0; } static void foo() { pthread_t *th = malloc(sizeof(pthread_t)); pthread_t th2; pthread_create(th, 0, thr, 0); pthread_create(&th2, 0, sendthr, th); pthread_join(*th, 0); } */ import "C"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 06 21:14:49 UTC 2024 - 968 bytes - Viewed (0) -
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/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) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Settings.kt
const val MAX_CONCURRENT_STREAMS = 4 /** HTTP/2: Size in bytes of the largest frame payload the sender will accept. */ const val MAX_FRAME_SIZE = 5 /** HTTP/2: Advisory only. Size in bytes of the largest header list the sender will accept. */ const val MAX_HEADER_LIST_SIZE = 6 /** Window size in bytes. */ const val INITIAL_WINDOW_SIZE = 7
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.8K 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/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)