View on GitHub

Vistle

Distributed Data-parallel Scientific Visualization in VR

Public Types | Public Member Functions | Static Public Member Functions | List of all members
vistle::message::MessageQueue Class Reference

#include <core/messagequeue.h>

Public Types

typedef boost::interprocess::message_queue message_queue
 

Public Member Functions

void makeNonBlocking ()
 
 ~MessageQueue ()
 
const std::string & getName () const
 
bool send (const Message &msg)
 
bool progress ()
 
void receive (Message &msg)
 
bool tryReceive (Message &msg)
 
size_t getNumMessages ()
 

Static Public Member Functions

static MessageQueuecreate (const std::string &m_name)
 
static MessageQueueopen (const std::string &m_name)
 
static std::string createName (const char *prefix, const int moduleID, const int rank)
 

Member Typedef Documentation

◆ message_queue

typedef boost::interprocess::message_queue vistle::message::MessageQueue::message_queue

Constructor & Destructor Documentation

◆ ~MessageQueue()

vistle::message::MessageQueue::~MessageQueue ( )

Member Function Documentation

◆ create()

MessageQueue * vistle::message::MessageQueue::create ( const std::string &  m_name)
static

◆ createName()

std::string vistle::message::MessageQueue::createName ( const char *  prefix,
const int  moduleID,
const int  rank 
)
static

◆ getName()

const std::string & vistle::message::MessageQueue::getName ( ) const

◆ getNumMessages()

size_t vistle::message::MessageQueue::getNumMessages ( )

◆ makeNonBlocking()

void vistle::message::MessageQueue::makeNonBlocking ( )

◆ open()

MessageQueue * vistle::message::MessageQueue::open ( const std::string &  m_name)
static

◆ progress()

bool vistle::message::MessageQueue::progress ( )

◆ receive()

void vistle::message::MessageQueue::receive ( Message msg)

◆ send()

bool vistle::message::MessageQueue::send ( const Message msg)

◆ tryReceive()

bool vistle::message::MessageQueue::tryReceive ( Message msg)

The documentation for this class was generated from the following files: