TRIQS/mpi 1.3.0
C++ interface to MPI
Loading...
Searching...
No Matches
string.hpp
Go to the documentation of this file.
1// Copyright (c) 2019-2024 Simons Foundation
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7// http://www.apache.org/licenses/LICENSE-2.0.txt
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14//
15// Authors: Thomas Hahn, Olivier Parcollet, Nils Wentzell
16
22#pragma once
23
24#include "./communicator.hpp"
26#include "./ranges.hpp"
27
28#include <string>
29
30namespace mpi {
31
47 inline void mpi_broadcast(std::string &s, communicator c, int root) {
48 size_t len = s.size();
49 broadcast(len, c, root);
50 if (c.rank() != root) s.resize(len);
51 broadcast_range(s, c, root);
52 }
53
65 inline std::string mpi_gather(std::string const &s, communicator c = {}, int root = 0, bool all = false) {
66 long len = static_cast<long>(all_reduce(s.size(), c));
67 std::string res{};
68 if (c.rank() == root || all) res.resize(len);
69 gather_range(s, res, len, c, root, all);
70 return res;
71 }
72
75} // namespace mpi
C++ wrapper around MPI_Comm providing various convenience functions.
int rank() const
Get the rank of the calling process in the communicator.
Provides a C++ wrapper class for an MPI_Comm object.
Provides generic implementations for a subset of collective MPI communications (broadcast,...
void broadcast_range(R &&rg, communicator c={}, int root=0)
Implementation of an MPI broadcast for an mpi::contiguous_sized_range object.
Definition ranges.hpp:93
void gather_range(R1 &&in_rg, R2 &&out_rg, long out_size, communicator c={}, int root=0, bool all=false)
Implementation of an MPI gather for an mpi::contiguous_sized_range.
Definition ranges.hpp:412
void mpi_broadcast(std::array< T, N > &arr, communicator c={}, int root=0)
Implementation of an MPI broadcast for a std::arr.
Definition array.hpp:51
decltype(auto) all_reduce(T &&x, communicator c={}, MPI_Op op=MPI_SUM)
Generic MPI all-reduce.
void broadcast(T &&x, communicator c={}, int root=0)
Generic MPI broadcast.
std::string mpi_gather(std::string const &s, communicator c={}, int root=0, bool all=false)
Implementation of an MPI gather for a std::string.
Definition string.hpp:65
Provides an MPI broadcast, reduce, scatter and gather for contiguous ranges.