Searched refs:bytes_processed (Results 1 – 9 of 9) sorted by relevance
527 size_t bytes_processed = 0; in GeneratePackets() local528 while (bytes_processed < payload_size_) { in GeneratePackets()529 size_t rem_bytes = payload_size_ - bytes_processed; in GeneratePackets()531 (bytes_processed ? PayloadDescriptorLengthMinusSsData(hdr_) in GeneratePackets()541 QueuePacket(bytes_processed, packet_bytes, bytes_processed == 0, in GeneratePackets()543 bytes_processed += packet_bytes; in GeneratePackets()545 assert(bytes_processed == payload_size_); in GeneratePackets()
82 var bytes_processed = 0; variable88 bytes_processed += frame.length - start;
83 size_t* bytes_processed) { in IOOperation() argument113 *bytes_processed = processed; in IOOperation()
67 size_t* bytes_processed);
63 def Progress(self, bytes_processed): argument65 self._bytes_processed_since_callback += bytes_processed
119 ThreadStats() : bytes_processed(0), items_processed(0) {} in ThreadStats()120 int64_t bytes_processed; member608 total->bytes_processed += st.bytes_processed(); in RunInThread()688 if (total.bytes_processed > 0 && seconds > 0.0) { in RunBenchmark()689 bytes_per_second = (total.bytes_processed / seconds); in RunBenchmark()
849 intptr_t bytes_processed = 0; in ProcessMarkingDeque() local853 while (!marking_deque->IsEmpty() && bytes_processed < bytes_to_process) { in ProcessMarkingDeque()864 bytes_processed += size - unscanned_bytes_of_large_object_; in ProcessMarkingDeque()866 return bytes_processed; in ProcessMarkingDeque()1158 intptr_t bytes_processed = 0; in Step() local1191 bytes_processed = ProcessMarkingDeque(bytes_to_process); in Step()1217 heap_->tracer()->AddIncrementalMarkingStep(duration, bytes_processed); in Step()1219 return bytes_processed; in Step()
285 size_t bytes_processed() const {
2755 intptr_t bytes_processed = 0; in TEST() local2757 bytes_processed = in TEST()2762 } while (bytes_processed); in TEST()