blob: 0db599be20bcbe2431ae7551d2265686b1f2b4de (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
// SPDX-License-Identifier: GPL-3.0-or-later
#include "aclk_alarm_api.h"
#include "aclk_query_queue.h"
#include "aclk_util.h"
#include "aclk.h"
void aclk_send_alarm_log_health(struct alarm_log_health *log_health)
{
aclk_query_t query = aclk_query_new(ALARM_LOG_HEALTH);
query->data.bin_payload.payload = generate_alarm_log_health(&query->data.bin_payload.size, log_health);
query->data.bin_payload.topic = ACLK_TOPICID_ALARM_HEALTH;
query->data.bin_payload.msg_name = "AlarmLogHealth";
QUEUE_IF_PAYLOAD_PRESENT(query);
}
void aclk_send_alarm_log_entry(struct alarm_log_entry *log_entry)
{
size_t payload_size;
char *payload = generate_alarm_log_entry(&payload_size, log_entry);
aclk_send_bin_msg(payload, payload_size, ACLK_TOPICID_ALARM_LOG, "AlarmLogEntry");
freez(payload);
}
void aclk_send_provide_alarm_cfg(struct provide_alarm_configuration *cfg)
{
aclk_query_t query = aclk_query_new(ALARM_PROVIDE_CFG);
query->data.bin_payload.payload = generate_provide_alarm_configuration(&query->data.bin_payload.size, cfg);
query->data.bin_payload.topic = ACLK_TOPICID_ALARM_CONFIG;
query->data.bin_payload.msg_name = "ProvideAlarmConfiguration";
QUEUE_IF_PAYLOAD_PRESENT(query);
}
void aclk_send_alarm_snapshot(alarm_snapshot_proto_ptr_t snapshot)
{
aclk_query_t query = aclk_query_new(ALARM_SNAPSHOT);
query->data.bin_payload.payload = generate_alarm_snapshot_bin(&query->data.bin_payload.size, snapshot);
query->data.bin_payload.topic = ACLK_TOPICID_ALARM_SNAPSHOT;
query->data.bin_payload.msg_name = "AlarmSnapshot";
QUEUE_IF_PAYLOAD_PRESENT(query);
}
|