summaryrefslogtreecommitdiff
path: root/program/src
diff options
context:
space:
mode:
Diffstat (limited to 'program/src')
-rw-r--r--program/src/cert_conf.cpp1
-rw-r--r--program/src/cert_session.cpp22
2 files changed, 15 insertions, 8 deletions
diff --git a/program/src/cert_conf.cpp b/program/src/cert_conf.cpp
index 4606603..c4816ff 100644
--- a/program/src/cert_conf.cpp
+++ b/program/src/cert_conf.cpp
@@ -123,7 +123,6 @@ static int load_module_config(const char *config)
mesa_runtime_log(RLOG_LV_FATAL, MODULE_NAME, "Certsotre redis port invalid");
goto finish;
}
-
finish:
return xret;
}
diff --git a/program/src/cert_session.cpp b/program/src/cert_session.cpp
index 8897f96..0753aa7 100644
--- a/program/src/cert_session.cpp
+++ b/program/src/cert_session.cpp
@@ -2015,24 +2015,32 @@ redis_link_detection(uint32_t __attribute__((__unused__)) uid,
x509_forge_thread *threads = (x509_forge_thread *)argv;
unsigned int thread_nu = cfg_instanec()->thread_nu;
- for (tid = 0; tid < (int)thread_nu; tid++) {
+ for (tid = 0; tid < (int)thread_nu; tid++)
+ {
info = threads + tid;
- if(info->sync == NULL){
+ if(info->sync == NULL && info->base != NULL)
+ {
redisFree(info->sync);
xret = redis_sync_init(&info->sync);
- if (xret < 0 || !info->sync){
+ if (xret < 0 || !info->sync)
+ {
mesa_runtime_log(RLOG_LV_FATAL, MODULE_NAME, "[%d]trying to connect sync redis failed", tid);
continue;
- }else{
+ }
+ else
+ {
mesa_runtime_log(RLOG_LV_FATAL, MODULE_NAME, "[%d]trying to connect sync redis success", tid);
}
if(cfg_instanec()->mode)
{
- xret = redis_rsync_init(info->base, &info->cl_ctx);
- if (xret < 0 || !info->cl_ctx){
+ xret = redis_rsync_init(info->base, &info->cl_ctx);
+ if (xret < 0 || !info->cl_ctx)
+ {
mesa_runtime_log(RLOG_LV_FATAL, MODULE_NAME, "[%d]trying to connect rsync redis failed", tid);
- }else{
+ }
+ else
+ {
mesa_runtime_log(RLOG_LV_FATAL, MODULE_NAME, "[%d]trying to connect rsync redis success", tid);
}
}