remove unused

parthenon-hpc-lab · Nov 19, 2024 · 0bd053e · 0bd053e
1 parent 06bd5d3
commit 0bd053e
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 49 deletions.
diff --git a/src/bvals/comms/boundary_communication.cpp b/src/bvals/comms/boundary_communication.cpp
@@ -273,10 +273,6 @@ TaskStatus SetBounds(std::shared_ptr<MeshData<Real>> &md) {
   Mesh *pmesh = md->GetMeshPointer();
   auto &cache = md->GetBvarsCache().GetSubCache(bound_type, false);
 
-  // if (pmesh->do_coalesced_comms) {
-  //   pmesh->pcoalesced_comms->Compare(md.get(), bound_type);
-  // }
-
   auto [rebuild, nbound] = CheckReceiveBufferCacheForRebuild<bound_type, false>(md);
 
   if (rebuild) {

diff --git a/src/bvals/comms/coalesced_buffers.cpp b/src/bvals/comms/coalesced_buffers.cpp
@@ -222,49 +222,6 @@ bool CoalescedBuffer::TryReceiveAndUnpack(const std::set<Uid_t> &vars) {
   return true;
 }
 
-//----------------------------------------------------------------------------------------
-void CoalescedBuffer::Compare(const std::set<Uid_t> &vars) {
-  PARTHENON_REQUIRE(coalesced_comm_buffer.GetState() == BufferState::received,
-                    "Combined buffer not in correct state");
-  PARTHENON_REQUIRE(sparse_status_buffer.GetState() == BufferState::received,
-                    "Combined buffer not in correct state");
-  const auto &var_set = vars.size() == 0 ? all_vars : vars;
-  // Allocate and free buffers as required
-  int idx{0};
-  auto &stat = sparse_status_buffer.buffer();
-  for (auto uid : var_set) {
-    for (auto &[bnd_id, pvbbuf] : coalesced_info_buf.at(uid)) {
-      if (stat[idx] == 1) {
-        PARTHENON_REQUIRE(pvbbuf->GetState() == BufferState::received,
-                          "State doesn't agree.");
-      } else {
-        PARTHENON_REQUIRE(pvbbuf->GetState() == BufferState::received_null,
-                          "State doesn't agree.");
-      }
-      idx++;
-    }
-  }
-
-  auto &bids = GetBndIdsOnDevice(vars);
-  Kokkos::parallel_for(
-      PARTHENON_AUTO_LABEL,
-      Kokkos::TeamPolicy<>(parthenon::DevExecSpace(), bids.size(), Kokkos::AUTO),
-      KOKKOS_LAMBDA(parthenon::team_mbr_t team_member) {
-        const int b = team_member.league_rank();
-        if (bids[b].buf_allocated) {
-          const int buf_size = bids[b].size();
-          Real *com_buf = &(bids[b].coalesced_buf(bids[b].start_idx()));
-          Real *buf = &(bids[b].buf(0));
-          Kokkos::parallel_for(Kokkos::TeamThreadRange<>(team_member, buf_size),
-                               [&](const int idx) {
-                                 PARTHENON_REQUIRE(buf[idx] == com_buf[idx], "Bad value");
-                               });
-        }
-      });
-  coalesced_comm_buffer.Stale();
-  sparse_status_buffer.Stale();
-}
-
 //----------------------------------------------------------------------------------------
 void CoalescedBuffer::AddVarBoundary(BndId &bnd_id) {
   auto key = GetChannelKey(bnd_id);

diff --git a/src/bvals/comms/coalesced_buffers.hpp b/src/bvals/comms/coalesced_buffers.hpp
@@ -98,8 +98,6 @@ struct CoalescedBuffer {
   void PackAndSend(const std::set<Uid_t> &vars);
 
   bool TryReceiveAndUnpack(const std::set<Uid_t> &vars);
-
-  void Compare(const std::set<Uid_t> &vars);
 };
 
 struct CoalescedBuffersRank {