PrioStreaming Class Reference
[Strategies for use in Charm++]

Class that streams messages the same way as StreamingStrategy, but adding a bypass for high priority messages to be flushed immediately. More...

#include <PrioStreaming.h>

Inheritance diagram for PrioStreaming:

[legend]

Collaboration diagram for PrioStreaming:

[legend]

Public Member Functions
	PrioStreaming (int periodMs=DEFAULT_TIMEOUT, int bufferMax=MAX_NUM_STREAMING_MESSAGES, int prio=0, int msgSizeMax=MAX_STREAMING_MESSAGE_SIZE, int bufSizeMAX=MAX_STREAMING_MESSAGE_SIZE *MAX_NUM_STREAMING_MESSAGES)
	Create a priority based streaming strategy, suitable for passing to ComlibManager.
	PrioStreaming (CkMigrateMessage *m)
void	insertMessage (MessageHolder *msg)
virtual void	insertMessage (CharmMessageHolder *msg)
void	setBasePriority (int p)
virtual void	pup (PUP::er &p)
	PUPable_decl (PrioStreaming)
Protected Attributes
int	basePriority
CkVec< int >	minPrioVec

---

Detailed Description

Class that streams messages the same way as StreamingStrategy, but adding a bypass for high priority messages to be flushed immediately.

These are the criteria for flushing all pending messages:

• it's been at least period (in ms) since the last flush, or
• the processor just went idle.

These criteria flush a single E's pending messages:

• more than bufferMax messages to buffered for one PE.
• Current message is a high priority message

Definition at line 29 of file PrioStreaming.h.

---

Constructor & Destructor Documentation

PrioStreaming::PrioStreaming

(

CkMigrateMessage *

m

)

[inline]

Definition at line 55 of file PrioStreaming.h.

---

Member Function Documentation

void PrioStreaming::insertMessage

(

MessageHolder *

msg

)

[inline]

Definition at line 57 of file PrioStreaming.h.

void PrioStreaming::setBasePriority

(

int

p

)

[inline]

Definition at line 62 of file PrioStreaming.h.

References basePriority, Converse::CkNumPes(), and minPrioVec.

PrioStreaming::PUPable_decl

(

PrioStreaming

)

---

Field Documentation

int PrioStreaming::basePriority [protected]

Definition at line 31 of file PrioStreaming.h.

Referenced by insertMessage(), pup(), and setBasePriority().

CkVec<int> PrioStreaming::minPrioVec [protected]

Definition at line 32 of file PrioStreaming.h.

Referenced by insertMessage(), pup(), and setBasePriority().

---

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

• ck-com/PrioStreaming.h
• ck-com/PrioStreaming.C