Sirikata::NetworkQueueWrapper Class Reference

#include <NetworkQueueWrapper.hpp>

Collaboration diagram for Sirikata::NetworkQueueWrapper:

List of all members.

Public Types
typedef Message *	ElementType
Public Member Functions
	NetworkQueueWrapper (Context *ctx, SpaceNetwork::ReceiveStream *rstrm, Trace::MessagePath tag)
	~NetworkQueueWrapper ()
QueueEnum::PushResult	push (const Message *msg)
Message *	front ()
Message *	pop ()
bool	empty () const
Private Types
typedef Network::Chunk	Chunk
Private Member Functions
Message *	parse (Chunk *c)
Private Attributes
Context *	mContext
SpaceNetwork::ReceiveStream *	mReceiveStream
Message *	mFront
Trace::MessagePath	mPathTag

---

Member Typedef Documentation

typedef Network::Chunk Sirikata::NetworkQueueWrapper::Chunk [private]

typedef Message* Sirikata::NetworkQueueWrapper::ElementType

---

Constructor & Destructor Documentation

Sirikata::NetworkQueueWrapper::NetworkQueueWrapper	(	Context *	ctx,
		SpaceNetwork::ReceiveStream *	rstrm,
		Trace::MessagePath	tag
	)		[inline]

Sirikata::NetworkQueueWrapper::~NetworkQueueWrapper

(

)

[inline]

---

Member Function Documentation

bool Sirikata::NetworkQueueWrapper::empty

(

)

const [inline]

References Sirikata::SpaceNetwork::ReceiveStream::front(), mFront, and mReceiveStream.

Message* Sirikata::NetworkQueueWrapper::front

(

)

[inline]

References Sirikata::SpaceNetwork::ReceiveStream::front(), mFront, mReceiveStream, and parse().

Message* Sirikata::NetworkQueueWrapper::parse

(

Chunk *

c

)

[inline, private]

References Sirikata::Message::deserialize(), Sirikata::SpaceNetwork::ReceiveStream::id(), mPathTag, mReceiveStream, SILOG, Sirikata::Message::source_server(), TIMESTAMP_PAYLOAD, and Sirikata::Logging::warning.

Referenced by front(), and pop().

Message* Sirikata::NetworkQueueWrapper::pop

(

)

[inline]

References mFront, mReceiveStream, parse(), and Sirikata::SpaceNetwork::ReceiveStream::pop().

QueueEnum::PushResult Sirikata::NetworkQueueWrapper::push

(

const Message *

msg

)

[inline]

References Sirikata::QueueEnum::PushExceededMaximumSize.

---

Member Data Documentation

Context* Sirikata::NetworkQueueWrapper::mContext [private]

Message* Sirikata::NetworkQueueWrapper::mFront [private]

Referenced by empty(), front(), and pop().

Trace::MessagePath Sirikata::NetworkQueueWrapper::mPathTag [private]

Referenced by parse().

SpaceNetwork::ReceiveStream* Sirikata::NetworkQueueWrapper::mReceiveStream [private]

Referenced by empty(), front(), parse(), and pop().

---

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

• space/src/NetworkQueueWrapper.hpp