CkQ< T > Class Template Reference

A single-ended FIFO queue. More...

#include <cklists.h>

Inheritance diagram for CkQ< T >:

[legend]

Collaboration diagram for CkQ< T >:

[legend]

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)
T &	peek ()
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

---

Detailed Description

template<class T>
class CkQ< T >

A single-ended FIFO queue.

See CkMsgQ if T is a Charm++ message type.

Definition at line 35 of file cklists.h.

---

Constructor & Destructor Documentation

template<class T>

CkQ< T >::CkQ

(

)

[inline]

Definition at line 56 of file cklists.h.

template<class T>

CkQ< T >::CkQ

(

int

sz

)

[inline]

Definition at line 57 of file cklists.h.

template<class T>

CkQ< T >::~CkQ

(

)

[inline]

Definition at line 64 of file cklists.h.

---

Member Function Documentation

template<class T>

void CkQ< T >::_expand

(

void

)

[inline, private]

Definition at line 41 of file cklists.h.

Referenced by CkQ< char * >::enq(), CkQ< char * >::insert(), and CkQ< char * >::push().

template<class T>

int CkQ< T >::length

(

void

)

[inline]

Definition at line 65 of file cklists.h.

Referenced by _removeProcessedLogHandler(), _ticketHandler(), batchHandleCorrectionMsg(), bgAddProjEvent(), BgAdjustTimeLineByIndex(), BgAdjustTimeLineFromIndex(), BgFinishCorrection(), BgIntegrityCheck(), BgLogEntryCommit(), bgUpdateProj(), BgWriteThreadTimeLine(), CkArrayBroadcaster::bringUpToDate(), CkGroupReadyCallback::callBuffered(), CkArrayReductionMgr::collectAllMessages(), correctMsgTime(), HashQueueT< CkFutureID, iget_token_struct >::deq(), RouterStrategy::doneInserting(), Router::EachToManyMulticastQ(), HypercubeRouter::EachToManyMulticastQ(), GridRouter::EachToManyMulticastQ(), DimexRouter::EachToManyMulticastQ(), win_obj::emptyQueue(), enqueueCorrectionMsg(), findLeastTime(), CkReductionMgr::finishReduction(), CpdList_msgStack::getLength(), AmpiSeqQ::getOutOfOrder(), BgTimeLineRec::getTimeLogOnThread(), handleCorrectionMsg(), liveVizPollArray::init(), CkLocRec_local::isObsolete(), HashQueueT< CkFutureID, iget_token_struct >::key_deq(), HashQueueT< CkFutureID, iget_token_struct >::key_find(), BgTimeLineRec::length(), liveVizPollArray::liveVizPoll0Deposit(), BgTimeLineRec::logEntryClose(), BgTimeLineRec::logEntryInsert(), BgTimeLineRec::logSplit(), processCorrectionMsg(), CpdList_msgStack::pup(), ChareMlogData::pup(), pupCkQ(), CkArrayReductionMgr::reduceMessages(), removeProcessedLogs(), liveVizPollArray::request(), resendMessageForChare(), sendCheckpointData(), PrefixRouter::sendPointToPoint(), BgTimeLineRec::setStartIdx(), CkArrayBroadcaster::springCleaning(), CkSema::waitN(), and BgTimeLineRec::~BgTimeLineRec().

template<class T>

int CkQ< T >::isEmpty

(

void

)

[inline]

Definition at line 66 of file cklists.h.

Referenced by CkLocRec_local::addedElement(), RecBisectBfLB::addToQ(), TraceProjections::beginExecute(), CkMulticastMgr::childrenReady(), CkExit(), BgTimeLineRec::clearSendingLogs(), PrefixRouter::EachToManyMulticastQ(), TraceProjections::endExecute(), CkReductionMgr::finishReduction(), CkReductionMgr::flushStates(), CkArrayReductionMgr::flushStates(), CkSemaPool::getNew(), CkMulticastMgr::recvPacket(), and PrefixRouter::sendMulticast().

template<class T>

T CkQ< T >::deq

(

void

)

[inline]

Definition at line 67 of file cklists.h.

Referenced by CkLocRec_local::addedElement(), RecBisectBfLB::addToQ(), batchHandleCorrectionMsg(), CkArrayBroadcaster::bringUpToDate(), CkGroupReadyCallback::callBuffered(), CkMulticastMgr::childrenReady(), SerialTree::ChildSearch(), CkCreateLocalGroup(), CkCreateLocalNodeGroup(), CkExit(), BgTimeLineRec::clearSendingLogs(), CkArrayReductionMgr::collectAllMessages(), CpdAfterEp(), QdState::deq(), HashQueueT< CkFutureID, iget_token_struct >::deq(), win_obj::dequeue(), Router::EachToManyMulticastQ(), HypercubeRouter::EachToManyMulticastQ(), GridRouter::EachToManyMulticastQ(), DimexRouter::EachToManyMulticastQ(), TraceProjections::endExecute(), VidBlock::fill(), CkReductionMgr::finishReduction(), CkArrayBroadcaster::flushState(), CkReductionMgr::flushStates(), CkArrayReductionMgr::flushStates(), InBuffer::getMessage(), CkSemaPool::getNew(), AmpiSeqQ::getOutOfOrder(), liveVizPollArray::liveVizPoll0Deposit(), win_obj::lockTopQueue(), CkArrayReductionMgr::reduceMessages(), removeProcessedLogs(), liveVizPollArray::request(), PrefixRouter::sendMulticast(), PrefixRouter::sendPointToPoint(), CkArrayBroadcaster::springCleaning(), BgNode::startCommTh(), CkSema::wait(), CkSema::waitN(), CkArrayBroadcaster::~CkArrayBroadcaster(), and SerialTree::~SerialTree().

