-
Notifications
You must be signed in to change notification settings - Fork 0
/
hash.c
71 lines (65 loc) · 1.69 KB
/
hash.c
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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
//
// Created by bluse on 2022/7/31.
//
#include <mosquitto.h>
#include <mosquitto_broker.h>
#include "hash.h"
#include "uthash.h"
void set(const char *key, struct delay_message msg) {
if (key == NULL) {
return;
}
struct dataItem *r;
HASH_FIND_STR(pData, key, r);
if (r == NULL) {
r = mosquitto_malloc(sizeof(struct dataItem));
r->key = key;
r->arr = mosquitto_malloc(sizeof(struct delay_message));
r->arr[0] = msg;
r->count = 1;
HASH_ADD_STR(pData, key, r);
} else {
r->count += 1;
struct delay_message *arr = mosquitto_calloc(r->count, sizeof(struct delay_message));
for (int i = 0; i < r->count; ++i) {
if (i < r->count - 1) {
arr[i] = r->arr[i];
} else {
arr[i] = msg;
}
}
mosquitto_free(r->arr);
r->arr = arr;
}
}
struct delay_message_array get(const char *key) {
if (key == NULL) {
return (struct delay_message_array) {NULL, 0};
}
struct dataItem *i;
HASH_FIND_STR(pData, key, i);
if (i == NULL) {
return (struct delay_message_array) {NULL, 0};
}
struct delay_message_array arr = {i->arr, i->count};
return arr;
}
void del(const char *key) {
if (key == NULL) {
return;
}
struct dataItem *r;
HASH_FIND_STR(pData, key, r);
if (r != NULL) {
HASH_DEL(pData, r);
// 完整清理
for (int i = 0; i < r->count; ++i) {
mosquitto_free(r->arr[i].topic);
mosquitto_free(r->arr[i].payload);
}
mosquitto_free(r->arr);
r->arr = NULL;
mosquitto_free(r);
r = NULL;
}
}