x
Yes
No
Do you want to visit DriveHQ English website?
首页
产品服务
价格
免费试用
下载客户端
关于我们
云文件服务
|
云备份服务
|
FTP服务
|
企业邮箱服务
|
网站托管
|
客户端软件
云文件服务
云备份服务
FTP服务
企业级邮箱服务
网站托管
客户端软件
gather.hpp - Hosted on DriveHQ Cloud IT Platform
返回上层目录
上传
下载
共享
发布
新建文件夹
新建文件
复制
剪切
删除
粘贴
评论
升级服务
路径: \\game3dprogramming\materials\GameFactory\GameFactoryDemo\references\boost_1_35_0\boost\mpi\collectives\gather.hpp
旋转
特效
属性
历史版本
// Copyright (C) 2005, 2006 Douglas Gregor. // Use, modification and distribution is subject to the Boost Software // License, Version 1.0. (See accompanying file LICENSE_1_0.txt or copy at // http://www.boost.org/LICENSE_1_0.txt) // Message Passing Interface 1.1 -- Section 4.5. Gather #ifndef BOOST_MPI_GATHER_HPP #define BOOST_MPI_GATHER_HPP #include
#include
#include
#include
#include
#include
#include
#include
#include
namespace boost { namespace mpi { namespace detail { // We're gathering at the root for a type that has an associated MPI // datatype, so we'll use MPI_Gather to do all of the work. template
void gather_impl(const communicator& comm, const T* in_values, int n, T* out_values, int root, mpl::true_) { MPI_Datatype type = get_mpi_datatype
(*in_values); BOOST_MPI_CHECK_RESULT(MPI_Gather, (const_cast
(in_values), n, type, out_values, n, type, root, comm)); } // We're gathering from a non-root for a type that has an associated MPI // datatype, so we'll use MPI_Gather to do all of the work. template
void gather_impl(const communicator& comm, const T* in_values, int n, int root, mpl::true_) { MPI_Datatype type = get_mpi_datatype
(*in_values); BOOST_MPI_CHECK_RESULT(MPI_Gather, (const_cast
(in_values), n, type, 0, n, type, root, comm)); } // We're gathering at the root for a type that does not have an // associated MPI datatype, so we'll need to serialize // it. Unfortunately, this means that we cannot use MPI_Gather, so // we'll just have all of the non-root nodes send individual // messages to the root. template
void gather_impl(const communicator& comm, const T* in_values, int n, T* out_values, int root, mpl::false_) { int tag = environment::collectives_tag(); int size = comm.size(); for (int src = 0; src < size; ++src) { if (src == root) std::copy(in_values, in_values + n, out_values + n * src); else comm.recv(src, tag, out_values + n * src, n); } } // We're gathering at a non-root for a type that does not have an // associated MPI datatype, so we'll need to serialize // it. Unfortunately, this means that we cannot use MPI_Gather, so // we'll just have all of the non-root nodes send individual // messages to the root. template
void gather_impl(const communicator& comm, const T* in_values, int n, int root, mpl::false_) { int tag = environment::collectives_tag(); comm.send(root, tag, in_values, n); } } // end namespace detail template
void gather(const communicator& comm, const T& in_value, T* out_values, int root) { if (comm.rank() == root) detail::gather_impl(comm, &in_value, 1, out_values, root, is_mpi_datatype
()); else detail::gather_impl(comm, &in_value, 1, root, is_mpi_datatype
()); } template
void gather(const communicator& comm, const T& in_value, int root) { BOOST_ASSERT(comm.rank() != root); detail::gather_impl(comm, &in_value, 1, root, is_mpi_datatype
()); } template
void gather(const communicator& comm, const T& in_value, std::vector
& out_values, int root) { if (comm.rank() == root) { out_values.resize(comm.size()); ::boost::mpi::gather(comm, in_value, &out_values[0], root); } else { ::boost::mpi::gather(comm, in_value, root); } } template
void gather(const communicator& comm, const T* in_values, int n, T* out_values, int root) { if (comm.rank() == root) detail::gather_impl(comm, in_values, n, out_values, root, is_mpi_datatype
()); else detail::gather_impl(comm, in_values, n, root, is_mpi_datatype
()); } template
void gather(const communicator& comm, const T* in_values, int n, std::vector
& out_values, int root) { ::boost::mpi::gather(comm, in_values, n, &out_values[0], root); } template
void gather(const communicator& comm, const T* in_values, int n, int root) { BOOST_ASSERT(comm.rank() != root); detail::gather_impl(comm, in_values, n, root, is_mpi_datatype
()); } } } // end namespace boost::mpi #endif // BOOST_MPI_GATHER_HPP
gather.hpp
网页地址
文件地址
上一页
5/8
下一页
下载
( 4 KB )
Comments
Total ratings:
0
Average rating:
无评论
of 10
Would you like to comment?
Join now
, or
Logon
if you are already a member.