Commit Graph
1392 Commits
Author SHA1 Message Date
fengzero 566487d1f8 add NEU_RESP_APP_SUBSCRIBE_GROUP msg nofity app subscribe group 2022-06-20 09:57:26 +00:00
fengzeroz ed459a0398 Merge pull request #559 from fengzeroz/main
refactor persist & adapter msg
2022-06-20 16:19:07 +08:00
fengzero 50f5121c3b adapter(driver): remove mtx 2022-06-20 08:14:37 +00:00
fengzero 993530f86b refactor persist & adapter msg 2022-06-20 08:08:40 +00:00
fengzeroz 13f103ad42 Merge pull request #560 from eeff/eeff/dev
chore(ekuiper): uniform logging using plog macros
2022-06-20 14:28:13 +08:00
eeff fae01c42f6 fix: plog_send_protocol and plog_recv_protocol format specifier 2022-06-20 13:48:18 +08:00
eeff 7b842956bb chore(ekuiper): uniform logging using plog macros 2022-06-20 13:15:19 +08:00
fengzeroz 4343c2ef74 Merge pull request #558 from gc87/mqtt-leak-fix
fix(mqtt): double free and context leak
2022-06-17 22:15:46 +08:00
gc87 41dec9b209 fix(mqtt): plog to mqtt 2022-06-17 18:46:30 +08:00
gc87 5e16738a23 fix(mqtt): double free and context leak 2022-06-17 17:57:14 +08:00
fengzeroz 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
fengzeroz 18bcf83309 Merge pull request #556 from fengzeroz/main
remove plugin_info.h & adapter_msg.h
2022-06-17 15:09:07 +08:00
fengzero 1e29e4cb1c remove plugin_info.h & adapter_msg.h 2022-06-17 07:02:32 +00:00
gc87 fe98452624 refactor(mqtt): remove sys/queue.h deps 2022-06-17 15:01:28 +08:00
fengzeroz dcb17c80cb Merge pull request #553 from gc87/mqtt-queue-remove
Disconnect on user send stop command
2022-06-17 14:50:21 +08:00
fengzeroz 5c974947a8 Merge pull request #555 from eeff/eeff/dev
chore(ekuiper): make log message more clear
2022-06-17 14:49:21 +08:00
eeff 26a5d7b922 chore(ekuiper): make log message more clear 2022-06-17 14:27:45 +08:00
fengzeroz 9340c9416b Merge pull request #554 from fengzeroz/main
rename tag address and replace neu_dtype_e
2022-06-17 13:40:35 +08:00
gc87 24eeb4787f refactor(mqtt): remove sys/queue.h deps 2022-06-17 11:49:08 +08:00
fengzero 67f0c2b2f0 rename tag address and replace neu_dtype_e 2022-06-17 03:48:51 +00:00
gc87 6881025f79 fix(mqtt): string leak 2022-06-16 18:45:32 +08:00
gc87 7da3b7b50a feat(mqtt): stop/start -> disconnect/reconnect 2022-06-16 18:45:32 +08:00
gc87 34a3e43c58 refactor(mqtt): fix connection state 2022-06-16 18:45:32 +08:00
fengzeroz 43aeb9c616 Merge pull request #552 from fengzeroz/main
fix set serial port opt
2022-06-16 18:37:43 +08:00
fengzero 0fd866c69f fix set serial port opt 2022-06-16 10:37:14 +00:00
fengzeroz e1f7f5b27b Merge pull request #550 from fengzeroz/main
del unused errorcode
2022-06-16 18:04:34 +08:00
fengzero 53ceeac9ff del unused errorcode 2022-06-16 10:04:04 +00:00
fengzeroz d6c69e21d3 Merge pull request #549 from fengzeroz/main
connection: add log category
2022-06-16 16:37:23 +08:00
fengzero 15401a0711 connection: add log category 2022-06-16 08:09:05 +00:00
fengzeroz a17ff73358 Merge pull request #548 from fengzeroz/main
fix serial port parameter
2022-06-16 15:18:07 +08:00
fengzero f2ae98b54a fix serial port parameter 2022-06-16 07:17:37 +00:00
fengzeroz aabd06fa66 Merge pull request #547 from fengzeroz/main
connection: add log
2022-06-16 14:33:31 +08:00
fengzero da7639eb85 connection: add log 2022-06-16 06:32:56 +00:00
fengzeroz 2856c2de4d Merge pull request #544 from fengzeroz/main
ci: remove release package
2022-06-16 10:47:31 +08:00
fengzeroz 38cffb9b60 Merge pull request #546 from gc87/mqtt-queue-remove
Mqtt publish queue remove
2022-06-16 10:47:22 +08:00
gc87 c787a2fc3e refactor(mqtt): remove all pthread mutex 2022-06-15 18:48:42 +08:00
gc87 a2147e2d28 fix(mqtt): topic pair double free 2022-06-15 18:24:57 +08:00
gc87 3ea1e02a14 refactor(mqtt): remove publish queue 2022-06-15 18:24:57 +08:00
fengzero 174cb88119 delete json include that does not need to be exported 2022-06-15 10:24:53 +00:00
fengzero e93e517f95 refactor CmakeLists.txt 2022-06-15 09:45:07 +00:00
fengzero c1592e6f98 ci: remove release package 2022-06-15 08:21:25 +00:00
fengzeroz 5b22fd348c Merge pull request #545 from eeff/eeff/dev
fix(core): initialize plugin common tag size
2022-06-15 15:57:22 +08:00
eeff efb601fe29 fix(core): initialize plugin common tag size 2022-06-15 15:56:16 +08:00
fengzeroz 4d1c2a0091 Merge pull request #541 from fengzeroz/main
refactor plugin interface config
2022-06-15 14:58:57 +08:00
fengzero f44a8db699 plugin: remove argument in open() 2022-06-15 06:49:02 +00:00
fengzero 2d38ae5f50 refactor plugin interface config 2022-06-15 06:40:30 +00:00
fengzeroz 3e0833a1f0 Merge pull request #540 from fengzeroz/main
remove mtx in plugin_manager
2022-06-15 14:39:20 +08:00
fengzero a52b16c1dc remove adapter/ndoe id 2022-06-15 06:14:51 +00:00
fengzero 7a9a7dd76b remove mtx in manager 2022-06-15 06:00:25 +00:00
fengzero 824734ef48 remove mtx in node_manager 2022-06-15 05:57:48 +00:00