ui::network::B Class Reference

Public Member Functions
	B (BowmanThread &, zmq::context_t &)
void	run ()

Private Member Functions
void	update_hal_settings ()
void	update_hal_settings (string const &client_id)

Private Attributes
BowmanThread &	bowman_thread
zmq::socket_t	bus
zmq::socket_t	hal
std::vector< zmq_pollitem_t >	poll_items
std::chrono::milliseconds const	timeout {2500}
std::chrono::milliseconds const	ping_interval {500}
std::chrono::steady_clock::time_point	last_ping_time
HAL_Settings	hal_settings
std::map< string, std::chrono::steady_clock::time_point >	clients

Detailed Description

actual implementation of BowmanThread::run Think of this as not of data type but as way to implement single, a few-pages long function

Constructor & Destructor Documentation

B()

B::B	(	BowmanThread &	_bowman_thread,
		zmq::context_t &	context
	)

References hal.

Member Function Documentation

run()

void B::run

(

)

References ui::network::as_hexadecimal(), execute::command, utility::io::oc::cout, utility::CSI_bgBlue(), utility::CSI_bgGreen(), utility::CSI_bgRed(), utility::CSI_Black(), utility::CSI_Reset(), kmeans_adaptive_kernel_density_bb_dependent_rotlib::m, and pyrosetta.utility.array::message.

update_hal_settings() [1/2]

void B::update_hal_settings ( )

private

update_hal_settings() [2/2]

void B::update_hal_settings ( string const &  client_id )

private

Member Data Documentation

bowman_thread

BowmanThread& ui::network::B::bowman_thread

private

bus

zmq::socket_t ui::network::B::bus

private

clients

std::map<string, std::chrono::steady_clock::time_point> ui::network::B::clients

private

Referenced by pyrosetta.distributed.cluster.utilities.SchedulerManager::_setup_clients_dict(), pyrosetta.tests.distributed.cluster.test_smoke.TestBase::tearDownClass(), pyrosetta.tests.distributed.cluster.test_smoke.GeneratorTest::test_generate_multi_user_clients(), pyrosetta.tests.distributed.cluster.test_smoke.GeneratorTest::test_generate_partition_clients(), pyrosetta.tests.distributed.cluster.test_smoke.RuntimeTest::test_timing_multi_instance(), and pyrosetta.tests.distributed.cluster.test_smoke.RuntimeTest::test_timing_single_instance().

hal

zmq::socket_t ui::network::B::hal

private

Referenced by B().

hal_settings

HAL_Settings ui::network::B::hal_settings

private

last_ping_time

std::chrono::steady_clock::time_point ui::network::B::last_ping_time

private

ping_interval

std::chrono::milliseconds const ui::network::B::ping_interval {500}

private

poll_items

std::vector<zmq_pollitem_t> ui::network::B::poll_items

private

timeout

std::chrono::milliseconds const ui::network::B::timeout {2500}

private

Referenced by pyrosetta.distributed.cluster.core.PyRosettaCluster::_run(), and pyrosetta.distributed.cluster.logging_listeners.SocketListener::serve_until_stopped().

---

The documentation for this class was generated from the following file:

• src/ui/network/bowman_thread.cpp