equal
deleted
inserted
replaced
170 _completed_buffers_tail = cbn; |
170 _completed_buffers_tail = cbn; |
171 } |
171 } |
172 _n_completed_buffers++; |
172 _n_completed_buffers++; |
173 |
173 |
174 if (!_process_completed && |
174 if (!_process_completed && |
175 _n_completed_buffers == _process_completed_threshold) { |
175 _n_completed_buffers >= _process_completed_threshold) { |
176 _process_completed = true; |
176 _process_completed = true; |
177 if (_notify_when_complete) |
177 if (_notify_when_complete) |
178 _cbl_mon->notify_all(); |
178 _cbl_mon->notify_all(); |
179 } |
179 } |
180 debug_only(assert_completed_buffer_list_len_correct_locked()); |
180 debug_only(assert_completed_buffer_list_len_correct_locked()); |