Added fetch to connect point for scoped readers

Nebukam · Oct 17, 2024 · d49f191 · d49f191
1 parent 2ef1b50
commit d49f191
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/Source/PCGExtendedToolkit/Private/Graph/PCGExConnectPoints.cpp b/Source/PCGExtendedToolkit/Private/Graph/PCGExConnectPoints.cpp
@@ -231,6 +231,12 @@ namespace PCGExConnectPoints
  for (int i = 0; i < Loops.Num(); i++) { DistributedEdgesSet.Add(MakeShared<TSet<uint64>>()); }
  }
 
+ void FProcessor::PrepareSingleLoopScopeForPoints(const uint32 StartIndex, const int32 Count)
+ {
+ TPointsProcessor<FPCGExConnectPointsContext, UPCGExConnectPointsSettings>::PrepareSingleLoopScopeForPoints(StartIndex, Count);
+ PointDataFacade->Fetch(StartIndex, Count);
+ }
+
  void FProcessor::ProcessSinglePoint(const int32 Index, FPCGPoint& Point, const int32 LoopIdx, const int32 Count)
  {
  TRACE_CPUPROFILER_EVENT_SCOPE(FPCGExConnectPointsElement::ProcessSinglePoint);

diff --git a/Source/PCGExtendedToolkit/Public/Graph/PCGExConnectPoints.h b/Source/PCGExtendedToolkit/Public/Graph/PCGExConnectPoints.h
@@ -169,6 +169,7 @@ namespace PCGExConnectPoints
  virtual bool Process(const TSharedPtr<PCGExMT::FTaskManager> InAsyncManager) override;
  void OnPreparationComplete();
  virtual void PrepareLoopScopesForPoints(const TArray<uint64>& Loops) override;
+ virtual void PrepareSingleLoopScopeForPoints(const uint32 StartIndex, const int32 Count) override;
  virtual void ProcessSinglePoint(const int32 Index, FPCGPoint& Point, const int32 LoopIdx, const int32 Count) override;
  virtual void CompleteWork() override;
  virtual void Write() override;