- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for Rd (0.08 sec)
-
cmd/storage-datatypes_gen_test.go
} en.Flush() } func BenchmarkDecodeBaseOptions(b *testing.B) { v := BaseOptions{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len())) rd := msgp.NewEndlessReader(buf.Bytes(), b) dc := msgp.NewReader(rd) b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { err := v.DecodeMsg(dc) if err != nil { b.Fatal(err) } } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 62.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/tensorflow/python/py_function_lib.py
# by their evaluated values. ds = repr_ds_map[signature_def_key] repr_ds_map[signature_def_key] = rd.replace_tensors_by_numpy_ndarrays( ds, sess ) def _create_sample_validator( expected_input_keys: Collection[str], ) -> Callable[[rd.RepresentativeSample], rd.RepresentativeSample]: """Creates a validator function for a representative sample. Args:
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 31 05:32:11 UTC 2024 - 27.4K bytes - Viewed (0) -
src/runtime/netpoll.go
} pd.publishInfo() combo := pd.rd > 0 && pd.rd == pd.wd rtf := netpollReadDeadline if combo { rtf = netpollDeadline } if !pd.rrun { if pd.rd > 0 { // Copy current seq into the timer arg. // Timer func will check the seq against current descriptor seq, // if they differ the descriptor was reused or timers were reset. pd.rt.modify(pd.rd, 0, rtf, pd.makeArg(), pd.rseq) pd.rrun = true }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 20.7K bytes - Viewed (0) -
src/internal/trace/resources.go
func MakeResourceID[T interface{ GoID | ProcID | ThreadID }](id T) ResourceID { var rd ResourceID var a any = id switch a.(type) { case GoID: rd.Kind = ResourceGoroutine case ProcID: rd.Kind = ResourceProc case ThreadID: rd.Kind = ResourceThread } rd.id = int64(id) return rd } // Goroutine obtains a GoID from the resource ID. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 8K bytes - Viewed (0) -
src/os/os_windows_test.go
} func (rd *reparseData) addSubstituteNameNoNUL(name string) { rd.substituteName.offset, rd.substituteName.length = rd.addStringNoNUL(name) } func (rd *reparseData) addPrintNameNoNUL(name string) { rd.printName.offset, rd.printName.length = rd.addStringNoNUL(name) } // pathBuffeLen returns length of rd pathBuf in bytes. func (rd *reparseData) pathBuffeLen() uint16 { return uint16(len(rd.pathBuf)) * 2 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 41.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
// catch-all flow schema. panic(fmt.Sprintf("no fallback catch-all flow schema found for request %#+v and user %#+v", rd.RequestInfo, rd.User)) } selectedFlowSchema = catchAllFlowSchema klog.Warningf("no match found for request %#+v and user %#+v; selecting catchAll=%s as fallback flow schema", rd.RequestInfo, rd.User, fcfmt.Fmt(selectedFlowSchema)) } plName := selectedFlowSchema.Spec.PriorityLevelConfiguration.Name
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/conversion.go
} rd.Headers.Request = h case k8s.HTTPRouteFilterResponseHeaderModifier: h := createHeadersFilter(filter.ResponseHeaderModifier) if h == nil { continue } if rd.Headers == nil { rd.Headers = &istio.Headers{} } rd.Headers.Response = h default: return nil, nil, &ConfigError{Reason: InvalidFilter, Message: fmt.Sprintf("unsupported filter type %q", filter.Type)} }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 84.7K bytes - Viewed (0) -
src/cmd/internal/obj/loong64/asm.go
v = int32(p.To.Target().Pc-p.Pc) >> 2 } as, rd, rj, width := p.As, p.Reg, p.From.Reg, 16 switch as { case ABGTZ, ABLEZ: rd, rj = rj, rd case ABFPT, ABFPF: width = 21 // FCC0 is the implicit source operand, now that we // don't register-allocate from the FCC bank. rd = REG_FCC0 case ABEQ, ABNE: if rd == 0 || rd == REGZERO || rj == REGZERO {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 02:04:54 UTC 2024 - 61.8K bytes - Viewed (0) -
cmd/server-main.go
} } func mergeServerCtxtFromConfigFile(configFile string, ctxt *serverCtxt) error { rd, err := xioutil.ReadFile(configFile) if err != nil { return err } cfReader := bytes.NewReader(rd) cv := config.ServerConfigVersion{} if err = yaml.Unmarshal(rd, &cv); err != nil { return err } switch cv.Version { case "v1", "v2": default:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 15:12:57 UTC 2024 - 34.5K bytes - Viewed (0) -
cmd/batch-handlers.go
} if err := gopts.SetMatchETag(srcObjInfo.ETag); err != nil { return err } rd, objInfo, _, err := core.GetObject(ctx, srcBucket, srcObject, gopts) if err != nil { return ErrorRespToObjectError(err, srcBucket, srcObject, srcObjInfo.VersionID) } defer rd.Close() hr, err := hash.NewReader(ctx, rd, objInfo.Size, "", "", objInfo.Size) if err != nil { return err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 56K bytes - Viewed (0)