More logging

cpp/arcticdb/processing/component_manager.hpp

@@ -114,6 +114,10 @@ class ComponentManager {
             // Using view.get theoretically and empirically faster than registry_.get
             auto view = registry_.view<const Args...>();
             for (auto id: ids) {
+                log::version().info("Component manager looking for entity {}", id);
+                for(auto have_entt : view.each())
+                    log::version().info("view has entity {}", std::get<0>(have_entt));
+
                 tuple_res.emplace_back(std::move(view.get(id)));
             }
             if (decrement_fetch_count) {

cpp/arcticdb/version/version_core.cpp

@@ -588,7 +588,7 @@ std::pair<std::vector<std::vector<EntityId>>, std::shared_ptr<ankerl::unordered_
 }
 
 std::shared_ptr<std::vector<folly::Future<std::vector<EntityId>>>> schedule_first_iteration(
-        std::shared_ptr<ComponentManager>& component_manager,
+        std::shared_ptr<ComponentManager> component_manager,
         size_t num_segments,
         std::vector<std::vector<EntityId>>&& entities_by_work_unit,
         std::shared_ptr<std::vector<EntityFetchCount>>&& segment_fetch_counts,
@@ -624,7 +624,7 @@ std::shared_ptr<std::vector<folly::Future<std::vector<EntityId>>>> schedule_firs
                     for (auto&& [idx, segment_and_slice]: folly::enumerate(segment_and_slices)) {
                         auto entity_id = entity_ids[idx];
                         auto pos = id_to_pos->at(entity_id);
-                        std::lock_guard<std::mutex> lock((*slice_added_mtx)[pos]);
+                        std::lock_guard lock{slice_added_mtx->at(pos)};
                         if (!(*slice_added)[pos]) {
                             log::version().info("Adding entity {}", entity_id);
                             add_slice_to_component_manager(entity_id, segment_and_slice, component_manager, (*segment_fetch_counts)[pos]);