
#include <pipelinestrategy.h>


Public Member Functions | |
| PipelineStrategy (int size=DEFAULT_PIPE, Strategy *st=NULL) | |
| PipelineStrategy (CkMigrateMessage *) | |
| int | getPipeSize () |
| void | commonInit () |
| void | deliverer (char *msg, int dim) |
| void | storing (char *msg) |
| void | conversePipeline (char *env, int size, int destination) |
| void | insertMessage (MessageHolder *msg) |
| Called for each message. | |
| void | doneInserting () |
| Called after all messages have been deposited in this processor. | |
| virtual void | pup (PUP::er &p) |
| Each strategy must define his own Pup interface. | |
| PUPable_decl (PipelineStrategy) | |
Protected Attributes | |
| int | pipeSize |
| int | seqNumber |
| CkQ< MessageHolder * > * | messageBuf |
| CkHashtableT< PipelineHashKey, PipelineHashObj * > | fragments |
| int | deliverHandle |
Definition at line 72 of file pipelinestrategy.h.
| PipelineStrategy::PipelineStrategy | ( | CkMigrateMessage * | ) | [inline] |
Definition at line 84 of file pipelinestrategy.h.
| int PipelineStrategy::getPipeSize | ( | ) | [inline] |
Definition at line 85 of file pipelinestrategy.h.
| void PipelineStrategy::commonInit | ( | ) |
| void PipelineStrategy::deliverer | ( | char * | msg, | |
| int | dim | |||
| ) |
| void PipelineStrategy::storing | ( | char * | msg | ) |
| void PipelineStrategy::insertMessage | ( | MessageHolder * | msg | ) | [virtual] |
| void PipelineStrategy::doneInserting | ( | void | ) | [virtual] |
Called after all messages have been deposited in this processor.
This corresponds to a call to ComlibEnd(cinst), where cinst is the ComlibInstanceHandle returned when registering the Strategy with Comlib. In higher levels this may need many ComlibEnd calls before invoking doneInserting.
Reimplemented from Strategy.
| virtual void PipelineStrategy::pup | ( | PUP::er & | p | ) | [virtual] |
| PipelineStrategy::PUPable_decl | ( | PipelineStrategy | ) |
int PipelineStrategy::pipeSize [protected] |
Definition at line 75 of file pipelinestrategy.h.
int PipelineStrategy::seqNumber [protected] |
Definition at line 77 of file pipelinestrategy.h.
CkQ<MessageHolder*>* PipelineStrategy::messageBuf [protected] |
Definition at line 78 of file pipelinestrategy.h.
CkHashtableT<PipelineHashKey, PipelineHashObj *> PipelineStrategy::fragments [protected] |
Definition at line 79 of file pipelinestrategy.h.
int PipelineStrategy::deliverHandle [protected] |
Definition at line 80 of file pipelinestrategy.h.
1.5.5