#include <GraphLabExecutor.h>
Classes | |
struct | Gather |
struct | Initialize |
struct | Scatter |
Public Member Functions | |
SyncEngine (Graph &g, Operator op) | |
void | signal (GNode node, const message_type &msg) |
void | execute () |
Private Types | |
typedef Operator::message_type | message_type |
typedef Operator::gather_type | gather_type |
typedef Graph::GraphNode | GNode |
typedef Graph::in_edge_iterator | in_edge_iterator |
typedef Graph::edge_iterator | edge_iterator |
typedef Galois::WorkList::dChunkedFIFO< 256 > | WL |
typedef std::pair< int, message_type > | Message |
typedef std::deque< Message > | MyMessages |
typedef Galois::Runtime::PerPackageStorage < MyMessages > | Messages |
Private Member Functions | |
template<bool IsFirst, typename Container1 , typename Container2 > | |
void | executeStep (Container1 &cur, Container2 &next) |
Private Attributes | |
Graph & | graph |
Operator | origOp |
Galois::LargeArray< Operator > | ops |
Messages | messages |
Galois::LargeArray< int > | scoreboard |
Galois::InsertBag< GNode > | wls [2] |
Galois::Runtime::LL::SimpleLock < true > | lock |
Static Private Attributes | |
static const bool | NeedMessages = !std::is_same<EmptyMessage,message_type>::value |
typedef Graph::edge_iterator Galois::GraphLab::SyncEngine< Graph, Operator >::edge_iterator [private] |
typedef Operator::gather_type Galois::GraphLab::SyncEngine< Graph, Operator >::gather_type [private] |
typedef Graph::GraphNode Galois::GraphLab::SyncEngine< Graph, Operator >::GNode [private] |
typedef Graph::in_edge_iterator Galois::GraphLab::SyncEngine< Graph, Operator >::in_edge_iterator [private] |
typedef std::pair<int,message_type> Galois::GraphLab::SyncEngine< Graph, Operator >::Message [private] |
typedef Operator::message_type Galois::GraphLab::SyncEngine< Graph, Operator >::message_type [private] |
typedef Galois::Runtime::PerPackageStorage<MyMessages> Galois::GraphLab::SyncEngine< Graph, Operator >::Messages [private] |
typedef std::deque<Message> Galois::GraphLab::SyncEngine< Graph, Operator >::MyMessages [private] |
typedef Galois::WorkList::dChunkedFIFO<256> Galois::GraphLab::SyncEngine< Graph, Operator >::WL [private] |
Galois::GraphLab::SyncEngine< Graph, Operator >::SyncEngine | ( | Graph & | g, | |
Operator | op | |||
) | [inline] |
void Galois::GraphLab::SyncEngine< Graph, Operator >::execute | ( | ) | [inline] |
void Galois::GraphLab::SyncEngine< Graph, Operator >::executeStep | ( | Container1 & | cur, | |
Container2 & | next | |||
) | [inline, private] |
void Galois::GraphLab::SyncEngine< Graph, Operator >::signal | ( | GNode | node, | |
const message_type & | msg | |||
) | [inline] |
Graph& Galois::GraphLab::SyncEngine< Graph, Operator >::graph [private] |
Galois::Runtime::LL::SimpleLock<true> Galois::GraphLab::SyncEngine< Graph, Operator >::lock [private] |
Messages Galois::GraphLab::SyncEngine< Graph, Operator >::messages [private] |
const bool Galois::GraphLab::SyncEngine< Graph, Operator >::NeedMessages = !std::is_same<EmptyMessage,message_type>::value [static, private] |
Galois::LargeArray<Operator> Galois::GraphLab::SyncEngine< Graph, Operator >::ops [private] |
Operator Galois::GraphLab::SyncEngine< Graph, Operator >::origOp [private] |
Galois::LargeArray<int> Galois::GraphLab::SyncEngine< Graph, Operator >::scoreboard [private] |
Galois::InsertBag<GNode> Galois::GraphLab::SyncEngine< Graph, Operator >::wls[2] [private] |