Previously, we only measured the execution time of built-in nodes. To get execution times of node groups, the time of each nested node was accumulated. This can lead to very bad accuracy when multiple nodes are evaluated at the same time. With this patch, we measure the time spend in each compute context more directly instead of relying on accumulating many small measurements. This also opens up some potential optimization opportunities, because we can skip measuring the time for contexts that we don't care about. However, that is not implemented yet. The time shown in the UI can still be misleading when many things are going on at the same time, but it should at least be more accurate in more situations now. Pull Request: https://projects.blender.org/blender/blender/pulls/127658
775 lines
28 KiB
C++
775 lines
28 KiB
C++
/* SPDX-FileCopyrightText: 2023 Blender Authors
|
|
*
|
|
* SPDX-License-Identifier: GPL-2.0-or-later */
|
|
|
|
#include "NOD_geometry_nodes_lazy_function.hh"
|
|
#include "NOD_geometry_nodes_log.hh"
|
|
|
|
#include "BKE_compute_contexts.hh"
|
|
#include "BKE_curves.hh"
|
|
#include "BKE_geometry_nodes_gizmos_transforms.hh"
|
|
#include "BKE_node_runtime.hh"
|
|
#include "BKE_node_socket_value.hh"
|
|
#include "BKE_type_conversions.hh"
|
|
#include "BKE_volume.hh"
|
|
#include "BKE_volume_openvdb.hh"
|
|
|
|
#include "DNA_grease_pencil_types.h"
|
|
#include "DNA_modifier_types.h"
|
|
#include "DNA_space_types.h"
|
|
|
|
#include "ED_geometry.hh"
|
|
#include "ED_node.hh"
|
|
#include "ED_viewer_path.hh"
|
|
|
|
#include "MOD_nodes.hh"
|
|
|
|
namespace blender::nodes::geo_eval_log {
|
|
|
|
using bke::bNodeTreeZone;
|
|
using bke::bNodeTreeZones;
|
|
using fn::FieldInput;
|
|
using fn::FieldInputs;
|
|
|
|
GenericValueLog::~GenericValueLog()
|
|
{
|
|
this->value.destruct();
|
|
}
|
|
|
|
FieldInfoLog::FieldInfoLog(const GField &field) : type(field.cpp_type())
|
|
{
|
|
const std::shared_ptr<const fn::FieldInputs> &field_input_nodes = field.node().field_inputs();
|
|
|
|
/* Put the deduplicated field inputs into a vector so that they can be sorted below. */
|
|
Vector<std::reference_wrapper<const FieldInput>> field_inputs;
|
|
if (field_input_nodes) {
|
|
field_inputs.extend(field_input_nodes->deduplicated_nodes.begin(),
|
|
field_input_nodes->deduplicated_nodes.end());
|
|
}
|
|
|
|
std::sort(
|
|
field_inputs.begin(), field_inputs.end(), [](const FieldInput &a, const FieldInput &b) {
|
|
const int index_a = int(a.category());
|
|
const int index_b = int(b.category());
|
|
if (index_a == index_b) {
|
|
return a.socket_inspection_name().size() < b.socket_inspection_name().size();
|
|
}
|
|
return index_a < index_b;
|
|
});
|
|
|
|
for (const FieldInput &field_input : field_inputs) {
|
|
this->input_tooltips.append(field_input.socket_inspection_name());
|
|
}
|
|
}
|
|
|
|
GeometryInfoLog::GeometryInfoLog(const bke::GeometrySet &geometry_set)
|
|
{
|
|
this->name = geometry_set.name;
|
|
|
|
static std::array all_component_types = {bke::GeometryComponent::Type::Curve,
|
|
bke::GeometryComponent::Type::Instance,
|
|
bke::GeometryComponent::Type::Mesh,
|
|
bke::GeometryComponent::Type::PointCloud,
|
|
bke::GeometryComponent::Type::GreasePencil,
|
|
bke::GeometryComponent::Type::Volume};
|
|
|
|
/* Keep track handled attribute names to make sure that we do not return the same name twice.
|
|
* Currently #GeometrySet::attribute_foreach does not do that. Note that this will merge
|
|
* attributes with the same name but different domains or data types on separate components. */
|
|
Set<StringRef> names;
|
|
|
|
geometry_set.attribute_foreach(
|
|
all_component_types,
|
|
true,
|
|
[&](const StringRef attribute_id,
|
|
const bke::AttributeMetaData &meta_data,
|
|
const bke::GeometryComponent & /*component*/) {
|
|
if (!bke::attribute_name_is_anonymous(attribute_id) && names.add(attribute_id)) {
|
|
this->attributes.append({attribute_id, meta_data.domain, meta_data.data_type});
|
|
}
|
|
});
|
|
|
|
for (const bke::GeometryComponent *component : geometry_set.get_components()) {
|
|
this->component_types.append(component->type());
|
|
switch (component->type()) {
|
|
case bke::GeometryComponent::Type::Mesh: {
|
|
const auto &mesh_component = *static_cast<const bke::MeshComponent *>(component);
|
|
MeshInfo &info = this->mesh_info.emplace();
|
|
info.verts_num = mesh_component.attribute_domain_size(bke::AttrDomain::Point);
|
|
info.edges_num = mesh_component.attribute_domain_size(bke::AttrDomain::Edge);
|
|
info.faces_num = mesh_component.attribute_domain_size(bke::AttrDomain::Face);
|
|
break;
|
|
}
|
|
case bke::GeometryComponent::Type::Curve: {
|
|
const auto &curve_component = *static_cast<const bke::CurveComponent *>(component);
|
|
CurveInfo &info = this->curve_info.emplace();
|
|
info.points_num = curve_component.attribute_domain_size(bke::AttrDomain::Point);
|
|
info.splines_num = curve_component.attribute_domain_size(bke::AttrDomain::Curve);
|
|
break;
|
|
}
|
|
case bke::GeometryComponent::Type::PointCloud: {
|
|
const auto &pointcloud_component = *static_cast<const bke::PointCloudComponent *>(
|
|
component);
|
|
PointCloudInfo &info = this->pointcloud_info.emplace();
|
|
info.points_num = pointcloud_component.attribute_domain_size(bke::AttrDomain::Point);
|
|
break;
|
|
}
|
|
case bke::GeometryComponent::Type::Instance: {
|
|
const auto &instances_component = *static_cast<const bke::InstancesComponent *>(component);
|
|
InstancesInfo &info = this->instances_info.emplace();
|
|
info.instances_num = instances_component.attribute_domain_size(bke::AttrDomain::Instance);
|
|
break;
|
|
}
|
|
case bke::GeometryComponent::Type::Edit: {
|
|
const auto &edit_component = *static_cast<const bke::GeometryComponentEditData *>(
|
|
component);
|
|
if (!this->edit_data_info) {
|
|
this->edit_data_info.emplace(EditDataInfo());
|
|
}
|
|
EditDataInfo &info = *this->edit_data_info;
|
|
if (const bke::CurvesEditHints *curve_edit_hints = edit_component.curves_edit_hints_.get())
|
|
{
|
|
info.has_deform_matrices = curve_edit_hints->deform_mats.has_value();
|
|
info.has_deformed_positions = curve_edit_hints->positions().has_value();
|
|
}
|
|
if (const bke::GizmoEditHints *gizmo_edit_hints = edit_component.gizmo_edit_hints_.get()) {
|
|
info.gizmo_transforms_num = gizmo_edit_hints->gizmo_transforms.size();
|
|
}
|
|
break;
|
|
}
|
|
case bke::GeometryComponent::Type::Volume: {
|
|
const auto &volume_component = *static_cast<const bke::VolumeComponent *>(component);
|
|
if (const Volume *volume = volume_component.get()) {
|
|
VolumeInfo &info = this->volume_info.emplace();
|
|
info.grids_num = BKE_volume_num_grids(volume);
|
|
}
|
|
break;
|
|
}
|
|
case bke::GeometryComponent::Type::GreasePencil: {
|
|
const auto &grease_pencil_component = *static_cast<const bke::GreasePencilComponent *>(
|
|
component);
|
|
if (const GreasePencil *grease_pencil = grease_pencil_component.get()) {
|
|
GreasePencilInfo &info = this->grease_pencil_info.emplace(GreasePencilInfo());
|
|
info.layers_num = grease_pencil->layers().size();
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
#ifdef WITH_OPENVDB
|
|
struct GridIsEmptyOp {
|
|
const openvdb::GridBase &base_grid;
|
|
bool result = false;
|
|
|
|
template<typename GridType> bool operator()()
|
|
{
|
|
result = static_cast<const GridType &>(base_grid).empty();
|
|
return true;
|
|
}
|
|
};
|
|
#endif /* WITH_OPENVDB */
|
|
|
|
GeometryInfoLog::GeometryInfoLog(const bke::GVolumeGrid &grid)
|
|
{
|
|
GridInfo &info = this->grid_info.emplace();
|
|
#ifdef WITH_OPENVDB
|
|
bke::VolumeTreeAccessToken token;
|
|
const openvdb::GridBase &vdb_grid = grid->grid(token);
|
|
const VolumeGridType grid_type = bke::volume_grid::get_type(vdb_grid);
|
|
|
|
GridIsEmptyOp is_empty_op{vdb_grid};
|
|
if (BKE_volume_grid_type_operation(grid_type, is_empty_op)) {
|
|
info.is_empty = is_empty_op.result;
|
|
}
|
|
else {
|
|
info.is_empty = true;
|
|
}
|
|
#else
|
|
UNUSED_VARS(grid);
|
|
info.is_empty = true;
|
|
#endif
|
|
}
|
|
|
|
/* Avoid generating these in every translation unit. */
|
|
GeoModifierLog::GeoModifierLog() = default;
|
|
GeoModifierLog::~GeoModifierLog() = default;
|
|
|
|
GeoTreeLogger::GeoTreeLogger() = default;
|
|
GeoTreeLogger::~GeoTreeLogger() = default;
|
|
|
|
GeoNodeLog::GeoNodeLog() = default;
|
|
GeoNodeLog::~GeoNodeLog() = default;
|
|
|
|
GeoTreeLog::GeoTreeLog(GeoModifierLog *modifier_log, Vector<GeoTreeLogger *> tree_loggers)
|
|
: modifier_log_(modifier_log), tree_loggers_(std::move(tree_loggers))
|
|
{
|
|
for (GeoTreeLogger *tree_logger : tree_loggers_) {
|
|
for (const ComputeContextHash &hash : tree_logger->children_hashes) {
|
|
children_hashes_.add(hash);
|
|
}
|
|
}
|
|
}
|
|
|
|
GeoTreeLog::~GeoTreeLog() = default;
|
|
|
|
void GeoTreeLogger::log_value(const bNode &node, const bNodeSocket &socket, const GPointer value)
|
|
{
|
|
const CPPType &type = *value.type();
|
|
|
|
auto store_logged_value = [&](destruct_ptr<ValueLog> value_log) {
|
|
auto &socket_values = socket.in_out == SOCK_IN ? this->input_socket_values :
|
|
this->output_socket_values;
|
|
socket_values.append(*this->allocator,
|
|
{node.identifier, socket.index(), std::move(value_log)});
|
|
};
|
|
|
|
auto log_generic_value = [&](const CPPType &type, const void *value) {
|
|
void *buffer = this->allocator->allocate(type.size(), type.alignment());
|
|
type.copy_construct(value, buffer);
|
|
store_logged_value(this->allocator->construct<GenericValueLog>(GMutablePointer{type, buffer}));
|
|
};
|
|
|
|
if (type.is<bke::GeometrySet>()) {
|
|
const bke::GeometrySet &geometry = *value.get<bke::GeometrySet>();
|
|
store_logged_value(this->allocator->construct<GeometryInfoLog>(geometry));
|
|
}
|
|
else if (type.is<bke::SocketValueVariant>()) {
|
|
bke::SocketValueVariant value_variant = *value.get<bke::SocketValueVariant>();
|
|
if (value_variant.is_context_dependent_field()) {
|
|
const GField field = value_variant.extract<GField>();
|
|
store_logged_value(this->allocator->construct<FieldInfoLog>(field));
|
|
}
|
|
#ifdef WITH_OPENVDB
|
|
else if (value_variant.is_volume_grid()) {
|
|
const bke::GVolumeGrid grid = value_variant.extract<bke::GVolumeGrid>();
|
|
store_logged_value(this->allocator->construct<GeometryInfoLog>(grid));
|
|
}
|
|
#endif
|
|
else {
|
|
value_variant.convert_to_single();
|
|
const GPointer value = value_variant.get_single_ptr();
|
|
log_generic_value(*value.type(), value.get());
|
|
}
|
|
}
|
|
else {
|
|
log_generic_value(type, value.get());
|
|
}
|
|
}
|
|
|
|
void GeoTreeLogger::log_viewer_node(const bNode &viewer_node, bke::GeometrySet geometry)
|
|
{
|
|
destruct_ptr<ViewerNodeLog> log = this->allocator->construct<ViewerNodeLog>();
|
|
log->geometry = std::move(geometry);
|
|
log->geometry.ensure_owns_direct_data();
|
|
this->viewer_node_logs.append(*this->allocator, {viewer_node.identifier, std::move(log)});
|
|
}
|
|
|
|
static bool warning_is_propagated(const NodeWarningPropagation propagation,
|
|
const NodeWarningType warning_type)
|
|
{
|
|
switch (propagation) {
|
|
case NODE_WARNING_PROPAGATION_ALL:
|
|
return true;
|
|
case NODE_WARNING_PROPAGATION_NONE:
|
|
return false;
|
|
case NODE_WARNING_PROPAGATION_ONLY_ERRORS:
|
|
return warning_type == NodeWarningType::Error;
|
|
case NODE_WARNING_PROPAGATION_ONLY_ERRORS_AND_WARNINGS:
|
|
return ELEM(warning_type, NodeWarningType::Error, NodeWarningType::Warning);
|
|
}
|
|
BLI_assert_unreachable();
|
|
return true;
|
|
}
|
|
|
|
void GeoTreeLog::ensure_node_warnings(const bNodeTree *tree)
|
|
{
|
|
if (reduced_node_warnings_) {
|
|
return;
|
|
}
|
|
|
|
for (GeoTreeLogger *tree_logger : tree_loggers_) {
|
|
for (const GeoTreeLogger::WarningWithNode &warning : tree_logger->node_warnings) {
|
|
NodeWarningPropagation propagation = NODE_WARNING_PROPAGATION_ALL;
|
|
if (tree) {
|
|
if (const bNode *node = tree->node_by_id(warning.node_id)) {
|
|
propagation = NodeWarningPropagation(node->warning_propagation);
|
|
}
|
|
}
|
|
this->nodes.lookup_or_add_default(warning.node_id).warnings.add(warning.warning);
|
|
if (warning_is_propagated(propagation, warning.warning.type)) {
|
|
this->all_warnings.add(warning.warning);
|
|
}
|
|
}
|
|
}
|
|
for (const ComputeContextHash &child_hash : children_hashes_) {
|
|
GeoTreeLog &child_log = modifier_log_->get_tree_log(child_hash);
|
|
if (child_log.tree_loggers_.is_empty()) {
|
|
continue;
|
|
}
|
|
NodeWarningPropagation propagation = NODE_WARNING_PROPAGATION_ALL;
|
|
const bNodeTree *child_tree = nullptr;
|
|
const std::optional<int32_t> &parent_node_id = child_log.tree_loggers_[0]->parent_node_id;
|
|
if (tree && parent_node_id) {
|
|
if (const bNode *node = tree->node_by_id(*parent_node_id)) {
|
|
propagation = NodeWarningPropagation(node->warning_propagation);
|
|
if (node->is_group() && node->id) {
|
|
child_tree = reinterpret_cast<const bNodeTree *>(node->id);
|
|
}
|
|
else if (bke::all_zone_output_node_types().contains(node->type)) {
|
|
child_tree = tree;
|
|
}
|
|
}
|
|
}
|
|
child_log.ensure_node_warnings(child_tree);
|
|
if (parent_node_id.has_value()) {
|
|
this->nodes.lookup_or_add_default(*parent_node_id)
|
|
.warnings.add_multiple(child_log.all_warnings);
|
|
}
|
|
for (const NodeWarning &warning : child_log.all_warnings) {
|
|
if (warning_is_propagated(propagation, warning.type)) {
|
|
this->all_warnings.add(warning);
|
|
continue;
|
|
}
|
|
}
|
|
}
|
|
reduced_node_warnings_ = true;
|
|
}
|
|
|
|
void GeoTreeLog::ensure_execution_times()
|
|
{
|
|
if (reduced_execution_times_) {
|
|
return;
|
|
}
|
|
for (GeoTreeLogger *tree_logger : tree_loggers_) {
|
|
for (const GeoTreeLogger::NodeExecutionTime &timings : tree_logger->node_execution_times) {
|
|
const std::chrono::nanoseconds duration = timings.end - timings.start;
|
|
this->nodes.lookup_or_add_default_as(timings.node_id).execution_time += duration;
|
|
}
|
|
this->execution_time += tree_logger->execution_time;
|
|
}
|
|
for (const ComputeContextHash &child_hash : children_hashes_) {
|
|
GeoTreeLog &child_log = modifier_log_->get_tree_log(child_hash);
|
|
if (child_log.tree_loggers_.is_empty()) {
|
|
continue;
|
|
}
|
|
child_log.ensure_execution_times();
|
|
const std::optional<int32_t> &parent_node_id = child_log.tree_loggers_[0]->parent_node_id;
|
|
if (parent_node_id.has_value()) {
|
|
this->nodes.lookup_or_add_default(*parent_node_id).execution_time +=
|
|
child_log.execution_time;
|
|
}
|
|
}
|
|
reduced_execution_times_ = true;
|
|
}
|
|
|
|
void GeoTreeLog::ensure_socket_values()
|
|
{
|
|
if (reduced_socket_values_) {
|
|
return;
|
|
}
|
|
for (GeoTreeLogger *tree_logger : tree_loggers_) {
|
|
for (const GeoTreeLogger::SocketValueLog &value_log_data : tree_logger->input_socket_values) {
|
|
this->nodes.lookup_or_add_as(value_log_data.node_id)
|
|
.input_values_.add(value_log_data.socket_index, value_log_data.value.get());
|
|
}
|
|
for (const GeoTreeLogger::SocketValueLog &value_log_data : tree_logger->output_socket_values) {
|
|
this->nodes.lookup_or_add_as(value_log_data.node_id)
|
|
.output_values_.add(value_log_data.socket_index, value_log_data.value.get());
|
|
}
|
|
}
|
|
reduced_socket_values_ = true;
|
|
}
|
|
|
|
void GeoTreeLog::ensure_viewer_node_logs()
|
|
{
|
|
if (reduced_viewer_node_logs_) {
|
|
return;
|
|
}
|
|
for (GeoTreeLogger *tree_logger : tree_loggers_) {
|
|
for (const GeoTreeLogger::ViewerNodeLogWithNode &viewer_log : tree_logger->viewer_node_logs) {
|
|
this->viewer_node_logs.add(viewer_log.node_id, viewer_log.viewer_log.get());
|
|
}
|
|
}
|
|
reduced_viewer_node_logs_ = true;
|
|
}
|
|
|
|
void GeoTreeLog::ensure_existing_attributes()
|
|
{
|
|
if (reduced_existing_attributes_) {
|
|
return;
|
|
}
|
|
this->ensure_socket_values();
|
|
|
|
auto handle_value_log = [&](const ValueLog &value_log) {
|
|
const GeometryInfoLog *geo_log = dynamic_cast<const GeometryInfoLog *>(&value_log);
|
|
if (geo_log == nullptr) {
|
|
return;
|
|
}
|
|
for (const GeometryAttributeInfo &attribute : geo_log->attributes) {
|
|
this->existing_attributes.append(&attribute);
|
|
}
|
|
};
|
|
|
|
for (const GeoNodeLog &node_log : this->nodes.values()) {
|
|
for (const ValueLog *value_log : node_log.input_values_.values()) {
|
|
handle_value_log(*value_log);
|
|
}
|
|
for (const ValueLog *value_log : node_log.output_values_.values()) {
|
|
handle_value_log(*value_log);
|
|
}
|
|
}
|
|
reduced_existing_attributes_ = true;
|
|
}
|
|
|
|
void GeoTreeLog::ensure_used_named_attributes()
|
|
{
|
|
if (reduced_used_named_attributes_) {
|
|
return;
|
|
}
|
|
|
|
auto add_attribute = [&](const int32_t node_id,
|
|
const StringRefNull attribute_name,
|
|
const NamedAttributeUsage &usage) {
|
|
this->nodes.lookup_or_add_default(node_id).used_named_attributes.lookup_or_add(attribute_name,
|
|
usage) |= usage;
|
|
this->used_named_attributes.lookup_or_add_as(attribute_name, usage) |= usage;
|
|
};
|
|
|
|
for (GeoTreeLogger *tree_logger : tree_loggers_) {
|
|
for (const GeoTreeLogger::AttributeUsageWithNode &item : tree_logger->used_named_attributes) {
|
|
add_attribute(item.node_id, item.attribute_name, item.usage);
|
|
}
|
|
}
|
|
for (const ComputeContextHash &child_hash : children_hashes_) {
|
|
GeoTreeLog &child_log = modifier_log_->get_tree_log(child_hash);
|
|
if (child_log.tree_loggers_.is_empty()) {
|
|
continue;
|
|
}
|
|
child_log.ensure_used_named_attributes();
|
|
if (const std::optional<int32_t> &parent_node_id = child_log.tree_loggers_[0]->parent_node_id)
|
|
{
|
|
for (const auto item : child_log.used_named_attributes.items()) {
|
|
add_attribute(*parent_node_id, item.key, item.value);
|
|
}
|
|
}
|
|
}
|
|
reduced_used_named_attributes_ = true;
|
|
}
|
|
|
|
void GeoTreeLog::ensure_debug_messages()
|
|
{
|
|
if (reduced_debug_messages_) {
|
|
return;
|
|
}
|
|
for (GeoTreeLogger *tree_logger : tree_loggers_) {
|
|
for (const GeoTreeLogger::DebugMessage &debug_message : tree_logger->debug_messages) {
|
|
this->nodes.lookup_or_add_as(debug_message.node_id)
|
|
.debug_messages.append(debug_message.message);
|
|
}
|
|
}
|
|
reduced_debug_messages_ = true;
|
|
}
|
|
|
|
void GeoTreeLog::ensure_evaluated_gizmo_nodes()
|
|
{
|
|
if (reduced_evaluated_gizmo_nodes_) {
|
|
return;
|
|
}
|
|
for (const GeoTreeLogger *tree_logger : tree_loggers_) {
|
|
for (const GeoTreeLogger::EvaluatedGizmoNode &evaluated_gizmo :
|
|
tree_logger->evaluated_gizmo_nodes)
|
|
{
|
|
this->evaluated_gizmo_nodes.add(evaluated_gizmo.node_id);
|
|
}
|
|
}
|
|
}
|
|
|
|
ValueLog *GeoTreeLog::find_socket_value_log(const bNodeSocket &query_socket)
|
|
{
|
|
/**
|
|
* Geometry nodes does not log values for every socket. That would produce a lot of redundant
|
|
* data,because often many linked sockets have the same value. To find the logged value for a
|
|
* socket one might have to look at linked sockets as well.
|
|
*/
|
|
|
|
BLI_assert(reduced_socket_values_);
|
|
if (query_socket.is_multi_input()) {
|
|
/* Not supported currently. */
|
|
return nullptr;
|
|
}
|
|
|
|
Set<const bNodeSocket *> added_sockets;
|
|
Stack<const bNodeSocket *> sockets_to_check;
|
|
sockets_to_check.push(&query_socket);
|
|
added_sockets.add(&query_socket);
|
|
|
|
while (!sockets_to_check.is_empty()) {
|
|
const bNodeSocket &socket = *sockets_to_check.pop();
|
|
const bNode &node = socket.owner_node();
|
|
if (GeoNodeLog *node_log = this->nodes.lookup_ptr(node.identifier)) {
|
|
ValueLog *value_log = socket.is_input() ?
|
|
node_log->input_values_.lookup_default(socket.index(), nullptr) :
|
|
node_log->output_values_.lookup_default(socket.index(), nullptr);
|
|
if (value_log != nullptr) {
|
|
return value_log;
|
|
}
|
|
}
|
|
|
|
if (socket.is_input()) {
|
|
const Span<const bNodeLink *> links = socket.directly_linked_links();
|
|
for (const bNodeLink *link : links) {
|
|
const bNodeSocket &from_socket = *link->fromsock;
|
|
if (added_sockets.add(&from_socket)) {
|
|
sockets_to_check.push(&from_socket);
|
|
}
|
|
}
|
|
}
|
|
else {
|
|
if (node.is_reroute()) {
|
|
const bNodeSocket &input_socket = node.input_socket(0);
|
|
if (added_sockets.add(&input_socket)) {
|
|
sockets_to_check.push(&input_socket);
|
|
}
|
|
const Span<const bNodeLink *> links = input_socket.directly_linked_links();
|
|
for (const bNodeLink *link : links) {
|
|
const bNodeSocket &from_socket = *link->fromsock;
|
|
if (added_sockets.add(&from_socket)) {
|
|
sockets_to_check.push(&from_socket);
|
|
}
|
|
}
|
|
}
|
|
else if (node.is_muted()) {
|
|
if (const bNodeSocket *input_socket = socket.internal_link_input()) {
|
|
if (added_sockets.add(input_socket)) {
|
|
sockets_to_check.push(input_socket);
|
|
}
|
|
const Span<const bNodeLink *> links = input_socket->directly_linked_links();
|
|
for (const bNodeLink *link : links) {
|
|
const bNodeSocket &from_socket = *link->fromsock;
|
|
if (added_sockets.add(&from_socket)) {
|
|
sockets_to_check.push(&from_socket);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
return nullptr;
|
|
}
|
|
|
|
bool GeoTreeLog::try_convert_primitive_socket_value(const GenericValueLog &value_log,
|
|
const CPPType &dst_type,
|
|
void *dst)
|
|
{
|
|
const void *src_value = value_log.value.get();
|
|
if (!src_value) {
|
|
return false;
|
|
}
|
|
const bke::DataTypeConversions &conversions = bke::get_implicit_type_conversions();
|
|
const CPPType &src_type = *value_log.value.type();
|
|
if (!conversions.is_convertible(src_type, dst_type) && src_type != dst_type) {
|
|
return false;
|
|
}
|
|
dst_type.destruct(dst);
|
|
conversions.convert_to_uninitialized(src_type, dst_type, src_value, dst);
|
|
return true;
|
|
}
|
|
|
|
GeoTreeLogger &GeoModifierLog::get_local_tree_logger(const ComputeContext &compute_context)
|
|
{
|
|
LocalData &local_data = data_per_thread_.local();
|
|
Map<ComputeContextHash, destruct_ptr<GeoTreeLogger>> &local_tree_loggers =
|
|
local_data.tree_logger_by_context;
|
|
destruct_ptr<GeoTreeLogger> &tree_logger_ptr = local_tree_loggers.lookup_or_add_default(
|
|
compute_context.hash());
|
|
if (tree_logger_ptr) {
|
|
return *tree_logger_ptr;
|
|
}
|
|
tree_logger_ptr = local_data.allocator.construct<GeoTreeLogger>();
|
|
GeoTreeLogger &tree_logger = *tree_logger_ptr;
|
|
tree_logger.allocator = &local_data.allocator;
|
|
const ComputeContext *parent_compute_context = compute_context.parent();
|
|
if (parent_compute_context != nullptr) {
|
|
tree_logger.parent_hash = parent_compute_context->hash();
|
|
GeoTreeLogger &parent_logger = this->get_local_tree_logger(*parent_compute_context);
|
|
parent_logger.children_hashes.append(compute_context.hash());
|
|
}
|
|
if (const bke::GroupNodeComputeContext *node_group_compute_context =
|
|
dynamic_cast<const bke::GroupNodeComputeContext *>(&compute_context))
|
|
{
|
|
tree_logger.parent_node_id.emplace(node_group_compute_context->node_id());
|
|
}
|
|
else if (const bke::RepeatZoneComputeContext *node_group_compute_context =
|
|
dynamic_cast<const bke::RepeatZoneComputeContext *>(&compute_context))
|
|
{
|
|
tree_logger.parent_node_id.emplace(node_group_compute_context->output_node_id());
|
|
}
|
|
else if (const bke::SimulationZoneComputeContext *node_group_compute_context =
|
|
dynamic_cast<const bke::SimulationZoneComputeContext *>(&compute_context))
|
|
{
|
|
tree_logger.parent_node_id.emplace(node_group_compute_context->output_node_id());
|
|
}
|
|
return tree_logger;
|
|
}
|
|
|
|
GeoTreeLog &GeoModifierLog::get_tree_log(const ComputeContextHash &compute_context_hash)
|
|
{
|
|
GeoTreeLog &reduced_tree_log = *tree_logs_.lookup_or_add_cb(compute_context_hash, [&]() {
|
|
Vector<GeoTreeLogger *> tree_logs;
|
|
for (LocalData &local_data : data_per_thread_) {
|
|
destruct_ptr<GeoTreeLogger> *tree_log = local_data.tree_logger_by_context.lookup_ptr(
|
|
compute_context_hash);
|
|
if (tree_log != nullptr) {
|
|
tree_logs.append(tree_log->get());
|
|
}
|
|
}
|
|
return std::make_unique<GeoTreeLog>(this, std::move(tree_logs));
|
|
});
|
|
return reduced_tree_log;
|
|
}
|
|
|
|
static void find_tree_zone_hash_recursive(
|
|
const bNodeTreeZone &zone,
|
|
ComputeContextBuilder &compute_context_builder,
|
|
Map<const bNodeTreeZone *, ComputeContextHash> &r_hash_by_zone)
|
|
{
|
|
switch (zone.output_node->type) {
|
|
case GEO_NODE_SIMULATION_OUTPUT: {
|
|
compute_context_builder.push<bke::SimulationZoneComputeContext>(*zone.output_node);
|
|
break;
|
|
}
|
|
case GEO_NODE_REPEAT_OUTPUT: {
|
|
const auto &storage = *static_cast<const NodeGeometryRepeatOutput *>(
|
|
zone.output_node->storage);
|
|
compute_context_builder.push<bke::RepeatZoneComputeContext>(*zone.output_node,
|
|
storage.inspection_index);
|
|
break;
|
|
}
|
|
}
|
|
r_hash_by_zone.add_new(&zone, compute_context_builder.hash());
|
|
for (const bNodeTreeZone *child_zone : zone.child_zones) {
|
|
find_tree_zone_hash_recursive(*child_zone, compute_context_builder, r_hash_by_zone);
|
|
}
|
|
compute_context_builder.pop();
|
|
}
|
|
|
|
Map<const bNodeTreeZone *, ComputeContextHash> GeoModifierLog::
|
|
get_context_hash_by_zone_for_node_editor(const SpaceNode &snode,
|
|
ComputeContextBuilder &compute_context_builder)
|
|
{
|
|
if (!ed::space_node::push_compute_context_for_tree_path(snode, compute_context_builder)) {
|
|
return {};
|
|
}
|
|
|
|
const bNodeTreeZones *tree_zones = snode.edittree->zones();
|
|
if (tree_zones == nullptr) {
|
|
return {};
|
|
}
|
|
Map<const bNodeTreeZone *, ComputeContextHash> hash_by_zone;
|
|
hash_by_zone.add_new(nullptr, compute_context_builder.hash());
|
|
for (const bNodeTreeZone *zone : tree_zones->root_zones) {
|
|
find_tree_zone_hash_recursive(*zone, compute_context_builder, hash_by_zone);
|
|
}
|
|
return hash_by_zone;
|
|
}
|
|
|
|
Map<const bNodeTreeZone *, ComputeContextHash> GeoModifierLog::
|
|
get_context_hash_by_zone_for_node_editor(const SpaceNode &snode, StringRefNull modifier_name)
|
|
{
|
|
ComputeContextBuilder compute_context_builder;
|
|
compute_context_builder.push<bke::ModifierComputeContext>(modifier_name);
|
|
return get_context_hash_by_zone_for_node_editor(snode, compute_context_builder);
|
|
}
|
|
|
|
Map<const bNodeTreeZone *, GeoTreeLog *> GeoModifierLog::get_tree_log_by_zone_for_node_editor(
|
|
const SpaceNode &snode)
|
|
{
|
|
switch (SpaceNodeGeometryNodesType(snode.geometry_nodes_type)) {
|
|
case SNODE_GEOMETRY_MODIFIER: {
|
|
std::optional<ed::space_node::ObjectAndModifier> object_and_modifier =
|
|
ed::space_node::get_modifier_for_node_editor(snode);
|
|
if (!object_and_modifier) {
|
|
return {};
|
|
}
|
|
GeoModifierLog *modifier_log = object_and_modifier->nmd->runtime->eval_log.get();
|
|
if (modifier_log == nullptr) {
|
|
return {};
|
|
}
|
|
const Map<const bNodeTreeZone *, ComputeContextHash> hash_by_zone =
|
|
GeoModifierLog::get_context_hash_by_zone_for_node_editor(
|
|
snode, object_and_modifier->nmd->modifier.name);
|
|
Map<const bNodeTreeZone *, GeoTreeLog *> log_by_zone;
|
|
for (const auto item : hash_by_zone.items()) {
|
|
GeoTreeLog &tree_log = modifier_log->get_tree_log(item.value);
|
|
log_by_zone.add(item.key, &tree_log);
|
|
}
|
|
return log_by_zone;
|
|
}
|
|
case SNODE_GEOMETRY_TOOL: {
|
|
const ed::geometry::GeoOperatorLog &log =
|
|
ed::geometry::node_group_operator_static_eval_log();
|
|
if (snode.geometry_nodes_tool_tree->id.name + 2 != log.node_group_name) {
|
|
return {};
|
|
}
|
|
ComputeContextBuilder compute_context_builder;
|
|
compute_context_builder.push<bke::OperatorComputeContext>();
|
|
const Map<const bNodeTreeZone *, ComputeContextHash> hash_by_zone =
|
|
GeoModifierLog::get_context_hash_by_zone_for_node_editor(snode, compute_context_builder);
|
|
Map<const bNodeTreeZone *, GeoTreeLog *> log_by_zone;
|
|
for (const auto item : hash_by_zone.items()) {
|
|
GeoTreeLog &tree_log = log.log->get_tree_log(item.value);
|
|
log_by_zone.add(item.key, &tree_log);
|
|
}
|
|
return log_by_zone;
|
|
}
|
|
}
|
|
BLI_assert_unreachable();
|
|
return {};
|
|
}
|
|
|
|
const ViewerNodeLog *GeoModifierLog::find_viewer_node_log_for_path(const ViewerPath &viewer_path)
|
|
{
|
|
const std::optional<ed::viewer_path::ViewerPathForGeometryNodesViewer> parsed_path =
|
|
ed::viewer_path::parse_geometry_nodes_viewer(viewer_path);
|
|
if (!parsed_path.has_value()) {
|
|
return nullptr;
|
|
}
|
|
const Object *object = parsed_path->object;
|
|
NodesModifierData *nmd = nullptr;
|
|
LISTBASE_FOREACH (ModifierData *, md, &object->modifiers) {
|
|
if (md->name == parsed_path->modifier_name) {
|
|
if (md->type == eModifierType_Nodes) {
|
|
nmd = reinterpret_cast<NodesModifierData *>(md);
|
|
}
|
|
}
|
|
}
|
|
if (nmd == nullptr) {
|
|
return nullptr;
|
|
}
|
|
if (!nmd->runtime->eval_log) {
|
|
return nullptr;
|
|
}
|
|
nodes::geo_eval_log::GeoModifierLog *modifier_log = nmd->runtime->eval_log.get();
|
|
|
|
ComputeContextBuilder compute_context_builder;
|
|
compute_context_builder.push<bke::ModifierComputeContext>(parsed_path->modifier_name);
|
|
for (const ViewerPathElem *elem : parsed_path->node_path) {
|
|
if (!ed::viewer_path::add_compute_context_for_viewer_path_elem(*elem, compute_context_builder))
|
|
{
|
|
return nullptr;
|
|
}
|
|
}
|
|
const ComputeContextHash context_hash = compute_context_builder.hash();
|
|
nodes::geo_eval_log::GeoTreeLog &tree_log = modifier_log->get_tree_log(context_hash);
|
|
tree_log.ensure_viewer_node_logs();
|
|
|
|
const ViewerNodeLog *viewer_log = tree_log.viewer_node_logs.lookup_default(
|
|
parsed_path->viewer_node_id, nullptr);
|
|
return viewer_log;
|
|
}
|
|
|
|
} // namespace blender::nodes::geo_eval_log
|