blob: a855737f9e1a1c2d86c20652a9b3c9eed79a0635 (
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
|
#ifndef MQTT_WEBSOCKETS_COMMON_PUBLIC_H
#define MQTT_WEBSOCKETS_COMMON_PUBLIC_H
#include <stddef.h>
/* free_fnc_t in general (in whatever function or struct it is used)
* decides how the related data will be handled.
* - If NULL the data are copied internally (causing malloc and later free)
* - If pointer provided the free function pointed will be called when data are no longer needed
* to free associated memory. This is effectively transfering ownership of that pointer to the library.
* This also allows caller to provide custom free function other than system one.
* - If == CALLER_RESPONSIBILITY the library will not copy the data pointed to and will not call free
* at the end. This is usefull to avoid copying memory (and associated malloc/free) when data are for
* example static. In this case caller has to guarantee the memory pointed to will be valid for entire duration
* it is needed. For example by freeing the data after PUBACK is received or by data being static.
*/
typedef void (*free_fnc_t)(void *ptr);
void _caller_responsibility(void *ptr);
#define CALLER_RESPONSIBILITY ((free_fnc_t)&_caller_responsibility)
struct mqtt_ng_stats {
size_t tx_bytes_queued;
int tx_messages_queued;
int tx_messages_sent;
int rx_messages_rcvd;
size_t tx_buffer_used;
size_t tx_buffer_free;
size_t tx_buffer_size;
// part of transaction buffer that containes mesages we can free alredy during the garbage colleciton step
size_t tx_buffer_reclaimable;
};
#endif /* MQTT_WEBSOCKETS_COMMON_PUBLIC_H */
|
