havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph > Class Template Reference

#include <visitor_queue.hpp>

Collaboration diagram for havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >:

Classes
class	visitor_queue_inserter
struct	visitor_wrapper

Public Member Functions
	visitor_queue (TGraph *_graph)
	~visitor_queue ()
void	init_visitor_traversal (vertex_locator _source_v)
void	do_visit (visitor_type &this_visitor)
void	init_visitor_traversal ()
void	queue_visitor (const visitor_type &v)

Private Types
typedef TVisitor	visitor_type
typedef termination_detection< uint64_t >	termination_detection_type
typedef TGraph	graph_type
typedef TGraph::vertex_locator	vertex_locator
typedef Queue< visitor_type >	local_queue_type
typedef mailbox_routed< visitor_wrapper >	mailbox_type

Private Member Functions
void	local_delegate_visit (const visitor_type &v)
void	process_pending_controllers ()
void	handle_mailbox_receive (visitor_wrapper vw)
void	push (const visitor_type &v)
visitor_type	pop_top ()
void	check_mailbox ()
bool	empty ()

Private Attributes
mailbox_type	m_mailbox
termination_detection_type	m_termination_detection
local_queue_type	m_localqueue_owned
local_queue_type	m_localqueue_delegates
TGraph *	m_ptr_graph
std::queue< TVisitor >	m_local_controller_queue

Detailed Description

template<typename TVisitor, template< typename T > class Queue, typename TGraph>
class havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >

Definition at line 68 of file visitor_queue.hpp.

Member Typedef Documentation

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

typedef TGraph havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::graph_type

private

Definition at line 72 of file visitor_queue.hpp.

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

typedef Queue<visitor_type> havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::local_queue_type

private

Definition at line 76 of file visitor_queue.hpp.

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

typedef mailbox_routed<visitor_wrapper> havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::mailbox_type

private

Definition at line 91 of file visitor_queue.hpp.

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

typedef termination_detection<uint64_t> havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::termination_detection_type

private

Definition at line 71 of file visitor_queue.hpp.

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

typedef TGraph::vertex_locator havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::vertex_locator

private

Definition at line 73 of file visitor_queue.hpp.

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

typedef TVisitor havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::visitor_type

private

Definition at line 69 of file visitor_queue.hpp.

Constructor & Destructor Documentation

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::visitor_queue ( TGraph *  _graph )

inline

Definition at line 96 of file visitor_queue.hpp.

    : m_mailbox(MPI_COMM_WORLD, 0)
    , m_termination_detection(MPI_COMM_WORLD, 2, 2, 3, 4)
    , m_ptr_graph(_graph) {
    //m_localqueue_owned.reserve(_graph->num_local_vertices());
    //m_localqueue_delegates.reserve(_graph->num_delegates() * 4);
  }

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::~visitor_queue ( )

inline

Definition at line 104 of file visitor_queue.hpp.

                   {
    // if(m_mailbox.comm_rank() == 0) {
    //   std::cout << "***************  Visitor Queue Statistics *****************" << std::endl;
    //   std::cout << "m_localqueue_owned.reserve  = " << m_ptr_graph->num_local_vertices() << std::endl;
    //   std::cout << "m_localqueue_owned.capacity = " << m_localqueue_owned.capacity() << std::endl;
    //   std::cout << "m_localqueue_delegates.reserve  = " << 0/*m_ptr_graph->num_delegates()*/ << std::endl;
    //   std::cout << "m_localqueue_delegates.capacity = " << m_localqueue_delegates.capacity() << std::endl;
    //   std::cout << "***********************************************************" << std::endl;
    // }
  }

Member Function Documentation

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

void havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::check_mailbox ( )

inlineprivate

Definition at line 391 of file visitor_queue.hpp.

                       {
    m_mailbox.receive(visitor_queue_inserter(this));
  }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

void havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::do_visit ( visitor_type &  this_visitor )

inline

Definition at line 180 of file visitor_queue.hpp.

                                            {
    vertex_locator v = this_visitor.vertex;
    bool ret = this_visitor.visit(*m_ptr_graph, this);
    if(ret && v.is_delegate() && m_ptr_graph->master(v) == m_mailbox.comm_rank()) {
      visitor_wrapper vw;
      vw.m_visitor = this_visitor;
      vw.set_bcast(true);
      m_mailbox.bcast(vw, visitor_queue_inserter(this));
      m_termination_detection.inc_queued(m_mailbox.comm_size());
    }
  }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

bool havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::empty ( )

inlineprivate

