From 151d79d697d51f01133ae1b90a76d96705167752 Mon Sep 17 00:00:00 2001 From: Joseph Schuchart Date: Thu, 25 Jun 2020 16:05:29 +0200 Subject: [PATCH] DART-MPI: call into MPI for local put/get to ensure progress --- dart-impl/mpi/src/dart_communication.c | 20 -------------------- 1 file changed, 20 deletions(-) diff --git a/dart-impl/mpi/src/dart_communication.c b/dart-impl/mpi/src/dart_communication.c index b4da40d73..f80efdc0b 100644 --- a/dart-impl/mpi/src/dart_communication.c +++ b/dart-impl/mpi/src/dart_communication.c @@ -220,16 +220,6 @@ dart__mpi__get_basic( { if (num_reqs) *num_reqs = 0; - if (team_data->unitid == team_unit_id.id) { - // use direct memcpy if we are on the same unit - memcpy(dest, seginfo->selfbaseptr + offset, - nelem * dart__mpi__datatype_sizeof(dtype)); - DART_LOG_DEBUG("dart_get: memcpy nelem:%zu " - "source (coll.): offset:%lu -> dest: %p", - nelem, offset, dest); - return DART_OK; - } - #if !defined(DART_MPI_DISABLE_SHARED_WINDOWS) DART_LOG_DEBUG("dart_get: shared windows enabled"); if (seginfo->segid >= 0 && team_data->sharedmem_tab[team_unit_id.id].id >= 0) { @@ -353,16 +343,6 @@ dart__mpi__put_basic( { if (num_reqs) *num_reqs = 0; - /* copy data directly if we are on the same unit */ - if (team_unit_id.id == team_data->unitid) { - if (flush_required_ptr) *flush_required_ptr = false; - memcpy(seginfo->selfbaseptr + offset, src, - nelem * dart__mpi__datatype_sizeof(dtype)); - DART_LOG_DEBUG("dart_put: memcpy nelem:%zu (from global allocation)" - "offset: %"PRIu64"", nelem, offset); - return DART_OK; - } - #if !defined(DART_MPI_DISABLE_SHARED_WINDOWS) DART_LOG_DEBUG("dart_put: shared windows enabled"); if (seginfo->segid >= 0 && team_data->sharedmem_tab[team_unit_id.id].id >= 0) {