Goby3  3.1.4
2024.02.22
io_interface.h File Reference
#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)