91 Commits

Author SHA1 Message Date
gc87 83eb1ecf61 fix(mqtt): non-user login to rabbitmq auth failed
- empty user name login to rqbbitmq login failed for user ''
2022-09-16 14:09:42 +08:00
fengzero a9f4089979 fix(connection): multithreaded connection status exception 2022-09-09 03:21:21 +00:00
fengzero a7a6ede305 chore(connection): stop/start connection 2022-08-18 09:04:45 +00:00
gc87 1991a3e836 fix(mqtt): handling bio connect error in inspector 2022-08-17 14:34:57 +08:00
gc87 4805340571 fix: bio read crash when do connect error 2022-08-17 14:34:57 +08:00
fengzero 7a54325804 chore(driver): optimize the time when the driver reads tag for the first time 2022-08-16 06:24:02 +00:00
fengzeroz 373641bbe0 Merge pull request #711 from eeff/eeff/dev
fix: neu_conn_wait_msg reset buffer offset at outset
2022-08-15 14:51:52 +08:00
eeff aef6e83a10 fix: neu_conn_wait_msg/neu_conn_tcp_server_recv reset buffer offset at outset 2022-08-15 14:46:10 +08:00
fengzero 04675ec04c fix(http): remove aio timeout 2022-08-05 09:32:42 +00:00
fengzero 55e009dc05 connection: serial port support more baud rates 2022-08-02 02:01:18 +00:00
gc87 8cf9ba95f8 refactor(mqtt): static alloc -> dynamic alloc 2022-07-29 15:52:39 +08:00
fengzero 844efd9ab0 fix serial port parameter 2022-07-28 08:55:46 +00:00
fengzero 58ce412192 fix: replace large stack var with heap var 2022-07-26 02:37:44 +00:00
fengzeroz f628c9153b Merge pull request #636 from gc87/branch-mqtt
Add heartbeat support for mqtt plugin
2022-07-15 17:21:22 +08:00
fengzero 003c31e4a6 fix(connection): send with bolck flag if conn is bolck 2022-07-15 06:48:08 +00:00
gc87 3c59046314 feat(mqtt): setting optional field 2022-07-15 13:51:02 +08:00
gc87 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
gc87 efd8083a75 fix(mqtt): bio should retry flag clear 2022-07-15 13:51:02 +08:00
fengzero 3c5ae487b0 fix(errorcode): return NEU_ERR_PLUGIN_TAG_NOT_READY when the tag value cache does not exist 2022-07-14 07:34:13 +00:00
fengzero e477336fa1 fix(connection): trigger disconnect callback if reconfig 2022-07-14 06:01:05 +00:00
fengzero a93796aa0c fix(driver): memory leak 2022-07-13 09:40:38 +00:00
fengzero 1fbebd3872 feat(connection): wait fixed msg 2022-07-13 07:46:38 +00:00
fengzero 82e7a907e3 mqtt: del sleep 1s 2022-07-06 07:08:35 +00:00
gc87 b0db5edea1 fix(mqtt): implicit conversion error
Resolves #474
2022-06-30 10:28:36 +08:00
gc87 8231e2ffd0 fix(mqtt): topic is subscribed repeatedly 2022-06-30 10:00:47 +08:00
fengzero 98306b5adb connection: add buf used log 2022-06-24 11:34:22 +00:00
gc87 d47ea13594 feat(mqtt): add zlog with cat to mqtt_c_client.c 2022-06-21 10:51:31 +08:00
fengzero 11788dab41 connection: add send log 2022-06-21 02:08:00 +00:00
gc87 fe98452624 refactor(mqtt): remove sys/queue.h deps 2022-06-17 15:01:28 +08:00
gc87 24eeb4787f refactor(mqtt): remove sys/queue.h deps 2022-06-17 11:49:08 +08:00
gc87 34a3e43c58 refactor(mqtt): fix connection state 2022-06-16 18:45:32 +08:00
fengzero 0fd866c69f fix set serial port opt 2022-06-16 10:37:14 +00:00
fengzero 53ceeac9ff del unused errorcode 2022-06-16 10:04:04 +00:00
fengzero 15401a0711 connection: add log category 2022-06-16 08:09:05 +00:00
fengzero f2ae98b54a fix serial port parameter 2022-06-16 07:17:37 +00:00
fengzero da7639eb85 connection: add log 2022-06-16 06:32:56 +00:00
fengzero 082f68b752 fix(connection): serial port device 2022-06-14 05:40:42 +00:00
gc87 36a16f1bb6 refactor(mqtt): trans-data upload 2022-06-14 11:28:53 +08:00
fengzero 8aa5d04072 feat(connection): serial port 2022-06-13 09:37:56 +00:00
fengzero 203328dffd copyright 2020-2022 2022-06-10 04:43:06 +00:00
fengzero be650d62f9 fix read log config 2022-06-10 01:32:49 +00:00
fengzero d9a43e20cc fix conn stream consume 2022-05-31 01:45:55 +00:00
fengzero e544d8618b connection: disconnect 2022-05-31 01:32:59 +00:00
gc87 b63753380e refactor(mqtt): remove nng mqtt 2022-05-30 10:17:16 +08:00
fengzero 27d1f38b1c refactor modbus-tcp 2022-05-29 09:47:58 +00:00
fengzero a7781b63ce log: replace log with zlog 2022-05-28 09:27:52 +00:00
fengzero e9d1cb10cd del log 2022-05-27 06:33:18 +00:00
fengzero 51f0f67ec6 remove recv msg function 2022-05-20 05:50:28 +00:00
fengzero fcd267d6ce fix(driver): write string 2022-05-19 06:45:38 +00:00
fengzeroz db31cee551 Merge pull request #485 from gc87/prepare-spb
Prepare work for sparkplugb plugin
2022-05-16 11:10:44 +08:00