Searched refs:jobs_ (Results 1 – 5 of 5) sorted by relevance
110 if (!jobs_.empty() && *cmdhash == jobs_.back().hash && in Parse()111 *t_start == jobs_.back().start_ms && *t_end == jobs_.back().end_ms) { in Parse()112 jobs_.back().names.append(" "); in Parse()113 jobs_.back().names.append(name); in Parse()117 jobs_.emplace_back(cur_build_id_, *t_start, *t_end, *cmdhash, name); in Parse()126 std::sort(jobs_.begin(), jobs_.end(), in NotifyEndOfFile()153 for (const auto& job : jobs_) { in NotifyEndOfFile()
75 std::vector<Job> jobs_; variable
81 jobs_.SetBuffer(buf_span); in ProcessingTask()84 bool ShouldRun() override { return jobs_.EntryCount() > 0; } in ShouldRun()90 size_t entry_count = jobs_.EntryCount(); in Run()93 jobs_.PeekFront(job_bytes.bytes, &bytes_read); in Run()94 jobs_.PopFront(); in Run()119 pw::ring_buffer::PrefixedEntryRingBuffer jobs_{false}; member in __anonecbbd0010111::ProcessingTask138 jobs_.PushBack(job.bytes); in AddJobInternal()
104 DCHECK(!jobs_.contains(job_id)); in CreateJob()105 jobs_[job_id] = job; in CreateJob()115 std::shared_ptr<Job> job = jobs_[produce_split.job_id()]; in ProduceSplit()132 job = jobs_[acquire_job_client.job_id()]; in AcquireJobClient()155 auto& job = jobs_[create_pending_task.job_id()]; in CreatePendingTask()190 auto& job = jobs_[create_task.job_id()]; in CreateTask()213 jobs_[task->job->job_id]->finished = all_finished; in FinishTask()263 jobs.reserve(jobs_.size()); in ListJobs()264 for (const auto& it : jobs_) { in ListJobs()272 auto it = jobs_.find(id); in JobFromId()[all …]
236 absl::flat_hash_map<int64, std::shared_ptr<Job>> jobs_; variable