holoscan::distributed::AppWorkerServer | Holoscan SDK Documentation

#include <holoscan/distributed/server.hpp>

Constructors

AppWorkerServer

holoscan::distributed::AppWorkerServer::AppWorkerServer(holoscan::distributed::AppWorkerServer::AppWorkerServer(
    holoscan::AppWorker *app_worker,
    bool need_health_check = false
)

Destructor

~AppWorkerServer

virtual holoscan::distributed::AppWorkerServer::~AppWorkerServer()virtual holoscan::distributed::AppWorkerServer::~AppWorkerServer()

Methods

start

void holoscan::distributed::AppWorkerServer::start()

stop

void holoscan::distributed::AppWorkerServer::stop()

wait

void holoscan::distributed::AppWorkerServer::wait()

notify

void holoscan::distributed::AppWorkerServer::notify()

connect_to_driver

bool holoscan::distributed::AppWorkerServer::connect_to_driver(
    int32_t max_connection_retry_count = kDefaultMaxConnectionRetryCount,
    int32_t connection_retry_interval_ms = kDefaultConnectionRetryIntervalMs
)

fragment_executors_future

Overload 1

Overload 2

std::shared_future<void> & holoscan::distributed::AppWorkerServer::fragment_executors_future()

notify_worker_execution_finished

void holoscan::distributed::AppWorkerServer::notify_worker_execution_finished(
    holoscan::AppWorkerTerminationCode code
)

app_driver_client

std::shared_ptr<distributed::AppDriverClient> holoscan::distributed::AppWorkerServer::app_driver_client() const

run

void holoscan::distributed::AppWorkerServer::run()

The thread function for the server thread.

Member variables

Name	Type	Description
`server_`	`std::unique_ptr< grpc::Server >`	Pointer to the gRPC server.
`server_thread_`	`std::unique_ptr< std::thread >`	Pointer to the server thread.
`cv_`	`std::condition_variable`	Condition variable for the server thread.
`mutex_`	`std::mutex`	Mutex for the server thread.
`join_mutex_`	`std::mutex`	Mutex for the join function.
`should_stop_`	`bool`	Whether the server should stop.
`app_worker_`	`holoscan::AppWorker *`	Pointer to the application worker.
`driver_client_`	`std::shared_ptr< AppDriverClient >`
`need_health_check_`	`bool`	Whether to check the health of the application.
`fragment_executors_future_`	`std::shared_future< void >`	Future for the fragment executors.