summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorShobhit Adlakha <ShobhitAd@users.noreply.github.com>2022-03-14 08:59:17 -0400
committerGitHub <noreply@github.com>2022-03-14 08:59:17 -0400
commit08b875d51fcb835ff1d157115f2f94d8927d8ddb (patch)
tree8c301fa40adc1fc1e14538252d250d33a90cdb59
parentcf9c3869d02b723d3aa74f6b0d25a6d3b810c061 (diff)
downloadsdl_core-08b875d51fcb835ff1d157115f2f94d8927d8ddb.tar.gz
Remove empty check in SaveConsumerFriendlyMessages to clear messages when core receives PTU with no consumer messages(with key defined) (#3879)
-rw-r--r--src/components/policy/policy_external/src/sql_pt_representation.cc4
-rw-r--r--src/components/policy/policy_regular/src/sql_pt_representation.cc4
2 files changed, 2 insertions, 6 deletions
diff --git a/src/components/policy/policy_external/src/sql_pt_representation.cc b/src/components/policy/policy_external/src/sql_pt_representation.cc
index 1570675cf9..5bee09773d 100644
--- a/src/components/policy/policy_external/src/sql_pt_representation.cc
+++ b/src/components/policy/policy_external/src/sql_pt_representation.cc
@@ -1611,9 +1611,7 @@ bool SQLPTRepresentation::SaveConsumerFriendlyMessages(
utils::dbms::SQLQuery query(db());
bool delete_query_exec_result = true;
- if (!messages.messages->empty()) {
- delete_query_exec_result = query.Exec(sql_pt::kDeleteMessageString);
- }
+ delete_query_exec_result = query.Exec(sql_pt::kDeleteMessageString);
if (!delete_query_exec_result) {
SDL_LOG_WARN("Failed to delete messages from DB.");
diff --git a/src/components/policy/policy_regular/src/sql_pt_representation.cc b/src/components/policy/policy_regular/src/sql_pt_representation.cc
index 0496896b60..f2254d7752 100644
--- a/src/components/policy/policy_regular/src/sql_pt_representation.cc
+++ b/src/components/policy/policy_regular/src/sql_pt_representation.cc
@@ -1575,9 +1575,7 @@ bool SQLPTRepresentation::SaveConsumerFriendlyMessages(
utils::dbms::SQLQuery query(db());
bool delete_query_exec_result = true;
- if (!messages.messages->empty()) {
- delete_query_exec_result = query.Exec(sql_pt::kDeleteMessageString);
- }
+ delete_query_exec_result = query.Exec(sql_pt::kDeleteMessageString);
if (!delete_query_exec_result) {
SDL_LOG_WARN("Failed to delete messages from DB.");