Jacques Lucke
8ba9d7b67a
The main goal here is to reduce the number of times thread-local data has to be looked up using e.g. `EnumerableThreadSpecific.local()`. While this isn't a bottleneck in many cases, it is when the action performed on the local data is very short and that happens very often (e.g. logging used sockets during geometry nodes evaluation). The solution is to simply pass the thread-local data as parameter to many functions that use it, instead of looking it up in those functions which generally is more costly. The lazy-function graph executor now only looks up the local data if it knows that it might be on a new thread, otherwise it uses the local data retrieved earlier. Alongside with `UserData` there is `LocalUserData` now. This allows users of the lazy-function evaluation (such as geometry nodes) to have custom thread-local data that is passed to all the lazy-functions automatically. This is used for logging now.
91 lines
1.9 KiB
C++
91 lines
1.9 KiB
C++
/* SPDX-License-Identifier: GPL-2.0-or-later */
|
|
|
|
/** \file
|
|
* \ingroup fn
|
|
*/
|
|
|
|
#include "BLI_array.hh"
|
|
|
|
#include "FN_lazy_function.hh"
|
|
|
|
namespace blender::fn::lazy_function {
|
|
|
|
std::string LazyFunction::name() const
|
|
{
|
|
return debug_name_;
|
|
}
|
|
|
|
std::string LazyFunction::input_name(int index) const
|
|
{
|
|
return inputs_[index].debug_name;
|
|
}
|
|
|
|
std::string LazyFunction::output_name(int index) const
|
|
{
|
|
return outputs_[index].debug_name;
|
|
}
|
|
|
|
void *LazyFunction::init_storage(LinearAllocator<> & /*allocator*/) const
|
|
{
|
|
return nullptr;
|
|
}
|
|
|
|
void LazyFunction::destruct_storage(void *storage) const
|
|
{
|
|
BLI_assert(storage == nullptr);
|
|
UNUSED_VARS_NDEBUG(storage);
|
|
}
|
|
|
|
void LazyFunction::possible_output_dependencies(const int /*output_index*/,
|
|
const FunctionRef<void(Span<int>)> fn) const
|
|
{
|
|
/* The output depends on all inputs by default. */
|
|
Vector<int, 16> indices(inputs_.size());
|
|
for (const int i : inputs_.index_range()) {
|
|
indices[i] = i;
|
|
}
|
|
fn(indices);
|
|
}
|
|
|
|
bool LazyFunction::always_used_inputs_available(const Params ¶ms) const
|
|
{
|
|
if (allow_missing_requested_inputs_) {
|
|
return true;
|
|
}
|
|
for (const int i : inputs_.index_range()) {
|
|
const Input &fn_input = inputs_[i];
|
|
if (fn_input.usage == ValueUsage::Used) {
|
|
if (params.try_get_input_data_ptr(i) == nullptr) {
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
void Params::set_default_remaining_outputs()
|
|
{
|
|
for (const int i : fn_.outputs().index_range()) {
|
|
if (this->output_was_set(i)) {
|
|
continue;
|
|
}
|
|
const Output &fn_output = fn_.outputs()[i];
|
|
const CPPType &type = *fn_output.type;
|
|
void *data_ptr = this->get_output_data_ptr(i);
|
|
type.value_initialize(data_ptr);
|
|
this->output_set(i);
|
|
}
|
|
}
|
|
|
|
bool Params::try_enable_multi_threading_impl()
|
|
{
|
|
return false;
|
|
}
|
|
|
|
destruct_ptr<LocalUserData> UserData::get_local(LinearAllocator<> & /*allocator*/)
|
|
{
|
|
return {};
|
|
}
|
|
|
|
} // namespace blender::fn::lazy_function
|