tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-07-27 15:44:11 +02:00
Code Issues Packages Projects Releases Wiki Activity

Handle transaction vectors better

Browse Source
This commit is contained in:
Jean Flach 2019-01-28 16:08:31 +01:00 committed by Michael Friedrich
parent b95e39952e
commit 0ad008f465
1 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
lib/redis/rediswriter-objects.cpp
View File

@ -107,7 +107,7 @@ void RedisWriter::UpdateAllConfigObjects()
std::vector<String> attributes = {"HMSET", m_PrefixConfigObject + lcType}; std::vector<String> attributes = {"HMSET", m_PrefixConfigObject + lcType};
std::vector<String> customVars = {"HMSET", m_PrefixConfigCustomVar + lcType}; std::vector<String> customVars = {"HMSET", m_PrefixConfigCustomVar + lcType};
std::vector<String> checksums = {"HMSET", m_PrefixConfigCheckSum + lcType}; std::vector<String> checksums = {"HMSET", m_PrefixConfigCheckSum + lcType};
std::vector<String> states = {"HMSET", m_PrefixStateObject + lcType }; std::vector<String> states = {"HMSET", m_PrefixStateObject + lcType};
std::vector<std::vector<String> > transaction = {{"MULTI"}}; std::vector<std::vector<String> > transaction = {{"MULTI"}};
bool dumpState = (lcType == "host" || lcType == "service"); bool dumpState = (lcType == "host" || lcType == "service");
@ -125,38 +125,38 @@ void RedisWriter::UpdateAllConfigObjects()
bulkCounter++; bulkCounter++;
if (!bulkCounter % 100) { if (!bulkCounter % 100) {
if (attributes.size() > 2) { if (attributes.size() > 2) {
transaction.push_back(attributes); transaction.push_back(std::move(attributes));
attributes.erase(attributes.begin() + 2, attributes.end()); attributes = {"HMSET", m_PrefixConfigObject + lcType};
} }
if (customVars.size() > 2) { if (customVars.size() > 2) {
transaction.push_back(customVars); transaction.push_back(std::move(customVars));
customVars.erase(customVars.begin() + 2, customVars.end()); customVars = {"HMSET", m_PrefixConfigCustomVar + lcType};
} }
if (checksums.size() > 2) { if (checksums.size() > 2) {
transaction.push_back(checksums); transaction.push_back(std::move(checksums));
checksums.erase(checksums.begin() + 2, checksums.end()); checksums = {"HMSET", m_PrefixConfigCheckSum + lcType};
} }
if (states.size() > 2) { if (states.size() > 2) {
transaction.push_back(states); transaction.push_back(std::move(states));
states.erase(states.begin() + 2, states.end()); states = {"HMSET", m_PrefixStateObject + lcType};
} }
if (transaction.size() > 1) { if (transaction.size() > 1) {
transaction.push_back({"EXEC"}); transaction.push_back({"EXEC"});
m_Rcon->ExecuteQueries(transaction); m_Rcon->ExecuteQueries(transaction);
transaction.erase(transaction.begin() + 1, transaction.end()); transaction = {{"MULTI"}};
} }
} }
} }
if (attributes.size() > 2) if (attributes.size() > 2)
transaction.push_back(attributes); transaction.push_back(std::move(attributes));
if (customVars.size() > 2) if (customVars.size() > 2)
transaction.push_back(customVars); transaction.push_back(std::move(customVars));
if (checksums.size() > 2) if (checksums.size() > 2)
transaction.push_back(checksums); transaction.push_back(std::move(checksums));
if (states.size() > 2) if (states.size() > 2)
transaction.push_back(states); transaction.push_back(std::move(states));
if (transaction.size() > 1) { if (transaction.size() > 1) {
transaction.push_back({"EXEC"}); transaction.push_back({"EXEC"});