- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 99 for rR (0.04 sec)
-
src/encoding/json/decode.go
r++ w++ case 't': b[w] = '\t' r++ w++ case 'u': r-- rr := getu4(s[r:]) if rr < 0 { return } r += 6 if utf16.IsSurrogate(rr) { rr1 := getu4(s[r:]) if dec := utf16.DecodeRune(rr, rr1); dec != unicode.ReplacementChar { // A valid pair; consume. r += 6 w += utf8.EncodeRune(b[w:], dec)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 00:18:55 UTC 2024 - 35.3K bytes - Viewed (0) -
cmd/erasure-decode.go
if canDecode { break } if readerIndex == len(p.readers) { break } if !readTrigger { continue } wg.Add(1) go func(i int) { defer wg.Done() rr := p.readers[i] if rr == nil { // Since reader is nil, trigger another read. readTriggerCh <- true return } bufIdx := p.readerToBuf[i] if p.buf[bufIdx] == nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 21 14:36:21 UTC 2024 - 9.4K bytes - Viewed (0) -
pkg/dns/client/dns_test.go
Registry: "External", }, }, }) } // reflect.DeepEqual doesn't seem to work well for dns.RR // as the Rdlength field is not updated in the a(), or aaaa() calls. // so zero them out before doing reflect.Deepequal func equalsDNSrecords(got []dns.RR, want []dns.RR) bool { for i := range got { got[i].Header().Rdlength = 0 } return reflect.DeepEqual(got, want)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 16:17:34 UTC 2024 - 20.4K bytes - Viewed (0) -
src/cmd/link/internal/arm/asm.go
ldr.Errorf(s, "missing section for %s", ldr.SymName(rs)) } rr.Xsym = rs rr.Type = r.Type() rr.Size = r.Siz() return rr, true } return rr, false } func addpltreloc(ldr *loader.Loader, plt *loader.SymbolBuilder, got *loader.SymbolBuilder, s loader.Sym, typ objabi.RelocType) { r, _ := plt.AddRel(typ) r.SetSym(got.Sym()) r.SetOff(int32(plt.Size())) r.SetSiz(4)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Aug 23 05:58:20 UTC 2023 - 22.9K bytes - Viewed (0) -
src/expvar/expvar_test.go
m2 := NewMap("map2") for i := 0; i < 9; i++ { m2.Add(strconv.Itoa(i), int64(i)) } rr := httptest.NewRecorder() rr.Body = new(bytes.Buffer) expvarHandler(rr, nil) want := `{ "map1": {"a": 1, "z": 2}, "map2": {"0": 0, "1": 1, "2": 2, "3": 3, "4": 4, "5": 5, "6": 6, "7": 7, "8": 8} } ` if got := rr.Body.String(); got != want { t.Errorf("HTTP handler wrote:\n%s\nWant:\n%s", got, want) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 04 14:46:19 UTC 2024 - 13.4K bytes - Viewed (0) -
src/fmt/scan.go
// io.Reader inside r. func (r *readRune) ReadRune() (rr rune, size int, err error) { if r.peekRune >= 0 { rr = r.peekRune r.peekRune = ^r.peekRune size = utf8.RuneLen(rr) return } r.buf[0], err = r.readByte() if err != nil { return } if r.buf[0] < utf8.RuneSelf { // fast check for common ASCII case rr = rune(r.buf[0]) size = 1 // Known to be 1.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:56:20 UTC 2024 - 31.9K bytes - Viewed (0) -
tests/integration/security/util/cert/cert.go
}, Check: check.NoError(), }) if result.Responses.Len() != 1 { t.Fatalf("dump cert failed, no responses") } var certs []string for _, rr := range result.Responses[0].Body() { var s string if err := json.Unmarshal([]byte(rr), &s); err != nil { t.Fatalf("failed to unmarshal: %v", err) } certs = append(certs, s) } return certs }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 15 16:44:37 UTC 2023 - 6.2K bytes - Viewed (0) -
pkg/test/framework/components/echo/check/checkers.go
// Gather the networks that were reached. networkHits := make(map[string]int) for _, rr := range result.Responses { c := allClusters.GetByName(rr.Cluster) if c != nil { networkHits[c.NetworkName()]++ } } // Verify that all expected networks were reached. for network := range expectedByNetwork {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 03 16:19:07 UTC 2023 - 17.5K bytes - Viewed (0) -
test/escape5.go
r, s = leaktoret22(q, p) return r, s } func leaktoret22f(p, q *int) (r, s *int) { // ERROR "leaking param: p to result s" "leaking param: q to result r" rr, ss := leaktoret22(q, p) return rr, ss } var gp *int func leaktosink(p *int) *int { // ERROR "leaking param: p" gp = p return p } func f1() { var x int p := noleak(&x) _ = p } func f2() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 18:50:24 UTC 2023 - 5.3K bytes - Viewed (0) -
pkg/proxy/ipvs/README.md
Prot LocalAddress:Port Scheduler Flags -> RemoteAddress:Port Forward Weight ActiveConn InActConn TCP 10.0.0.1:443 rr persistent 10800 -> 192.168.0.1:6443 Masq 1 1 0 TCP 10.0.0.10:53 rr -> 172.17.0.2:53 Masq 1 0 0 UDP 10.0.0.10:53 rr -> 172.17.0.2:53 Masq 1 0 0 ``` ### Why kube-proxy can't start IPVS mode
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 02:32:29 UTC 2021 - 18.8K bytes - Viewed (0)