ProcessingStreamGroup.h

 
#pragma once
 
#include <Foundation/Basics.h>
#include <Foundation/Communication/Event.h>
#include <Foundation/Containers/HybridArray.h>
#include <Foundation/DataProcessing/Stream/ProcessingStream.h>
 
class plProcessingStreamProcessor;
class plProcessingStreamGroup;
 
struct plStreamGroupElementRemovedEvent
{
  plProcessingStreamGroup* m_pStreamGroup;
  plUInt64 m_uiElementIndex;
};
 
struct plStreamGroupElementsClearedEvent
{
  plProcessingStreamGroup* m_pStreamGroup;
};
 
class PL_FOUNDATION_DLL plProcessingStreamGroup
{
public:
  plProcessingStreamGroup();
 
  ~plProcessingStreamGroup();
 
  void Clear();
 
  void AddProcessor(plProcessingStreamProcessor* pProcessor);
 
  void RemoveProcessor(plProcessingStreamProcessor* pProcessor);
 
  void ClearProcessors();
 
  plProcessingStream* AddStream(plStringView sName, plProcessingStream::DataType type);
 
  void RemoveStreamByName(plStringView sName);
 
  plProcessingStream* GetStreamByName(plStringView sName) const;
 
  void SetSize(plUInt64 uiNumElements);
 
  void RemoveElement(plUInt64 uiElementIndex);
 
  void InitializeElements(plUInt64 uiNumElements);
 
  void Process();
 
  inline plUInt64 GetNumElements() const { return m_uiNumElements; }
 
  inline plUInt64 GetNumActiveElements() const { return m_uiNumActiveElements; }
 
  inline plUInt64 GetHighestNumActiveElements() const { return m_uiHighestNumActiveElements; }
 
  plEvent<const plStreamGroupElementRemovedEvent&> m_ElementRemovedEvent;
 
private:
  void RunPendingDeletions();
 
  void EnsureStreamAssignmentValid();
 
  void RunPendingSpawns();
 
  void SortProcessorsByPriority();
 
  plHybridArray<plProcessingStreamProcessor*, 8> m_Processors;
 
  plHybridArray<plProcessingStream*, 8> m_DataStreams;
 
  plHybridArray<plUInt64, 64> m_PendingRemoveIndices;
 
  plUInt64 m_uiPendingNumberOfElementsToSpawn;
 
  plUInt64 m_uiNumElements;
 
  plUInt64 m_uiNumActiveElements;
 
  plUInt64 m_uiHighestNumActiveElements;
 
  bool m_bStreamAssignmentDirty;
};