Commit 6f096dca authored by TousakaRin's avatar TousakaRin

change _parse_time_us to _received_us

parent 7b65d3ab
...@@ -136,7 +136,7 @@ void MethodStatus::SetConcurrencyLimiter(ConcurrencyLimiter* cl) { ...@@ -136,7 +136,7 @@ void MethodStatus::SetConcurrencyLimiter(ConcurrencyLimiter* cl) {
ScopedMethodStatus::~ScopedMethodStatus() { ScopedMethodStatus::~ScopedMethodStatus() {
if (_status) { if (_status) {
_status->OnResponded(_c->ErrorCode(), butil::cpuwide_time_us() - _start_parse_us); _status->OnResponded(_c->ErrorCode(), butil::cpuwide_time_us() - _received_us);
_status = NULL; _status = NULL;
} }
ServerPrivateAccessor(_c->server()).RemoveConcurrency(_c); ServerPrivateAccessor(_c->server()).RemoveConcurrency(_c);
......
...@@ -85,17 +85,17 @@ class ScopedMethodStatus { ...@@ -85,17 +85,17 @@ class ScopedMethodStatus {
public: public:
ScopedMethodStatus(MethodStatus* status, ScopedMethodStatus(MethodStatus* status,
Controller* c, Controller* c,
int64_t start_parse_us) int64_t received_us)
: _status(status) : _status(status)
, _c(c) , _c(c)
, _start_parse_us(start_parse_us) {} , _received_us(received_us) {}
~ScopedMethodStatus(); ~ScopedMethodStatus();
operator MethodStatus* () const { return _status; } operator MethodStatus* () const { return _status; }
private: private:
DISALLOW_COPY_AND_ASSIGN(ScopedMethodStatus); DISALLOW_COPY_AND_ASSIGN(ScopedMethodStatus);
MethodStatus* _status; MethodStatus* _status;
Controller* _c; Controller* _c;
uint64_t _start_parse_us; uint64_t _received_us;
}; };
inline bool MethodStatus::OnRequested() { inline bool MethodStatus::OnRequested() {
......
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