diff options
author | Emmanuel Vasilakis <mrzammler@mm.st> | 2021-10-19 11:30:10 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-10-19 11:30:10 +0300 |
commit | 0882ed03b4000b6f9e1f64743321e4cd6e2aa39f (patch) | |
tree | 4faececbbd9434ec18ae9a068b605edb29285320 /aclk/aclk_rx_msgs.c | |
parent | bc8b5a8add5abf772a2ad291bad4448099677ea8 (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.c | 11 |
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 |