Index: webrtc/p2p/base/port.cc |
diff --git a/webrtc/p2p/base/port.cc b/webrtc/p2p/base/port.cc |
index eb63436dc8d83806e60d12aab074a5bf0094e4ee..dc99a338d5ed82b98ea8185a812d9bb74b9e235d 100644 |
--- a/webrtc/p2p/base/port.cc |
+++ b/webrtc/p2p/base/port.cc |
@@ -868,7 +868,7 @@ Connection::Connection(Port* port, |
last_data_received_(0), |
last_ping_response_received_(0), |
reported_(false), |
- state_(STATE_WAITING), |
+ state_(IceCandidatePairState::WAITING), |
receiving_timeout_(WEAK_CONNECTION_RECEIVE_TIMEOUT), |
time_created_ms_(rtc::TimeMillis()) { |
// All of our connections start in WAITING state. |
@@ -937,8 +937,8 @@ void Connection::UpdateReceiving(int64_t now) { |
SignalStateChange(this); |
} |
-void Connection::set_state(State state) { |
- State old_state = state_; |
+void Connection::set_state(IceCandidatePairState state) { |
+ IceCandidatePairState old_state = state_; |
state_ = state; |
if (state != old_state) { |
LOG_J(LS_VERBOSE, this) << "set_state"; |
@@ -1126,12 +1126,12 @@ void Connection::Destroy() { |
} |
void Connection::FailAndDestroy() { |
- set_state(Connection::STATE_FAILED); |
+ set_state(IceCandidatePairState::FAILED); |
Destroy(); |
} |
void Connection::FailAndPrune() { |
- set_state(Connection::STATE_FAILED); |
+ set_state(IceCandidatePairState::FAILED); |
Prune(); |
} |
@@ -1223,7 +1223,7 @@ void Connection::Ping(int64_t now) { |
<< ", id=" << rtc::hex_encode(req->id()) |
<< ", nomination=" << nomination_; |
requests_.Send(req); |
- state_ = STATE_INPROGRESS; |
+ state_ = IceCandidatePairState::IN_PROGRESS; |
num_pings_sent_++; |
} |
@@ -1250,7 +1250,7 @@ void Connection::ReceivedPingResponse(int rtt, const std::string& request_id) { |
last_ping_response_received_ = rtc::TimeMillis(); |
UpdateReceiving(last_ping_response_received_); |
set_write_state(STATE_WRITABLE); |
- set_state(STATE_SUCCEEDED); |
+ set_state(IceCandidatePairState::SUCCEEDED); |
rtt_samples_++; |
rtt_ = (RTT_RATIO * rtt_ + rtt) / (RTT_RATIO + 1); |
} |
@@ -1331,8 +1331,8 @@ std::string Connection::ToString() const { |
<< ":" << remote.protocol() << ":" << remote.address().ToSensitiveString() |
<< "|" << CONNECT_STATE_ABBREV[connected()] |
<< RECEIVE_STATE_ABBREV[receiving()] << WRITE_STATE_ABBREV[write_state()] |
- << ICESTATE[state()] << "|" << remote_nomination() << "|" << nomination() |
- << "|" << priority() << "|"; |
+ << ICESTATE[static_cast<int>(state())] << "|" << remote_nomination() << "|" |
+ << nomination() << "|" << priority() << "|"; |
if (rtt_ < DEFAULT_RTT) { |
ss << rtt_ << "]"; |
} else { |
@@ -1471,6 +1471,16 @@ ConnectionInfo Connection::stats() { |
stats_.recv_total_bytes = recv_rate_tracker_.TotalSampleCount(); |
stats_.sent_bytes_second = round(send_rate_tracker_.ComputeRate()); |
stats_.sent_total_bytes = send_rate_tracker_.TotalSampleCount(); |
+ stats_.receiving = receiving_; |
+ stats_.writable = write_state_ == STATE_WRITABLE; |
+ stats_.timeout = write_state_ == STATE_WRITE_TIMEOUT; |
+ stats_.new_connection = !reported_; |
+ stats_.rtt = rtt_; |
+ stats_.local_candidate = local_candidate(); |
+ stats_.remote_candidate = remote_candidate(); |
+ stats_.key = this; |
+ stats_.state = state_; |
+ stats_.priority = priority(); |
return stats_; |
} |