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::io::detail::IOThread< line_in_group, line_out_group, publish_layer, subscribe_layer, IOConfig, SocketType, ThreadType, use_indexed_groups >

Namespaces
namespace	goby
	The global namespace for the Goby project.
namespace	goby::middleware
	Objects implementing the Goby nested middleware.
namespace	goby::middleware::io
namespace	goby::middleware::io::detail

Enumerations
enum class	goby::middleware::io::ThreadState { goby::middleware::io::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)