- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 39 for Rd (0.04 sec)
-
cmd/batch-job-common-types_gen_test.go
} en.Flush() } func BenchmarkDecodeBatchJobKV(b *testing.B) { v := BatchJobKV{} 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: Sat Dec 02 10:51:33 UTC 2023 - 11.3K bytes - Viewed (0) -
cmd/batch-rotate_gen_test.go
} func BenchmarkDecodeBatchJobKeyRotateEncryption(b *testing.B) { v := BatchJobKeyRotateEncryption{} 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: Tue Aug 29 18:27:23 UTC 2023 - 11.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/controller_test.go
} func (cts *ctlrTestState) addHeldRequest(plName string, rd RequestDigest, finishCh chan struct{}) { cts.lock.Lock() defer cts.lock.Unlock() hrs := cts.heldRequestsMap[plName] hrs = append(hrs, heldRequest{rd, finishCh}) cts.heldRequestsMap[plName] = hrs if testDebugLogs { cts.t.Logf("Holding %#+v for %s, count:=%d", rd, plName, len(hrs)) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 18.4K bytes - Viewed (0) -
src/bufio/bufio.go
// size, it returns the underlying [Reader]. func NewReaderSize(rd io.Reader, size int) *Reader { // Is it already a Reader? b, ok := rd.(*Reader) if ok && len(b.buf) >= size { return b } r := new(Reader) r.reset(make([]byte, max(size, minReadBufferSize)), rd) return r } // NewReader returns a new [Reader] whose buffer has the default size. func NewReader(rd io.Reader) *Reader { return NewReaderSize(rd, defaultBufSize)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 12 14:39:08 UTC 2023 - 21.8K bytes - Viewed (0) -
pkg/log/config_test.go
defer ticker.Stop() var rd []os.DirEntry for { select { case <-ticker.C: rd, err := os.ReadDir(dir) if err != nil { t.Fatalf("Unable to read dir: %v", err) } if len(rd) == o.RotationMaxBackups+1 { // perfect, we're done return } case <-time.After(5 * time.Second): for _, f := range rd { t.Log(f.Name()) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 26 20:38:10 UTC 2024 - 10.9K 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) -
src/io/io_test.go
} func BenchmarkCopyNSmall(b *testing.B) { bs := bytes.Repeat([]byte{0}, 512+1) rd := bytes.NewReader(bs) buf := new(Buffer) b.ResetTimer() for i := 0; i < b.N; i++ { CopyN(buf, rd, 512) rd.Reset(bs) } } func BenchmarkCopyNLarge(b *testing.B) { bs := bytes.Repeat([]byte{0}, (32*1024)+1) rd := bytes.NewReader(bs) buf := new(Buffer) b.ResetTimer() for i := 0; i < b.N; i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 09 22:04:41 UTC 2023 - 18.9K 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) -
src/syscall/syscall_linux_test.go
// This will return when the write side is closed. n, err := syscall.Read(int(rd.Fd()), data) if !(n == 0 && err == nil) { t.Errorf("expected read to return 0, got %d, %s", n, err) } // Clean up rd and also ensure rd stays reachable so // it doesn't get closed by GC. rd.Close() wg.Done() }() <-ready // Loop here to give the goroutine more time to block in read.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 23K bytes - Viewed (0)