Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 0 additions & 1 deletion bindings/c/src/dispatcher_concurrent_vamana.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -191,7 +191,6 @@ svs::DynamicVamana load_concurrent_vamana_index(
std::move(data),
std::move(D),
std::move(pool),
/*debug_load_from_static=*/false,
std::move(logger)
);
}
Expand Down
2 changes: 0 additions & 2 deletions bindings/c/src/dispatcher_dynamic_vamana.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,6 @@ svs::DynamicVamana load_dynamic_vamana_index(
std::move(data),
std::move(D),
std::move(pool),
/*debug_load_from_static=*/false,
std::move(logger)
);
}
Expand Down Expand Up @@ -129,7 +128,6 @@ svs::DynamicVamana load_stream_dynamic_vamana_index(
svs::make_stream_loader<data_type>(allocator),
distance,
std::move(pool),
/*debug_load_from_static=*/false,
std::move(logger)
);
}
Expand Down
1 change: 0 additions & 1 deletion bindings/c/src/dispatcher_dynamic_vamana_copy.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -100,7 +100,6 @@ struct RegularVamanaFlavor {
std::move(data),
std::move(distance),
std::move(pool),
/*debug_load_from_static=*/false,
std::move(logger)
);
}
Expand Down
8 changes: 7 additions & 1 deletion bindings/python/src/dynamic_vamana.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -322,7 +322,13 @@ svs::DynamicVamana assemble_uncompressed(
});

return svs::DynamicVamana::assemble<Q>(
config_path, load_graph, load_data, distance, num_threads, debug_load_from_static
config_path,
load_graph,
load_data,
distance,
num_threads,
svs::logging::get(),
debug_load_from_static
);
}

Expand Down
12 changes: 6 additions & 6 deletions include/svs/orchestrators/concurrent_dynamic_vamana.h
Original file line number Diff line number Diff line change
Expand Up @@ -130,8 +130,8 @@ class ConcurrentDynamicVamana : public DynamicVamana {
DataLoader&& data_loader,
Distance distance,
ThreadPoolProto threadpool_proto,
bool debug_load_from_static = false,
svs::logging::logger_ptr logger = svs::logging::get()
svs::logging::logger_ptr logger = svs::logging::get(),
bool debug_load_from_static = false
)
requires(!std::is_base_of_v<std::istream, std::remove_cvref_t<ConfigProto>> && !is_stream_loader_v<std::remove_cvref_t<GraphLoader>> && !is_stream_loader_v<std::remove_cvref_t<DataLoader>>)
{
Expand Down Expand Up @@ -182,8 +182,8 @@ class ConcurrentDynamicVamana : public DynamicVamana {
const DataLoader& data_loader,
Distance distance,
ThreadPoolProto threadpool_proto,
bool debug_load_from_static = false,
svs::logging::logger_ptr logger = svs::logging::get()
svs::logging::logger_ptr logger = svs::logging::get(),
bool debug_load_from_static = false
)
requires(is_stream_loader_v<GraphLoader> && is_stream_loader_v<DataLoader>)
{
Expand Down Expand Up @@ -241,8 +241,8 @@ class ConcurrentDynamicVamana : public DynamicVamana {
data_loader.load(data_path),
std::move(distance),
std::move(threadpool),
debug_load_from_static,
std::move(logger)
std::move(logger),
debug_load_from_static
);
}
};
Expand Down
20 changes: 10 additions & 10 deletions include/svs/orchestrators/dynamic_vamana.h
Original file line number Diff line number Diff line change
Expand Up @@ -353,10 +353,10 @@ class DynamicVamana : public manager::IndexManager<DynamicVamanaInterface> {
/// @param data_loader An acceptable data loader or dataset.
/// @param distance Distance functor or ``svs::DistanceType`` enum.
/// @param threadpool_proto Thread pool or number of threads to use.
/// @param debug_load_from_static Internal/unstable: load files produced by the static
/// index using an identity ID translation.
/// @param logger The logger to use for this index. Defaults to the global SVS logger
/// (``svs::logging::get()``).
/// @param debug_load_from_static Internal/unstable: load files produced by the static
/// index using an identity ID translation.
///
template <
manager::QueryTypeDefinition QueryTypes,
Expand All @@ -372,8 +372,8 @@ class DynamicVamana : public manager::IndexManager<DynamicVamanaInterface> {
DataLoader&& data_loader,
const Distance& distance,
ThreadPoolProto threadpool_proto,
bool debug_load_from_static = false,
svs::logging::logger_ptr logger = svs::logging::get()
svs::logging::logger_ptr logger = svs::logging::get(),
bool debug_load_from_static = false
) {
return DynamicVamana(
AssembleTag(),
Expand Down Expand Up @@ -409,10 +409,10 @@ class DynamicVamana : public manager::IndexManager<DynamicVamanaInterface> {
/// @param data_loader The ``StreamLoader`` for the data to use.
/// @param distance Distance functor or ``svs::DistanceType`` enum.
/// @param threadpool_proto Thread pool or number of threads to use.
/// @param debug_load_from_static Internal/unstable: load files produced by the static
/// index using an identity ID translation.
/// @param logger The logger to use for this index. Defaults to the global SVS logger
/// (``svs::logging::get()``).
/// @param debug_load_from_static Internal/unstable: load files produced by the static
/// index using an identity ID translation.
///
template <
manager::QueryTypeDefinition QueryTypes,
Expand All @@ -427,8 +427,8 @@ class DynamicVamana : public manager::IndexManager<DynamicVamanaInterface> {
const DataLoader& data_loader,
const Distance& distance,
ThreadPoolProto threadpool_proto,
bool debug_load_from_static = false,
svs::logging::logger_ptr logger = svs::logging::get()
svs::logging::logger_ptr logger = svs::logging::get(),
bool debug_load_from_static = false
) {
using Graph = typename GraphLoader::return_type;
using Data = typename DataLoader::return_type;
Expand Down Expand Up @@ -495,8 +495,8 @@ class DynamicVamana : public manager::IndexManager<DynamicVamanaInterface> {
data_loader.load(data_path),
distance,
threads::as_threadpool(std::move(threadpool_proto)),
debug_load_from_static,
logger
logger,
debug_load_from_static
);
}
}
Expand Down
2 changes: 0 additions & 2 deletions tests/svs/orchestrators/dynamic_vamana.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -279,14 +279,12 @@ CATCH_TEST_CASE("DynamicVamana Per-Index Logger", "[managers][dynamic_vamana][lo
auto custom = CapturingLogger("custom_logger");
auto global_baseline = global.logger.use_count();

// `debug_load_from_static` precedes the logger and must be passed explicitly.
svs::DynamicVamana with_custom = svs::DynamicVamana::assemble<float>(
config_dir,
svs::GraphLoader(graph_dir),
svs::VectorDataLoader<float>(data_dir),
distance,
num_threads,
false,
custom.logger
);
CATCH_REQUIRE(custom.logger.use_count() == 2);
Expand Down
Loading