| 2365 | } |
| 2366 | |
| 2367 | void TmpFileBufferPool::RemoveWriteRanges(RequestContext* io_ctx) { |
| 2368 | DCHECK(io_ctx != nullptr); |
| 2369 | vector<TmpFileMgr::WriteDoneCallback> write_callbacks; |
| 2370 | { |
| 2371 | unique_lock<mutex> lock(lock_); |
| 2372 | RemoveWriteRangesInternal(io_ctx, &write_callbacks); |
| 2373 | } |
| 2374 | for (const TmpFileMgr::WriteDoneCallback& write_callback : write_callbacks) { |
| 2375 | write_callback(TMP_FILE_BUFFER_POOL_CONTEXT_CANCELLED); |
| 2376 | } |
| 2377 | } |
| 2378 | |
| 2379 | void TmpFileBufferPool::EnqueueTmpFilesPool(shared_ptr<TmpFile>& tmp_file, bool front) { |
| 2380 | DCHECK(tmp_file != nullptr); |