632915b4ae
fix(mqtt): crash caused by global static variables
2022-07-27 17:22:07 +08:00
93fbc3eaa5
refactor(mqtt): update module description
2022-07-19 17:51:27 +08:00
b820d74796
fix(mqtt): free ctx if msg send error
2022-07-18 18:24:26 +08:00
9d3b411627
fix(mqtt): setting free
...
* Add unit test for setting
* Set mqtt.json format field to optinal
2022-07-15 14:39:57 +08:00
094dc7f122
refactor(mqtt): nng timer -> event timer
2022-07-15 13:51:02 +08:00
3c59046314
feat(mqtt): setting optional field
2022-07-15 13:51:02 +08:00
96992eff71
refactor(mqtt): Modify unreasonable code
...
* Modify header file ordering
* Modify mqtt.* to mqtt_*.* to avoid ide parsing exception
* Modify part of the code according to the pr revision comments
2022-07-15 13:51:02 +08:00
596cd699fd
feat(mqtt): state json string send
2022-07-15 13:51:02 +08:00
1f9e3ea0db
feat(mqtt): add node state cache & add hb command
2022-07-15 13:51:02 +08:00
1c9d6a4b68
feat(mqtt): add heartbeat timer
2022-07-15 13:51:02 +08:00
649de85b61
feat(mqtt): add heartbeat setting
2022-07-15 13:51:02 +08:00
a2c9da83b8
fix(mqtt): connection in stoped state
2022-07-01 14:28:57 +08:00
23b83b7df2
refactor(mqtt): gettimeofday-> common.timestamp
2022-06-24 09:45:07 +08:00
b7881b4b93
fix(mqtt): write response topic error
2022-06-22 10:30:10 +08:00
d47ea13594
feat(mqtt): add zlog with cat to mqtt_c_client.c
2022-06-21 10:51:31 +08:00
566487d1f8
add NEU_RESP_APP_SUBSCRIBE_GROUP msg nofity app subscribe group
2022-06-20 09:57:26 +00:00
993530f86b
refactor persist & adapter msg
2022-06-20 08:08:40 +00:00
41dec9b209
fix(mqtt): plog to mqtt
2022-06-17 18:46:30 +08:00
5e16738a23
fix(mqtt): double free and context leak
2022-06-17 17:57:14 +08:00
341bdfd61f
Merge pull request #557 from gc87/mqtt-queue-remove
...
refactor(mqtt): remove sys/queue.h deps
2022-06-17 15:25:15 +08:00
1e29e4cb1c
remove plugin_info.h & adapter_msg.h
2022-06-17 07:02:32 +00:00
fe98452624
refactor(mqtt): remove sys/queue.h deps
2022-06-17 15:01:28 +08:00
dcb17c80cb
Merge pull request #553 from gc87/mqtt-queue-remove
...
Disconnect on user send stop command
2022-06-17 14:50:21 +08:00
67f0c2b2f0
rename tag address and replace neu_dtype_e
2022-06-17 03:48:51 +00:00
6881025f79
fix(mqtt): string leak
2022-06-16 18:45:32 +08:00
7da3b7b50a
feat(mqtt): stop/start -> disconnect/reconnect
2022-06-16 18:45:32 +08:00
34a3e43c58
refactor(mqtt): fix connection state
2022-06-16 18:45:32 +08:00
53ceeac9ff
del unused errorcode
2022-06-16 10:04:04 +00:00
2856c2de4d
Merge pull request #544 from fengzeroz/main
...
ci: remove release package
2022-06-16 10:47:31 +08:00
c787a2fc3e
refactor(mqtt): remove all pthread mutex
2022-06-15 18:48:42 +08:00
a2147e2d28
fix(mqtt): topic pair double free
2022-06-15 18:24:57 +08:00
3ea1e02a14
refactor(mqtt): remove publish queue
2022-06-15 18:24:57 +08:00
174cb88119
delete json include that does not need to be exported
2022-06-15 10:24:53 +00:00
e93e517f95
refactor CmakeLists.txt
2022-06-15 09:45:07 +00:00
f44a8db699
plugin: remove argument in open()
2022-06-15 06:49:02 +00:00
2d38ae5f50
refactor plugin interface config
2022-06-15 06:40:30 +00:00
95db2396ba
feat(msg): notify app subscribe/unsubscribe info
2022-06-14 09:13:21 +00:00
6d878c6276
refactor(mqtt): new write response
2022-06-14 11:28:53 +08:00
61306faefd
refactor(mqtt): new read data
2022-06-14 11:28:53 +08:00
36a16f1bb6
refactor(mqtt): trans-data upload
2022-06-14 11:28:53 +08:00
ff2729c798
fix(mqtt): remove libvector
2022-06-10 16:50:17 +08:00
203328dffd
copyright 2020-2022
2022-06-10 04:43:06 +00:00
dc65873e93
async process op msg
2022-06-10 04:43:06 +00:00
5b24337575
format
2022-06-10 04:43:05 +00:00
38a2652930
remove vector and data_expr
2022-06-10 04:43:05 +00:00
7d6e7c7a37
remove unused file
2022-06-10 04:43:05 +00:00
0a99036cbf
remove tty
2022-06-10 04:43:05 +00:00
c8234633e0
add/del/get group
2022-06-10 04:43:05 +00:00
4a1a34de43
simplify the plugin type to driver and app
2022-05-30 02:45:17 +00:00
a7781b63ce
log: replace log with zlog
2022-05-28 09:27:52 +00:00
gc87