- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 20 for sendErr (0.19 sec)
-
src/reflect/type.go
type aTextOff = abi.TextOff // ChanDir represents a channel type's direction. type ChanDir int const ( RecvDir ChanDir = 1 << iota // <-chan SendDir // chan<- BothDir = RecvDir | SendDir // chan ) // arrayType represents a fixed array type. type arrayType = abi.ArrayType // chanType represents a channel type. type chanType = abi.ChanType
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 85.5K bytes - Viewed (0) -
internal/grid/connection.go
// Returning error here is too noisy. return nil case c.outQueue <- msg: return nil } } // queueMsg queues a message, with an optional payload. // sender should not reference msg.Payload func (c *Connection) queueMsg(msg message, payload sender) error { // Add baseflags. msg.Flags.Set(c.baseFlags) // This cannot encode subroute. msg.Flags.Clear(FlagSubroute) if payload != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
src/net/http/h2_bundle.go
} // Sender sending more than they'd declared? if st.declBodyBytes != -1 && st.bodyBytes+int64(len(data)) > st.declBodyBytes { if !sc.inflow.take(f.Length) { return sc.countError("data_flow", http2streamError(id, http2ErrCodeFlowControl)) } sc.sendWindowUpdate(nil, int(f.Length)) // conn-level
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
src/crypto/tls/handshake_client.go
if err != nil { return nil, nil, nil, err } } return hello, keyShareKeys, ech, nil } type echContext struct { config *echConfig hpkeContext *hpke.Sender encapsulatedKey []byte innerHello *clientHelloMsg innerTranscript hash.Hash kdfID uint16 aeadID uint16 echRejected bool }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 38.6K bytes - Viewed (0) -
src/text/template/exec.go
} om := fmtsort.Sort(val) for _, m := range om { oneIteration(m.Key, m.Value) } return case reflect.Chan: if val.IsNil() { break } if val.Type().ChanDir() == reflect.SendDir { s.errorf("range over send-only channel %v", val) break } i := 0 for ; ; i++ { elem, ok := val.Recv() if !ok { break } oneIteration(reflect.ValueOf(i), elem) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:22:24 UTC 2024 - 32K bytes - Viewed (0) -
cmd/bucket-handlers.go
writeSuccessResponseXML(w, encodedSuccessResponse) } // ListBucketsHandler - GET Service. // ----------- // This implementation of the GET operation returns a list of all buckets // owned by the authenticated sender of the request. func (api objectAPIHandlers) ListBucketsHandler(w http.ResponseWriter, r *http.Request) { ctx := newContext(r, w, "ListBuckets") defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 61.2K bytes - Viewed (0) -
src/runtime/export_test.go
ch := make(chan int) go func(ch chan int) { ch <- 5 LockOSThread() }(ch) g1 := getg() // Block on a receive. This is likely to get us a thread // switch. If we yield to the sender goroutine, it will // lock the thread, forcing us to resume on a different // thread. <-ch g2 := getg() if g1 != g2 { panic("g1 != g2") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:50:53 UTC 2024 - 46.1K bytes - Viewed (0) -
src/reflect/all_test.go
// check construction and use of type not in binary type T string crt := ChanOf(RecvDir, TypeOf(T(""))) cst := ChanOf(SendDir, TypeOf(T(""))) // check that type already in binary is found type T1 int checkSameType(t, ChanOf(RecvDir, TypeOf(T1(1))), (<-chan T1)(nil)) checkSameType(t, ChanOf(SendDir, TypeOf(T1(1))), (chan<- T1)(nil)) // check String form of ChanDir if crt.ChanDir().String() != "<-chan" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 218.8K bytes - Viewed (0) -
src/database/sql/sql.go
// should probably start a goroutine to read from req. This best // effort select existed before the change to check 'deleted'. // But if we know for sure it wasn't deleted and a sender is // outstanding, we should probably block on req (in a new // goroutine) to get the connection back. select { default: case ret, ok := <-req: if ok && ret.conn != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K bytes - Viewed (0) -
doc/go_spec.html
make(chan int, 100) </pre> <p> The capacity, in number of elements, sets the size of the buffer in the channel. If the capacity is zero or absent, the channel is unbuffered and communication succeeds only when both a sender and receiver are ready. Otherwise, the channel is buffered and communication succeeds without blocking if the buffer is not full (sends) or not empty (receives). A <code>nil</code> channel is never ready for communication.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 21:07:21 UTC 2024 - 281.5K bytes - Viewed (1)