OilfieldToolsNet/opm-simulators
4
0
Fork 0
mirror of https://github.com/OPM/opm-simulators.git synced 2025-02-25 18:55:30 -06:00
Code Issues Packages Projects Releases Wiki Activity

remove error logging in std::cerr

Browse Source
This commit is contained in:
Tobias Meyer Andersen 2024-04-17 13:46:49 +02:00
parent ccd014cc1a
commit 2eefedf661
1 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
opm/simulators/linalg/cuistl/CuOwnerOverlapCopy.hpp
View File

@ -76,7 +76,7 @@ public:
const auto dotAtRank = x.dot(y, *m_indicesOwner); const auto dotAtRank = x.dot(y, *m_indicesOwner);
output = m_cpuOwnerOverlapCopy.communicator().sum(dotAtRank); output = m_cpuOwnerOverlapCopy.communicator().sum(dotAtRank);
} }
/** /**
* @brief norm computes the l^2-norm of x across processes. * @brief norm computes the l^2-norm of x across processes.
* *
@ -110,12 +110,12 @@ protected:
* @tparam OwnerOverlapCopyCommunicationType is typically a Dune::LinearOperator::communication_type * @tparam OwnerOverlapCopyCommunicationType is typically a Dune::LinearOperator::communication_type
*/ */
template <class field_type, int block_size, class OwnerOverlapCopyCommunicationType> template <class field_type, int block_size, class OwnerOverlapCopyCommunicationType>
class GPUObliviousMPISender : public GPUSender<field_type, OwnerOverlapCopyCommunicationType> class GPUObliviousMPISender : public GPUSender<field_type, OwnerOverlapCopyCommunicationType>
{ {
public: public:
using X = CuVector<field_type>; using X = CuVector<field_type>;
GPUObliviousMPISender(const OwnerOverlapCopyCommunicationType& cpuOwnerOverlapCopy) GPUObliviousMPISender(const OwnerOverlapCopyCommunicationType& cpuOwnerOverlapCopy)
: GPUSender<field_type, OwnerOverlapCopyCommunicationType>(cpuOwnerOverlapCopy) : GPUSender<field_type, OwnerOverlapCopyCommunicationType>(cpuOwnerOverlapCopy)
{ {
} }
@ -236,15 +236,13 @@ public:
MPI_Waitany(m_messageInformation.size(), recvRequests.data(), &finished, &status); MPI_Waitany(m_messageInformation.size(), recvRequests.data(), &finished, &status);
if(status.MPI_ERROR!=MPI_SUCCESS) { if(status.MPI_ERROR!=MPI_SUCCESS) {
std::cerr<< rank << ": MPI_Error occurred while receiving message from "<< processMap[finished] << std::endl; OPM_THROW(std::runtime_error, fmt::format("MPI_Error occurred while rank {} received a message from rank {}", rank, processMap[finished]));
OPM_THROW(std::runtime_error, "MPI_Error while receiving message");
} }
} }
MPI_Status recvStatus; MPI_Status recvStatus;
for(size_t i = 0; i < m_messageInformation.size(); i++) { for(size_t i = 0; i < m_messageInformation.size(); i++) {
if(MPI_SUCCESS!=MPI_Wait(&sendRequests[i], &recvStatus)) { if(MPI_SUCCESS!=MPI_Wait(&sendRequests[i], &recvStatus)) {
std::cerr << rank << ": MPI_Error occurred while sending message to " << processMap[finished] << std::endl; OPM_THROW(std::runtime_error, fmt::format("MPI_Error occurred while rank {} sent a message from rank {}", rank, processMap[finished]));
OPM_THROW(std::runtime_error, "MPI_Error while sending message");
} }
} }
// ...End of MPI stuff // ...End of MPI stuff