Definition at line 395 of file visitor_queue.hpp.

               {
    if(m_localqueue_owned.empty() && m_localqueue_delegates.empty()) {
      check_mailbox();
    }
    return m_localqueue_owned.empty() && m_localqueue_delegates.empty();
  }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

void havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::handle_mailbox_receive ( visitor_wrapper  vw )

inlineprivate

Definition at line 309 of file visitor_queue.hpp.

                                                  {
    if(vw.m_visitor.vertex.is_delegate()) {
      if(vw.m_visitor.vertex.get_bcast()) {
        //delegate_bcast(vw.m_visitor);
        if(m_ptr_graph->master(vw.m_visitor.vertex) == uint32_t(m_mailbox.comm_rank())) {
          //This is because the mailbox bcast returns to self -- this should be fixed!
          m_termination_detection.inc_completed();
        } else {
          //vw.m_visitor.pre_visit();
          //push(vw.m_visitor);
          /*  2013.10.11 -- this causes too much recursion in mailbox, trying something new....
          vw.m_visitor.visit(*m_ptr_graph, this);
          m_termination_detection.inc_completed();
          */
          m_local_controller_queue.push(vw.m_visitor);
        }
      } else {
        assert(m_ptr_graph->master(vw.m_visitor.vertex) == uint32_t(m_mailbox.comm_rank()));
        if(vw.m_visitor.pre_visit()) {
          //if(m_ptr_graph->master(vw.m_visitor.vertex) == m_mailbox.comm_rank()) {
            //delegate_bcast(vw.m_visitor);
            push(vw.m_visitor);
            /* This was working, trying new way for master bcast
            vw.set_bcast(true);
            vw.set_intercept(false);
            m_mailbox.bcast(vw, visitor_queue_inserter(this));
            m_termination_detection.inc_queued(m_mailbox.comm_size());*/
          //} else {
          //  delegate_parent(vw.m_visitor);
          //}
        } else {
          m_termination_detection.inc_completed();
        }
      }
    } else {
      assert(vw.m_visitor.vertex.owner() == uint32_t(m_mailbox.comm_rank()));
      //
      // Now handle owned vertices
      if(vw.m_visitor.pre_visit()) {
        push(vw.m_visitor);
      } else {
        m_termination_detection.inc_completed();
      }
    }
  }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

void havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::init_visitor_traversal ( vertex_locator  _source_v )

inline

Definition at line 152 of file visitor_queue.hpp.

                                                        {
    if(0 /*_source_v.owner()*/ == m_mailbox.comm_rank()) {
      queue_visitor(visitor_type(_source_v));
    }
    do {
      do {
      process_pending_controllers();
      while(!empty()) {
        process_pending_controllers();
        visitor_type this_visitor = pop_top();
        vertex_locator v = this_visitor.vertex;
        bool ret = this_visitor.visit(*m_ptr_graph, this);
        if(ret && v.is_delegate() && m_ptr_graph->master(v) == m_mailbox.comm_rank()) {
          visitor_wrapper vw;
          vw.m_visitor = this_visitor;
          vw.set_bcast(true);
          m_mailbox.bcast(vw, visitor_queue_inserter(this));
          m_termination_detection.inc_queued(m_mailbox.comm_size());
        }
        m_termination_detection.inc_completed();
      }
      m_mailbox.flush_buffers_if_idle();
      } while(!m_local_controller_queue.empty() || !m_mailbox.is_idle() );
      sched_yield();
    } while(!m_termination_detection.test_for_termination());
  }

Here is the call graph for this function:

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

void havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::init_visitor_traversal ( )

inline

Definition at line 192 of file visitor_queue.hpp.

                                {
    typename TGraph::controller_iterator citr = m_ptr_graph->controller_begin();
    for(; citr != m_ptr_graph->controller_end(); ++citr) {
      visitor_type v(*citr);
      if(v.pre_visit()) {  //RECENTLY ADDED 2013.10.10
        do_visit( v );
        check_mailbox();
      }
    }
    typename TGraph::vertex_iterator vitr = m_ptr_graph->vertices_begin();
    for(; vitr != m_ptr_graph->vertices_end(); ++vitr) {
      visitor_type v(*vitr);
      if(v.pre_visit()) {  //RECENTLY ADDED 2013.10.10
        do_visit( v );
        check_mailbox();
      }
    }
    do {
      do {
      process_pending_controllers();
      while(!empty()) {
        process_pending_controllers();
        visitor_type this_visitor = pop_top();
        do_visit(this_visitor);
        m_termination_detection.inc_completed();
      }
      m_mailbox.flush_buffers_if_idle();
      } while(!m_local_controller_queue.empty() || !m_mailbox.is_idle() );
    } while(!m_termination_detection.test_for_termination());
  }

