View on GitHub

Vistle

Distributed Data-parallel Scientific Visualization in VR

Namespaces | Macros | Typedefs | Functions | Variables
tcpmessage.cpp File Reference
#include <iostream>
#include <functional>
#include <memory>
#include <boost/asio.hpp>
#include <mutex>
#include <vistle/util/tools.h>
#include <vistle/util/buffer.h>
#include "tcpmessage.h"
#include "message.h"
#include "messages.h"
#include "messagepayload.h"
#include <deque>
Include dependency graph for tcpmessage.cpp:

Namespaces

namespace  vistle
 
namespace  vistle::message
 

Macros

#define PRINT_MESSAGE_TYPE
 

Typedefs

typedef uint32_t vistle::message::SizeType
 

Functions

void vistle::message::return_buffer (std::shared_ptr< buffer > &buf)
 
std::shared_ptr< buffer > vistle::message::get_buffer (size_t size)
 
bool vistle::message::recv_payload (socket_t &sock, message::Buffer &msg, error_code &ec, buffer *payload)
 
bool vistle::message::recv_message (socket_t &sock, message::Buffer &msg, error_code &ec, bool block)
 
bool vistle::message::recv (socket_t &sock, message::Buffer &msg, error_code &ec, bool block, buffer *payload)
 
void vistle::message::async_recv (socket_t &sock, message::Buffer &msg, std::function< void(boost::system::error_code ec, std::shared_ptr< buffer >)> handler)
 
void vistle::message::async_recv_header (socket_t &sock, message::Buffer &msg, std::function< void(boost::system::error_code ec)> handler)
 
bool vistle::message::send (socket_t &sock, const message::Message &msg, error_code &ec, const char *payload, size_t size)
 
bool vistle::message::send (socket_t &sock, const message::Message &msg, error_code &ec, const buffer *payload)
 
bool vistle::message::send (socket_t &sock, const Message &msg, const buffer *payload)
 
void vistle::message::async_send (socket_t &sock, const message::Message &msg, std::shared_ptr< buffer > payload, const std::function< void(error_code ec)> handler)
 
void vistle::message::async_send (socket_t &sock, const message::Message &msg, const MessagePayload &payload, const std::function< void(error_code ec)> handler)
 
void vistle::message::async_forward (socket_t &sock, const message::Message &msg, std::shared_ptr< socket_t > payloadSock, const std::function< void(error_code ec)> handler)
 

Variables

static const size_t vistle::message::buffersize = 16384
 

Macro Definition Documentation

◆ PRINT_MESSAGE_TYPE

#define PRINT_MESSAGE_TYPE