pa/eqemu-server
2
0
Fork 0
mirror of https://github.com/EQEmu/Server.git synced 2026-06-26 23:57:17 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Perf boost

Browse Source
This commit is contained in:
Akkadius
2025-02-16 21:05:00 -06:00
parent db618fee38
commit 55d3e507d3
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
zone/data_bucket.cpp
+8 -7
View File
@@ -15,7 +15,7 @@ std::vector<DataBucketsRepository::DataBuckets> g_data_bucket_cache = {};
void DataBucket::SetData(const std::string &bucket_key, const std::string &bucket_value, std::string expires_time) void DataBucket::SetData(const std::string &bucket_key, const std::string &bucket_value, std::string expires_time)
{ {
auto k = DataBucketKey{ thread_local auto k = DataBucketKey{
.key = bucket_key, .key = bucket_key,
.value = bucket_value, .value = bucket_value,
.expires = expires_time, .expires = expires_time,
@@ -26,13 +26,13 @@ void DataBucket::SetData(const std::string &bucket_key, const std::string &bucke
void DataBucket::SetData(const DataBucketKey &k_) void DataBucket::SetData(const DataBucketKey &k_)
{ {
DataBucketKey k = k_; // copy the key so we can modify it thread_local DataBucketKey k = k_; // copy the key so we can modify it
if (k.key.find(NESTED_KEY_DELIMITER) != std::string::npos) { if (k.key.find(NESTED_KEY_DELIMITER) != std::string::npos) {
k.key = Strings::Split(k.key, NESTED_KEY_DELIMITER).front(); k.key = Strings::Split(k.key, NESTED_KEY_DELIMITER).front();
} }
auto b = DataBucketsRepository::NewEntity(); thread_local auto b = DataBucketsRepository::NewEntity();
auto r = GetData(k, true); thread_local auto r = GetData(k, true);
// if we have an entry, use it // if we have an entry, use it
if (r.id > 0) { if (r.id > 0) {
b = r; b = r;
@@ -178,7 +178,7 @@ DataBucketsRepository::DataBuckets DataBucket::ExtractNestedValue(
// the only place we should be ignoring the misses cache is on the initial read during SetData // the only place we should be ignoring the misses cache is on the initial read during SetData
DataBucketsRepository::DataBuckets DataBucket::GetData(const DataBucketKey &k_, bool ignore_misses_cache) DataBucketsRepository::DataBuckets DataBucket::GetData(const DataBucketKey &k_, bool ignore_misses_cache)
{ {
DataBucketKey k = k_; // Copy the key so we can modify it thread_local DataBucketKey k = k_; // Copy the key so we can modify it
bool is_nested_key = k.key.find(NESTED_KEY_DELIMITER) != std::string::npos; bool is_nested_key = k.key.find(NESTED_KEY_DELIMITER) != std::string::npos;
@@ -268,7 +268,7 @@ DataBucketsRepository::DataBuckets DataBucket::GetData(const DataBucketKey &k_,
return DataBucketsRepository::NewEntity(); return DataBucketsRepository::NewEntity();
} }
auto bucket = r.front(); thread_local auto bucket = r.front();
// If the entry has expired, delete it // If the entry has expired, delete it
if (bucket.expires > 0 && bucket.expires < static_cast<long long>(std::time(nullptr))) { if (bucket.expires > 0 && bucket.expires < static_cast<long long>(std::time(nullptr))) {
@@ -311,7 +311,8 @@ std::string DataBucket::GetDataRemaining(const std::string &bucket_key)
bool DataBucket::DeleteData(const std::string &bucket_key) bool DataBucket::DeleteData(const std::string &bucket_key)
{ {
return DeleteData(DataBucketKey{.key = bucket_key}); thread_local auto k = DataBucketKey{.key = bucket_key};
return DeleteData(k);
} }
// GetDataBuckets bulk loads all data buckets for a mob // GetDataBuckets bulk loads all data buckets for a mob