Otf2MessagePassingProfilingService.h

// -*- tab-width: 2; indent-tabs-mode: nil; coding: utf-8-with-signature -*-
//-----------------------------------------------------------------------------
// Copyright 2000-2022 CEA (www.cea.fr) IFPEN (www.ifpenergiesnouvelles.com)
// See the top-level COPYRIGHT file for details.
// SPDX-License-Identifier: Apache-2.0
//-----------------------------------------------------------------------------
/*---------------------------------------------------------------------------*/
/* Otf2MessagePassingProfilingService.h                        (C) 2000-2019 */
/*                                                                           */
/* Informations de performances du "message passing" au format Otf2          */
/*---------------------------------------------------------------------------*/
#ifndef ARCANE_STD_OTF2MESSAGEPASSINGPROFILINGSERVICE_H
#define ARCANE_STD_OTF2MESSAGEPASSINGPROFILINGSERVICE_H
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
#include "arcane/AbstractService.h"
#include "arcane/ISubDomain.h"
#include "arcane/ObserverPool.h"
#include "arcane/VariableSynchronizerEventArgs.h"
#include "arcane/utils/IMessagePassingProfilingService.h"
#include "arcane/utils/String.h"
#include "arccore/message_passing/Stat.h"
#include "arcane/std/Otf2LibWrapper.h"
#include "arcane/std/Otf2MpiProfiling.h"
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
namespace Arcane
{
namespace MP = ::Arccore::MessagePassing;
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
class Otf2MessagePassingProfilingService
: public AbstractService
, public IMessagePassingProfilingService
{
 public:
  explicit Otf2MessagePassingProfilingService(const ServiceBuildInfo& sbi);
  ~Otf2MessagePassingProfilingService() noexcept override;
 
  void startProfiling() override;
  void stopProfiling() override;
  void printInfos(std::ostream& output) override;
  String implName() override;
 
 private:
  void _updateFromBeginEntryPointEvt();
  void _updateFromEndEntryPointEvt();
  void _updateFromSynchronizeEvt(const VariableSynchronizerEventArgs& arg);
 
  ISubDomain* m_sub_domain = nullptr;
  Otf2LibWrapper m_otf2_wrapper;
  Otf2MpiProfiling m_otf2_prof;
  MP::IProfiler* m_prof_backup = nullptr;
  ObserverPool m_observer;
  EventObserverPool m_observer_pool;
  String m_impl_name;
  MP::IControlDispatcher* m_control_dispatcher = nullptr;
};
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
}  // namespace Arcane
 
/*---------------------------------------------------------------------------*/
/*---------------------------------------------------------------------------*/
 
#endif