Commit 4da91251 authored by TousakaRin's avatar TousakaRin Committed by TousakaRin

Keep the SharedPart' is defined in the cpp file.

parent ffca94c0
......@@ -17,7 +17,6 @@
#ifndef BRPC_CIRCUIT_BREAKER_H
#define BRPC_CIRCUIT_BREAKER_H
#include "butil/containers/doubly_buffered_data.h"
#include "butil/atomicops.h"
namespace brpc {
......
......@@ -778,8 +778,8 @@ void Controller::Call::OnComplete(Controller* c, int error_code/*note*/,
if (enable_circuit_breaker) {
SocketUniquePtr sock;
if (Socket::Address(peer_id, &sock) == 0) {
// sock->GetSharedPart()->circuit_breaker.OnCallEnd(
// error_code, butil::gettimeofday_us() - begin_time_us);
sock->FeedbackCircuitBreaker(error_code,
butil::gettimeofday_us() - begin_time_us);
}
}
}
......
......@@ -762,8 +762,6 @@ private:
butil::Mutex _stream_mutex;
std::set<StreamId> *_stream_set;
CircuitBreaker _circuit_breaker;
};
} // namespace brpc
......
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