GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-28 22:59:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(monitor): not allow subscription

Browse Source
This commit is contained in:
eeff
2022-12-15 15:48:54 +08:00
parent 96aa7cd69f
commit 05e8bd509a
3 changed files with 17 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
include/neuron/errcodes.h
+11 -10
View File
@@ -46,16 +46,17 @@ typedef enum {
NEU_ERR_DUPLICATE_PASSWORD = 1013,
NEU_ERR_COMMAND_EXECUTION_FAILED = 1014,
NEU_ERR_NODE_EXIST = 2002,
NEU_ERR_NODE_NOT_EXIST = 2003,
NEU_ERR_NODE_SETTING_INVALID = 2004,
NEU_ERR_NODE_SETTING_NOT_FOUND = 2005,
NEU_ERR_NODE_NOT_READY = 2006,
NEU_ERR_NODE_IS_RUNNING = 2007,
NEU_ERR_NODE_NOT_RUNNING = 2008,
NEU_ERR_NODE_IS_STOPED = 2009,
NEU_ERR_NODE_NAME_TOO_LONG = 2010,
NEU_ERR_NODE_NOT_ALLOW_DELETE = 2011,
NEU_ERR_NODE_EXIST = 2002,
NEU_ERR_NODE_NOT_EXIST = 2003,
NEU_ERR_NODE_SETTING_INVALID = 2004,
NEU_ERR_NODE_SETTING_NOT_FOUND = 2005,
NEU_ERR_NODE_NOT_READY = 2006,
NEU_ERR_NODE_IS_RUNNING = 2007,
NEU_ERR_NODE_NOT_RUNNING = 2008,
NEU_ERR_NODE_IS_STOPED = 2009,
NEU_ERR_NODE_NAME_TOO_LONG = 2010,
NEU_ERR_NODE_NOT_ALLOW_DELETE = 2011,
NEU_ERR_NODE_NOT_ALLOW_SUBSCRIBE = 2012,
NEU_ERR_GROUP_ALREADY_SUBSCRIBED = 2101,
NEU_ERR_GROUP_NOT_SUBSCRIBE = 2102,
src/core/manager_internal.c
+5
View File
@@ -192,6 +192,11 @@ int neu_manager_subscribe(neu_manager_t *manager, const char *app,
return NEU_ERR_NODE_NOT_EXIST;
}
if (0 == strcmp(app, "monitor")) {
// filter out monitor node
return NEU_ERR_NODE_NOT_ALLOW_SUBSCRIBE;
}
ret =
neu_adapter_driver_group_exist((neu_adapter_driver_t *) adapter, group);
if (ret != NEU_ERR_SUCCESS) {
src/utils/http.c
+1
View File
@@ -314,6 +314,7 @@ int neu_http_response(nng_aio *aio, neu_err_code_e code, char *content)
case NEU_ERR_BODY_IS_WRONG:
case NEU_ERR_PARAM_IS_WRONG:
case NEU_ERR_NODE_SETTING_INVALID:
case NEU_ERR_NODE_NOT_ALLOW_SUBSCRIBE:
case NEU_ERR_LIBRARY_INFO_INVALID:
case NEU_ERR_LICENSE_INVALID:
case NEU_ERR_GROUP_PARAMETER_INVALID: