| 308 | void FinishReading() { read_thread_.join(); } |
| 309 | |
| 310 | void TearDown() override { |
| 311 | ASSERT_OK(self_pipe_->Shutdown()); |
| 312 | if (read_thread_.joinable()) { |
| 313 | read_thread_.join(); |
| 314 | } |
| 315 | instance_ = nullptr; |
| 316 | } |
| 317 | |
| 318 | Status ReadStatus() { |
| 319 | std::lock_guard<std::mutex> lock(mutex_); |