// Copyright Epic Games, Inc. All Rights Reserved. #include "StateTree.h" #include "Misc/PackageName.h" #include "StateTreeLinker.h" #include "StateTreeTaskBase.h" #include "StateTreeEvaluatorBase.h" #include "StateTreeConditionBase.h" #include "AssetRegistry/AssetData.h" #include "Misc/ScopeRWLock.h" #include "StateTreeDelegates.h" #include "Logging/LogScopedVerbosityOverride.h" #include "Misc/DataValidation.h" #include "StructUtilsDelegates.h" #include "Misc/EnumerateRange.h" #include "UObject/AssetRegistryTagsContext.h" #if WITH_EDITOR #include "Engine/UserDefinedStruct.h" #endif #include UE_INLINE_GENERATED_CPP_BY_NAME(StateTree) const FGuid FStateTreeCustomVersion::GUID(0x28E21331, 0x501F4723, 0x8110FA64, 0xEA10DA1E); FCustomVersionRegistration GRegisterStateTreeCustomVersion(FStateTreeCustomVersion::GUID, FStateTreeCustomVersion::LatestVersion, TEXT("StateTreeAsset")); bool UStateTree::IsReadyToRun() const { // Valid tree must have at least one state and valid instance data. return States.Num() > 0 && bIsLinked && PropertyBindings.IsValid(); } FConstStructView UStateTree::GetNode(const int32 NodeIndex) const { return Nodes.IsValidIndex(NodeIndex) ? Nodes[NodeIndex] : FConstStructView(); } FStateTreeIndex16 UStateTree::GetNodeIndexFromId(const FGuid Id) const { const FStateTreeNodeIdToIndex* Entry = IDToNodeMappings.FindByPredicate([Id](const FStateTreeNodeIdToIndex& Entry){ return Entry.Id == Id; }); return Entry != nullptr ? Entry->Index : FStateTreeIndex16::Invalid; } FGuid UStateTree::GetNodeIdFromIndex(const FStateTreeIndex16 NodeIndex) const { const FStateTreeNodeIdToIndex* Entry = NodeIndex.IsValid() ? IDToNodeMappings.FindByPredicate([NodeIndex](const FStateTreeNodeIdToIndex& Entry){ return Entry.Index == NodeIndex; }) : nullptr; return Entry != nullptr ? Entry->Id : FGuid(); } const FCompactStateTreeState* UStateTree::GetStateFromHandle(const FStateTreeStateHandle StateHandle) const { return States.IsValidIndex(StateHandle.Index) ? &States[StateHandle.Index] : nullptr; } FStateTreeStateHandle UStateTree::GetStateHandleFromId(const FGuid Id) const { const FStateTreeStateIdToHandle* Entry = IDToStateMappings.FindByPredicate([Id](const FStateTreeStateIdToHandle& Entry){ return Entry.Id == Id; }); return Entry != nullptr ? Entry->Handle : FStateTreeStateHandle::Invalid; } FGuid UStateTree::GetStateIdFromHandle(const FStateTreeStateHandle Handle) const { const FStateTreeStateIdToHandle* Entry = IDToStateMappings.FindByPredicate([Handle](const FStateTreeStateIdToHandle& Entry){ return Entry.Handle == Handle; }); return Entry != nullptr ? Entry->Id : FGuid(); } const FCompactStateTransition* UStateTree::GetTransitionFromIndex(const FStateTreeIndex16 TransitionIndex) const { return TransitionIndex.IsValid() && Transitions.IsValidIndex(TransitionIndex.Get()) ? &Transitions[TransitionIndex.Get()] : nullptr; } FStateTreeIndex16 UStateTree::GetTransitionIndexFromId(const FGuid Id) const { const FStateTreeTransitionIdToIndex* Entry = IDToTransitionMappings.FindByPredicate([Id](const FStateTreeTransitionIdToIndex& Entry){ return Entry.Id == Id; }); return Entry != nullptr ? Entry->Index : FStateTreeIndex16::Invalid; } FGuid UStateTree::GetTransitionIdFromIndex(const FStateTreeIndex16 Index) const { const FStateTreeTransitionIdToIndex* Entry = IDToTransitionMappings.FindByPredicate([Index](const FStateTreeTransitionIdToIndex& Entry){ return Entry.Index == Index; }); return Entry != nullptr ? Entry->Id : FGuid(); } TSharedPtr UStateTree::GetSharedInstanceData() const { // Create a unique index for each thread. static std::atomic_int ThreadIndexCounter {0}; static thread_local int32 ThreadIndex = INDEX_NONE; // Cannot init directly on WinRT if (ThreadIndex == INDEX_NONE) { ThreadIndex = ThreadIndexCounter.fetch_add(1); } // If shared instance data for this thread exists, return it. { FReadScopeLock ReadLock(PerThreadSharedInstanceDataLock); if (ThreadIndex < PerThreadSharedInstanceData.Num()) { return PerThreadSharedInstanceData[ThreadIndex]; } } // Not initialized yet, create new instances up to the index. FWriteScopeLock WriteLock(PerThreadSharedInstanceDataLock); // It is possible that multiple threads are waiting for the write lock, // which means that execution may get here so that 'ThreadIndex' is already in valid range. // The loop below is organized to handle that too. const int32 NewNum = ThreadIndex + 1; PerThreadSharedInstanceData.Reserve(NewNum); UStateTree* NonConstThis = const_cast(this); for (int32 Index = PerThreadSharedInstanceData.Num(); Index < NewNum; Index++) { TSharedPtr SharedData = MakeShared(); SharedData->CopyFrom(*NonConstThis, SharedInstanceData); PerThreadSharedInstanceData.Add(SharedData); } return PerThreadSharedInstanceData[ThreadIndex]; } bool UStateTree::HasCompatibleContextData(const UStateTree& Other) const { if (ContextDataDescs.Num() != Other.ContextDataDescs.Num()) { return false; } const int32 Num = ContextDataDescs.Num(); for (int32 Index = 0; Index < Num; Index++) { const FStateTreeExternalDataDesc& Desc = ContextDataDescs[Index]; const FStateTreeExternalDataDesc& OtherDesc = Other.ContextDataDescs[Index]; if (!OtherDesc.Struct || !OtherDesc.Struct->IsChildOf(Desc.Struct)) { return false; } } return true; } #if WITH_EDITOR void UStateTree::ResetCompiled() { Schema = nullptr; States.Reset(); Transitions.Reset(); Nodes.Reset(); DefaultInstanceData.Reset(); SharedInstanceData.Reset(); ContextDataDescs.Reset(); PropertyBindings.Reset(); Parameters.Reset(); IDToStateMappings.Reset(); IDToNodeMappings.Reset(); IDToTransitionMappings.Reset(); EvaluatorsBegin = 0; EvaluatorsNum = 0; GlobalTasksBegin = 0; GlobalTasksNum = 0; bHasGlobalTransitionTasks = false; ResetLinked(); } void UStateTree::OnObjectsReinstanced(const FReplacementObjectMap& ObjectMap) { if (ObjectMap.IsEmpty()) { return; } // If the asset is not linked yet (or has failed), no need to link. if (!bIsLinked) { return; } // Relink only if the reinstantiated object belongs to this asset, // or anything from the property binding refers to the classes of the reinstantiated object. bool bShouldRelink = false; for (TMap::TConstIterator It(ObjectMap); It; ++It) { if (const UObject* ObjectToBeReplaced = It->Value) { if (ObjectToBeReplaced->IsInOuter(this)) { bShouldRelink = true; break; } } } if (!bShouldRelink) { TSet Structs; for (TMap::TConstIterator It(ObjectMap); It; ++It) { if (const UObject* ObjectToBeReplaced = It->Value) { Structs.Add(ObjectToBeReplaced->GetClass()); } } bShouldRelink |= PropertyBindings.ContainsAnyStruct(Structs); } if (bShouldRelink) { if (!Link()) { UE_LOG(LogStateTree, Error, TEXT("%s failed to link after Object reinstantiation. Take a look at the asset for any errors. Asset will not be usable at runtime."), *GetFullName()); } } } void UStateTree::OnUserDefinedStructReinstanced(const UUserDefinedStruct& UserDefinedStruct) { // Struct utils handle reinstancing the struct values (instanced struct, property bag, etc). // We will need to update the property binding. TSet Structs; Structs.Add(&UserDefinedStruct); if (PropertyBindings.ContainsAnyStruct(Structs)) { if (!Link()) { UE_LOG(LogStateTree, Error, TEXT("%s failed to link after Struct reinstantiation. Take a look at the asset for any errors. Asset will not be usable at runtime."), *GetFullName()); } } } void UStateTree::PostInitProperties() { Super::PostInitProperties(); OnObjectsReinstancedHandle = FCoreUObjectDelegates::OnObjectsReinstanced.AddUObject(this, &UStateTree::OnObjectsReinstanced); OnUserDefinedStructReinstancedHandle = UE::StructUtils::Delegates::OnUserDefinedStructReinstanced.AddUObject(this, &UStateTree::OnUserDefinedStructReinstanced); } void UStateTree::BeginDestroy() { if (OnObjectsReinstancedHandle.IsValid()) { FCoreUObjectDelegates::OnObjectsReinstanced.Remove(OnObjectsReinstancedHandle); OnObjectsReinstancedHandle.Reset(); } if (OnUserDefinedStructReinstancedHandle.IsValid()) { UE::StructUtils::Delegates::OnUserDefinedStructReinstanced.Remove(OnUserDefinedStructReinstancedHandle); OnUserDefinedStructReinstancedHandle.Reset(); } Super::BeginDestroy(); } void UStateTree::GetAssetRegistryTags(TArray& OutTags) const { PRAGMA_DISABLE_DEPRECATION_WARNINGS; Super::GetAssetRegistryTags(OutTags); PRAGMA_ENABLE_DEPRECATION_WARNINGS; } void UStateTree::GetAssetRegistryTags(FAssetRegistryTagsContext Context) const { const FString SchemaClassName = Schema ? Schema->GetClass()->GetPathName() : TEXT(""); Context.AddTag(FAssetRegistryTag(UE::StateTree::SchemaTag, SchemaClassName, FAssetRegistryTag::TT_Alphabetical)); Super::GetAssetRegistryTags(Context); } void UStateTree::PostLoadAssetRegistryTags(const FAssetData& InAssetData, TArray& OutTagsAndValuesToUpdate) const { Super::PostLoadAssetRegistryTags(InAssetData, OutTagsAndValuesToUpdate); static const FName SchemaTag(TEXT("Schema")); const FString SchemaTagValue = InAssetData.GetTagValueRef(SchemaTag); if (!SchemaTagValue.IsEmpty() && FPackageName::IsShortPackageName(SchemaTagValue)) { const FTopLevelAssetPath SchemaTagClassPathName = UClass::TryConvertShortTypeNameToPathName(SchemaTagValue, ELogVerbosity::Warning, TEXT("UStateTree::PostLoadAssetRegistryTags")); if (!SchemaTagClassPathName.IsNull()) { OutTagsAndValuesToUpdate.Add(FAssetRegistryTag(SchemaTag, SchemaTagClassPathName.ToString(), FAssetRegistryTag::TT_Alphabetical)); } } } EDataValidationResult UStateTree::IsDataValid(FDataValidationContext& Context) const { if (!const_cast(this)->Link()) { Context.AddError(FText::FromString(FString::Printf(TEXT("%s failed to link. Please recompile the State Tree for more details errors."), *GetFullName()))); return EDataValidationResult::Invalid; } return Super::IsDataValid(Context); } #endif // WITH_EDITOR void UStateTree::AddReferencedObjects(UObject* InThis, FReferenceCollector& Collector) { Super::AddReferencedObjects(InThis, Collector); const UStateTree* StateTree = Cast(InThis); check(StateTree); FReadScopeLock ReadLock(StateTree->PerThreadSharedInstanceDataLock); for (const TSharedPtr& InstanceData : StateTree->PerThreadSharedInstanceData) { if (InstanceData.IsValid()) { Collector.AddPropertyReferencesWithStructARO(FStateTreeInstanceData::StaticStruct(), InstanceData.Get(), StateTree); } } } void UStateTree::PostLoad() { Super::PostLoad(); const int32 CurrentVersion = GetLinkerCustomVersion(FStateTreeCustomVersion::GUID); if (CurrentVersion < FStateTreeCustomVersion::LatestVersion) { #if WITH_EDITOR if (EditorData) { // Make sure all the fix up logic in the editor data has had chance to happen. EditorData->ConditionalPostLoad(); } // Compiled data is in older format, try to compile the StateTree. if (UE::StateTree::Delegates::OnRequestCompile.IsBound()) { LOG_SCOPE_VERBOSITY_OVERRIDE(LogStateTree, ELogVerbosity::Log); UE_LOG(LogStateTree, Log, TEXT("%s: compiled data is in older format. Trying to compile the asset..."), *GetFullName()); UE::StateTree::Delegates::OnRequestCompile.Execute(*this); } else { ResetCompiled(); UE_LOG(LogStateTree, Warning, TEXT("%s: compiled data is in older format. Please resave the StateTree asset."), *GetFullName()); } #else UE_LOG(LogStateTree, Error, TEXT("%s: compiled data is in older format. Please recompile the StateTree asset."), *GetFullName()); #endif return; } if (!Link()) { UE_LOG(LogStateTree, Log, TEXT("%s failed to link. Asset will not be usable at runtime."), *GetFullName()); } } #if WITH_EDITORONLY_DATA void UStateTree::DeclareConstructClasses(TArray& OutConstructClasses, const UClass* SpecificSubclass) { Super::DeclareConstructClasses(OutConstructClasses, SpecificSubclass); TArray SchemaClasses; GetDerivedClasses(UStateTreeSchema::StaticClass(), SchemaClasses); for (UClass* SchemaClass : SchemaClasses) { if (!SchemaClass->HasAnyClassFlags(CLASS_Abstract | CLASS_Transient)) { OutConstructClasses.Add(FTopLevelAssetPath(SchemaClass)); } } } #endif void UStateTree::Serialize(const FStructuredArchiveRecord Record) { Super::Serialize(Record); Record.GetUnderlyingArchive().UsingCustomVersion(FStateTreeCustomVersion::GUID); // We need to link and rebind property bindings each time a BP is compiled, // because property bindings may get invalid, and instance data potentially needs refreshed. if (Record.GetUnderlyingArchive().IsModifyingWeakAndStrongReferences()) { if (!Link()) { UE_LOG(LogStateTree, Log, TEXT("%s failed to link. Asset will not be usable at runtime."), *GetName()); } } } void UStateTree::ResetLinked() { bIsLinked = false; ExternalDataDescs.Reset(); FWriteScopeLock WriteLock(PerThreadSharedInstanceDataLock); PerThreadSharedInstanceData.Reset(); } bool UStateTree::Link() { // Initialize the instance data default value. // This data will be used to allocate runtime instance on all StateTree users. ResetLinked(); // Resolves nodes references to other StateTree data FStateTreeLinker Linker(Schema); for (int32 Index = 0; Index < Nodes.Num(); Index++) { FStructView Node = Nodes[Index]; if (FStateTreeNodeBase* NodePtr = Node.GetPtr()) { const bool bLinkSucceeded = NodePtr->Link(Linker); if (!bLinkSucceeded || Linker.GetStatus() == EStateTreeLinkerStatus::Failed) { UE_LOG(LogStateTree, Error, TEXT("%s: node '%s' failed to resolve its references."), *GetFullName(), *NodePtr->StaticStruct()->GetName()); return false; } } } ExternalDataDescs = Linker.GetExternalDataDescs(); if (States.Num() > 0 && Nodes.Num() > 0) { // Check that all nodes are valid. for (FConstStructView Node : Nodes) { if (!Node.IsValid()) { UE_LOG(LogStateTree, Error, TEXT("%s: State Tree asset was not properly loaded (missing node). See log for loading failures, or recompile the StateTree asset."), *GetFullName()); return false; } } } if (!DefaultInstanceData.AreAllInstancesValid()) { UE_LOG(LogStateTree, Error, TEXT("%s: State Tree asset was not properly loaded (missing instance data). See log for loading failures, or recompile the StateTree asset."), *GetFullName()); return false; } if (!SharedInstanceData.AreAllInstancesValid()) { UE_LOG(LogStateTree, Error, TEXT("%s: State Tree asset was not properly loaded (missing shared instance data). See log for loading failures, or recompile the StateTree asset."), *GetFullName()); return false; } if (!PatchBindings()) { return false; } // Resolves property paths used by bindings a store property pointers if (!PropertyBindings.ResolvePaths()) { return false; } // Link succeeded, setup tree to be ready to run bIsLinked = true; return true; } bool UStateTree::PatchBindings() { const TArrayView SourceStructs = PropertyBindings.SourceStructs; const TArrayView CopyBatches = PropertyBindings.CopyBatches; const TArrayView PropertyPathBindings = PropertyBindings.PropertyPathBindings; // Make mapping from data handle to source struct. TMap SourceStructByHandle; for (TConstEnumerateRef SourceStruct : EnumerateRange(SourceStructs)) { SourceStructByHandle.Add(SourceStruct->DataHandle, SourceStruct.GetIndex()); } auto GetSourceStructByHandle = [&SourceStructByHandle, &SourceStructs](const FStateTreeDataHandle DataHandle) -> FStateTreeBindableStructDesc* { if (int32* Index = SourceStructByHandle.Find(DataHandle)) { return &SourceStructs[*Index]; } return nullptr; }; // Reconcile out of date classes. for (FStateTreeBindableStructDesc& SourceStruct : SourceStructs) { if (const UClass* SourceClass = Cast(SourceStruct.Struct)) { if (SourceClass->HasAnyClassFlags(CLASS_NewerVersionExists)) { SourceStruct.Struct = SourceClass->GetAuthoritativeClass(); } } } for (FStateTreePropertyCopyBatch& CopyBatch : CopyBatches) { if (const UClass* TargetClass = Cast(CopyBatch.TargetStruct.Struct)) { if (TargetClass->HasAnyClassFlags(CLASS_NewerVersionExists)) { CopyBatch.TargetStruct.Struct = TargetClass->GetAuthoritativeClass(); } } } auto PatchPropertyPath = [](FStateTreePropertyPath& PropertyPath) { for (FStateTreePropertyPathSegment& Segment : PropertyPath.GetMutableSegments()) { if (const UClass* InstanceStruct = Cast(Segment.GetInstanceStruct())) { if (InstanceStruct->HasAnyClassFlags(CLASS_NewerVersionExists)) { Segment.SetInstanceStruct(InstanceStruct->GetAuthoritativeClass()); } } } }; for (FStateTreePropertyPathBinding& PropertyPathBinding : PropertyPathBindings) { PatchPropertyPath(PropertyPathBinding.GetMutableSourcePath()); PatchPropertyPath(PropertyPathBinding.GetMutableTargetPath()); } // Update property bag structs before resolving binding. if (FStateTreeBindableStructDesc* RootParamsDesc = GetSourceStructByHandle(FStateTreeDataHandle(EStateTreeDataSourceType::GlobalParameterData))) { RootParamsDesc->Struct = Parameters.GetPropertyBagStruct(); } // Refresh state parameter descs and bindings batches. for (const FCompactStateTreeState& State : States) { // For subtrees and linked states, the parameters must exists. if (State.Type == EStateTreeStateType::Subtree || State.Type == EStateTreeStateType::Linked || State.Type == EStateTreeStateType::LinkedAsset) { if (!State.ParameterTemplateIndex.IsValid()) { UE_LOG(LogStateTree, Error, TEXT("%s: Data for state '%s' is malformed. Please recompile the StateTree asset."), *GetFullName(), *State.Name.ToString()); return false; } } if (State.ParameterTemplateIndex.IsValid()) { // Subtree is a bind source, update bag struct. const FCompactStateTreeParameters& Params = DefaultInstanceData.GetMutableStruct(State.ParameterTemplateIndex.Get()).Get(); FStateTreeBindableStructDesc* Desc = GetSourceStructByHandle(State.ParameterDataHandle); if (!Desc) { UE_LOG(LogStateTree, Error, TEXT("%s: Data for state '%s' is malformed. Please recompile the StateTree asset."), *GetFullName(), *State.Name.ToString()); return false; } Desc->Struct = Params.Parameters.GetPropertyBagStruct(); if (State.ParameterBindingsBatch.IsValid()) { FStateTreePropertyCopyBatch& Batch = CopyBatches[State.ParameterBindingsBatch.Get()]; Batch.TargetStruct.Struct = Params.Parameters.GetPropertyBagStruct(); } } } // Check linked state property bags consistency for (const FCompactStateTreeState& State : States) { if (State.Type == EStateTreeStateType::Linked && State.LinkedState.IsValid()) { const FCompactStateTreeState& LinkedState = States[State.LinkedState.Index]; if (State.ParameterTemplateIndex.IsValid() == false || LinkedState.ParameterTemplateIndex.IsValid() == false) { UE_LOG(LogStateTree, Error, TEXT("%s: Data for state '%s' is malformed. Please recompile the StateTree asset."), *GetFullName(), *State.Name.ToString()); return false; } // Check that the bag in linked state matches. const FCompactStateTreeParameters& Params = DefaultInstanceData.GetMutableStruct(State.ParameterTemplateIndex.Get()).Get(); const FCompactStateTreeParameters& LinkedStateParams = DefaultInstanceData.GetMutableStruct(LinkedState.ParameterTemplateIndex.Get()).Get(); if (LinkedStateParams.Parameters.GetPropertyBagStruct() != Params.Parameters.GetPropertyBagStruct()) { UE_LOG(LogStateTree, Error, TEXT("%s: The parameters on state '%s' does not match the linked state parameters in state '%s'. Please recompile the StateTree asset."), *GetFullName(), *State.Name.ToString(), *LinkedState.Name.ToString()); return false; } } else if (State.Type == EStateTreeStateType::LinkedAsset && State.LinkedAsset) { // Check that the bag in linked state matches. const FInstancedPropertyBag& TargetTreeParameters = State.LinkedAsset->Parameters; const FCompactStateTreeParameters& Params = DefaultInstanceData.GetMutableStruct(State.ParameterTemplateIndex.Get()).Get(); if (TargetTreeParameters.GetPropertyBagStruct() != Params.Parameters.GetPropertyBagStruct()) { UE_LOG(LogStateTree, Error, TEXT("%s: The parameters on state '%s' does not match the linked asset parameters '%s'. Please recompile the StateTree asset."), *GetFullName(), *State.Name.ToString(), *State.LinkedAsset->GetFullName()); return false; } } } TMap DataViews; TMap BindingBatchDataView; // Tree parameters DataViews.Add(FStateTreeDataHandle(EStateTreeDataSourceType::GlobalParameterData), Parameters.GetMutableValue()); // Setup data views for context data. Since the external data is passed at runtime, we can only provide the type. for (const FStateTreeExternalDataDesc& DataDesc : ContextDataDescs) { DataViews.Add(DataDesc.Handle.DataHandle, FStateTreeDataView(DataDesc.Struct, nullptr)); } // Setup data views for state parameters. for (FCompactStateTreeState& State : States) { if (State.ParameterDataHandle.IsValid()) { FCompactStateTreeParameters& Params = DefaultInstanceData.GetMutableStruct(State.ParameterTemplateIndex.Get()).Get(); DataViews.Add(State.ParameterDataHandle, Params.Parameters.GetMutableValue()); if (State.ParameterBindingsBatch.IsValid()) { BindingBatchDataView.Add(State.ParameterBindingsBatch, Params.Parameters.GetMutableValue()); } } } // Setup data views for all nodes. for (FConstStructView NodeView : Nodes) { const FStateTreeNodeBase& Node = NodeView.Get(); FStateTreeInstanceData* SourceInstanceData = &DefaultInstanceData; if (NodeView.GetPtr()) { // Conditions are stored in shared instance data. SourceInstanceData = &SharedInstanceData; } FStateTreeDataView NodeDataView = Node.InstanceDataHandle.IsObjectSource() ? FStateTreeDataView(SourceInstanceData->GetMutableObject(Node.InstanceTemplateIndex.Get())) : FStateTreeDataView(SourceInstanceData->GetMutableStruct(Node.InstanceTemplateIndex.Get())); DataViews.Add(Node.InstanceDataHandle, NodeDataView); if (Node.BindingsBatch.IsValid()) { BindingBatchDataView.Add(Node.BindingsBatch, NodeDataView); } } auto GetDataSourceView = [&DataViews](const FStateTreeDataHandle Handle) -> FStateTreeDataView { if (const FStateTreeDataView* ViewPtr = DataViews.Find(Handle)) { return *ViewPtr; } return FStateTreeDataView(); }; auto GetBindingBatchDataView = [&BindingBatchDataView](const FStateTreeIndex16 Index) -> FStateTreeDataView { if (const FStateTreeDataView* ViewPtr = BindingBatchDataView.Find(Index)) { return *ViewPtr; } return FStateTreeDataView(); }; for (int32 BatchIndex = 0; BatchIndex < CopyBatches.Num(); ++BatchIndex) { const FStateTreePropertyCopyBatch& Batch = CopyBatches[BatchIndex]; // Find data view for the binding target. FStateTreeDataView TargetView = GetBindingBatchDataView(FStateTreeIndex16(BatchIndex)); if (!TargetView.IsValid()) { UE_LOG(LogStateTree, Error, TEXT("%hs: Invalid target struct when trying to bind to '%s'."), __FUNCTION__, *Batch.TargetStruct.Name.ToString()); return false; } FString ErrorMsg; for (int32 Index = Batch.BindingsBegin; Index != Batch.BindingsEnd; Index++) { FStateTreePropertyPathBinding& Binding = PropertyPathBindings[Index]; FStateTreeDataView SourceView = GetDataSourceView(Binding.GetSourceDataHandle()); if (!Binding.GetMutableSourcePath().UpdateSegmentsFromValue(SourceView, &ErrorMsg)) { UE_LOG(LogStateTree, Error, TEXT("%hs: Failed to update source instance structs for property binding '%s'. Reason: %s"), __FUNCTION__, *Binding.GetTargetPath().ToString(), *ErrorMsg); return false; } if (!Binding.GetMutableTargetPath().UpdateSegmentsFromValue(TargetView, &ErrorMsg)) { UE_LOG(LogStateTree, Error, TEXT("%hs: Failed to update target instance structs for property binding '%s'. Reason: %s"), __FUNCTION__, *Binding.GetTargetPath().ToString(), *ErrorMsg); return false; } } } return true; } #if WITH_EDITOR void FStateTreeMemoryUsage::AddUsage(const FConstStructView View) { if (const UScriptStruct* ScriptStruct = View.GetScriptStruct()) { EstimatedMemoryUsage = Align(EstimatedMemoryUsage, ScriptStruct->GetMinAlignment()); EstimatedMemoryUsage += ScriptStruct->GetStructureSize(); } } void FStateTreeMemoryUsage::AddUsage(const UObject* Object) { if (Object != nullptr) { check(Object->GetClass()); EstimatedMemoryUsage += Object->GetClass()->GetStructureSize(); } } TArray UStateTree::CalculateEstimatedMemoryUsage() const { TArray MemoryUsages; TArray> StateLinks; if (!bIsLinked || States.IsEmpty() || !Nodes.IsValid()) { return MemoryUsages; } const int32 TreeMemUsageIndex = MemoryUsages.Emplace(TEXT("State Tree Max")); const int32 InstanceMemUsageIndex = MemoryUsages.Emplace(TEXT("Instance Overhead")); const int32 EvalMemUsageIndex = MemoryUsages.Emplace(TEXT("Evaluators")); const int32 GlobalTaskMemUsageIndex = MemoryUsages.Emplace(TEXT("GlobalTask")); const int32 SharedMemUsageIndex = MemoryUsages.Emplace(TEXT("Shared Data")); auto GetRootStateHandle = [this](const FStateTreeStateHandle InState) -> FStateTreeStateHandle { FStateTreeStateHandle Result = InState; while (Result.IsValid() && States[Result.Index].Parent.IsValid()) { Result = States[Result.Index].Parent; } return Result; }; auto GetUsageIndexForState = [&MemoryUsages, this](const FStateTreeStateHandle InStateHandle) -> int32 { check(InStateHandle.IsValid()); const int32 FoundMemUsage = MemoryUsages.IndexOfByPredicate([InStateHandle](const FStateTreeMemoryUsage& MemUsage) { return MemUsage.Handle == InStateHandle; }); if (FoundMemUsage != INDEX_NONE) { return FoundMemUsage; } const FCompactStateTreeState& CompactState = States[InStateHandle.Index]; return MemoryUsages.Emplace(TEXT("State ") + CompactState.Name.ToString(), InStateHandle); }; // Calculate memory usage per state. TArray TempStateMemoryUsages; TempStateMemoryUsages.SetNum(States.Num()); for (int32 Index = 0; Index < States.Num(); Index++) { const FStateTreeStateHandle StateHandle((uint16)Index); const FCompactStateTreeState& CompactState = States[Index]; const FStateTreeStateHandle ParentHandle = GetRootStateHandle(StateHandle); const int32 ParentUsageIndex = GetUsageIndexForState(ParentHandle); FStateTreeMemoryUsage& MemUsage = CompactState.Parent.IsValid() ? TempStateMemoryUsages[Index] : MemoryUsages[GetUsageIndexForState(StateHandle)]; MemUsage.NodeCount += CompactState.TasksNum; if (CompactState.Type == EStateTreeStateType::Linked) { const int32 LinkedUsageIndex = GetUsageIndexForState(CompactState.LinkedState); StateLinks.Emplace(ParentUsageIndex, LinkedUsageIndex); } if (CompactState.ParameterTemplateIndex.IsValid()) { MemUsage.NodeCount++; MemUsage.AddUsage(DefaultInstanceData.GetStruct(CompactState.ParameterTemplateIndex.Get())); } for (int32 TaskIndex = CompactState.TasksBegin; TaskIndex < (CompactState.TasksBegin + CompactState.TasksNum); TaskIndex++) { if (const FStateTreeTaskBase* Task = Nodes[TaskIndex].GetPtr()) { if (Task->InstanceDataHandle.IsObjectSource()) { MemUsage.NodeCount++; MemUsage.AddUsage(DefaultInstanceData.GetObject(Task->InstanceTemplateIndex.Get())); } else { MemUsage.NodeCount++; MemUsage.AddUsage(DefaultInstanceData.GetStruct(Task->InstanceTemplateIndex.Get())); } } } } // Combine max child usage to parents. Iterate backwards to update children first. for (int32 Index = States.Num() - 1; Index >= 0; Index--) { const FStateTreeStateHandle StateHandle((uint16)Index); const FCompactStateTreeState& CompactState = States[Index]; FStateTreeMemoryUsage& MemUsage = CompactState.Parent.IsValid() ? TempStateMemoryUsages[Index] : MemoryUsages[GetUsageIndexForState(StateHandle)]; int32 MaxChildStateMem = 0; int32 MaxChildStateNodes = 0; for (uint16 ChildState = CompactState.ChildrenBegin; ChildState < CompactState.ChildrenEnd; ChildState = States[ChildState].GetNextSibling()) { const FStateTreeMemoryUsage& ChildMemUsage = TempStateMemoryUsages[ChildState]; if (ChildMemUsage.EstimatedMemoryUsage > MaxChildStateMem) { MaxChildStateMem = ChildMemUsage.EstimatedMemoryUsage; MaxChildStateNodes = ChildMemUsage.NodeCount; } } MemUsage.EstimatedMemoryUsage += MaxChildStateMem; MemUsage.NodeCount += MaxChildStateNodes; } // Accumulate linked states. for (int32 Index = StateLinks.Num() - 1; Index >= 0; Index--) { FStateTreeMemoryUsage& ParentUsage = MemoryUsages[StateLinks[Index].Get<0>()]; const FStateTreeMemoryUsage& LinkedUsage = MemoryUsages[StateLinks[Index].Get<1>()]; const int32 LinkedTotalUsage = LinkedUsage.EstimatedMemoryUsage + LinkedUsage.EstimatedChildMemoryUsage; if (LinkedTotalUsage > ParentUsage.EstimatedChildMemoryUsage) { ParentUsage.EstimatedChildMemoryUsage = LinkedTotalUsage; ParentUsage.ChildNodeCount = LinkedUsage.NodeCount + LinkedUsage.ChildNodeCount; } } // Evaluators FStateTreeMemoryUsage& EvalMemUsage = MemoryUsages[EvalMemUsageIndex]; for (int32 EvalIndex = EvaluatorsBegin; EvalIndex < (EvaluatorsBegin + EvaluatorsNum); EvalIndex++) { const FStateTreeEvaluatorBase& Eval = Nodes[EvalIndex].Get(); if (Eval.InstanceDataHandle.IsObjectSource()) { EvalMemUsage.AddUsage(DefaultInstanceData.GetObject(Eval.InstanceTemplateIndex.Get())); } else { EvalMemUsage.AddUsage(DefaultInstanceData.GetStruct(Eval.InstanceTemplateIndex.Get())); } EvalMemUsage.NodeCount++; } // Global Tasks FStateTreeMemoryUsage& GlobalTaskMemUsage = MemoryUsages[GlobalTaskMemUsageIndex]; for (int32 TaskIndex = GlobalTasksBegin; TaskIndex < (GlobalTasksBegin + GlobalTasksNum); TaskIndex++) { const FStateTreeTaskBase& Task = Nodes[TaskIndex].Get(); if (Task.InstanceDataHandle.IsObjectSource()) { GlobalTaskMemUsage.AddUsage(DefaultInstanceData.GetObject(Task.InstanceTemplateIndex.Get())); } else { GlobalTaskMemUsage.AddUsage(DefaultInstanceData.GetStruct(Task.InstanceTemplateIndex.Get())); } GlobalTaskMemUsage.NodeCount++; } // Estimate highest combined usage. FStateTreeMemoryUsage& TreeMemUsage = MemoryUsages[TreeMemUsageIndex]; // Exec state TreeMemUsage.AddUsage(DefaultInstanceData.GetStruct(0)); TreeMemUsage.NodeCount++; TreeMemUsage.EstimatedMemoryUsage += EvalMemUsage.EstimatedMemoryUsage; TreeMemUsage.NodeCount += EvalMemUsage.NodeCount; TreeMemUsage.EstimatedMemoryUsage += GlobalTaskMemUsage.EstimatedMemoryUsage; TreeMemUsage.NodeCount += GlobalTaskMemUsage.NodeCount; FStateTreeMemoryUsage& InstanceMemUsage = MemoryUsages[InstanceMemUsageIndex]; // FStateTreeInstanceData overhead. InstanceMemUsage.EstimatedMemoryUsage += sizeof(FStateTreeInstanceData); // FInstancedStructContainer overhead. InstanceMemUsage.EstimatedMemoryUsage += TreeMemUsage.NodeCount * FInstancedStructContainer::OverheadPerItem; TreeMemUsage.EstimatedMemoryUsage += InstanceMemUsage.EstimatedMemoryUsage; int32 MaxSubtreeUsage = 0; int32 MaxSubtreeNodeCount = 0; for (const FStateTreeMemoryUsage& MemUsage : MemoryUsages) { if (MemUsage.Handle.IsValid()) { const int32 TotalUsage = MemUsage.EstimatedMemoryUsage + MemUsage.EstimatedChildMemoryUsage; if (TotalUsage > MaxSubtreeUsage) { MaxSubtreeUsage = TotalUsage; MaxSubtreeNodeCount = MemUsage.NodeCount + MemUsage.ChildNodeCount; } } } TreeMemUsage.EstimatedMemoryUsage += MaxSubtreeUsage; TreeMemUsage.NodeCount += MaxSubtreeNodeCount; FStateTreeMemoryUsage& SharedMemUsage = MemoryUsages[SharedMemUsageIndex]; SharedMemUsage.NodeCount = SharedInstanceData.Num(); SharedMemUsage.EstimatedMemoryUsage = SharedInstanceData.GetEstimatedMemoryUsage(); return MemoryUsages; } #endif // WITH_EDITOR