summaryrefslogtreecommitdiffstats
path: root/aclk/aclk_rx_msgs.c
diff options
context:
space:
mode:
authorEmmanuel Vasilakis <mrzammler@mm.st>2021-10-19 11:30:10 +0300
committerGitHub <noreply@github.com>2021-10-19 11:30:10 +0300
commit0882ed03b4000b6f9e1f64743321e4cd6e2aa39f (patch)
tree4faececbbd9434ec18ae9a068b605edb29285320 /aclk/aclk_rx_msgs.c
parentbc8b5a8add5abf772a2ad291bad4448099677ea8 (diff)
Add snapshot message and calls to sql_queue_removed_alerts_to_aclk (#11664)
Diffstat (limited to 'aclk/aclk_rx_msgs.c')
-rw-r--r--aclk/aclk_rx_msgs.c11
1 files changed, 11 insertions, 0 deletions
diff --git a/aclk/aclk_rx_msgs.c b/aclk/aclk_rx_msgs.c
index c5e0ffb14a..0790b435de 100644
--- a/aclk/aclk_rx_msgs.c
+++ b/aclk/aclk_rx_msgs.c
@@ -398,6 +398,17 @@ void aclk_handle_new_cloud_msg(const char *message_type, const char *msg, size_t
freez(config_hash);
return;
}
+ if (!strcmp(message_type, "SendAlarmSnapshot")) {
+ struct send_alarm_snapshot *sas = parse_send_alarm_snapshot(msg, msg_len);
+ if (!sas->node_id || !sas->claim_id) {
+ error("Error parsing SendAlarmSnapshot");
+ destroy_send_alarm_snapshot(sas);
+ return;
+ }
+ aclk_process_send_alarm_snapshot(sas->node_id, sas->claim_id, sas->snapshot_id, sas->sequence_id);
+ destroy_send_alarm_snapshot(sas);
+ return;
+ }
error ("Unknown new cloud arch message type received \"%s\"", message_type);
}
#endif