holoscan::distributed::AppWorkerServer

Beta
View as Markdown
#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

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

NameTypeDescription
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_variableCondition variable for the server thread.
mutex_std::mutexMutex for the server thread.
join_mutex_std::mutexMutex for the join function.
should_stop_boolWhether the server should stop.
app_worker_holoscan::AppWorker *Pointer to the application worker.
driver_client_std::shared_ptr< AppDriverClient >
need_health_check_boolWhether to check the health of the application.
fragment_executors_future_std::shared_future< void >Future for the fragment executors.