test_pipegraph.cxx File Reference

#include "WireCellPgraph/Graph.h"
#include <iostream>
#include <sstream>

Go to the source code of this file.

Classes
class	IdNode
class	Source< OutputType >
class	Sink< InputType >
class	Njoin
class	SplitQueueBuffer
class	Nfan
class	Func

Functions
int	main ()

Function Documentation

int main

(

void

)

Definition at line 189 of file test_pipegraph.cxx.

           {
    using Pgraph::Node;
    using Pgraph::Graph;

    int count = 0;
    auto src1 = new Source(count++, 0,4);
    auto src2 = new Source(count++, 10,14);
    auto dst1 = new Sink(count++);
    auto dst2 = new Sink(count++);
    auto fun1 = new Func(count++);
    auto fun2 = new Func(count++);
    auto fun3 = new Func(count++);
    auto fan1 = new Nfan(count++, 2);
    auto joi1 = new Njoin(count++, 2);
    auto sqb1 = new SplitQueueBuffer(count++);
    

    Graph g;
    g.connect(src1,fun1);
    g.connect(fun1,fan1);
    g.connect(fan1,dst1);
    g.connect(fan1,fun2,1);
    g.connect(fun2,joi1);
    g.connect(src2,fun3);
    g.connect(fun3,joi1,0,1);
    g.connect(joi1,sqb1);
    g.connect(sqb1,dst2);

    auto sorted = g.sort_kahn();
    cout << "Sorted to " << sorted.size() << " nodes\n";

    for (size_t ind=0; ind<sorted.size(); ++ind) {
        IdNode* idn = dynamic_cast<IdNode*>(sorted[ind]);
        idn->msg("at index ") << ind << endl;
    }
    cout << "Executing:\n";

    g.execute();

}