GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-25 19:31:41 +08:00
Code Issues Packages Projects Releases Wiki Activity
621 Commits 22 Branches 165 Tags
f25ed185a3bcba024d03f40eb235f9fa6ec7da0f
Commit Graph
621 Commits
This Branch
This Branch
All Branches
Author SHA1 Message Date
fengzero f25ed185a3 float supports changing endianness 2022-02-09 17:43:22 +08:00
fengzero 189acf9008 refactor device rw errorcode 2022-02-09 17:43:22 +08:00
fengzero f218c27abf refactor reconnect 2022-02-09 17:43:22 +08:00
fengzero e2a96781b8 mqtt ft:skip modbus execption 2022-02-09 17:43:22 +08:00
fengzero 86cdb6ee85 del unused errorcode 2022-02-09 17:43:22 +08:00
fengzero 96fe9e33be add reconnect on tcp server/client connection 2022-02-09 17:43:22 +08:00
fengzero ef78632f50 ft: modbus and mqtt network exception 2022-02-09 17:43:22 +08:00
fengzero 0ab8f6534a io event on linux 2022-02-09 17:43:22 +08:00
fengzero 9074364d59 tcp server and client send and receive data 2022-02-09 17:43:22 +08:00
lixiumei 6e7fdbcc87 Adding data for pressures tests 2022-02-09 17:42:44 +08:00
eeff 6cd5c8db6a Update persist adapter to load subscription infos 2022-01-30 09:29:15 +08:00
eeff 9c6ebbdf5d Add function persister_singleton_load_subscriptions 2022-01-30 09:29:15 +08:00
eeff ba479d76aa Add function neu_manager_adapter_get_grp_config_ref_by_name 2022-01-30 09:29:15 +08:00
eeff 79476693ba Add function neu_manager_get_node_id_by_name 2022-01-30 09:29:15 +08:00
eeff 45d3be37ab Add syslog callback in neu_log 2022-01-28 21:52:53 +08:00
eeff 1a34021e18 Rename neu_log log level enum to avoid name collision 2022-01-28 21:52:53 +08:00
eeff f18c6b9765 Fix persistence loading to ignore if no group configs exist 2022-01-28 21:40:18 +08:00
eeff 30b20ee6ac Update adapter loop to handle node subscribe/unsubscribe events 2022-01-28 21:36:56 +08:00
eeff 12e790575e Add function neu_manager_get_persist_subscription_infos 2022-01-28 21:36:56 +08:00
eeff b443d6f0b2 Add function neu_persist_subscription_infos_free 2022-01-28 21:36:56 +08:00
eeff a9562e8432 Update neu_manager loop to send subscribe/unsubscribe events 2022-01-28 21:36:56 +08:00
eeff 9d7d19f0cf Add message type for subscribe/unsubscribe node events 
Add new message type MSG_EVENT_SUBSCRIBE_NODE and
  MSG_EVENT_UNSUBSCRIBE_NODE
 2022-01-28 21:36:56 +08:00
eeff 99ad951503 Refactor persistence api function neu_persister_load_subscriptions 2022-01-27 21:16:42 +08:00
eeff f9dfdf32c6 Refactor persistence api function neu_persister_store_subscriptions 2022-01-27 21:16:42 +08:00
eeff 595ec514a4 Refactor neu_manager loop persistence event forwarding code 2022-01-27 21:09:03 +08:00
eeff 81e7b3dc85 Add helper function manager_send_msg_to_pipe 2022-01-27 21:09:03 +08:00
eeff aa7ba3e09d Add function nng_msg_inplace_from_buf 2022-01-27 21:09:03 +08:00
eeff 1b9ed271a4 Cache persist adapter pipe in neu_manager loop for performance 2022-01-27 21:09:03 +08:00
eeff 04dffb12f8 Refactor neu_manager loop MSG_CMD_UNSUBSCRIBE_NODE handler code 
The handler code for message type MSG_CMD_UNSUBSCRIBE_NODE is
  refactored into a new function neu_manager_unsubscribe_node
 2022-01-27 21:09:03 +08:00
eeff b032785e6e Refactor neu_manager loop MSG_CMD_SUBSCRIBE_NODE handler code 
The handler code for message type MSG_CMD_SUBSCRIBE_NODE is refactored
  into a new function neu_manager_subscribe_node
 2022-01-27 21:09:03 +08:00
eeff fa22f535ed Fix neu_manager loop memory leak when sub/unsub node 2022-01-27 21:09:03 +08:00
gc87 da831249c4 Refactoring mqtt_send_loop 2022-01-27 15:42:50 +08:00
gc87 7a5af05601 Implement mqtt's start and stop processing 2022-01-27 15:42:50 +08:00
eeff 0bd3fbe7e1 Fix neu_manager loop to acquire lock when finding persist adapter 2022-01-27 10:17:32 +08:00
eeff be35cf5db2 Fix neu_manager loop to use the correct pipe when sub/unsub node 
1. When handling MSG_CMD_SUBSCRIBE_NODE, use the pipe of the
     destination node
  2. When handling MSG_CMD_UNSUBSCRIBE_NODE, use the pipe of the
     destination node
2.0.0-alpha.2 		2022-01-26 11:03:31 +08:00
eeff b5c159caaa Fix persist adapter to persist node state 
Update adapter command to send node update event when handling
  message type NEU_REQRESP_NODE_CTL.
 2022-01-26 10:46:36 +08:00
eeff e4a674ed8e Update persist adapter to start node according to node state 2022-01-26 10:43:00 +08:00
eeff 9ec363e631 Add function neu_manager_start_adapter_with_id 2022-01-26 10:43:00 +08:00
eeff 70aa5e2d8c Fix neu_persister_create to create adapters directory 2022-01-26 10:41:12 +08:00
eeff 29c15d76f3 Refactor neu_persister_create 2022-01-26 10:41:12 +08:00
gc87 6373646972 Fix opcua plugin schema name 2022-01-25 15:07:56 +08:00
eeff a4707c61f4 Add persistence test data for pressure testing 2022-01-24 18:44:38 +08:00
eeff 3f897f22b2 Add pressure testing robot file 
The pressure testing code is in the file pressure.test, so that CI
  does not pick it up.
 2022-01-24 18:44:38 +08:00
eeff 9aa743bca0 Add pressure testing robotframework common resource 2022-01-24 18:44:38 +08:00
eeff c5f961cd6d Add robotframework keywords for pressure testing 
1. Add keyword Get Random Node
  2. Add keyword Get Random Group Config
 2022-01-24 18:44:38 +08:00
eeff 8a9feb4dd6 Fix neu_persister_delete_adapter to delete adapter data 2022-01-24 18:29:33 +08:00
eeff 418785d2c2 Fix persistence group config json unit tests 2022-01-24 18:22:59 +08:00
eeff c8729c247b Fix neu_persist_group_config_infos_free 2022-01-24 18:22:59 +08:00
eeff 1842ea9302 Fix persister_singleton_handle_grp_config 2022-01-24 18:22:59 +08:00
eeff fe47802eb1 Update persistence group config json 
1. Update API docs
  2. Regenerate parser code
 2022-01-24 18:22:59 +08:00