Searched refs:produce_split (Results 1 – 4 of 4) sorted by relevance
40 ProduceSplit(update.produce_split()); in Apply()114 void DispatcherState::ProduceSplit(const ProduceSplitUpdate& produce_split) { in ProduceSplit() argument115 std::shared_ptr<Job> job = jobs_[produce_split.job_id()]; in ProduceSplit()118 DCHECK_EQ(produce_split.repetition(), state.repetition); in ProduceSplit()119 if (produce_split.finished()) { in ProduceSplit()
15 ProduceSplitUpdate produce_split = 8; field
804 ProduceSplitUpdate* produce_split = update.mutable_produce_split(); in RecordSplitProduced() local805 produce_split->set_job_id(job_id); in RecordSplitProduced()806 produce_split->set_repetition(repetition); in RecordSplitProduced()807 produce_split->set_finished(finished); in RecordSplitProduced()
216 void ProduceSplit(const ProduceSplitUpdate& produce_split);