vistle::message Namespace Reference

Namespaces
namespace	SetParameterChoices

Classes
class	AddHub
class	AddObject
class	AddObjectCompleted
class	AddParameter
class	AddPort
class	Barrier
class	BarrierReached
class	Buffer
class	Busy
class	CancelExecute
class	CloseConnection
class	codec_error
class	Connect
class	Cover
class	CreateModuleCompound
class	DataTransferState
class	Debug
class	DefaultSender
class	Disconnect
class	Execute
class	ExecutionProgress
class	FileQuery
class	FileQueryResult
class	Identify
class	Idle
class	Kill
class	LockUi
class	Message
class	MessageBase
class	MessageFactory
class	MessageQueue
class	ModuleAvailable
struct	ModuleBaseMessage
class	ModuleExit
class	ObjectReceivePolicy
class	Ping
class	Pong
class	Quit
class	ReducePolicy
class	RemoteRenderMessage
class	RemoveHub
class	RemoveParameter
class	RemovePort
class	ReplayFinished
class	RequestObject
class	RequestTunnel
class	Router
class	SchedulingPolicy
class	SendObject
class	SendText
class	SetId
class	SetParameter
class	SetParameterChoices
class	Spawn
class	SpawnPrepared
class	Started
class	Trace
class	UpdateStatus

Typedefs
typedef std::array< char, ModuleNameLength >	module_name_t
typedef std::array< char, 32 >	port_name_t
typedef std::array< char, 32 >	param_name_t
typedef std::array< char, 256 >	param_value_t
typedef std::array< char, 50 >	param_choice_t
typedef std::array< char, 300 >	shmsegname_t
typedef std::array< char, 350 >	description_t
typedef std::array< char, 200 >	address_t
typedef std::array< char, 500 >	path_t
typedef boost::uuids::uuid	uuid_t
typedef uint32_t	SizeType
typedef boost::asio::ip::tcp::socket	socket_t

Enumerations
enum	RoutingFlags

Functions
buffer	compressPayload (CompressionMode &mode, const buffer &raw, int speed)
buffer	compressPayload (CompressionMode &mode, const char *raw, size_t size, int speed)
buffer	compressPayload (CompressionMode mode, Message &msg, buffer &raw, int speed)
buffer	decompressPayload (CompressionMode mode, size_t size, size_t rawsize, buffer &compressed)
buffer	decompressPayload (CompressionMode mode, size_t size, size_t rawsize, const char *compressed)
buffer	decompressPayload (const Message &msg, buffer &compressed)
	DEFINE_ENUM_WITH_STRING_CONVERSIONS (CompressionMode,(CompressionNone)(CompressionLz4)(CompressionZstd)(CompressionSnappy)) DEFINE_ENUM_WITH_STRING_CONVERSIONS(Type
	INVALID (ANY)(IDENTIFY)(CLOSECONNECTION)(ADDHUB)(REMOVEHUB)(SETID)(TRACE)(SPAWN)(SPAWNPREPARED)(KILL)(DEBUG)(QUIT)(STARTED)(MODULEEXIT)(BUSY)(IDLE)(EXECUTIONPROGRESS)(EXECUTE)(CANCELEXECUTE)(ADDOBJECT)(ADDOBJECTCOMPLETED)(DATATRANSFERSTATE)(ADDPORT)(REMOVEPORT)(CONNECT)(DISCONNECT)(ADDPARAMETER)(REMOVEPARAMETER)(SETPARAMETER)(SETPARAMETERCHOICES)(PING)(PONG)(BARRIER)(BARRIERREACHED)(SENDTEXT)(UPDATESTATUS)(OBJECTRECEIVEPOLICY)(SCHEDULINGPOLICY)(REDUCEPOLICY)(MODULEAVAILABLE)(CREATEMODULECOMPOUND)(LOCKUI)(REPLAYFINISHED)(REQUESTTUNNEL)(REQUESTOBJECT)(SENDOBJECT)(REMOTERENDERING)(FILEQUERY)(FILEQUERYRESULT)(COVER)(INSITU)(NumMessageTypes)) struct V_COREEXPORT Id
V_COREEXPORT buffer	compressPayload (vistle::message::CompressionMode &mode, const char *raw, size_t size, int speed=-1)
V_COREEXPORT buffer	compressPayload (vistle::message::CompressionMode &mode, const buffer &raw, int speed=-1)
V_COREEXPORT buffer	compressPayload (vistle::message::CompressionMode mode, Message &msg, buffer &raw, int speed=-1)
V_COREEXPORT buffer	decompressPayload (vistle::message::CompressionMode mode, size_t size, size_t rawsize, buffer &compressed)
V_COREEXPORT std::ostream &	operator<< (std::ostream &s, const Message &msg)
buffer	addPayload (Message &message, const Payload &payload)
void	getFromPayload (const buffer &data, Payload &payload)
Payload	getPayload (const buffer &data)
static T	min (T a, T b)
template V_COREEXPORT buffer	addPayload< std::string > (Message &message, const std::string &payload)
template V_COREEXPORT buffer	addPayload< SendText::Payload > (Message &message, const SendText::Payload &payload)
template V_COREEXPORT buffer	addPayload< SetParameterChoices::Payload > (Message &message, const SetParameterChoices::Payload &payload)
void	return_buffer (std::shared_ptr< buffer > &buf)
std::shared_ptr< buffer >	get_buffer (size_t size)
bool	recv_payload (socket_t &sock, message::Buffer &msg, error_code &ec, buffer *payload)
bool	recv_message (socket_t &sock, message::Buffer &msg, error_code &ec, bool block)
bool	recv (socket_t &sock, message::Buffer &msg, error_code &ec, bool block, buffer *payload)
void	async_recv (socket_t &sock, message::Buffer &msg, std::function< void(boost::system::error_code ec, std::shared_ptr< buffer >)> handler)
void	async_recv_header (socket_t &sock, message::Buffer &msg, std::function< void(boost::system::error_code ec)> handler)
bool	send (socket_t &sock, const message::Message &msg, error_code &ec, const char *payload, size_t size)
bool	send (socket_t &sock, const message::Message &msg, error_code &ec, const buffer *payload)
bool	send (socket_t &sock, const Message &msg, const buffer *payload)
void	async_send (socket_t &sock, const message::Message &msg, std::shared_ptr< buffer > payload, const std::function< void(error_code ec)> handler)
void	async_send (socket_t &sock, const message::Message &msg, const MessagePayload &payload, const std::function< void(error_code ec)> handler)
void	async_forward (socket_t &sock, const message::Message &msg, std::shared_ptr< socket_t > payloadSock, const std::function< void(error_code ec)> handler)
void V_COREEXPORT	async_recv (socket_t &sock, vistle::message::Buffer &msg, std::function< void(error_code, std::shared_ptr< buffer >)> handler)
void V_COREEXPORT	async_recv_header (socket_t &sock, vistle::message::Buffer &msg, std::function< void(error_code)> handler)

Variables
	Track
	NodeLocal
	ClusterLocal
	DestMasterHub
	DestSlaveHub
	DestLocalHub
	DestHub
	DestUi
	DestModules
	DestMasterManager
	DestSlaveManager
	DestLocalManager
	DestManager
	Special
	RequiresSubscription
	Broadcast
	BroadcastModule
	HandleOnNode
	HandleOnRank0
	HandleOnHub
	HandleOnMaster
	HandleOnDest
	QueueIfUnhandled
	TriggerQueue
	CleanQueue
	OnlyRank0
static boost::uuids::random_generator	s_uuidGenerator
const int	ModuleNameLength
static const size_t	buffersize