- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 370 for batches (0.62 sec)
-
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) -
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/internal/trace/oldtrace.go
// usage, and minimal GC pressure. It allocates events in batches so that even // though we have to load the entire trace into memory, the conversion process // shouldn't result in a doubling of memory usage, even if all converted events // are kept alive, as we free batches once we're done with them. // // The conversion process is lossless. package trace import ( "errors"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 17.2K bytes - Viewed (0) -
src/internal/trace/event.go
// a placeholder for a differently encoded event that's actually present in the experimental data. type ExperimentalData struct { // Batches contain the actual experimental data, along with metadata about each batch. Batches []ExperimentalBatch } // ExperimentalBatch represents a packet of unparsed data along with metadata about that packet. type ExperimentalBatch struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 12:39:00 UTC 2024 - 28.9K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
// // It groups the calls into batches, starting with a group of initialBatchSize. // Within each batch, it may call the function multiple times concurrently. // // If a whole batch succeeds, the next batch may get exponentially larger. // If there are any failures in a batch, all remaining batches are skipped // after waiting for the current batch to complete. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
/** True if either side has cleanly shut down this stream. We shall send no more bytes. */ var finished: Boolean = false, ) : Sink { /** * Buffer of outgoing data. This batches writes of small writes into this sink as larges frames * written to the outgoing connection. Batching saves the (small) framing overhead. */ private val sendBuffer = Buffer()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
src/runtime/mfinal.go
// after an object is no longer referenced, the runtime is allowed to perform // a space-saving optimization that batches objects together in a single // allocation slot. The finalizer for an unreferenced object in such an // allocation may never run if it always exists in the same batch as a // referenced object. Typically, this batching only happens for tiny // (on the order of 16 bytes or less) and pointer-free objects. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 01:56:56 UTC 2024 - 19K bytes - Viewed (0) -
src/runtime/mgcsweep.go
// single span is in general a very fast operation, taking as little as 30 ns // on modern hardware. (See #54767.) // // As a result, bgsweep sweeps in batches, and only calls into the scheduler // at the end of every batch. Furthermore, it only yields its time if there // isn't spare idle time available on other cores. If there's available idle
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:52:18 UTC 2024 - 32.9K bytes - Viewed (0) -
cmd/encryption-v1.go
if len(SSES3SinglePartObjects) == 0 { for i := range batch { size, err := batch[i].GetActualSize() if err != nil { return err } batch[i].Size = size if _, ok := crypto.IsEncrypted(batch[i].UserDefined); ok { ETag, err := etag.Parse(batch[i].ETag) if err != nil { return err } batch[i].ETag = ETag.Format().String() } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 37.1K bytes - Viewed (0)