#include <cklists.h>
Inheritance diagram for CkQ< T >:


Public Member Functions | |
| CkQ () | |
| CkQ (int sz) | |
| ~CkQ () | |
| int | length (void) |
| int | isEmpty (void) |
| T | deq (void) |
| void | enq (const T &elt) |
| void | push (const T &elt) |
| void | insert (int pos, const T &elt) |
| T | remove (int pos) |
| void | removeFrom (int pos) |
| T & | operator[] (size_t n) |
| T * | getArray (void) |
| void | pup (PUP::er &p) |
Private Member Functions | |
| void | _expand (void) |
Private Attributes | |
| T * | block |
| int | blklen |
| int | first |
| int | len |
| int | mask |
See CkMsgQ if T is a Charm++ message type.
Definition at line 35 of file cklists.h.
Definition at line 41 of file cklists.h.
Referenced by CkQ< CharmStrategy * >::enq(), CkQ< CharmStrategy * >::insert(), and CkQ< CharmStrategy * >::push().
Definition at line 65 of file cklists.h.
Referenced by batchHandleCorrectionMsg(), bgAddProjEvent(), BgAdjustTimeLineByIndex(), BgAdjustTimeLineFromIndex(), BgFinishCorrection(), BgIntegrityCheck(), BgLogEntryCommit(), bgUpdateProj(), BgWriteThreadTimeLine(), CkArrayBroadcaster::bringUpToDate(), ComlibManager::broadcastStrategies(), CkGroupReadyCallback::callBuffered(), CkNodeReductionMgr::clearBlockedMsgs(), CkArrayReductionMgr::collectAllMessages(), correctMsgTime(), HashQueueT< KEY, OBJ >::deq(), CkNodeReductionMgr::doAddContribution(), NodeMulticast::doneInserting(), CkNodeReductionMgr::doRecvMsg(), Router::EachToManyMulticastQ(), GridRouter::EachToManyMulticastQ(), DimexRouter::EachToManyMulticastQ(), win_obj::emptyQueue(), CkReductionMgr::endArrayReduction(), enqueueCorrectionMsg(), findLeastTime(), CkNodeReductionMgr::findMaxRedNo(), CkNodeReductionMgr::finishReduction(), CkReductionMgr::finishReduction(), CkMessageReplay::flush(), MeshStreamingStrategy::FlushColumn(), MeshStreamingStrategy::FlushRow(), AmpiSeqQ::getOutOfOrder(), BgTimeLineRec::getTimeLogOnThread(), liveVizPollArray::init(), CkLocRec_local::isObsolete(), HashQueueT< KEY, OBJ >::key_deq(), HashQueueT< KEY, OBJ >::key_find(), CkNodeReductionMgr::LateMigrantMsg(), BgTimeLineRec::length(), liveVizPollArray::liveVizPoll0Deposit(), BgTimeLineRec::logEntryClose(), BgTimeLineRec::logEntryInsert(), processCorrectionMsg(), pupCkQ(), ComlibManager::receiveRemoteSend(), CkNodeReductionMgr::reduceMessages(), CkReductionMgr::reduceMessages(), CkArrayReductionMgr::reduceMessages(), liveVizPollArray::request(), PrefixRouter::sendPointToPoint(), ComlibManager::sendRemote(), BgTimeLineRec::setStartIdx(), CkArrayBroadcaster::springCleaning(), CkSema::waitN(), and BgTimeLineRec::~BgTimeLineRec().
Definition at line 66 of file cklists.h.
Referenced by CkLocRec_local::addedElement(), RecBisectBfLB::addToQ(), CkMulticastMgr::childrenReady(), BgTimeLineRec::clearSendingLogs(), PipelineStrategy::doneInserting(), PipeBroadcastConverse::doneInserting(), PipeBroadcastStrategy::doneInserting(), PrefixRouter::EachToManyMulticastQ(), CkNodeReductionMgr::flushStates(), CkReductionMgr::flushStates(), CkArrayReductionMgr::flushStates(), CkSemaPool::getNew(), CkMulticastMgr::recvPacket(), and PrefixRouter::sendMulticast().
Definition at line 67 of file cklists.h.
Referenced by CkLocRec_local::addedElement(), RecBisectBfLB::addToQ(), batchHandleCorrectionMsg(), CkArrayBroadcaster::bringUpToDate(), ComlibManager::broadcastStrategies(), CkGroupReadyCallback::callBuffered(), CkMulticastMgr::childrenReady(), SerialTree::ChildSearch(), CkCreateLocalGroup(), CkCreateLocalNodeGroup(), CkNodeReductionMgr::clearBlockedMsgs(), BgTimeLineRec::clearSendingLogs(), CkArrayReductionMgr::collectAllMessages(), QdState::deq(), HashQueueT< KEY, OBJ >::deq(), win_obj::dequeue(), PipelineStrategy::doneInserting(), PipeBroadcastConverse::doneInserting(), PipeBroadcastStrategy::doneInserting(), NodeMulticast::doneInserting(), Router::EachToManyMulticastQ(), GridRouter::EachToManyMulticastQ(), DimexRouter::EachToManyMulticastQ(), CkReductionMgr::endArrayReduction(), VidBlock::fill(), CkNodeReductionMgr::finishReduction(), CkReductionMgr::finishReduction(), CkMessageReplay::flush(), MeshStreamingStrategy::FlushColumn(), StreamingStrategy::flushPE(), CkArrayBroadcaster::flushState(), CkNodeReductionMgr::flushStates(), CkReductionMgr::flushStates(), CkArrayReductionMgr::flushStates(), InBuffer::getMessage(), CkSemaPool::getNew(), AmpiSeqQ::getOutOfOrder(), liveVizPollArray::liveVizPoll0Deposit(), win_obj::lockTopQueue(), MsgPacker::MsgPacker(), ComlibManager::receiveRemoteSend(), CkNodeReductionMgr::reduceMessages(), CkReductionMgr::reduceMessages(), CkArrayReductionMgr::reduceMessages(), liveVizPollArray::request(), PrefixRouter::sendMulticast(), PrefixRouter::sendPointToPoint(), ComlibManager::sendRemote(), CkArrayBroadcaster::springCleaning(), BgNode::startCommTh(), CkSema::wait(), CkSema::waitN(), CkArrayBroadcaster::~CkArrayBroadcaster(), and SerialTree::~SerialTree().
Definition at line 75 of file cklists.h.
Referenced by CkReductionMgr::addContribution(), BgNode::addMessage(), RecBisectBfLB::addToQ(), CkReductionMgr::ArrayReductionHandler(), ComlibManager::ArraySend(), batchHandleCorrectionMsg(), BgAdjustTimeLineFromIndex(), CkArrayBroadcaster::bringUpToDate(), CkGroupReadyCallback::callMeBack(), CkArrayReductionMgr::collectAllMessages(), ComlibManager::collectStats(), CkArrayReductionMgr::contributeArrayReduction(), CkLocRec_local::deliver(), CkNodeReductionMgr::doAddContribution(), CkNodeReductionMgr::doRecvMsg(), CkReductionMgr::endArrayReduction(), BgTimeLineRec::enq(), QdState::enq(), RecBisectBfLB::enqChildren(), TableEntry::enqMsg(), win_obj::enqueue(), CkNodeReductionMgr::finishReduction(), CkMessageReplay::flush(), AmpiSeqQ::getOutOfOrder(), CkArrayBroadcaster::incoming(), MeshStreamingStrategy::InsertIntoRowBucket(), PipelineStrategy::insertMessage(), PipeBroadcastConverse::insertMessage(), StreamingStrategy::insertMessage(), PrioStreaming::insertMessage(), PipeBroadcastStrategy::insertMessage(), NodeMulticast::insertMessage(), MeshStreamingStrategy::insertMessage(), HashQueueT< KEY, OBJ >::key_enq(), CkNodeReductionMgr::LateMigrantMsg(), liveVizPollArray::liveVizPoll0Deposit(), RecBisectBfLB::partitionInTwo(), CkMessageReplay::processMessage(), BgTimeLineRec::pup(), pupCkQ(), InBuffer::putMessage(), AmpiSeqQ::putOutOfOrder(), CkMulticastMgr::recvMsg(), CkMulticastMgr::recvPacket(), ComlibManager::registerStrategy(), CkSemaPool::release(), liveVizPollArray::request(), SerialTree::Search(), VidBlock::send(), and CkSema::signal().
Definition at line 81 of file cklists.h.
Referenced by RouterStrategy::DummyEP(), RouterStrategy::ProcManyMsg(), and RouterStrategy::RecvManyMsg().
Definition at line 88 of file cklists.h.
Referenced by HashQueueT< KEY, OBJ >::HashQueueT(), HashQueueT< KEY, OBJ >::key_promote(), win_obj::lockTopQueue(), and HashQueueT< KEY, OBJ >::updatetable().
Definition at line 97 of file cklists.h.
Referenced by BgAdjustTimeLineByIndex(), BgAdjustTimeLineFromIndex(), and HashQueueT< KEY, OBJ >::key_deq().
Definition at line 106 of file cklists.h.
Referenced by BgAdjustTimeLineByIndex(), and BgAdjustTimeLineFromIndex().
Reimplemented in CkMsgQ< MSG >, CkMsgQ< liveVizRequestMsg >, CkMsgQ< AmpiMsg >, and CkMsgQ< CkReductionMsg >.
Definition at line 129 of file cklists.h.
Referenced by BgTimeLineRec::pup().
Definition at line 37 of file cklists.h.
Referenced by CkQ< CharmStrategy * >::_expand(), CkQ< CharmStrategy * >::CkQ(), CkQ< CharmStrategy * >::enq(), CkQ< CharmStrategy * >::insert(), and CkQ< CharmStrategy * >::push().
Definition at line 38 of file cklists.h.
Referenced by CkQ< CharmStrategy * >::_expand(), CkQ< CharmStrategy * >::deq(), CkQ< CharmStrategy * >::enq(), CkQ< CharmStrategy * >::getArray(), CkQ< CharmStrategy * >::insert(), CkQ< CharmStrategy * >::operator[](), CkQ< CharmStrategy * >::push(), and CkQ< CharmStrategy * >::remove().
Definition at line 39 of file cklists.h.
Referenced by CkQ< CharmStrategy * >::deq(), CkQ< CharmStrategy * >::enq(), CkQ< CharmStrategy * >::getArray(), CkQ< CharmStrategy * >::insert(), CkQ< CharmStrategy * >::isEmpty(), CkQ< CharmStrategy * >::length(), CkQ< CharmStrategy * >::push(), CkQ< CharmStrategy * >::remove(), and CkQ< CharmStrategy * >::removeFrom().
Definition at line 40 of file cklists.h.
Referenced by CkQ< CharmStrategy * >::_expand(), CkQ< CharmStrategy * >::CkQ(), CkQ< CharmStrategy * >::deq(), CkQ< CharmStrategy * >::enq(), CkQ< CharmStrategy * >::getArray(), CkQ< CharmStrategy * >::insert(), CkQ< CharmStrategy * >::operator[](), CkQ< CharmStrategy * >::push(), and CkQ< CharmStrategy * >::remove().
1.5.1