Method add_with_id_impl

src/core/algorithm/flat/flat_streamer.cc:264–302

template <size_t BATCH_SIZE>
int FlatStreamer<BATCH_SIZE>::add_with_id_impl(uint32_t id, const void *query,
                                               const IndexQueryMeta &qmeta,
                                               Context::Pointer &context) {
  if (!query || qmeta.dimension() != meta_.dimension() ||
      qmeta.data_type() != meta_.data_type() ||
      qmeta.element_size() != meta_.element_size()) {
    LOG_ERROR(
        "Failed to add for invalid arguments, query=%p, qmeta(type=%u "
        "dim=%u size=%u) vs meta(type=%u dim=%u size=%u)",
        query, qmeta.data_type(), qmeta.dimension(), qmeta.element_size(),
        meta_.data_type(), meta_.dimension(), meta_.element_size());
    (*stats_.mutable_discarded_count())++;
    return IndexError_InvalidArgument;
  }

  auto *ctx = dynamic_cast<FlatStreamerContext<BATCH_SIZE> *>(context.get());
  if (!ctx) {
    LOG_ERROR("Failed to cast FlatStreamerContext");
    (*stats_.mutable_discarded_count())++;
    return IndexError_Cast;
  }

  READ_LOCK_GUARD_DEFER(dump_mutex_, dump_lock);

  if (!dump_lock.try_lock()) {
    LOG_ERROR("Cannot add vector while dumping index");
    (*stats_.mutable_discarded_count())++;
    return IndexError_Unsupported;
  }

  int ret = entity_.add_vector_with_id(id, query, qmeta.element_size());
  if (ret != 0) {
    LOG_ERROR("Failed to add record for %s", IndexError::What(ret));
    (*stats_.mutable_discarded_count())++;
    return ret;
  }

  return 0;
}

template <size_t BATCH_SIZE>
int FlatStreamer<BATCH_SIZE>::search_bf_impl(const void *query,