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(), CkArrayBroadcaster::bringUpToDate(), CkGroupReadyCallback::callBuffered(), CkNodeReductionMgr::clearBlockedMsgs(), CkArrayReductionMgr::collectAllMessages(), CpdInUserCode(), HashQueueT< CkFutureID, iget_token_struct >::deq(), CkNodeReductionMgr::doAddContribution(), RouterStrategy::doneInserting(), CkNodeReductionMgr::doRecvMsg(), Router::EachToManyMulticastQ(), HypercubeRouter::EachToManyMulticastQ(), GridRouter::EachToManyMulticastQ(), DimexRouter::EachToManyMulticastQ(), win_obj::emptyQueue(), CkReductionMgr::endArrayReduction(), CkNodeReductionMgr::findMaxRedNo(), CkNodeReductionMgr::finishReduction(), CkReductionMgr::finishReduction(), CpdList_msgStack::getLength(), AmpiSeqQ::getOutOfOrder(), liveVizPollArray::init(), CkLocRec_local::isObsolete(), HashQueueT< CkFutureID, iget_token_struct >::key_deq(), HashQueueT< CkFutureID, iget_token_struct >::key_find(), CkNodeReductionMgr::LateMigrantMsg(), liveVizPollArray::liveVizPoll0Deposit(), CpdList_msgStack::pup(), ChareMlogData::pup(), pupCkQ(), CkNodeReductionMgr::reduceMessages(), CkReductionMgr::reduceMessages(), CkArrayReductionMgr::reduceMessages(), removeProcessedLogs(), liveVizPollArray::request(), resendMessageForChare(), sendCheckpointData(), PrefixRouter::sendPointToPoint(), CkArrayBroadcaster::springCleaning(), and CkSema::waitN().

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(), PrefixRouter::EachToManyMulticastQ(), TraceProjections::endExecute(), CkNodeReductionMgr::flushStates(), 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(), CkArrayBroadcaster::bringUpToDate(), CkGroupReadyCallback::callBuffered(), CkMulticastMgr::childrenReady(), SerialTree::ChildSearch(), CkCreateLocalGroup(), CkCreateLocalNodeGroup(), CkNodeReductionMgr::clearBlockedMsgs(), CkArrayReductionMgr::collectAllMessages(), CpdAfterEp(), QdState::deq(), HashQueueT< CkFutureID, iget_token_struct >::deq(), win_obj::dequeue(), Router::EachToManyMulticastQ(), HypercubeRouter::EachToManyMulticastQ(), GridRouter::EachToManyMulticastQ(), DimexRouter::EachToManyMulticastQ(), CkReductionMgr::endArrayReduction(), TraceProjections::endExecute(), VidBlock::fill(), CkNodeReductionMgr::finishReduction(), CkReductionMgr::finishReduction(), CkArrayBroadcaster::flushState(), CkNodeReductionMgr::flushStates(), CkReductionMgr::flushStates(), CkArrayReductionMgr::flushStates(), CkSemaPool::getNew(), AmpiSeqQ::getOutOfOrder(), liveVizPollArray::liveVizPoll0Deposit(), win_obj::lockTopQueue(), CkNodeReductionMgr::reduceMessages(), CkReductionMgr::reduceMessages(), CkArrayReductionMgr::reduceMessages(), removeProcessedLogs(), liveVizPollArray::request(), PrefixRouter::sendMulticast(), PrefixRouter::sendPointToPoint(), CkArrayBroadcaster::springCleaning(), 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(), RecBisectBfLB::addToQ(), CkReductionMgr::ArrayReductionHandler(), TraceProjections::beginExecute(), CkArrayBroadcaster::bringUpToDate(), CkGroupReadyCallback::callMeBack(), CkArrayReductionMgr::collectAllMessages(), CkArrayReductionMgr::contributeArrayReduction(), CkLocRec_local::deliver(), CkNodeReductionMgr::doAddContribution(), CkNodeReductionMgr::doRecvMsg(), CkReductionMgr::endArrayReduction(), QdState::enq(), RecBisectBfLB::enqChildren(), TableEntry::enqMsg(), win_obj::enqueue(), CkNodeReductionMgr::finishReduction(), CkReductionMgr::finishReduction(), AmpiSeqQ::getOutOfOrder(), CkArrayBroadcaster::incoming(), HashQueueT< CkFutureID, iget_token_struct >::key_enq(), CkNodeReductionMgr::LateMigrantMsg(), liveVizPollArray::liveVizPoll0Deposit(), RecBisectBfLB::partitionInTwo(), ChareMlogData::pup(), pupCkQ(), AmpiSeqQ::putOutOfOrder(), CkMulticastMgr::recvMsg(), CkReductionMgr::RecvMsg(), CkMulticastMgr::recvPacket(), registerExitFn(), CkSemaPool::release(), removeProcessedLogs(), liveVizPollArray::request(), SerialTree::Search(), VidBlock::send(), and CkSema::signal().

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(), CpdInUserCode(), 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 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.

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.

---

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