| 954 | } |
| 955 | |
| 956 | bool Reactor::DrainTaskQueue(boost::intrusive::list<ReactorTask>* tasks) { // NOLINT(*) |
| 957 | std::lock_guard<LockType> l(lock_); |
| 958 | if (closing_) { |
| 959 | return false; |
| 960 | } |
| 961 | tasks->swap(pending_tasks_); |
| 962 | return true; |
| 963 | } |
| 964 | |
| 965 | } // namespace rpc |
| 966 | } // namespace kudu |