Here is the call graph for this function:

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

void havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::local_delegate_visit ( const visitor_type &  v )

inlineprivate

Definition at line 244 of file visitor_queue.hpp.

                                                   {
    if(v.pre_visit()) {
      if(m_ptr_graph->master(v.vertex) == uint32_t(m_mailbox.comm_rank())) {
        //delegate_bcast(v);
        push(v);
        m_termination_detection.inc_queued();
        /*  THIS was working, but trying to change how delegates are bcast from the master
        visitor_wrapper vw;
        vw.m_visitor = v;
        vw.set_bcast(true);
        m_mailbox.bcast(vw, visitor_queue_inserter(this));
        m_termination_detection.inc_queued(m_mailbox.comm_size());*/
      } else { //send interceptable to parent
        visitor_wrapper vw;
        vw.m_visitor = v;
        vw.set_intercept(true);
        uint32_t master_rank = m_ptr_graph->master(v.vertex);
        vw.set_dest(master_rank);
        m_mailbox.send(master_rank, vw, visitor_queue_inserter(this));
        //delegate_parent(v);
        m_termination_detection.inc_queued();
      }
    }
  }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

visitor_type havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::pop_top ( )

inlineprivate

Definition at line 364 of file visitor_queue.hpp.

                         {
    check_mailbox();
    visitor_type to_return;
    assert(!(m_localqueue_delegates.empty() && m_localqueue_owned.empty()));

    /*if(m_localqueue_delegates.empty()) {
      to_return = m_localqueue_owned.top();
      m_localqueue_owned.pop();
    } else {
      if(m_localqueue_owned.empty()) {
        to_return = m_localqueue_delegates.top();
        m_localqueue_delegates.pop();
      } else {
        if(m_localqueue_delegates.top() < m_localqueue_owned.top()) {
          to_return = m_localqueue_delegates.top();
          m_localqueue_delegates.pop();
        } else {
          to_return = m_localqueue_owned.top();
          m_localqueue_owned.pop();
        }
      }
    }*/
    to_return = m_localqueue_owned.top(); m_localqueue_owned.pop();
    return to_return;
  }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

void havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::process_pending_controllers ( )

inlineprivate

Definition at line 299 of file visitor_queue.hpp.

  {
    while(!m_local_controller_queue.empty()) {
      TVisitor v = m_local_controller_queue.front();
      m_local_controller_queue.pop();
      v.visit(*m_ptr_graph, this);
      m_termination_detection.inc_completed();
    }
  }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

void havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::push ( const visitor_type &  v )

inlineprivate

Definition at line 355 of file visitor_queue.hpp.

                                   {
    /*if(v.vertex.is_delegate()) {
      m_localqueue_delegates.push(v);
    } else {
      m_localqueue_owned.push(v);
    }*/
    m_localqueue_owned.push(v);
  }

Here is the caller graph for this function:

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

void havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::queue_visitor ( const visitor_type &  v )

inline

Definition at line 223 of file visitor_queue.hpp.

                                            {
    if(v.vertex.is_delegate()) {
      local_delegate_visit(v);
    } else {
      if(v.vertex.owner() == uint32_t(m_mailbox.comm_rank())) {
        if(v.pre_visit()) {
          push(v);
          m_termination_detection.inc_queued();
        }
      } else {
        visitor_wrapper vw;
        //vw.m_dest = v.vertex.owner();
        vw.m_visitor = v;
        m_mailbox.send(v.vertex.owner(), vw, visitor_queue_inserter(this));
        m_termination_detection.inc_queued();
      }
    }
  }

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

std::queue<TVisitor> havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::m_local_controller_queue

private

Definition at line 439 of file visitor_queue.hpp.

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

local_queue_type havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::m_localqueue_delegates

private

Definition at line 437 of file visitor_queue.hpp.

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

local_queue_type havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::m_localqueue_owned

private

Definition at line 436 of file visitor_queue.hpp.

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

mailbox_type havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::m_mailbox

private

Definition at line 434 of file visitor_queue.hpp.

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

TGraph* havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::m_ptr_graph

private

Definition at line 438 of file visitor_queue.hpp.

template<typename TVisitor , template< typename T > class Queue, typename TGraph >

termination_detection_type havoqgt::mpi::visitor_queue< TVisitor, Queue, TGraph >::m_termination_detection

private

Definition at line 435 of file visitor_queue.hpp.

---

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

• include/havoqgt/visitor_queue.hpp