wns::scheduler::queue::SegmentingQueue Class Reference


Public Member Functions
ConnectionSet	filterQueuedCids (ConnectionSet connections)
	Returns the set of connections for which the queue has backlogged PDUs.
void	frameStarts ()
	May be called to signal that a frame starts.
ConnectionSet	getActiveConnections () const
	Returns a ConnectionSet of all connections who have backlogged PDUs in his queue.
bool	getByteAlignHeader ()
Bit	getExtensionHeaderSize ()
Bit	getFixedHeaderSize ()
wns::ldk::CompoundPtr	getHeadOfLinePDU (ConnectionID cid)
	compound out
int	getHeadOfLinePDUbits (ConnectionID cid)
	Delivers the size in bits of the PDU that will be returned by the next call to getHeadOfLinePDU(ConnectionID cid).
wns::ldk::CompoundPtr	getHeadOfLinePDUSegment (ConnectionID cid, int bits)
	get compound out and do segmentation into bits (gross)
unsigned long int	getMinimumSegmentSize ()
int	getMinimumSegmentSize () const
	if supportsDynamicSegmentation, this is the minimum size of a segment in bits
std::queue< wns::ldk::CompoundPtr >	getQueueCopy (ConnectionID cid)
	Retrieves a copy of the queue for a CID. Queued compounds are not copied but point to the same ones as in the original queue!
UserSet	getQueuedUsers () const
	Returns a UserSet of all users who have backlogged PDUs in at least one of their queues.
QueueStatusContainer	getQueueStatus () const
	Returns the a container of QueueStatus for each cid.
bool	hasQueue (ConnectionID cid)
	Return True if a queue for this cid exists.
bool	isAccepting (const wns::ldk::CompoundPtr &compound) const
	Has to be called before calling put(CompoundPtr) to see whether the queue module can still accept the PDU. According to the specific implementation the acceptance may be determined by the fill level of the correspondig queue. called in doIsAccepting(..) of the ResourceScheduler-FU.
bool	isEmpty () const
	Return True if there is no compound in the queue.
unsigned long int	numBitsForCid (ConnectionID cid) const
	Returns the number of Bits schedules for one user.
unsigned long int	numCompoundsForCid (ConnectionID cid) const
	Returns the number of Compounds the Queue has stored for a certain user.
std::string	printAllQueues ()
	print number of bits and pdus in each queue
void	put (const wns::ldk::CompoundPtr &compound)
	compound in
bool	queueHasPDUs (ConnectionID cid) const
	Returns true if the queue belonging to cid has backlogged PDUs.
ProbeOutput	resetAllQueues ()
	Resets all internal queues and deletes all backlogged PDUs.
ProbeOutput	resetQueue (ConnectionID cid)
	Resets only the queue belonging to the given ConnectionID and all backlogged PDUs from this queue.
ProbeOutput	resetQueues (UserID user)
	Resets all queues belonging to the given user and deletes all backlogged PDUs in these queues.
	SegmentingQueue (wns::ldk::HasReceptorInterface *, const wns::pyconfig::View &config)
void	setColleagues (RegistryProxyInterface *_registry)
	Gives the queue module access to the RegistryProxy.
void	setFUN (wns::ldk::fun::FUN *fun)
	needed for probes
bool	supportsDynamicSegmentation () const
	true if getHeadOfLinePDUSegment() is supported
virtual	~SegmentingQueue ()
Protected Member Functions
void	probe ()
Private Types
typedef std::map< ConnectionID, int >	FixedOverheadContainer
typedef std::map< ConnectionID, detail::InnerQueue >	QueueContainer
Private Attributes
bool	byteAlignHeader
struct wns::scheduler::queue::SegmentingQueue::Colleagues	colleagues
wns::pyconfig::View	config
wns::probe::bus::ContextCollectorPtr	delayProbeBus
Bit	extensionHeaderSize
Bit	fixedHeaderSize
FixedOverheadContainer	fixedOverhead
bool	isDropping
wns::logger::Logger	logger
long int	maxSize
unsigned long int	minimumSegmentSize
wns::ldk::fun::FUN *	myFUN
wns::probe::bus::ContextCollectorPtr	overheadProbeBus
wns::ldk::CommandReaderInterface *	probeHeaderReader
QueueContainer	queues
wns::ldk::CommandReaderInterface *	segmentHeaderReader
wns::probe::bus::ContextCollectorPtr	sizeProbeBus
bool	usePadding
Classes
struct	Colleagues