Commit 036a8a4c authored by TousakaRin's avatar TousakaRin

Fix the bug that in the pooled mode, after the isolation occurs, the health…

Fix the bug that in the pooled mode, after the isolation occurs, the health check will not be started.
parent 79ab26ff
...@@ -42,7 +42,6 @@ ...@@ -42,7 +42,6 @@
#include "brpc/shared_object.h" #include "brpc/shared_object.h"
#include "brpc/policy/rtmp_protocol.h" // FIXME #include "brpc/policy/rtmp_protocol.h" // FIXME
#include "brpc/periodic_task.h" #include "brpc/periodic_task.h"
#include "brpc/circuit_breaker.h" // CircuitBreaker
#if defined(OS_MACOSX) #if defined(OS_MACOSX)
#include <sys/event.h> #include <sys/event.h>
#endif #endif
...@@ -880,8 +879,8 @@ int Socket::SetFailed() { ...@@ -880,8 +879,8 @@ int Socket::SetFailed() {
void Socket::FeedbackCircuitBreaker(int error_code, int64_t latency_us) { void Socket::FeedbackCircuitBreaker(int error_code, int64_t latency_us) {
if (!GetOrNewSharedPart()->circuit_breaker.OnCallEnd(error_code, latency_us)) { if (!GetOrNewSharedPart()->circuit_breaker.OnCallEnd(error_code, latency_us)) {
LOG(ERROR) << "Socket[" << *this << "] deactivted by circuit breaker"; LOG(ERROR) << "Socket[" << *this << "] isolated by circuit breaker";
SetFailed(); SetFailed(main_socket_id());
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment