Merge branch 'fix-backoff' of git://github.com/abiliojr/mosquitto into abiliojr-fix-backoff

pull/2166/head
Roger A. Light 5 years ago
commit 4b0a4c5c08

@ -314,10 +314,8 @@ int bridge__connect_step3(struct mosquitto *context)
rc = send__connect(context, context->keepalive, context->clean_start, NULL); rc = send__connect(context, context->keepalive, context->clean_start, NULL);
if(rc == MOSQ_ERR_SUCCESS){ if(rc == MOSQ_ERR_SUCCESS){
bridge__backoff_reset(context);
return MOSQ_ERR_SUCCESS; return MOSQ_ERR_SUCCESS;
}else if(rc == MOSQ_ERR_ERRNO && errno == ENOTCONN){ }else if(rc == MOSQ_ERR_ERRNO && errno == ENOTCONN){
bridge__backoff_reset(context);
return MOSQ_ERR_SUCCESS; return MOSQ_ERR_SUCCESS;
}else{ }else{
if(rc == MOSQ_ERR_TLS){ if(rc == MOSQ_ERR_TLS){
@ -455,10 +453,8 @@ int bridge__connect(struct mosquitto *context)
rc2 = send__connect(context, context->keepalive, context->clean_start, NULL); rc2 = send__connect(context, context->keepalive, context->clean_start, NULL);
if(rc2 == MOSQ_ERR_SUCCESS){ if(rc2 == MOSQ_ERR_SUCCESS){
bridge__backoff_reset(context);
return rc; return rc;
}else if(rc2 == MOSQ_ERR_ERRNO && errno == ENOTCONN){ }else if(rc2 == MOSQ_ERR_ERRNO && errno == ENOTCONN){
bridge__backoff_reset(context);
return MOSQ_ERR_SUCCESS; return MOSQ_ERR_SUCCESS;
}else{ }else{
if(rc2 == MOSQ_ERR_TLS){ if(rc2 == MOSQ_ERR_TLS){
@ -563,6 +559,8 @@ int bridge__on_connect(struct mosquitto *context)
} }
} }
bridge__backoff_reset(context);
return MOSQ_ERR_SUCCESS; return MOSQ_ERR_SUCCESS;
} }

Loading…
Cancel
Save