GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-26 03:40:01 +08:00
Code Issues Packages Projects Releases Wiki Activity
636 Commits 22 Branches 165 Tags
4fdba85396fcb0bb8350a86947584358fab75689
Commit Graph
636 Commits
This Branch
This Branch
All Branches
Author SHA1 Message Date
eeff 4fdba85396 Move ft/data/persistence-simple-1k to ft/data/persistence/simple-1k 2022-02-11 19:05:26 +08:00
eeff 6eea2f2914 Fix CI for pressure testing 2022-02-11 15:51:30 +08:00
eeff 503e3f3708 Profile CPU and MEM usage in pressure testing 2022-02-11 15:51:30 +08:00
eeff 462c178548 Add robot keyword Profile Neuron for pressure testing report 2022-02-11 15:51:30 +08:00
eeff 8bdbdb30a5 Add dependencies for pressure testing 
1. psrecord
  2. matplotlib
 2022-02-11 15:51:30 +08:00
fengzero 75474e3def error codes classify 2022-02-11 11:54:13 +08:00
fengzero e70c72e043 remove opcua errorcode 2022-02-11 11:54:13 +08:00
fengzero 8650468b4f bit operations use the bit type 2022-02-11 11:54:13 +08:00
fengzero 84accdf861 Delete the first errorcode in the read/write result 2022-02-11 11:54:13 +08:00
fengzero c4f6d8c710 unpack array 2022-02-09 17:43:22 +08:00
fengzero ace744fcb4 change connection default block 2022-02-09 17:43:22 +08:00
fengzero 9917cb243e add device rw errorcode 2022-02-09 17:43:22 +08:00
fengzero b704110fa9 disable mqtt exception case 2022-02-09 17:43:22 +08:00
fengzero 3bc0dc3187 search group filter unanchored 2022-02-09 17:43:22 +08:00
fengzero 93a2b24680 add change string type function 2022-02-09 17:43:22 +08:00
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