Goby3  3.1.4
2024.02.22
goby::zeromq Namespace Reference

Namespaces

 groups
 
 protobuf
 

Classes

class  InterProcessPortalImplementation
 
class  InterProcessPortalMainThread
 
class  InterProcessPortalReadThread
 
class  LiaisonCommsThread
 
class  LiaisonContainer
 
class  LiaisonContainerWithComms
 
class  Manager
 
class  Router
 

Typedefs

template<class Config >
using MultiThreadApplication = goby::middleware::MultiThreadApplication< Config, InterProcessPortal >
 
template<class Config >
using SingleThreadApplication = goby::middleware::SingleThreadApplication< Config, InterProcessPortal >
 
template<typename InnerTransporter = middleware::NullTransporter>
using InterModulePortal = InterProcessPortalImplementation< InnerTransporter, middleware::InterModulePortalBase >
 
using zmq_recv_flags_type = int
 
using zmq_send_flags_type = int
 
template<typename InnerTransporter = middleware::NullTransporter>
using InterProcessPortal = InterProcessPortalImplementation< InnerTransporter, middleware::InterProcessPortalBase >
 

Enumerations

enum  IdentifierWildcard { IdentifierWildcard::NO_WILDCARDS, IdentifierWildcard::THREAD_WILDCARD, IdentifierWildcard::PROCESS_THREAD_WILDCARD }
 

Functions

const Wt::WColor goby_blue (28, 159, 203)
 
const Wt::WColor goby_orange (227, 96, 52)
 
std::string liaison_internal_publish_socket_name ()
 
std::string liaison_internal_subscribe_socket_name ()
 
void setup_socket (zmq::socket_t &socket, const protobuf::Socket &cfg)
 
std::string identifier_part_to_string (int i)
 
std::string identifier_part_to_string (std::thread::id i)
 
template<typename Key >
const std::string & id_component (const Key &k, std::unordered_map< Key, std::string > &map)
 Given key, find the string in the map, or create it (to_string) and store it, and return the string. More...
 
std::string make_identifier (const std::string &type_name, int scheme, const std::string &group, IdentifierWildcard wildcard, const std::string &process, std::unordered_map< int, std::string > *schemes_buffer=nullptr, std::unordered_map< std::thread::id, std::string > *threads_buffer=nullptr)
 

Typedef Documentation

◆ InterModulePortal

template<typename InnerTransporter = middleware::NullTransporter>
using goby::zeromq::InterModulePortal = typedef InterProcessPortalImplementation<InnerTransporter, middleware::InterModulePortalBase>

Definition at line 37 of file intermodule.h.

◆ InterProcessPortal

template<typename InnerTransporter = middleware::NullTransporter>
using goby::zeromq::InterProcessPortal = typedef InterProcessPortalImplementation<InnerTransporter, middleware::InterProcessPortalBase>

Definition at line 827 of file interprocess.h.

◆ MultiThreadApplication

Definition at line 36 of file multi_thread.h.

◆ SingleThreadApplication

Definition at line 37 of file single_thread.h.

◆ zmq_recv_flags_type

Definition at line 161 of file interprocess.h.

◆ zmq_send_flags_type

Definition at line 162 of file interprocess.h.

Enumeration Type Documentation

◆ IdentifierWildcard

Enumerator
NO_WILDCARDS 
THREAD_WILDCARD 
PROCESS_THREAD_WILDCARD 

Definition at line 94 of file interprocess.h.

Function Documentation

◆ goby_blue()

const Wt::WColor goby::zeromq::goby_blue ( 28  ,
159  ,
203   
)

◆ goby_orange()

const Wt::WColor goby::zeromq::goby_orange ( 227  ,
96  ,
52   
)

◆ id_component()

template<typename Key >
const std::string& goby::zeromq::id_component ( const Key &  k,
std::unordered_map< Key, std::string > &  map 
)

Given key, find the string in the map, or create it (to_string) and store it, and return the string.

Definition at line 113 of file interprocess.h.

◆ identifier_part_to_string() [1/2]

std::string goby::zeromq::identifier_part_to_string ( int  i)
inline

Definition at line 102 of file interprocess.h.

◆ identifier_part_to_string() [2/2]

std::string goby::zeromq::identifier_part_to_string ( std::thread::id  i)
inline

Definition at line 106 of file interprocess.h.

◆ liaison_internal_publish_socket_name()

std::string goby::zeromq::liaison_internal_publish_socket_name ( )
inline

Definition at line 48 of file liaison_container.h.

◆ liaison_internal_subscribe_socket_name()

std::string goby::zeromq::liaison_internal_subscribe_socket_name ( )
inline

Definition at line 52 of file liaison_container.h.

◆ make_identifier()

std::string goby::zeromq::make_identifier ( const std::string &  type_name,
int  scheme,
const std::string &  group,
IdentifierWildcard  wildcard,
const std::string &  process,
std::unordered_map< int, std::string > *  schemes_buffer = nullptr,
std::unordered_map< std::thread::id, std::string > *  threads_buffer = nullptr 
)
inline

Definition at line 125 of file interprocess.h.

◆ setup_socket()

void goby::zeromq::setup_socket ( zmq::socket_t socket,
const protobuf::Socket cfg 
)