holoscan::distributed::AppDriverServer | Holoscan SDK Documentation

#include <holoscan/distributed/server.hpp>

Constructors

AppDriverServer

holoscan::distributed::AppDriverServer::AppDriverServer(
    holoscan::AppDriver *app_driver,
    bool need_driver = true,
    bool need_health_check = false
)

Destructor

~AppDriverServer

virtual holoscan::distributed::AppDriverServer::~AppDriverServer()

Methods

start

void holoscan::distributed::AppDriverServer::start()

stop

void holoscan::distributed::AppDriverServer::stop()

wait

void holoscan::distributed::AppDriverServer::wait()

notify

void holoscan::distributed::AppDriverServer::notify()

connect_to_worker

std::unique_ptr<AppWorkerClient> & holoscan::distributed::AppDriverServer::connect_to_worker(
    const std::string &worker_address
)

close_worker_connection

bool holoscan::distributed::AppDriverServer::close_worker_connection(
    const std::string &worker_address
)

get_worker_addresses

std::vector<std::string> holoscan::distributed::AppDriverServer::get_worker_addresses() const

num_worker_connections

std::size_t holoscan::distributed::AppDriverServer::num_worker_connections() const

run

void holoscan::distributed::AppDriverServer::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_driver_`	`holoscan::AppDriver *`	Pointer to the application driver.
`need_driver_`	`bool`	Whether to run the application in driver mode.
`need_health_check_`	`bool`	Whether to check the health of the application.
`worker_clients_`	`std::unordered_map< std::string, std::unique_ptr< AppWorkerClient > >`	Map of worker addresses to worker clients.