1 #include <time.h>
2
3 #define WITH_BROKER
4
5 #include <logging_mosq.h>
6 #include <memory_mosq.h>
7 #include <mosquitto_broker_internal.h>
8 #include <net_mosq.h>
9 #include <send_mosq.h>
10 #include <time_mosq.h>
11
12 extern uint64_t last_retained;
13 extern char *last_sub;
14 extern int last_qos;
15
context__init(mosq_sock_t sock)16 struct mosquitto *context__init(mosq_sock_t sock)
17 {
18 UNUSED(sock);
19
20 return mosquitto__calloc(1, sizeof(struct mosquitto));
21 }
22
log__printf(struct mosquitto * mosq,unsigned int priority,const char * fmt,...)23 int log__printf(struct mosquitto *mosq, unsigned int priority, const char *fmt, ...)
24 {
25 UNUSED(mosq);
26 UNUSED(priority);
27 UNUSED(fmt);
28
29 return 0;
30 }
31
mosquitto_time(void)32 time_t mosquitto_time(void)
33 {
34 return 123;
35 }
36
net__socket_close(struct mosquitto * mosq)37 int net__socket_close(struct mosquitto *mosq)
38 {
39 UNUSED(mosq);
40
41 return MOSQ_ERR_SUCCESS;
42 }
43
send__pingreq(struct mosquitto * mosq)44 int send__pingreq(struct mosquitto *mosq)
45 {
46 UNUSED(mosq);
47
48 return MOSQ_ERR_SUCCESS;
49 }
50
mosquitto_acl_check(struct mosquitto * context,const char * topic,uint32_t payloadlen,void * payload,uint8_t qos,bool retain,int access)51 int mosquitto_acl_check(struct mosquitto *context, const char *topic, uint32_t payloadlen, void* payload, uint8_t qos, bool retain, int access)
52 {
53 UNUSED(context);
54 UNUSED(topic);
55 UNUSED(payloadlen);
56 UNUSED(payload);
57 UNUSED(qos);
58 UNUSED(retain);
59 UNUSED(access);
60
61 return MOSQ_ERR_SUCCESS;
62 }
63
acl__find_acls(struct mosquitto * context)64 int acl__find_acls(struct mosquitto *context)
65 {
66 UNUSED(context);
67
68 return MOSQ_ERR_SUCCESS;
69 }
70
71
send__publish(struct mosquitto * mosq,uint16_t mid,const char * topic,uint32_t payloadlen,const void * payload,uint8_t qos,bool retain,bool dup,const mosquitto_property * cmsg_props,const mosquitto_property * store_props,uint32_t expiry_interval)72 int send__publish(struct mosquitto *mosq, uint16_t mid, const char *topic, uint32_t payloadlen, const void *payload, uint8_t qos, bool retain, bool dup, const mosquitto_property *cmsg_props, const mosquitto_property *store_props, uint32_t expiry_interval)
73 {
74 UNUSED(mosq);
75 UNUSED(mid);
76 UNUSED(topic);
77 UNUSED(payloadlen);
78 UNUSED(payload);
79 UNUSED(qos);
80 UNUSED(retain);
81 UNUSED(dup);
82 UNUSED(cmsg_props);
83 UNUSED(store_props);
84 UNUSED(expiry_interval);
85
86 return MOSQ_ERR_SUCCESS;
87 }
88
send__pubcomp(struct mosquitto * mosq,uint16_t mid,const mosquitto_property * properties)89 int send__pubcomp(struct mosquitto *mosq, uint16_t mid, const mosquitto_property *properties)
90 {
91 UNUSED(mosq);
92 UNUSED(mid);
93 UNUSED(properties);
94
95 return MOSQ_ERR_SUCCESS;
96 }
97
send__pubrec(struct mosquitto * mosq,uint16_t mid,uint8_t reason_code,const mosquitto_property * properties)98 int send__pubrec(struct mosquitto *mosq, uint16_t mid, uint8_t reason_code, const mosquitto_property *properties)
99 {
100 UNUSED(mosq);
101 UNUSED(mid);
102 UNUSED(reason_code);
103 UNUSED(properties);
104
105 return MOSQ_ERR_SUCCESS;
106 }
107
send__pubrel(struct mosquitto * mosq,uint16_t mid,const mosquitto_property * properties)108 int send__pubrel(struct mosquitto *mosq, uint16_t mid, const mosquitto_property *properties)
109 {
110 UNUSED(mosq);
111 UNUSED(mid);
112 UNUSED(properties);
113
114 return MOSQ_ERR_SUCCESS;
115 }
116