template<class T>

void CkQ< T >::enq

(

const T &

elt

)

[inline]

Definition at line 75 of file cklists.h.

Referenced by _removeProcessedLogHandler(), CkReductionMgr::addContribution(), ChareMlogData::addLogEntry(), BgNode::addMessage(), RecBisectBfLB::addToQ(), batchHandleCorrectionMsg(), TraceProjections::beginExecute(), BgAdjustTimeLineFromIndex(), CkArrayBroadcaster::bringUpToDate(), CkGroupReadyCallback::callMeBack(), CkArrayReductionMgr::collectAllMessages(), CkArrayReductionMgr::contributeArrayReduction(), CkLocRec_local::deliver(), BgTimeLineRec::enq(), QdState::enq(), RecBisectBfLB::enqChildren(), TableEntry::enqMsg(), win_obj::enqueue(), enqueueCorrectionMsg(), CkReductionMgr::finishReduction(), AmpiSeqQ::getOutOfOrder(), CkArrayBroadcaster::incoming(), HashQueueT< CkFutureID, iget_token_struct >::key_enq(), liveVizPollArray::liveVizPoll0Deposit(), RecBisectBfLB::partitionInTwo(), BgTimeLineRec::pup(), ChareMlogData::pup(), pupCkQ(), InBuffer::putMessage(), AmpiSeqQ::putOutOfOrder(), CkMulticastMgr::recvMsg(), CkMulticastMgr::recvPacket(), registerExitFn(), CkSemaPool::release(), removeProcessedLogs(), liveVizPollArray::request(), SerialTree::Search(), VidBlock::send(), CkSema::signal(), and BgTimeLineRec::winPup().

template<class T>

void CkQ< T >::push

(

const T &

elt

)

[inline]

Definition at line 81 of file cklists.h.

Referenced by CpdBeforeEp(), RouterStrategy::doneInserting(), and RouterStrategy::insertMessage().

template<class T>

T& CkQ< T >::peek

(

)

[inline]

Definition at line 88 of file cklists.h.

Referenced by CpdAfterEp(), CpdBeforeEp(), CpdGetCurrentMsg(), CpdGetCurrentObject(), and TraceProjections::endExecute().

template<class T>

void CkQ< T >::insert	(	int	pos,
		const T &	elt
	)			[inline]

Definition at line 92 of file cklists.h.

Referenced by HashQueueT< CkFutureID, iget_token_struct >::HashQueueT(), HashQueueT< CkFutureID, iget_token_struct >::key_promote(), win_obj::lockTopQueue(), and HashQueueT< CkFutureID, iget_token_struct >::updatetable().

template<class T>

T CkQ< T >::remove

(

int

pos

)

[inline]

Definition at line 101 of file cklists.h.

Referenced by BgAdjustTimeLineByIndex(), BgAdjustTimeLineFromIndex(), and HashQueueT< CkFutureID, iget_token_struct >::key_deq().

template<class T>

void CkQ< T >::removeFrom

(

int

pos

)

[inline]

Definition at line 110 of file cklists.h.

Referenced by BgAdjustTimeLineByIndex(), and BgAdjustTimeLineFromIndex().

template<class T>

T& CkQ< T >::operator[]

(

size_t

n

)

[inline]

Definition at line 115 of file cklists.h.

template<class T>

T* CkQ< T >::getArray

(

void

)

[inline]

Definition at line 121 of file cklists.h.

template<class T>

void CkQ< T >::pup

(

PUP::er &

p

)

[inline]

Reimplemented in CkMsgQ< MSG >, CkMsgQ< liveVizRequestMsg >, CkMsgQ< AmpiMsg >, and CkMsgQ< CkReductionMsg >.

Definition at line 133 of file cklists.h.

Referenced by BgTimeLineRec::pup().

---

Field Documentation

template<class T>

T* CkQ< T >::block [private]

Definition at line 36 of file cklists.h.

template<class T>

int CkQ< T >::blklen [private]

Definition at line 37 of file cklists.h.

Referenced by CkQ< char * >::_expand(), CkQ< char * >::CkQ(), CkQ< char * >::enq(), CkQ< char * >::insert(), and CkQ< char * >::push().

template<class T>

int CkQ< T >::first [private]

Definition at line 38 of file cklists.h.

Referenced by CkQ< char * >::_expand(), CkQ< char * >::deq(), CkQ< char * >::enq(), CkQ< char * >::getArray(), CkQ< char * >::insert(), CkQ< char * >::operator[](), CkQ< char * >::peek(), CkQ< char * >::push(), and CkQ< char * >::remove().

template<class T>

int CkQ< T >::len [private]

Definition at line 39 of file cklists.h.

Referenced by CkQ< char * >::deq(), CkQ< char * >::enq(), CkQ< char * >::getArray(), CkQ< char * >::insert(), CkQ< char * >::isEmpty(), CkQ< char * >::length(), CkQ< char * >::push(), CkQ< char * >::remove(), and CkQ< char * >::removeFrom().

template<class T>

int CkQ< T >::mask [private]

Definition at line 40 of file cklists.h.

Referenced by CkQ< char * >::_expand(), CkQ< char * >::CkQ(), CkQ< char * >::deq(), CkQ< char * >::enq(), CkQ< char * >::getArray(), CkQ< char * >::insert(), CkQ< char * >::operator[](), CkQ< char * >::push(), and CkQ< char * >::remove().

---

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

• util/cklists.h