ceph/src/boost/libs/graph_parallel/include/boost/graph/distributed/adjlist/handlers.hpp

   1 // Copyright (C) 2007 Douglas Gregor
   2
   3 // Use, modification and distribution is subject to the Boost Software
   4 // License, Version 1.0. (See accompanying file LICENSE_1_0.txt or copy at
   5 // http://www.boost.org/LICENSE_1_0.txt)
   6
   7 // This file contains code for the distributed adjacency list's
   8 // message handlers. It should not be included directly by users.
   9
  10 #ifndef BOOST_GRAPH_DISTRIBUTED_ADJLIST_HANDLERS_HPP
  11 #define BOOST_GRAPH_DISTRIBUTED_ADJLIST_HANDLERS_HPP
  12
  13 #ifndef BOOST_GRAPH_USE_MPI
  14 #error "Parallel BGL files should not be included unless <boost/graph/use_mpi.hpp> has been included"
  15 #endif
  16
  17 #include <boost/graph/parallel/simple_trigger.hpp>
  18 #include <boost/graph/parallel/detail/untracked_pair.hpp>
  19
  20 namespace boost {
  21
  22 template<PBGL_DISTRIB_ADJLIST_TEMPLATE_PARMS>
  23 void
  24 PBGL_DISTRIB_ADJLIST_TYPE::
  25 setup_triggers()
  26 {
  27   using boost::graph::parallel::simple_trigger;
  28
  29   simple_trigger(process_group_, msg_add_vertex_with_property, this,
  30                  &adjacency_list::handle_add_vertex_with_property);
  31   simple_trigger(process_group_, msg_add_vertex_with_property_and_reply, this,
  32                  &adjacency_list::handle_add_vertex_with_property_and_reply);
  33   simple_trigger(process_group_, msg_add_edge, this,
  34                  &adjacency_list::handle_add_edge);
  35   simple_trigger(process_group_, msg_add_edge_with_reply, this,
  36                  &adjacency_list::handle_add_edge_with_reply);
  37   simple_trigger(process_group_, msg_add_edge_with_property, this,
  38                  &adjacency_list::handle_add_edge_with_property);
  39   simple_trigger(process_group_,  msg_add_edge_with_property_and_reply, this,
  40                  &adjacency_list::handle_add_edge_with_property_and_reply);
  41   simple_trigger(process_group_, msg_nonlocal_edge, this,
  42                  &adjacency_list::handle_nonlocal_edge);
  43   simple_trigger(process_group_, msg_remove_edge, this,
  44                  &adjacency_list::handle_remove_edge);
  45 }
  46
  47 template<PBGL_DISTRIB_ADJLIST_TEMPLATE_PARMS>
  48 void
  49 PBGL_DISTRIB_ADJLIST_TYPE::
  50 handle_add_vertex_with_property(int source, int tag,
  51                                 const vertex_property_type& data,
  52                                 trigger_receive_context)
  53 {
  54   vertex_descriptor v(this->processor(),
  55                       add_vertex(this->build_vertex_property(data),
  56                                  this->base()));
  57   if (on_add_vertex)
  58     on_add_vertex(v, *this);
  59 }
  60
  61 template<PBGL_DISTRIB_ADJLIST_TEMPLATE_PARMS>
  62 typename PBGL_DISTRIB_ADJLIST_TYPE::local_vertex_descriptor
  63 PBGL_DISTRIB_ADJLIST_TYPE::
  64 handle_add_vertex_with_property_and_reply(int source, int tag,
  65                                           const vertex_property_type& data,
  66                                           trigger_receive_context)
  67 {
  68   // Try to find a vertex with this name
  69   local_vertex_descriptor local_v
  70     = add_vertex(this->build_vertex_property(data), this->base());
  71
  72   vertex_descriptor v(processor(), local_v);
  73   if (on_add_vertex)
  74     on_add_vertex(v, *this);
  75
  76   return local_v;
  77 }
  78
  79 template<PBGL_DISTRIB_ADJLIST_TEMPLATE_PARMS>
  80 void
  81 PBGL_DISTRIB_ADJLIST_TYPE::
  82 handle_add_edge(int source, int tag, const msg_add_edge_data& data,
  83                 trigger_receive_context)
  84 {
  85   add_edge(vertex_descriptor(processor(), data.source),
  86            data.target, *this);
  87 }
  88
  89 template<PBGL_DISTRIB_ADJLIST_TEMPLATE_PARMS>
  90 boost::parallel::detail::untracked_pair<typename PBGL_DISTRIB_ADJLIST_TYPE::edge_descriptor, bool>
  91 PBGL_DISTRIB_ADJLIST_TYPE::
  92 handle_add_edge_with_reply(int source, int tag, const msg_add_edge_data& data,
  93                            trigger_receive_context)
  94 {
  95   std::pair<typename PBGL_DISTRIB_ADJLIST_TYPE::edge_descriptor, bool> p =
  96     add_edge(vertex_descriptor(processor(), data.source),data.target, *this);
  97   return p;
  98 }
  99
 100 template<PBGL_DISTRIB_ADJLIST_TEMPLATE_PARMS>
 101 void
 102 PBGL_DISTRIB_ADJLIST_TYPE::
 103 handle_add_edge_with_property(int source, int tag,
 104                               const msg_add_edge_with_property_data& data,
 105                               trigger_receive_context)
 106 {
 107   add_edge(vertex_descriptor(processor(), data.source),
 108            data.target, data.get_property(), *this);
 109 }
 110
 111 template<PBGL_DISTRIB_ADJLIST_TEMPLATE_PARMS>
 112 boost::parallel::detail::untracked_pair<typename PBGL_DISTRIB_ADJLIST_TYPE::edge_descriptor, bool>
 113 PBGL_DISTRIB_ADJLIST_TYPE::
 114 handle_add_edge_with_property_and_reply
 115   (int source, int tag,
 116    const msg_add_edge_with_property_data& data,
 117    trigger_receive_context)
 118 {
 119   std::pair<typename PBGL_DISTRIB_ADJLIST_TYPE::edge_descriptor, bool> p =
 120     add_edge(vertex_descriptor(processor(), data.source),
 121                   data.target, data.get_property(), *this);
 122   return p;
 123 }
 124
 125 template<PBGL_DISTRIB_ADJLIST_TEMPLATE_PARMS>
 126 void
 127 PBGL_DISTRIB_ADJLIST_TYPE::
 128 handle_nonlocal_edge(int source, int tag,
 129                      const msg_nonlocal_edge_data& data,
 130                      trigger_receive_context)
 131 {
 132   add_remote_edge(data, source, directed_selector());
 133 }
 134
 135 template<PBGL_DISTRIB_ADJLIST_TEMPLATE_PARMS>
 136 void
 137 PBGL_DISTRIB_ADJLIST_TYPE::
 138 handle_remove_edge(int source, int tag,
 139                    const msg_remove_edge_data& data,
 140                    trigger_receive_context)
 141 {
 142   remove_local_edge(data, source, directed_selector());
 143 }
 144
 145 }
 146
 147 #endif // BOOST_GRAPH_DISTRIBUTED_ADJLIST_HANDLERS_HPP
 148