- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 752 for batches (0.29 sec)
-
src/internal/trace/batchcursor.go
lastTs Time idx int // next index into []batch dataOff int // next index into batch.data ev baseEvent // last read event } func (b *batchCursor) nextEvent(batches []batch, freq frequency) (ok bool, err error) { // Batches should generally always have at least one event, // but let's be defensive about that and accept empty batches. for b.idx < len(batches) && len(batches[b.idx].data) == b.dataOff { b.idx++
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 4.1K bytes - Viewed (0) -
src/internal/trace/reader.go
r.cpuSamples = r.gen.cpuSamples // Reset frontier. for m, batches := range r.gen.batches { bc := &batchCursor{m: m} ok, err := bc.nextEvent(batches, r.gen.freq) if err != nil { return Event{}, err } if !ok { // Turns out there aren't actually any events in these batches. continue } r.frontier = heapInsert(r.frontier, bc) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 6.7K bytes - Viewed (0) -
src/internal/trace/internal/testgen/go122/trace.go
trace *Trace gen uint64 batches []*Batch strings map[string]uint64 stacks map[stack]uint64 // Options applied when Trace.Generate is called. ignoreStringBatchSizeLimit bool ignoreStackBatchSizeLimit bool } // Batch starts a new event batch in the trace data. // // This is convenience function for generating correct batches. func (g *Generation) Batch(thread trace.ThreadID, time Time) *Batch {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 9.7K bytes - Viewed (0) -
src/internal/trace/generation.go
}, batches: make(map[ThreadID][]batch), } // Process the spilled batch. if spill != nil { g.gen = spill.gen if err := processBatch(g, *spill.batch); err != nil { return nil, nil, err } spill = nil } // Read batches one at a time until we either hit EOF or // the next generation. var spillErr error for { b, gen, err := readBatch(r) if err == io.EOF { break }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 22:14:45 UTC 2024 - 12.1K bytes - Viewed (0) -
pkg/kubelet/cm/dra/manager.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:29 UTC 2024 - 19.4K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/conflicts/FailOnVersionConflictGraphVisitor.java
import org.gradle.api.internal.artifacts.ivyservice.resolveengine.graph.DependencyGraphVisitor; import java.util.LinkedHashSet; import java.util.Set; /** * A visitor which batches up all conflicts and reports them all at once at the end of * the resolution. */ public class FailOnVersionConflictGraphVisitor implements DependencyGraphVisitor {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 11:33:46 UTC 2024 - 2.9K bytes - Viewed (0) -
src/internal/trace/internal/oldtrace/parser.go
p.batchOffsets[raw.batchPid] = append(p.batchOffsets[raw.batchPid], bo) curP = raw.batchPid } batches := p.batchOffsets[curP] if len(batches) == 0 { return fmt.Errorf("read event %d with current P of %d, but P has no batches yet", raw.typ, curP) } batches[len(batches)-1].numEvents++ if raw.typ == EvCPUSample { e := Event{Type: raw.typ} argOffset := 1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:15:28 UTC 2024 - 46.8K bytes - Viewed (0) -
src/runtime/tracestring.go
// traceStringTable is map of string -> unique ID that also manages // writing strings out into the trace. type traceStringTable struct { // lock protects buf. lock mutex buf *traceBuf // string batches to write out to the trace. // tab is a mapping of string -> unique ID. tab traceMap } // put adds a string to the table, emits it, and returns a unique ID for it.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 2.4K bytes - Viewed (0) -
src/runtime/traceexp.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package runtime // traceExpWriter is a wrapper around trace writer that produces traceEvExperimentalBatch // batches. This means that the data written to the writer need not conform to the standard // trace format. type traceExpWriter struct { traceWriter exp traceExperiment }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 2.4K bytes - Viewed (0) -
pilot/pkg/xds/discovery_test.go
expect(0, 0) }, }, { name: "Should send full updates in batches", test: func(updateCh chan *model.PushRequest, expect func(partial, full int32)) { updateCh <- &model.PushRequest{Full: true} updateCh <- &model.PushRequest{Full: true} expect(0, 1) }, }, { name: "Should send full updates in batches, partial updates immediately",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 9.2K bytes - Viewed (0)