| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright 2015 The WebRTC Project Authors. All rights reserved. | 2 * Copyright 2015 The WebRTC Project Authors. All rights reserved. |
| 3 * | 3 * |
| 4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
| 5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
| 6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
| 7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
| 8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
| 9 */ | 9 */ |
| 10 | 10 |
| (...skipping 88 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 99 | 99 |
| 100 private: | 100 private: |
| 101 AsyncCallback callback_; | 101 AsyncCallback callback_; |
| 102 rtc::SocketAddress addr_; | 102 rtc::SocketAddress addr_; |
| 103 std::vector<rtc::SocketAddress>* result_; | 103 std::vector<rtc::SocketAddress>* result_; |
| 104 | 104 |
| 105 // Not using smart ptr here as this requires specific release pattern. | 105 // Not using smart ptr here as this requires specific release pattern. |
| 106 rtc::AsyncResolver* resolver_; | 106 rtc::AsyncResolver* resolver_; |
| 107 }; | 107 }; |
| 108 | 108 |
| 109 std::string HistogramName(bool behind_nat, | 109 const char* PrintNatType(stunprober::NatType type) { |
| 110 bool is_src_port_shared, | 110 switch (type) { |
| 111 int interval_ms, | 111 case stunprober::NATTYPE_NONE: |
| 112 std::string suffix) { | 112 return "Not behind a NAT"; |
| 113 char output[1000]; | 113 case stunprober::NATTYPE_UNKNOWN: |
| 114 rtc::sprintfn(output, sizeof(output), "NetConnectivity6.%s.%s.%dms.%s", | 114 return "Unknown NAT type"; |
| 115 behind_nat ? "NAT" : "NoNAT", | 115 case stunprober::NATTYPE_SYMMETRIC: |
| 116 is_src_port_shared ? "SrcPortShared" : "SrcPortUnique", | 116 return "Symmetric NAT"; |
| 117 interval_ms, suffix.c_str()); | 117 case stunprober::NATTYPE_NON_SYMMETRIC: |
| 118 return std::string(output); | 118 return "Non-Symmetric NAT"; |
| 119 default: |
| 120 return "Invalid"; |
| 121 } |
| 119 } | 122 } |
| 120 | 123 |
| 121 void PrintStats(StunProber* prober) { | 124 void PrintStats(StunProber* prober) { |
| 122 StunProber::Stats stats; | 125 StunProber::Stats stats; |
| 123 if (!prober->GetStats(&stats)) { | 126 if (!prober->GetStats(&stats)) { |
| 124 LOG(LS_WARNING) << "Results are inconclusive."; | 127 LOG(LS_WARNING) << "Results are inconclusive."; |
| 125 return; | 128 return; |
| 126 } | 129 } |
| 127 | 130 |
| 128 LOG(LS_INFO) << "Shared Socket Mode: " << stats.shared_socket_mode; | 131 LOG(LS_INFO) << "Shared Socket Mode: " << stats.shared_socket_mode; |
| 129 LOG(LS_INFO) << "Requests sent: " << stats.num_request_sent; | 132 LOG(LS_INFO) << "Requests sent: " << stats.num_request_sent; |
| 130 LOG(LS_INFO) << "Responses received: " << stats.num_response_received; | 133 LOG(LS_INFO) << "Responses received: " << stats.num_response_received; |
| 131 LOG(LS_INFO) << "Target interval (ns): " << stats.target_request_interval_ns; | 134 LOG(LS_INFO) << "Target interval (ns): " << stats.target_request_interval_ns; |
| 132 LOG(LS_INFO) << "Actual interval (ns): " << stats.actual_request_interval_ns; | 135 LOG(LS_INFO) << "Actual interval (ns): " << stats.actual_request_interval_ns; |
| 133 LOG(LS_INFO) << "Behind NAT: " << stats.behind_nat; | 136 LOG(LS_INFO) << "NAT Type: " << PrintNatType(stats.nat_type); |
| 134 if (stats.behind_nat) { | |
| 135 LOG(LS_INFO) << "NAT is symmetrical: " << (stats.srflx_addrs.size() > 1); | |
| 136 } | |
| 137 LOG(LS_INFO) << "Host IP: " << stats.host_ip; | 137 LOG(LS_INFO) << "Host IP: " << stats.host_ip; |
| 138 LOG(LS_INFO) << "Server-reflexive ips: "; | 138 LOG(LS_INFO) << "Server-reflexive ips: "; |
| 139 for (auto& ip : stats.srflx_addrs) { | 139 for (auto& ip : stats.srflx_addrs) { |
| 140 LOG(LS_INFO) << "\t" << ip; | 140 LOG(LS_INFO) << "\t" << ip; |
| 141 } | 141 } |
| 142 | 142 |
| 143 std::string histogram_name = HistogramName( | 143 LOG(LS_INFO) << "Success Precent: " << stats.success_percent; |
| 144 stats.behind_nat, FLAG_shared_socket, FLAG_interval, "SuccessPercent"); | 144 LOG(LS_INFO) << "Response Latency:" << stats.average_rtt_ms; |
| 145 | |
| 146 LOG(LS_INFO) << "Histogram '" << histogram_name.c_str() | |
| 147 << "' = " << stats.success_percent; | |
| 148 | |
| 149 histogram_name = HistogramName(stats.behind_nat, FLAG_shared_socket, | |
| 150 FLAG_interval, "ResponseLatency"); | |
| 151 | |
| 152 LOG(LS_INFO) << "Histogram '" << histogram_name.c_str() | |
| 153 << "' = " << stats.average_rtt_ms << " ms"; | |
| 154 } | 145 } |
| 155 | 146 |
| 156 void StopTrial(rtc::Thread* thread, StunProber* prober, int result) { | 147 void StopTrial(rtc::Thread* thread, StunProber* prober, int result) { |
| 157 thread->Quit(); | 148 thread->Quit(); |
| 158 if (prober) { | 149 if (prober) { |
| 159 LOG(LS_INFO) << "Result: " << result; | 150 LOG(LS_INFO) << "Result: " << result; |
| 160 if (result == StunProber::SUCCESS) { | 151 if (result == StunProber::SUCCESS) { |
| 161 PrintStats(prober); | 152 PrintStats(prober); |
| 162 } | 153 } |
| 163 } | 154 } |
| (...skipping 27 matching lines...) Expand all Loading... |
| 191 new SocketFactory(), new TaskRunner()); | 182 new SocketFactory(), new TaskRunner()); |
| 192 auto finish_callback = | 183 auto finish_callback = |
| 193 [thread, prober](int result) { StopTrial(thread, prober, result); }; | 184 [thread, prober](int result) { StopTrial(thread, prober, result); }; |
| 194 prober->Start(server_addresses, FLAG_shared_socket, FLAG_interval, | 185 prober->Start(server_addresses, FLAG_shared_socket, FLAG_interval, |
| 195 FLAG_pings_per_ip, FLAG_timeout, | 186 FLAG_pings_per_ip, FLAG_timeout, |
| 196 AsyncCallback(finish_callback)); | 187 AsyncCallback(finish_callback)); |
| 197 thread->Run(); | 188 thread->Run(); |
| 198 delete prober; | 189 delete prober; |
| 199 return 0; | 190 return 0; |
| 200 } | 191 } |
| OLD | NEW |