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

Merge pull request #938 from fengzeroz/main

Browse Source 
jwt: load key from config and persistence dir
This commit is contained in:
fengzeroz
2022-11-28 15:51:54 +08:00
committed by GitHub
parent 2d1a14422d a1773a8b72
commit 8c8d599d38
3 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adapter/adapter.c
+1 -1
View File
@@ -1025,7 +1025,7 @@ static int level_check(void *usr_data)
gettimeofday(&tv, NULL);
diff = tv.tv_sec - adapter->timestamp_lev;
if (delay_s <= diff) {
int ret = zlog_level_switch(ct, ZLOG_LEVEL_INFO);
int ret = zlog_level_switch(ct, default_log_level);
if (0 != ret) {
nlog_error("Modify default log level fail, ret:%d", ret);
}
src/core/manager.c
+1 -1
View File
@@ -206,7 +206,7 @@ static int manager_level_check(void *usr_data)
gettimeofday(&tv, NULL);
diff = tv.tv_sec - manager->timestamp_lev_manager;
if (delay_s <= diff) {
int ret = zlog_level_switch(neuron, ZLOG_LEVEL_INFO);
int ret = zlog_level_switch(neuron, default_log_level);
if (0 != ret) {
nlog_error("Modify default log level fail, ret:%d", ret);
}
src/utils/neu_jwt.c
+8 -2
View File
@@ -92,7 +92,7 @@ static char *load_key(const char *dir, char *name)
return content;
}
int neu_jwt_init(const char *dir_path)
static void scanf_key(const char *dir_path)
{
DIR * dir = NULL;
struct dirent *ptr = NULL;
@@ -100,7 +100,7 @@ int neu_jwt_init(const char *dir_path)
dir = opendir(dir_path);
if (dir == NULL) {
zlog_error(neuron, "Open dir error: %s", strerror(errno));
return -1;
return;
}
while (NULL != (ptr = readdir(dir))) {
@@ -127,6 +127,12 @@ int neu_jwt_init(const char *dir_path)
}
closedir(dir);
}
int neu_jwt_init(const char *dir_path)
{
scanf_key(dir_path);
scanf_key("persistence");
return 0;
}