User Manual, Developers Guide and API Documentation
|
User Manual, Developers Guide and API Documentation |
|
#include <scheduler/queue/QueueProxy.hpp>
Public Member Functions | |
| wns::scheduler::ConnectionSet | filterQueuedCids (wns::scheduler::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. | |
| wns::scheduler::ConnectionSet | getActiveConnections () const |
| Returns a ConnectionSet of all connections who have backlogged PDUs in his queue. | |
| wns::ldk::CompoundPtr | getHeadOfLinePDU (wns::scheduler::ConnectionID cid) |
| compound out | |
| int | getHeadOfLinePDUbits (wns::scheduler::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 (wns::scheduler::ConnectionID cid, int bits) |
| get compound out and do segmentation into bits | |
| int | getMinimumSegmentSize () const |
| if supportsDynamicSegmentation, this is the minimum size of a segment in bits | |
| virtual std::queue < wns::ldk::CompoundPtr > | getQueueCopy (ConnectionID cid) |
| Retrieves a copy of the queue for a CID. This class uses the method from other queues but it makes no sense to call our method so we throw. | |
| wns::scheduler::UserSet | getQueuedUsers () const |
| Returns a UserSet of all users who have backlogged PDUs in at least one of their queues. | |
| wns::scheduler::QueueStatusContainer | getQueueStatus () const |
| Returns the a container of QueueStatus for each cid. | |
| bool | hasQueue (wns::scheduler::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 (wns::scheduler::ConnectionID cid) const |
| Returns the number of Bits schedules for one user. | |
| unsigned long int | numCompoundsForCid (wns::scheduler::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 (wns::scheduler::ConnectionID cid) const |
| Returns true if the queue belonging to cid has backlogged PDUs. | |
| QueueProxy (wns::ldk::HasReceptorInterface *, const wns::pyconfig::View &config) | |
| wns::scheduler::queue::QueueInterface::ProbeOutput | resetAllQueues () |
| Resets all internal queues and deletes all backlogged PDUs. | |
| wns::scheduler::queue::QueueInterface::ProbeOutput | resetQueue (wns::scheduler::ConnectionID cid) |
| Resets only the queue belonging to the given ConnectionID and all backlogged PDUs from this queue. | |
| wns::scheduler::queue::QueueInterface::ProbeOutput | resetQueues (wns::scheduler::UserID user) |
| Resets all queues belonging to the given user and deletes all backlogged PDUs in these queues. | |
| void | setColleagues (wns::scheduler::RegistryProxyInterface *_registry) |
| Gives the queue module access to the RegistryProxy. | |
| void | setFUN (wns::ldk::fun::FUN *fun) |
| needed for probes | |
| void | startCollectionIfNeeded (wns::scheduler::ConnectionID cid) const |
| bool | supportsDynamicSegmentation () const |
| true if getHeadOfLinePDUSegment() is supported | |
| virtual | ~QueueProxy () |
Private Member Functions | |
| void | createQueueCopyIfNeeded (wns::scheduler::ConnectionID cid) const |
Private Attributes | |
| struct wns::scheduler::queue::QueueProxy::Colleagues | colleagues |
| detail::IInnerCopyQueue * | copyQueue_ |
| std::map < wns::scheduler::ConnectionID, wns::simulator::Time > | lastChecked_ |
| std::map < wns::scheduler::ConnectionID, wns::simulator::Time > | lastCollected_ |
| wns::logger::Logger | logger_ |
| wns::ldk::fun::FUN * | myFUN_ |
| std::string | queueManagerServiceName_ |
| bool | supportsDynamicSegmentation_ |
Classes | |
| struct | Colleagues |
Definition at line 44 of file QueueProxy.hpp.
| QueueProxy::QueueProxy | ( | wns::ldk::HasReceptorInterface * | hasReceptor, | |
| const wns::pyconfig::View & | config | |||
| ) |
Definition at line 38 of file QueueProxy.cpp.
| QueueProxy::~QueueProxy | ( | ) | [virtual] |
Definition at line 62 of file QueueProxy.cpp.
| void QueueProxy::createQueueCopyIfNeeded | ( | wns::scheduler::ConnectionID | cid | ) | const [private] |
Definition at line 383 of file QueueProxy.cpp.
| wns::scheduler::ConnectionSet QueueProxy::filterQueuedCids | ( | wns::scheduler::ConnectionSet | connections | ) | [virtual] |
| void QueueProxy::frameStarts | ( | ) | [virtual] |
| wns::scheduler::ConnectionSet QueueProxy::getActiveConnections | ( | ) | const [virtual] |
| wns::ldk::CompoundPtr QueueProxy::getHeadOfLinePDU | ( | wns::scheduler::ConnectionID | cid | ) | [virtual] |
| int QueueProxy::getHeadOfLinePDUbits | ( | wns::scheduler::ConnectionID | cid | ) | [virtual] |
| wns::ldk::CompoundPtr QueueProxy::getHeadOfLinePDUSegment | ( | wns::scheduler::ConnectionID | cid, | |
| int | bits | |||
| ) | [virtual] |
| int QueueProxy::getMinimumSegmentSize | ( | ) | const [virtual] |
Reimplemented from wns::scheduler::queue::QueueInterface.
Definition at line 373 of file QueueProxy.cpp.
| std::queue< wns::ldk::CompoundPtr > QueueProxy::getQueueCopy | ( | ConnectionID | cid | ) | [virtual] |
| wns::scheduler::UserSet QueueProxy::getQueuedUsers | ( | ) | const [virtual] |
| wns::scheduler::QueueStatusContainer QueueProxy::getQueueStatus | ( | ) | const [virtual] |
| bool QueueProxy::hasQueue | ( | wns::scheduler::ConnectionID | cid | ) | [virtual] |
| bool QueueProxy::isAccepting | ( | const wns::ldk::CompoundPtr & | compound | ) | const [virtual] |
| bool QueueProxy::isEmpty | ( | ) | const [virtual] |
| unsigned long int QueueProxy::numBitsForCid | ( | wns::scheduler::ConnectionID | cid | ) | const [virtual] |
| unsigned long int QueueProxy::numCompoundsForCid | ( | wns::scheduler::ConnectionID | cid | ) | const [virtual] |
| std::string QueueProxy::printAllQueues | ( | ) | [virtual] |
| void QueueProxy::put | ( | const wns::ldk::CompoundPtr & | compound | ) | [virtual] |
| bool QueueProxy::queueHasPDUs | ( | wns::scheduler::ConnectionID | cid | ) | const [virtual] |
| QueueInterface::ProbeOutput QueueProxy::resetAllQueues | ( | ) | [virtual] |
| QueueInterface::ProbeOutput QueueProxy::resetQueue | ( | wns::scheduler::ConnectionID | cid | ) | [virtual] |
| QueueInterface::ProbeOutput QueueProxy::resetQueues | ( | wns::scheduler::UserID | user | ) | [virtual] |
| void QueueProxy::setColleagues | ( | wns::scheduler::RegistryProxyInterface * | registry | ) | [virtual] |
| void QueueProxy::setFUN | ( | wns::ldk::fun::FUN * | fun | ) | [virtual] |
| void QueueProxy::startCollectionIfNeeded | ( | wns::scheduler::ConnectionID | cid | ) | const |
Definition at line 435 of file QueueProxy.cpp.
| bool QueueProxy::supportsDynamicSegmentation | ( | ) | const [virtual] |
struct wns::scheduler::queue::QueueProxy::Colleagues wns::scheduler::queue::QueueProxy::colleagues [private] |
detail::IInnerCopyQueue* wns::scheduler::queue::QueueProxy::copyQueue_ [mutable, private] |
Definition at line 150 of file QueueProxy.hpp.
std::map<wns::scheduler::ConnectionID, wns::simulator::Time> wns::scheduler::queue::QueueProxy::lastChecked_ [mutable, private] |
Definition at line 148 of file QueueProxy.hpp.
std::map<wns::scheduler::ConnectionID, wns::simulator::Time> wns::scheduler::queue::QueueProxy::lastCollected_ [mutable, private] |
Definition at line 149 of file QueueProxy.hpp.
Definition at line 152 of file QueueProxy.hpp.
Definition at line 153 of file QueueProxy.hpp.
std::string wns::scheduler::queue::QueueProxy::queueManagerServiceName_ [private] |
Definition at line 145 of file QueueProxy.hpp.
Definition at line 146 of file QueueProxy.hpp.
1.5.5