| 922 | SC::Result SC::AsyncEventLoop::runNoWait() { return internal.runStep(*this, Internal::SyncMode::NoWait); } |
| 923 | |
| 924 | SC::Result SC::AsyncEventLoop::run() |
| 925 | { |
| 926 | while (internal.getTotalNumberOfActiveHandle() != 0 or not internal.submissions.isEmpty() or |
| 927 | internal.numberOfManualCompletions != 0 or internal.hasPendingKernelCancellations or |
| 928 | not internal.cancellations.isEmpty()) |
| 929 | { |
| 930 | SC_TRY(runOnce()); |
| 931 | if (internal.interrupted) |
| 932 | { |
| 933 | internal.interrupted = false; |
| 934 | break; |
| 935 | } |
| 936 | }; |
| 937 | // We may still have pending cancellation callbacks |
| 938 | internal.executeCancellationCallbacks(*this); |
| 939 | return SC::Result(true); |
| 940 | } |
| 941 | |
| 942 | SC::Result SC::AsyncEventLoop::submitRequests(AsyncKernelEvents& kernelEvents) |
| 943 | { |
no test coverage detected