mirror of
https://github.com/latentPrion/libspinscale.git
synced 2026-08-12 15:42:10 +00:00
latentprionandCursor
15ebf375ef
Move ProbeComponentThreadHarness into spinscale_probe_support (sscl::probe) so tools can link it without gtest; keep a sscl::tests compatibility shim. Co-authored-by: Cursor <cursoragent@cursor.com>
72 lines
2.0 KiB
C++
72 lines
2.0 KiB
C++
#ifndef SPINSCALE_PROBE_COMPONENT_THREAD_H
|
|
#define SPINSCALE_PROBE_COMPONENT_THREAD_H
|
|
|
|
#include <chrono>
|
|
#include <exception>
|
|
#include <functional>
|
|
#include <future>
|
|
#include <memory>
|
|
#include <stdexcept>
|
|
#include <string>
|
|
|
|
#include <spinscale/componentThread.h>
|
|
#include <spinscale/co/invokers.h>
|
|
#include <spinscale/co/nonViralTaskNursery.h>
|
|
|
|
namespace sscl::probe {
|
|
|
|
constexpr std::chrono::milliseconds defaultProbeTaskTimeout{10000};
|
|
|
|
void runNonViralNurseryOnComponentThread(
|
|
const std::shared_ptr<sscl::ComponentThread>& componentThread,
|
|
std::function<sscl::co::NonViralNonPostingInvoker(
|
|
sscl::co::NonViralTaskNursery::Slot::Lease&)> invokerFactory,
|
|
std::chrono::milliseconds timeout = defaultProbeTaskTimeout);
|
|
|
|
/** Sync driver: run work on a temporary puppeteer ComponentThread.
|
|
*
|
|
* Shared by lcameraDev probe tools and HIL/unit tests. Not tied to gtest.
|
|
*/
|
|
class ProbeComponentThreadHarness
|
|
{
|
|
public:
|
|
explicit ProbeComponentThreadHarness(
|
|
const char *threadName = "spinscale-probe");
|
|
~ProbeComponentThreadHarness();
|
|
|
|
ProbeComponentThreadHarness(const ProbeComponentThreadHarness &) = delete;
|
|
ProbeComponentThreadHarness &operator=(
|
|
const ProbeComponentThreadHarness &) = delete;
|
|
|
|
std::shared_ptr<sscl::ComponentThread> componentThread() const;
|
|
|
|
void runSync(
|
|
const std::function<void(
|
|
const std::shared_ptr<sscl::ComponentThread>&)>& work);
|
|
|
|
template <typename InvokerFactory>
|
|
void runNonViralNurseryTask(
|
|
InvokerFactory &&invokerFactory,
|
|
std::chrono::milliseconds timeout = defaultProbeTaskTimeout)
|
|
{
|
|
runSync(
|
|
[this, &invokerFactory, timeout](
|
|
const std::shared_ptr<sscl::ComponentThread>& componentThread)
|
|
{
|
|
sscl::probe::runNonViralNurseryOnComponentThread(
|
|
componentThread,
|
|
std::forward<InvokerFactory>(invokerFactory),
|
|
timeout);
|
|
});
|
|
}
|
|
|
|
private:
|
|
std::string threadName;
|
|
std::shared_ptr<sscl::pptr::PuppeteerComponent> dummyComponent;
|
|
std::shared_ptr<sscl::ComponentThread> lastComponentThread;
|
|
};
|
|
|
|
} // namespace sscl::probe
|
|
|
|
#endif // SPINSCALE_PROBE_COMPONENT_THREAD_H
|