- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 383 for batches (0.17 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) -
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/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) -
subprojects/core/src/main/java/org/gradle/internal/buildtree/IntermediateBuildActionRunner.java
import org.gradle.internal.operations.RunnableBuildOperation; import java.util.ArrayList; import java.util.Collection; import java.util.List; import java.util.function.Supplier; /** * Executor for batches of intermediate build actions that can be initiated * from the top-level build action or from model builders. * <p> * All actions are always executed, and <b>may run in {@link #isParallel() parallel}</b>.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 08 07:46:55 UTC 2024 - 4.7K bytes - Viewed (0) -
platforms/core-runtime/daemon-services/src/test/groovy/org/gradle/internal/daemon/clientinput/StdInStreamTest.groovy
thread.block() stream.received(bytes) } then: 1 * dispatch.onOutput({ it instanceof ReadStdInEvent }) >> { instant.requested } } def "can read multiple batches of input from client"() { def dispatch = Mock(OutputEventListener) def stream = new StdInStream(dispatch) def text1 = "some text" def bytes1 = text1.bytes def text2 = "more"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 5.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/tests/reconfig_batch_op.mlir
// RUN: tf-tfrt-opt -split-input-file -tfrt-reconfig-batch-op="tfrt-min-num-batch-threads=2 tfrt-min-max-enqueued-batches=3" %s | FileCheck %s --dump-input=always // ----- // The num_batch_threads is lowered bound to 2 from the original attribute of 1 // CHECK-LABEL: func private @batched_function func.func private @batched_function(%arg0: tensor<1x3xf32>) -> tensor<1x3xf32> { %2 = "tf.Identity"(%arg0) : (tensor<1x3xf32>) -> tensor<1x3xf32>
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 31 17:38:34 UTC 2024 - 5.2K bytes - Viewed (0)