#include "base/supports_user_data.h"
#include "base/auto_reset.h"
#include "base/feature_list.h"
#include "base/logging.h"
#include "base/sequence_checker.h"
#include "third_party/abseil-cpp/absl/container/flat_hash_map.h"
namespace base {
struct SupportsUserData::Impl {
absl::flat_hash_map<const void*, std::unique_ptr<Data>> user_data_;
};
std::unique_ptr<SupportsUserData::Data> SupportsUserData::Data::Clone() {
return nullptr;
}
SupportsUserData::SupportsUserData() : impl_(std::make_unique<Impl>()) {
DETACH_FROM_SEQUENCE(sequence_checker_);
}
SupportsUserData::SupportsUserData(SupportsUserData&& rhs) {
*this = std::move(rhs);
}
SupportsUserData& SupportsUserData::operator=(SupportsUserData&& rhs) {
CHECK(!in_clear_);
CHECK(!rhs.in_clear_);
impl_ = std::move(rhs.impl_);
rhs.impl_ = std::make_unique<Impl>();
return *this;
}
SupportsUserData::Data* SupportsUserData::GetUserData(const void* key) const {
DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
DCHECK(key);
if (impl_ == nullptr) {
LOG(ERROR) << "impl_ is " << (impl_ != nullptr);
return nullptr;
}
auto found = impl_->user_data_.find(key);
if (found != impl_->user_data_.end()) {
#if BUILDFLAG(ARKWEB_WEBSTORAGE)
if (!found->second.get()) {
LOG(ERROR) << "GetUserData called, key : " << key << ", value nullptr";
}
#endif
return found->second.get();
}
return nullptr;
}
std::unique_ptr<SupportsUserData::Data> SupportsUserData::TakeUserData(
const void* key) {
DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
CHECK(key);
auto found = impl_->user_data_.find(key);
if (found != impl_->user_data_.end()) {
std::unique_ptr<SupportsUserData::Data> deowned;
deowned.swap(found->second);
impl_->user_data_.erase(key);
return deowned;
}
return nullptr;
}
void SupportsUserData::SetUserData(const void* key,
std::unique_ptr<Data> data) {
DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
CHECK(!in_clear_) << "Calling SetUserData() when SupportsUserData is "
"being cleared or destroyed is not supported.";
DCHECK(key);
if (data.get()) {
impl_->user_data_[key] = std::move(data);
} else {
RemoveUserData(key);
}
}
void SupportsUserData::RemoveUserData(const void* key) {
DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
auto it = impl_->user_data_.find(key);
if (it != impl_->user_data_.end()) {
auto owned_data = std::move(it->second);
impl_->user_data_.erase(it);
}
}
void SupportsUserData::DetachFromSequence() {
DETACH_FROM_SEQUENCE(sequence_checker_);
}
void SupportsUserData::CloneDataFrom(const SupportsUserData& other) {
CHECK(!in_clear_);
CHECK(!other.in_clear_);
for (const auto& data_pair : other.impl_->user_data_) {
auto cloned_data = data_pair.second->Clone();
if (cloned_data) {
SetUserData(data_pair.first, std::move(cloned_data));
}
}
}
SupportsUserData::~SupportsUserData() {
if (!impl_->user_data_.empty()) {
DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
}
CHECK(!in_clear_);
in_clear_ = true;
absl::flat_hash_map<const void*, std::unique_ptr<Data>> user_data;
impl_->user_data_.swap(user_data);
}
void SupportsUserData::ClearAllUserData() {
DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
CHECK(!in_clear_);
base::AutoReset<bool> reset_in_clear(&in_clear_, true);
absl::flat_hash_map<const void*, std::unique_ptr<Data>> user_data;
impl_->user_data_.swap(user_data);
}
size_t SupportsUserData::UserDataCount() const {
DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
return impl_->user_data_.size();
}
}