Sirikata::TCPSpaceNetwork::RemoteStream Struct Reference

Collaboration diagram for Sirikata::TCPSpaceNetwork::RemoteStream:

List of all members.

Public Types
enum	Initiator { Us, Them }
typedef Sirikata::SizedThreadSafeQueue < Chunk *, CountResourceMonitor >	SizedChunkReceiveQueue
Public Member Functions
	RemoteStream (TCPSpaceNetwork *parent, Sirikata::Network::Stream *strm, ServerID remote_id, Address4 remote_net, Initiator init)
	~RemoteStream ()
bool	push (Chunk &data, bool *was_empty)
Chunk *	pop (Network::IOStrand *ios)
Public Attributes
Sirikata::Network::Stream *	stream
Address4	network_endpoint
ServerID	logical_endpoint
Initiator	initiator
bool	connected
bool	shutting_down
SizedChunkReceiveQueue	receive_queue
bool	paused
boost::mutex	mPushPopMutex

---

Member Typedef Documentation

typedef Sirikata::SizedThreadSafeQueue<Chunk*,CountResourceMonitor> Sirikata::TCPSpaceNetwork::RemoteStream::SizedChunkReceiveQueue

---

Member Enumeration Documentation

enum Sirikata::TCPSpaceNetwork::RemoteStream::Initiator

Enumerator:

Us
Them

---

Constructor & Destructor Documentation

Sirikata::TCPSpaceNetwork::RemoteStream::RemoteStream	(	TCPSpaceNetwork *	parent,
		Sirikata::Network::Stream *	strm,
		ServerID	remote_id,
		Address4	remote_net,
		Initiator	init
	)

Sirikata::TCPSpaceNetwork::RemoteStream::~RemoteStream

(

)

---

Member Function Documentation

Chunk * Sirikata::TCPSpaceNetwork::RemoteStream::pop

(

Network::IOStrand *

ios

)

References Sirikata::Network::IOStrand::post(), and Sirikata::Network::Stream::readyRead().

bool Sirikata::TCPSpaceNetwork::RemoteStream::push	(	Chunk &	data,
		bool *	was_empty
	)

References Sirikata::Logging::insane, and TCPNET_LOG.

---

Member Data Documentation

bool Sirikata::TCPSpaceNetwork::RemoteStream::connected

Initiator Sirikata::TCPSpaceNetwork::RemoteStream::initiator

ServerID Sirikata::TCPSpaceNetwork::RemoteStream::logical_endpoint

boost::mutex Sirikata::TCPSpaceNetwork::RemoteStream::mPushPopMutex

Address4 Sirikata::TCPSpaceNetwork::RemoteStream::network_endpoint

bool Sirikata::TCPSpaceNetwork::RemoteStream::paused

SizedChunkReceiveQueue Sirikata::TCPSpaceNetwork::RemoteStream::receive_queue

bool Sirikata::TCPSpaceNetwork::RemoteStream::shutting_down

Sirikata::Network::Stream* Sirikata::TCPSpaceNetwork::RemoteStream::stream

---

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

• space/src/TCPSpaceNetwork.hpp
• space/src/TCPSpaceNetwork.cpp