oss_src/rpc/fiber_buffered_exchange.hpp
fiber_buffered_exchange(distributed_control& dc,
                      const size_t max_buffer_size = DEFAULT_BUFFERED_EXCHANGE_SIZE) :
      rpc(dc, this),
      max_buffer_size(max_buffer_size) {
       send_buffers.resize(fiber_control::get_instance().num_workers());
       recv_buffers.resize(fiber_control::get_instance().num_workers());
       for (size_t i = 0;i < send_buffers.size(); ++i) {
         send_buffers[i].resize(dc.numprocs());
         for (size_t j = 0;j < send_buffers[i].size(); ++j) {
           send_buffers[i][j].oarc = NULL;
           send_buffers[i][j].numinserts = 0;
         }
       }
       rpc.barrier();
      }
/**
     * Constructs a buffered exchange object.
     *
     * \ref dc The master distributed_control object
     * \ref max_buffer_size The size of the per thread and per target send buffer.
     */
Constructs a buffered exchange object.
\ref dc The master distributed_control object
\ref max_buffer_size The size of the per thread and per target send buffer.
Constructs a buffered exchange object . \ ref dc The master distributed_control object \ ref max_buffer_size The size of the per thread and per target send buffer .
fiber_buffered_exchange(distributed_control& dc,
                      const size_t max_buffer_size = DEFAULT_BUFFERED_EXCHANGE_SIZE) :
      rpc(dc, this),
      max_buffer_size(max_buffer_size) {
       send_buffers.resize(fiber_control::get_instance().num_workers());
       recv_buffers.resize(fiber_control::get_instance().num_workers());
       for (size_t i = 0;i < send_buffers.size(); ++i) {
         send_buffers[i].resize(dc.numprocs());
         for (size_t j = 0;j < send_buffers[i].size(); ++j) {
           send_buffers[i][j].oarc = NULL;
           send_buffers[i][j].numinserts = 0;
         }
       }
       rpc.barrier();
      }
fiber_buffered_exchange ( distributed_control & dc , const size_t max_buffer_size = DEFAULT_BUFFERED_EXCHANGE_SIZE ) : rpc ( dc , this ) , max_buffer_size ( max_buffer_size ) { send_buffers . resize ( fiber_control :: get_instance ( ) . num_workers ( ) ) ; recv_buffers . resize ( fiber_control :: get_instance ( ) . num_workers ( ) ) ; for ( size_t i = 0 ; i < send_buffers . size ( ) ; ++ i ) { send_buffers [ i ] . resize ( dc . numprocs ( ) ) ; for ( size_t j = 0 ; j < send_buffers [ i ] . size ( ) ; ++ j ) { send_buffers [ i ] [ j ] . oarc = NULL ; send_buffers [ i ] [ j ] . numinserts = 0 ; } } rpc . barrier ( ) ; }
Constructs a buffered exchange object.
Constructs a buffered exchange object .