- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for sendErr (0.15 sec)
-
cmd/erasure-server-pool.go
vcfg, _ := globalBucketVersioningSys.Get(bucket) go func() { defer cancelCause(nil) defer xioutil.SafeClose(results) sentErr := false sendErr := func(err error) { if !sentErr { select { case results <- itemOrErr[ObjectInfo]{Err: err}: sentErr = true case <-parentCtx.Done(): } } } send := func(oi ObjectInfo) bool { select {
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/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/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) -
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) -
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) -
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) -
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) -
src/internal/abi/type.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:09:59 UTC 2024 - 21.8K bytes - Viewed (0)