| 2210 | } |
| 2211 | |
| 2212 | void TmpFileBufferPool::ShutDown() { |
| 2213 | { |
| 2214 | unique_lock<mutex> l(lock_); |
| 2215 | shut_down_ = true; |
| 2216 | } |
| 2217 | // Wake up the waiting thread. |
| 2218 | work_available_.NotifyAll(); |
| 2219 | } |
| 2220 | |
| 2221 | void TmpFileBufferPool::TmpFileSpaceReserveThreadLoop() { |
| 2222 | while (true) { |