User Manual, Developers Guide and API Documentation
|
User Manual, Developers Guide and API Documentation |
|
#include <scheduler/queue/SimpleQueue.hpp>
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. | |
| 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) | |
| 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. | |
| void | setColleagues (RegistryProxyInterface *_registry) |
| Gives the queue module access to the RegistryProxy. | |
| void | setFUN (wns::ldk::fun::FUN *fun) |
| needed for probes | |
| SimpleQueue (wns::ldk::HasReceptorInterface *, const wns::pyconfig::View &config) | |
| bool | supportsDynamicSegmentation () const |
| true if getHeadOfLinePDUSegment() is supported | |
| virtual | ~SimpleQueue () |
Protected Member Functions | |
| void | probe () |
Private Types | |
| typedef std::map< ConnectionID, Queue > | QueueContainer |
Private Attributes | |
| struct wns::scheduler::queue::SimpleQueue::Colleagues | colleagues |
| wns::pyconfig::View | config |
| wns::logger::Logger | logger |
| long int | maxSize |
| wns::ldk::fun::FUN * | myFUN |
| wns::probe::bus::contextprovider::Variable * | probeContextProviderForCid |
| wns::probe::bus::contextprovider::Variable * | probeContextProviderForPriority |
| QueueContainer | queues |
| wns::probe::bus::ContextCollectorPtr | sizeProbeBus |
Classes | |
| struct | Colleagues |
| struct | Queue |
Definition at line 49 of file SimpleQueue.hpp.
typedef std::map<ConnectionID, Queue> wns::scheduler::queue::SimpleQueue::QueueContainer [private] |
Definition at line 122 of file SimpleQueue.hpp.
| SimpleQueue::SimpleQueue | ( | wns::ldk::HasReceptorInterface * | , | |
| const wns::pyconfig::View & | config | |||
| ) |
Definition at line 42 of file SimpleQueue.cpp.
| SimpleQueue::~SimpleQueue | ( | ) | [virtual] |
Definition at line 52 of file SimpleQueue.cpp.
| ConnectionSet SimpleQueue::filterQueuedCids | ( | ConnectionSet | connections | ) | [virtual] |
| void wns::scheduler::queue::SimpleQueue::frameStarts | ( | ) | [inline, virtual] |
| ConnectionSet SimpleQueue::getActiveConnections | ( | ) | const [virtual] |
| wns::ldk::CompoundPtr SimpleQueue::getHeadOfLinePDU | ( | ConnectionID | cid | ) | [virtual] |
| int SimpleQueue::getHeadOfLinePDUbits | ( | ConnectionID | cid | ) | [virtual] |
| wns::ldk::CompoundPtr wns::scheduler::queue::SimpleQueue::getHeadOfLinePDUSegment | ( | ConnectionID | cid, | |
| int | bits | |||
| ) | [inline, virtual] |
| int wns::scheduler::queue::SimpleQueue::getMinimumSegmentSize | ( | ) | const [inline, virtual] |
Reimplemented from wns::scheduler::queue::QueueInterface.
Definition at line 94 of file SimpleQueue.hpp.
| std::queue< wns::ldk::CompoundPtr > SimpleQueue::getQueueCopy | ( | ConnectionID | cid | ) | [virtual] |
| UserSet SimpleQueue::getQueuedUsers | ( | ) | const [virtual] |
| QueueStatusContainer SimpleQueue::getQueueStatus | ( | ) | const [virtual] |
| bool SimpleQueue::hasQueue | ( | ConnectionID | cid | ) | [virtual] |
| bool SimpleQueue::isAccepting | ( | const wns::ldk::CompoundPtr & | compound | ) | const [virtual] |
| bool SimpleQueue::isEmpty | ( | ) | const [virtual] |
| unsigned long int SimpleQueue::numBitsForCid | ( | ConnectionID | cid | ) | const [virtual] |
| unsigned long int SimpleQueue::numCompoundsForCid | ( | ConnectionID | cid | ) | const [virtual] |
| std::string SimpleQueue::printAllQueues | ( | ) | [virtual] |
| void wns::scheduler::queue::SimpleQueue::probe | ( | ) | [protected] |
| void SimpleQueue::put | ( | const wns::ldk::CompoundPtr & | compound | ) | [virtual] |
| bool SimpleQueue::queueHasPDUs | ( | ConnectionID | cid | ) | const [virtual] |
| QueueInterface::ProbeOutput SimpleQueue::resetAllQueues | ( | ) | [virtual] |
| QueueInterface::ProbeOutput SimpleQueue::resetQueue | ( | ConnectionID | cid | ) | [virtual] |
| QueueInterface::ProbeOutput SimpleQueue::resetQueues | ( | UserID | user | ) | [virtual] |
| void SimpleQueue::setColleagues | ( | RegistryProxyInterface * | registry | ) | [virtual] |
| void SimpleQueue::setFUN | ( | wns::ldk::fun::FUN * | fun | ) | [virtual] |
| bool wns::scheduler::queue::SimpleQueue::supportsDynamicSegmentation | ( | ) | const [inline, virtual] |
struct wns::scheduler::queue::SimpleQueue::Colleagues wns::scheduler::queue::SimpleQueue::colleagues [private] |
Definition at line 131 of file SimpleQueue.hpp.
Definition at line 130 of file SimpleQueue.hpp.
long int wns::scheduler::queue::SimpleQueue::maxSize [private] |
Definition at line 120 of file SimpleQueue.hpp.
Definition at line 132 of file SimpleQueue.hpp.
wns::probe::bus::contextprovider::Variable* wns::scheduler::queue::SimpleQueue::probeContextProviderForCid [private] |
Definition at line 107 of file SimpleQueue.hpp.
wns::probe::bus::contextprovider::Variable* wns::scheduler::queue::SimpleQueue::probeContextProviderForPriority [private] |
Definition at line 108 of file SimpleQueue.hpp.
Definition at line 123 of file SimpleQueue.hpp.
Definition at line 109 of file SimpleQueue.hpp.
1.5.5