mirror of
https://github.com/emqx/neuron.git
synced 2026-10-17 04:40:42 +08:00
feat(schema):add a group_interval field
This commit is contained in:
@@ -5,6 +5,7 @@
|
||||
"regex": ""
|
||||
}
|
||||
],
|
||||
"group_interval": 1000,
|
||||
"file_length": {
|
||||
"name": "file_length",
|
||||
"description": "",
|
||||
|
||||
@@ -25,6 +25,7 @@
|
||||
"regex": "^[0-9]+!([0-1][0-9]+|[3-4][0-9]+\\.([0-9]|[0-1][0-5]))$"
|
||||
}
|
||||
],
|
||||
"group_interval": 1000,
|
||||
"host": {
|
||||
"name": "host",
|
||||
"description": "local ip in server mode, remote device ip in client mode",
|
||||
|
||||
@@ -1051,10 +1051,10 @@ inline static void reply(neu_adapter_t *adapter, neu_reqresp_head_t *header,
|
||||
int ret = nng_sendmsg(adapter->sock, msg, 0);
|
||||
if (ret != 0) {
|
||||
nng_msg_free(msg);
|
||||
nlog_warn("%s reply %s to %s, error: %s",header->sender,
|
||||
neu_reqresp_type_string(header->type), header->receiver, nng_strerror(ret));
|
||||
nlog_warn("%s reply %s to %s, error: %s", header->sender,
|
||||
neu_reqresp_type_string(header->type), header->receiver,
|
||||
nng_strerror(ret));
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
inline static void notify_monitor(neu_adapter_t * adapter,
|
||||
|
||||
Reference in New Issue
Block a user