| 898 | } |
| 899 | |
| 900 | Status Sorter::Run::AddIntermediateBatch( |
| 901 | RowBatch* batch, int start_index, int* num_processed) { |
| 902 | DCHECK(!initial_run_); |
| 903 | bool allocation_failed = false; |
| 904 | if (has_var_len_slots_) { |
| 905 | return AddBatchInternal<true, false>( |
| 906 | batch, start_index, num_processed, &allocation_failed); |
| 907 | } else { |
| 908 | return AddBatchInternal<false, false>( |
| 909 | batch, start_index, num_processed, &allocation_failed); |
| 910 | } |
| 911 | } |
| 912 | |
| 913 | void Sorter::Run::CleanupRuns(deque<Sorter::Run*>* runs) { |
| 914 | for (Run* run : *runs) { |
no outgoing calls
no test coverage detected