Home
last modified time | relevance | path

Searched refs:stop_requested (Results 1 – 16 of 16) sorted by relevance

/openbmc/sdbusplus/src/async/
H A Dcontext.cpp102 while (!ctx.final_stop.stop_requested()) in loop()
165 if (stop_requested()) in spawn_complete()
176 if (stop_requested()) in check_stop_requested()
206 return !final_stop.stop_requested(); in caller_run()
308 ctx.final_stop.stop_requested(); in wait_once()
320 if (!ctx.final_stop.stop_requested() && ctx.pending) in wait_once()
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/
H A Dstop_token.hpp102 static constexpr auto stop_requested() noexcept -> bool in stop_requested() function
130 auto stop_requested() const noexcept -> bool in stop_requested() function in stdexec::inplace_stop_source
185 [[nodiscard]] auto stop_requested() const noexcept -> bool in stop_requested() function in stdexec::inplace_stop_token
187 return __source_ != nullptr && __source_->stop_requested(); in stop_requested()
H A Dtask.hpp146 [[nodiscard]] auto stop_requested() const noexcept -> bool in stop_requested() function in exec::__task::__default_task_context_impl
148 return __stop_token_.stop_requested(); in stop_requested()
508 __coro_.promise().stop_requested() ? 0 : 1; in await_suspend()
511 if (__coro_.promise().stop_requested()) in await_suspend()
H A Dsequence_senders.hpp127 if (__token.stop_requested()) in set_stopped()
525 if (!token.stop_requested()) in __set_value_unless_stopped()
H A Dasync_scope.hpp387 else if (get_stop_token(get_env(__rcvr_)).stop_requested()) in __complete_()
/openbmc/sdbusplus/include/sdbusplus/async/
H A Dcontext.hpp89 bool stop_requested() noexcept in stop_requested() function in sdbusplus::async::context
91 return initial_stop.stop_requested(); in stop_requested()
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/
H A D__shared.hpp322 else if (__stop_source_.stop_requested()) in __try_start()
350 else if (__stok.stop_requested()) in __try_add_waiter()
527 if (!__stok.stop_requested())
H A D__stop_token.hpp39 { __token.stop_requested() } noexcept -> __boolean_testable_;
H A D__run_loop.hpp76 .stop_requested()) in __execute_impl()
H A D__when_all.hpp343 if (__state.__stop_source_.stop_requested())
/openbmc/phosphor-health-monitor/
H A Dhealth_monitor.cpp42 while (!ctx.stop_requested()) in run()
/openbmc/linux/drivers/staging/media/atomisp/pci/runtime/pipeline/interface/
H A Dia_css_pipeline.h46 bool stop_requested; member
/openbmc/linux/drivers/staging/media/atomisp/pci/
H A Dia_css_pipe.h115 bool stop_requested; member
H A Dsh_css.c3914 if (pipe && pipe->stop_requested) { in ia_css_pipe_dequeue_buffer()
3928 pipe->stop_requested = false; in ia_css_pipe_dequeue_buffer()
4272 pipe->stop_requested = false; in sh_css_pipe_start()
4297 stream->pipes[i]->stop_requested = false; in sh_css_pipe_start()
4301 stream->pipes[i]->stop_requested = false; in sh_css_pipe_start()
4305 stream->pipes[i]->stop_requested = false; in sh_css_pipe_start()
4309 stream->pipes[i]->stop_requested = false; in sh_css_pipe_start()
/openbmc/linux/drivers/staging/media/atomisp/pci/runtime/pipeline/src/
H A Dpipeline.c210 pipeline->stop_requested = true; in ia_css_pipeline_request_stop()
677 pipeline->stop_requested = false; in pipeline_init_defaults()
/openbmc/pldm/requester/
H A Dhandler.hpp505 if (stopToken.stop_requested()) in tag_invoke()