Goby3
3.1.5a
2024.05.23
|
#include <chrono>
#include <exception>
#include <memory>
#include <mutex>
#include <ostream>
#include <string>
#include <thread>
#include <unistd.h>
#include <boost/asio/write.hpp>
#include <boost/system/error_code.hpp>
#include "goby/exception.h"
#include "goby/middleware/application/multi_thread.h"
#include "goby/middleware/common.h"
#include "goby/middleware/io/groups.h"
#include "goby/middleware/protobuf/io.pb.h"
#include "goby/time/steady_clock.h"
#include "goby/util/asio_compat.h"
#include "goby/util/debug_logger.h"
#include "io_transporters.h"
Go to the source code of this file.
Classes | |
class | goby::middleware::InterProcessForwarder< InnerTransporter > |
Implements the forwarder concept for the interprocess layer. More... | |
class | goby::middleware::io::detail::IOThread< line_in_group, line_out_group, publish_layer, subscribe_layer, IOConfig, SocketType, ThreadType, use_indexed_groups > |
Namespaces | |
goby | |
The global namespace for the Goby project. | |
goby::middleware | |
Objects implementing the Goby nested middleware. | |
goby::middleware::io | |
goby::middleware::io::detail | |
Enumerations | |
enum | goby::middleware::io::ThreadState { goby::middleware::io::ThreadState::SUBSCRIPTIONS_COMPLETE } |
Functions | |
template<typename ProtobufEndpoint , typename ASIOEndpoint > | |
ProtobufEndpoint | goby::middleware::io::detail::endpoint_convert (const ASIOEndpoint &asio_ep) |
template<class IOThreadImplementation > | |
void | goby::middleware::io::detail::basic_async_write (IOThreadImplementation *this_thread, std::shared_ptr< const goby::middleware::protobuf::IOData > io_msg) |