SharedMemoryService.h

Go to the documentation of this file.

#ifndef LINTEL_SHAREDMEMORYSERVICE_H
#define LINTEL_SHAREDMEMORYSERVICE_H
 
#include <filesystem>
#include <map>
#include <memory>
#include <mutex>
#include <ostream>
#include <set>
#include <utility>
 
#include "lintel/core/exceptions/ShmSegmentNotFound.h"
#include "lintel/core/models/SharedMemorySegment.h"
#include "lintel/core/models/SharedMemorySegmentInfo.h"
#include "lintel/core/services/ISharedMemoryService.h"
#include "lintel/core/services/LoggerService.h"
#include "lintel/core/services/PropertyRegistration.h"
#include "lintel/core/shm/ShmSegmentAccessor.h"
#include "lintel/features/base/services/SchedulerService.h"
#include "lintel/features/base/services/SharedMemorySegmentManager.h"
 
namespace lintel {
class SharedMemorySegmentHandle;
 
class SharedMemoryService
  : public PropertyRegistration<SharedMemoryService>
  , public ISharedMemoryService
  , public std::enable_shared_from_this<SharedMemoryService>
{
private:
  // variables
  std::map<std::string, std::shared_ptr<SharedMemorySegmentHandle>> m_segments;
  mutable std::mutex m_segmentsMutex;
  std::size_t m_generation = 0;
  std::shared_ptr<SchedulerService> m_schedulerService;
  // properties
  std::shared_ptr<Property<std::chrono::seconds>> m_scheduleRate;
  std::shared_ptr<Property<bool>> m_autoExtend;
  std::shared_ptr<Property<std::size_t>> m_autoExtendEpsilon;
 
  // initializer function
  static std::map<std::string, std::shared_ptr<SharedMemorySegmentHandle>> create(
    const std::vector<std::shared_ptr<SharedMemorySegment>> &set);
 
  void onCheck();
 
public:
  SharedMemoryService(const std::shared_ptr<SharedMemorySegmentManager> &sharedMemorySegmentManager,
    std::shared_ptr<SchedulerService> schedulerService,
    const std::shared_ptr<ProcessName> &processName);
 
  ~SharedMemoryService() override = default;
 
  void onInitialize() override;
 
  [[nodiscard]] std::size_t getGeneration() const;
 
  void growOf(const std::shared_ptr<SharedMemorySegment> &segment, std::size_t grow) override;
 
  void shrinkOf(const std::shared_ptr<SharedMemorySegment> &segment) override;
 
  [[nodiscard]] SharedMemorySegmentInfo showStateOf(const std::shared_ptr<SharedMemorySegment> &segment) const override;
 
  std::map<std::string, std::shared_ptr<SharedMemorySegmentHandle>> &segmentsOf() { return m_segments; }
 
  std::mutex &segmentsMutexOf() { return m_segmentsMutex; }
 
  SharedMemorySegmentHandle &segmentOf(const std::string &name);
 
  ShmSegmentAccessor getSegmentAccessor(const std::shared_ptr<SharedMemorySegment> &segment);
};
 
}// namespace lintel
#endif// LINTEL_SHAREDMEMORYSERVICE_H