Index: webrtc/p2p/stunprober/main.cc |
diff --git a/webrtc/p2p/stunprober/main.cc b/webrtc/p2p/stunprober/main.cc |
deleted file mode 100644 |
index a3ce992e9f31edac7a9e7813f61826c85e01b2e1..0000000000000000000000000000000000000000 |
--- a/webrtc/p2p/stunprober/main.cc |
+++ /dev/null |
@@ -1,140 +0,0 @@ |
-/* |
- * Copyright 2015 The WebRTC Project Authors. All rights reserved. |
- * |
- * Use of this source code is governed by a BSD-style license |
- * that can be found in the LICENSE file in the root of the source |
- * tree. An additional intellectual property rights grant can be found |
- * in the file PATENTS. All contributing project authors may |
- * be found in the AUTHORS file in the root of the source tree. |
- */ |
- |
-#include <stdio.h> |
-#include <stdlib.h> |
-#include <string.h> |
- |
-#include <iostream> |
-#include <map> |
-#include <memory> |
- |
-#include "webrtc/base/checks.h" |
-#include "webrtc/base/flags.h" |
-#include "webrtc/base/helpers.h" |
-#include "webrtc/base/nethelpers.h" |
-#include "webrtc/base/network.h" |
-#include "webrtc/base/logging.h" |
-#include "webrtc/base/ssladapter.h" |
-#include "webrtc/base/stringutils.h" |
-#include "webrtc/base/thread.h" |
-#include "webrtc/base/timeutils.h" |
-#include "webrtc/p2p/base/basicpacketsocketfactory.h" |
-#include "webrtc/p2p/stunprober/stunprober.h" |
- |
-using stunprober::StunProber; |
-using stunprober::AsyncCallback; |
- |
-DEFINE_bool(help, false, "Prints this message"); |
-DEFINE_int(interval, 10, "Interval of consecutive stun pings in milliseconds"); |
-DEFINE_bool(shared_socket, false, "Share socket mode for different remote IPs"); |
-DEFINE_int(pings_per_ip, |
- 10, |
- "Number of consecutive stun pings to send for each IP"); |
-DEFINE_int(timeout, |
- 1000, |
- "Milliseconds of wait after the last ping sent before exiting"); |
-DEFINE_string( |
- servers, |
- "stun.l.google.com:19302,stun1.l.google.com:19302,stun2.l.google.com:19302", |
- "Comma separated STUN server addresses with ports"); |
- |
-namespace { |
- |
-const char* PrintNatType(stunprober::NatType type) { |
- switch (type) { |
- case stunprober::NATTYPE_NONE: |
- return "Not behind a NAT"; |
- case stunprober::NATTYPE_UNKNOWN: |
- return "Unknown NAT type"; |
- case stunprober::NATTYPE_SYMMETRIC: |
- return "Symmetric NAT"; |
- case stunprober::NATTYPE_NON_SYMMETRIC: |
- return "Non-Symmetric NAT"; |
- default: |
- return "Invalid"; |
- } |
-} |
- |
-void PrintStats(StunProber* prober) { |
- StunProber::Stats stats; |
- if (!prober->GetStats(&stats)) { |
- LOG(LS_WARNING) << "Results are inconclusive."; |
- return; |
- } |
- |
- LOG(LS_INFO) << "Shared Socket Mode: " << stats.shared_socket_mode; |
- LOG(LS_INFO) << "Requests sent: " << stats.num_request_sent; |
- LOG(LS_INFO) << "Responses received: " << stats.num_response_received; |
- LOG(LS_INFO) << "Target interval (ns): " << stats.target_request_interval_ns; |
- LOG(LS_INFO) << "Actual interval (ns): " << stats.actual_request_interval_ns; |
- LOG(LS_INFO) << "NAT Type: " << PrintNatType(stats.nat_type); |
- LOG(LS_INFO) << "Host IP: " << stats.host_ip; |
- LOG(LS_INFO) << "Server-reflexive ips: "; |
- for (auto& ip : stats.srflx_addrs) { |
- LOG(LS_INFO) << "\t" << ip; |
- } |
- |
- LOG(LS_INFO) << "Success Precent: " << stats.success_percent; |
- LOG(LS_INFO) << "Response Latency:" << stats.average_rtt_ms; |
-} |
- |
-void StopTrial(rtc::Thread* thread, StunProber* prober, int result) { |
- thread->Quit(); |
- if (prober) { |
- LOG(LS_INFO) << "Result: " << result; |
- if (result == StunProber::SUCCESS) { |
- PrintStats(prober); |
- } |
- } |
-} |
- |
-} // namespace |
- |
-int main(int argc, char** argv) { |
- rtc::FlagList::SetFlagsFromCommandLine(&argc, argv, true); |
- if (FLAG_help) { |
- rtc::FlagList::Print(nullptr, false); |
- return 0; |
- } |
- |
- std::vector<rtc::SocketAddress> server_addresses; |
- std::istringstream servers(FLAG_servers); |
- std::string server; |
- while (getline(servers, server, ',')) { |
- rtc::SocketAddress addr; |
- if (!addr.FromString(server)) { |
- LOG(LS_ERROR) << "Parsing " << server << " failed."; |
- return -1; |
- } |
- server_addresses.push_back(addr); |
- } |
- |
- rtc::InitializeSSL(); |
- rtc::InitRandom(rtc::Time32()); |
- rtc::Thread* thread = rtc::ThreadManager::Instance()->WrapCurrentThread(); |
- std::unique_ptr<rtc::BasicPacketSocketFactory> socket_factory( |
- new rtc::BasicPacketSocketFactory()); |
- std::unique_ptr<rtc::BasicNetworkManager> network_manager( |
- new rtc::BasicNetworkManager()); |
- rtc::NetworkManager::NetworkList networks; |
- network_manager->GetNetworks(&networks); |
- StunProber* prober = |
- new StunProber(socket_factory.get(), rtc::Thread::Current(), networks); |
- auto finish_callback = [thread](StunProber* prober, int result) { |
- StopTrial(thread, prober, result); |
- }; |
- prober->Start(server_addresses, FLAG_shared_socket, FLAG_interval, |
- FLAG_pings_per_ip, FLAG_timeout, |
- AsyncCallback(finish_callback)); |
- thread->Run(); |
- delete prober; |
- return 0; |
-} |