qos.h

Go to the documentation of this file.

/*
 * Copyright (c) 2022 Nordic Semiconductor ASA
 *
 * SPDX-License-Identifier: LicenseRef-Nordic-5-Clause
 */
 
#ifndef QOS_H__
#define QOS_H__
 
#include <zephyr/kernel.h>
#include <stdbool.h>
#include <stdio.h>
 
#ifdef __cplusplus
extern "C" {
#endif
 
#define QOS_MESSAGE_ID_BASE 15000
 
#define QOS_FLAG_RELIABILITY_ACK_DISABLED 0x01
 
#define QOS_FLAG_RELIABILITY_ACK_REQUIRED 0x02
 
enum qos_evt_type {
 
        QOS_EVT_MESSAGE_NEW,
 
        QOS_EVT_MESSAGE_TIMER_EXPIRED,
 
        QOS_EVT_MESSAGE_REMOVED_FROM_LIST,
};
 
struct qos_payload {
        uint8_t *buf;
        size_t len;
};
 
struct qos_data {
        uint32_t flags;
 
        uint16_t id;
 
        uint16_t notified_count;
 
        uint8_t type;
 
        struct qos_payload data;
 
        bool heap_allocated;
};
 
struct qos_evt {
        enum qos_evt_type type;
        struct qos_data message;
};
 
typedef void (*qos_evt_handler_t)(const struct qos_evt *evt);
 
int qos_init(qos_evt_handler_t evt_handler);
 
int qos_message_add(struct qos_data *message);
 
int qos_message_remove(uint32_t id);
 
bool qos_message_has_flag(const struct qos_data *message, uint32_t flag);
 
void qos_message_print(const struct qos_data *message);
 
uint16_t qos_message_id_get_next(void);
 
void qos_message_notify_all(void);
 
void qos_message_remove_all(void);
 
void qos_timer_reset(void);
 
#ifdef __cplusplus
}
#endif
 
#endif /* QOS_H__ */