Mirrorlandia_minetest/minetestmapper
1
0
Fork 0
mirror of https://github.com/minetest/minetestmapper.git synced 2024-11-21 23:13:53 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix another bug in the Redis backend

Browse Source 
introduced in 7ff2288
This commit is contained in:
sfan5 2020-03-28 00:56:11 +01:00
parent 48bf44c72d
commit 539bdbd30c
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
db-redis.cpp
View File

@ -130,6 +130,7 @@ void DBRedis::HMGET(const std::vector<BlockPos> &positions,
std::vector<BlockPos>::const_iterator position = positions.begin(); std::vector<BlockPos>::const_iterator position = positions.begin();
std::size_t remaining = positions.size(); std::size_t remaining = positions.size();
std::size_t abs_i = 0;
while (remaining > 0) { while (remaining > 0) {
const std::size_t batch_size = const std::size_t batch_size =
(remaining > DB_REDIS_HMGET_NUMFIELDS) ? DB_REDIS_HMGET_NUMFIELDS : remaining; (remaining > DB_REDIS_HMGET_NUMFIELDS) ? DB_REDIS_HMGET_NUMFIELDS : remaining;
@ -161,9 +162,10 @@ void DBRedis::HMGET(const std::vector<BlockPos> &positions,
REPLY_TYPE_ERR(subreply, "HMGET subreply"); REPLY_TYPE_ERR(subreply, "HMGET subreply");
if (subreply->len == 0) if (subreply->len == 0)
throw std::runtime_error("HMGET empty string"); throw std::runtime_error("HMGET empty string");
result(i, ustring((const unsigned char *) subreply->str, subreply->len)); result(abs_i + i, ustring((const unsigned char *) subreply->str, subreply->len));
} }
freeReplyObject(reply); freeReplyObject(reply);
abs_i += reply->elements;
remaining -= batch_size; remaining -= batch_size;
} }
} }