- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 90 for sendErr (0.16 sec)
-
src/time/sleep_test.go
// Start two goroutines ping-ponging on a channel send. // At any given time, at least one of these goroutines is runnable: // if the channel buffer is full, the receiver is runnable, // and if it is not full, the sender is runnable. // // In addition, the AfterFunc callback should become runnable after // the indicated delay. // // Even if GOMAXPROCS=1, we expect the runtime to eventually schedule
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 22 16:33:57 UTC 2024 - 22.5K bytes - Viewed (0) -
tensorflow/compiler/jit/mark_for_compilation_pass_test.cc
Scope root = Scope::NewRootScope().ExitOnError(); Output recv_a = ops::_Recv(root.WithOpName("recv_a"), DT_BOOL, "tensor_a", "sender", 0, "receiver"); Output recv_b = ops::_Recv(root.WithOpName("recv_b"), DT_BOOL, "tensor_b", "sender", 0, "receiver"); Output const_a = ops::Const(root.WithOpName("const_a"), 42); ops::ControlTrigger ctrl_trigger_a(root.WithOpName("ctrl_trigger_a"));
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 14 10:11:10 UTC 2024 - 79.6K bytes - Viewed (0) -
src/net/http/fs.go
if !isZeroTime(modtime) { w.Header().Set("Last-Modified", modtime.UTC().Format(TimeFormat)) } } func writeNotModified(w ResponseWriter) { // RFC 7232 section 4.1: // a sender SHOULD NOT generate representation metadata other than the // above listed fields unless said metadata exists for the purpose of // guiding cache updates (e.g., Last-Modified might be useful if the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 09 17:06:47 UTC 2024 - 31.1K 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) -
pilot/pkg/networking/core/listener.go
httpOpts := &httpListenerOpts{ // Set 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. This helps to retain the timeout headers // such as "x-envoy-upstream-rq-timeout-ms" set by the calling application.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 55.1K 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)