- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 100 for Rd (0.02 sec)
-
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) -
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) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/util/NumberUtil.java
private static final List<String> UNITS = unmodifiableList(asList(" B", " KiB", " MiB", " GiB", " TiB", " PiB", " EiB")); private static final List<String> ORDINAL_SUFFIXES = unmodifiableList(asList("th", "st", "nd", "rd", "th", "th", "th", "th", "th", "th")); /** * Percentage (0-...) of given input. * * @param fraction the fraction of total, must be >= 0. if 0, the result will be 100.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 3.3K 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) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/borrowing_test.go
startWG.Add(clientsPerFlow[0] + clientsPerFlow[1]) // Launch 20 client threads for each flow for flow := 0; flow < 2; flow++ { username := usernames[flow] flowUser := testUser{name: username} rd := RequestDigest{ RequestInfo: reqInfo, User: flowUser, } concIntegrator := fq.NewNamedIntegrator(clk, username) concIntegrators[flow] = concIntegrator exec := func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 9K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/cover/profile.go
func ParseProfilesFromReader(rd io.Reader) ([]*Profile, error) { // First line is "mode: foo", where foo is "set", "count", or "atomic". // Rest of file is in the format // encoding/base64/base64.go:34.44,37.40 3 1 // where the fields are: name.go:line.column,line.column numberOfStatements count files := make(map[string]*Profile) s := bufio.NewScanner(rd) mode := "" for s.Scan() { line := s.Text()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 11 17:02:03 UTC 2021 - 7.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) -
src/crypto/sha512/sha512_test.go
"",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 03 21:17:08 UTC 2023 - 105.6K bytes - Viewed (0)