Searched refs:flush_callback (Results 1 – 7 of 7) sorted by relevance
326 void TaskTracker::FlushAsyncForTesting(OnceClosure flush_callback) { in FlushAsyncForTesting() argument327 DCHECK(flush_callback); in FlushAsyncForTesting()332 flush_callback_for_testing_ = std::move(flush_callback); in FlushAsyncForTesting()827 OnceClosure flush_callback; in CallFlushCallbackForTesting() local830 flush_callback = std::move(flush_callback_for_testing_); in CallFlushCallbackForTesting()832 if (flush_callback) in CallFlushCallbackForTesting()833 std::move(flush_callback).Run(); in CallFlushCallbackForTesting()
247 void TaskSchedulerImpl::FlushAsyncForTesting(OnceClosure flush_callback) { in FlushAsyncForTesting() argument248 task_tracker_->FlushAsyncForTesting(std::move(flush_callback)); in FlushAsyncForTesting()
88 void FlushAsyncForTesting(OnceClosure flush_callback) override;
165 virtual void FlushAsyncForTesting(OnceClosure flush_callback) = 0;
127 void FlushAsyncForTesting(OnceClosure flush_callback);
594 std::function<void()> flush_callback; in BindToProducerEndpoint() local618 flush_callback = TakePendingFlushCallbacksLocked(); in BindToProducerEndpoint()627 FlushPendingCommitDataRequests(flush_callback); in BindToProducerEndpoint()694 std::function<void()> flush_callback; in BindStartupTargetBufferImpl() local720 flush_callback = TakePendingFlushCallbacksLocked(); in BindStartupTargetBufferImpl()736 FlushPendingCommitDataRequests(flush_callback); in BindStartupTargetBufferImpl()
392 auto flush_callback = [weak_this, flush_request_id, ds_id] { in Flush() local396 it->second->Flush(flush_request_id, flush_callback); in Flush()