| 840 | } |
| 841 | |
| 842 | Status Reactor::RunOnReactorThread(std::function<Status()> f) { |
| 843 | RunFunctionTask task(std::move(f)); |
| 844 | ScheduleReactorTask(&task); |
| 845 | return task.Wait(); |
| 846 | } |
| 847 | |
| 848 | Status Reactor::DumpConnections(const DumpConnectionsRequestPB& req, |
| 849 | DumpConnectionsResponsePB* resp) { |