- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for wr (0.02 sec)
-
pkg/xds/server.go
var previousResources []string var alwaysRespond bool w.UpdateWatchedResource(request.TypeUrl, func(wr *WatchedResource) *WatchedResource { previousResources = wr.ResourceNames wr.NonceAcked = request.ResponseNonce wr.ResourceNames = request.ResourceNames alwaysRespond = wr.AlwaysRespond wr.AlwaysRespond = false return wr }) // Envoy can send two DiscoveryRequests with same version and nonce.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
con.proxy.UpdateWatchedResource(request.TypeUrl, func(wr *model.WatchedResource) *model.WatchedResource { previousResources = wr.ResourceNames currentResources, _ = deltaWatchedResources(previousResources, request) wr.NonceAcked = request.ResponseNonce wr.ResourceNames = currentResources alwaysRespond = wr.AlwaysRespond wr.AlwaysRespond = false return wr })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
cmd/metacache-walk.go
func (p *xlStorageDiskIDCheck) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) (err error) { if err := p.checkID(opts.DiskID); err != nil { return err } ctx, done, err := p.TrackDiskHealth(ctx, storageMetricWalkDir, opts.Bucket, opts.BaseDir) if err != nil { return err } defer done(0, &err) return p.storage.WalkDir(ctx, opts, wr) } // WalkDir will traverse a directory and return all entries found.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 05:17:37 UTC 2024 - 12.4K bytes - Viewed (0) -
src/cmd/internal/goobj/objfile.go
} func (n *RefName) Write(w *Writer) { w.Bytes(n[:]) } type Writer struct { wr *bio.Writer stringMap map[string]uint32 off uint32 // running offset b [8]byte // scratch space for writing bytes } func NewWriter(wr *bio.Writer) *Writer { return &Writer{wr: wr, stringMap: make(map[string]uint32)} } func (w *Writer) AddString(s string) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 23.8K bytes - Viewed (0) -
pilot/pkg/xds/bench_test.go
for svc := 0; svc < tt.services; svc++ { watchedResources = append(watchedResources, fmt.Sprintf("outbound|80||foo-%d.com", svc)) } wr := &model.WatchedResource{ResourceNames: watchedResources} c, _, _ = s.Discovery.Generators[v3.EndpointType].Generate(proxy, wr, &model.PushRequest{Full: true, Push: s.PushContext()}) } logDebug(b, c) }) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 22 18:13:40 UTC 2024 - 19.7K bytes - Viewed (0) -
src/text/template/exec.go
func (t *Template) Execute(wr io.Writer, data any) error { return t.execute(wr, data) } func (t *Template) execute(wr io.Writer, data any) (err error) { defer errRecover(&err) value, ok := data.(reflect.Value) if !ok { value = reflect.ValueOf(data) } state := &state{ tmpl: t, wr: wr, vars: []variable{{"$", value}}, }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:22:24 UTC 2024 - 32K bytes - Viewed (0) -
src/html/template/template.go
// writing the output to wr. // If an error occurs executing the template or writing its output, // execution stops, but partial results may already have been written to // the output writer. // A template may be executed safely in parallel, although if parallel // executions share a Writer the output may be interleaved. func (t *Template) Execute(wr io.Writer, data any) error { if err := t.escape(); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 21:00:46 UTC 2024 - 17K bytes - Viewed (0) -
src/net/http/response_test.go
buf.WriteString("Transfer-Encoding: chunked\r\n") } else { buf.WriteString("Content-Length: 1000000\r\n") } var wr io.Writer = &buf if test.chunked { wr = internal.NewChunkedWriter(wr) } if test.compressed { buf.WriteString("Content-Encoding: gzip\r\n") wr = gzip.NewWriter(wr) } buf.WriteString("\r\n") chunk := bytes.Repeat([]byte{'x'}, 1000) for i := 0; i < 1000; i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 08 19:01:29 UTC 2024 - 23.6K bytes - Viewed (0) -
pilot/pkg/model/context.go
node.RLock() defer node.RUnlock() wr := node.WatchedResources[typeURL] if wr != nil { return wr.NonceSent } return "" } func (node *Proxy) NonceAcked(typeURL string) string { node.RLock() defer node.RUnlock() wr := node.WatchedResources[typeURL] if wr != nil { return wr.NonceAcked } return "" }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (0) -
src/vendor/golang.org/x/net/nettest/conntest.go
t.Errorf("unexpected c1.Close error: %v", err) } }() go func() { wr := new(bytes.Buffer) if err := chunkedCopy(wr, c2); err != nil { t.Errorf("unexpected c2.Read error: %v", err) } if err := c2.Close(); err != nil { t.Errorf("unexpected c2.Close error: %v", err) } dataCh <- wr.Bytes() }() if got := <-dataCh; !bytes.Equal(got, want) { t.Error("transmitted data differs")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 12.2K bytes - Viewed (0)