RequestListBase.cc

// -*- tab-width: 2; indent-tabs-mode: nil; coding: utf-8-with-signature -*-
//-----------------------------------------------------------------------------
// Copyright 2000-2026 CEA (www.cea.fr) IFPEN (www.ifpenergiesnouvelles.com)
// See the top-level COPYRIGHT file for details.
// SPDX-License-Identifier: Apache-2.0
//-----------------------------------------------------------------------------
/*---------------------------------------------------------------------------*/
/* RequestListBase.cc                                          (C) 2000-2025 */
/*                                                                           */
/* MPI request list.                                                         */
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
#include "arccore/message_passing/RequestListBase.h"
#include "arccore/base/NotImplementedException.h"
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
namespace Arcane::MessagePassing::internal
{
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
void RequestListBase::
clear()
{
  m_requests.clear();
  m_requests_done.clear();
  m_done_request_indexes.clear();
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
void RequestListBase::
removeDoneRequests()
{
  // TODO: optimize this by removing multiple values at once
  for (Integer i = 0, n = m_requests.size(); i < n; ++i) {
    if (m_requests_done[i]) {
      _removeRequestAtIndex(i);
      --i;
      --n;
    }
  }
  m_done_request_indexes.clear();
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
ConstArrayView<Int32> RequestListBase::
doneRequestIndexes() const
{
  return m_done_request_indexes.view();
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
Int32 RequestListBase::
wait(eWaitType wait_type)
{
  m_requests_done.fill(false);
 
  // Delegates the actual call to the derived class which must fill
  // the m_requests_done field (except for WaitAll)
  _wait(wait_type);
 
  if (wait_type == WaitAll)
    m_requests_done.fill(true);
 
  Integer nb_request = size();
  m_done_request_indexes.clear();
  m_done_request_indexes.reserve(nb_request);
  Int32 nb_done = 0;
  for (Integer i = 0; i < nb_request; ++i)
    if (m_requests_done[i]) {
      m_done_request_indexes.add(i);
      ++nb_done;
    }
  return nb_done;
}
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
} // namespace Arcane::MessagePassing::internal
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/