| 232 | } |
| 233 | |
| 234 | port::Status HostExecutor::WaitForEvent(Stream *stream, Event *event) { |
| 235 | std::shared_ptr<absl::Notification> notification = |
| 236 | AsHostEvent(event)->notification(); |
| 237 | AsHostStream(stream)->EnqueueTask( |
| 238 | [notification]() { notification->WaitForNotification(); }); |
| 239 | return port::Status::OK(); |
| 240 | } |
| 241 | |
| 242 | Event::Status HostExecutor::PollForEventStatus(Event *event) { |
| 243 | absl::Notification ¬ification = *AsHostEvent(event)->notification(); |
nothing calls this directly
no test coverage detected