Sirikata::FairServerMessageQueue Class Reference

#include <FairServerMessageQueue.hpp>

Inheritance diagram for Sirikata::FairServerMessageQueue:

Collaboration diagram for Sirikata::FairServerMessageQueue:

List of all members.

Classes
struct	SenderAdapterQueue
Public Member Functions
	FairServerMessageQueue (SpaceContext *ctx, SpaceNetwork *net, Sender *sender)
	~FairServerMessageQueue ()
Protected Types
typedef FairQueue< Message, ServerID, SenderAdapterQueue >	FairSendQueue
typedef boost::lock_guard < boost::recursive_mutex >	MutexLock
Protected Member Functions
virtual void	messageReady (ServerID sid)
	Indicate that a new message is available upstream, destined for the specified server.
virtual void	networkReadyToSend (const ServerID &from)
	Invoked when, after a call to Network::send() fails, the network determines it can accept more data.
virtual void	handleUpdateReceiverStats (ServerID sid, double total_weight, double used_weight)
void	addInputQueue (ServerID sid, float weight)
void	removeInputQueue (ServerID sid)
float	getAverageServerWeight () const
void	enableDownstream (ServerID sid)
void	disableDownstream (ServerID sid)
void	scheduleServicing ()
void	service ()
Protected Attributes
FairSendQueue	mServerQueues
Sirikata::AtomicValue< bool >	mServiceScheduled
uint64	mStoppedBlocked
uint64	mStoppedUnderflow
boost::recursive_mutex	mMutex

---

Member Typedef Documentation

typedef FairQueue<Message, ServerID, SenderAdapterQueue> Sirikata::FairServerMessageQueue::FairSendQueue [protected]

typedef boost::lock_guard<boost::recursive_mutex> Sirikata::FairServerMessageQueue::MutexLock [protected]

---

Constructor & Destructor Documentation

Sirikata::FairServerMessageQueue::FairServerMessageQueue	(	SpaceContext *	ctx,
		SpaceNetwork *	net,
		Sender *	sender
	)

Sirikata::FairServerMessageQueue::~FairServerMessageQueue

(

)

References Sirikata::Logging::info, mStoppedBlocked, mStoppedUnderflow, and SILOG.

---

Member Function Documentation

void Sirikata::FairServerMessageQueue::addInputQueue	(	ServerID	sid,
		float	weight
	)		[protected]

References Sirikata::FairQueue< Message, Key, TQueue >::addQueue(), Sirikata::FairQueue< Message, Key, TQueue >::hasQueue(), Sirikata::Logging::info, Sirikata::ServerMessageQueue::mSender, mServerQueues, and SILOG.

Referenced by handleUpdateReceiverStats(), and messageReady().

void Sirikata::FairServerMessageQueue::disableDownstream

(

ServerID

sid

)

[protected]

References Sirikata::FairQueue< Message, Key, TQueue >::disableQueue(), Sirikata::Logging::info, Sirikata::ServerMessageQueue::mContext, mServerQueues, Sirikata::Time::null(), SILOG, and Sirikata::Context::simTime().

Referenced by service().

void Sirikata::FairServerMessageQueue::enableDownstream

(

ServerID

sid

)

[protected]

References Sirikata::FairQueue< Message, Key, TQueue >::enableQueue(), mMutex, mServerQueues, and scheduleServicing().

Referenced by networkReadyToSend().

float Sirikata::FairServerMessageQueue::getAverageServerWeight

(

)

const [protected]

References Sirikata::FairQueue< Message, Key, TQueue >::avg_weight(), and mServerQueues.

Referenced by messageReady().

void Sirikata::FairServerMessageQueue::handleUpdateReceiverStats	(	ServerID	sid,
		double	total_weight,
		double	used_weight
	)		[protected, virtual]

Implements Sirikata::ServerMessageQueue.

References addInputQueue(), Sirikata::FairQueue< Message, Key, TQueue >::hasQueue(), mMutex, mServerQueues, and Sirikata::FairQueue< Message, Key, TQueue >::setQueueWeight().

void Sirikata::FairServerMessageQueue::messageReady

(

ServerID

sid

)

[protected, virtual]

Indicate that a new message is available upstream, destined for the specified server.

Implements Sirikata::ServerMessageQueue.

References addInputQueue(), getAverageServerWeight(), Sirikata::FairQueue< Message, Key, TQueue >::hasQueue(), mMutex, mServerQueues, Sirikata::FairQueue< Message, Key, TQueue >::notifyPushFront(), and scheduleServicing().

void Sirikata::FairServerMessageQueue::networkReadyToSend

(

const ServerID &

from

)

[protected, virtual]

Invoked when, after a call to Network::send() fails, the network determines it can accept more data.

Implements Sirikata::ServerMessageQueue.

References enableDownstream(), Sirikata::Logging::info, Sirikata::ServerMessageQueue::mContext, Sirikata::Time::null(), SILOG, and Sirikata::Context::simTime().

void Sirikata::FairServerMessageQueue::removeInputQueue

(

ServerID

sid

)

[protected]

References Sirikata::FairQueue< Message, Key, TQueue >::hasQueue(), mMutex, mServerQueues, and Sirikata::FairQueue< Message, Key, TQueue >::removeQueue().

void Sirikata::FairServerMessageQueue::scheduleServicing

(

)

[protected]

References Sirikata::ServerMessageQueue::mSenderStrand, mServiceScheduled, Sirikata::Network::IOStrand::post(), Sirikata::AtomicValue< T >::read(), and service().

Referenced by enableDownstream(), messageReady(), and service().

void Sirikata::FairServerMessageQueue::service

(

)

[protected]

References disableDownstream(), Sirikata::SimpleRateEstimator::estimate_rate(), Sirikata::TimeProfiler::Stage::finished(), Sirikata::FairQueue< Message, Key, TQueue >::front(), MAX_MESSAGES_PER_ROUND, Sirikata::ServerMessageQueue::mBlocked, Sirikata::ServerMessageQueue::mCapacityEstimator, Sirikata::ServerMessageQueue::mContext, mMutex, Sirikata::ServerMessageQueue::mProfiler, mServerQueues, mServiceScheduled, mStoppedBlocked, mStoppedUnderflow, Sirikata::FairQueue< Message, Key, TQueue >::pop(), scheduleServicing(), Sirikata::Context::simTime(), Sirikata::TimeProfiler::Stage::started(), and Sirikata::ServerMessageQueue::trySend().

Referenced by scheduleServicing().

---

Member Data Documentation

boost::recursive_mutex Sirikata::FairServerMessageQueue::mMutex [mutable, protected]

Referenced by enableDownstream(), handleUpdateReceiverStats(), messageReady(), removeInputQueue(), and service().

FairSendQueue Sirikata::FairServerMessageQueue::mServerQueues [protected]

Referenced by addInputQueue(), disableDownstream(), enableDownstream(), getAverageServerWeight(), handleUpdateReceiverStats(), messageReady(), removeInputQueue(), and service().

Sirikata::AtomicValue<bool> Sirikata::FairServerMessageQueue::mServiceScheduled [protected]

Referenced by scheduleServicing(), and service().

uint64 Sirikata::FairServerMessageQueue::mStoppedBlocked [protected]

Referenced by service(), and ~FairServerMessageQueue().

uint64 Sirikata::FairServerMessageQueue::mStoppedUnderflow [protected]

Referenced by service(), and ~FairServerMessageQueue().

---

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

• space/src/FairServerMessageQueue.hpp
• space/src/FairServerMessageQueue.cpp