147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org/* 247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * Copyright 2004 The WebRTC Project Authors. All rights reserved. 347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * 447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * Use of this source code is governed by a BSD-style license 547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * that can be found in the LICENSE file in the root of the source 647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * tree. An additional intellectual property rights grant can be found 747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * in the file PATENTS. All contributing project authors may 847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org * be found in the AUTHORS file in the root of the source tree. 947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org */ 1047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 1147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#include "webrtc/base/autodetectproxy.h" 1247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#include "webrtc/base/httpcommon.h" 1347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#include "webrtc/base/httpcommon-inl.h" 1447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org#include "webrtc/base/nethelpers.h" 1547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 1647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgnamespace rtc { 1747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 1847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgstatic const ProxyType TEST_ORDER[] = { 1947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org PROXY_HTTPS, PROXY_SOCKS5, PROXY_UNKNOWN 2047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org}; 2147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 2247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgstatic const int kSavedStringLimit = 128; 2347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 2447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgstatic void SaveStringToStack(char *dst, 2547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org const std::string &src, 2647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org size_t dst_size) { 2747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org strncpy(dst, src.c_str(), dst_size - 1); 2847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org dst[dst_size - 1] = '\0'; 2947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 3047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 3147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgAutoDetectProxy::AutoDetectProxy(const std::string& user_agent) 3247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org : agent_(user_agent), resolver_(NULL), socket_(NULL), next_(0) { 3347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 3447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 3547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgAutoDetectProxy::~AutoDetectProxy() { 3647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (resolver_) { 3747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org resolver_->Destroy(false); 3847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 3947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 4047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 4147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid AutoDetectProxy::DoWork() { 4247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // TODO: Try connecting to server_url without proxy first here? 4347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (!server_url_.empty()) { 4447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG(LS_INFO) << "GetProxySettingsForUrl(" << server_url_ << ") - start"; 4547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org GetProxyForUrl(agent_.c_str(), server_url_.c_str(), &proxy_); 4647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG(LS_INFO) << "GetProxySettingsForUrl - stop"; 4747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 4847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Url<char> url(proxy_.address.HostAsURIString()); 4947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (url.valid()) { 5047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG(LS_WARNING) << "AutoDetectProxy removing http prefix on proxy host"; 5147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org proxy_.address.SetIP(url.host()); 5247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 5347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG(LS_INFO) << "AutoDetectProxy found proxy at " << proxy_.address; 5447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (proxy_.type == PROXY_UNKNOWN) { 5547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG(LS_INFO) << "AutoDetectProxy initiating proxy classification"; 5647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Next(); 5747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Process I/O until Stop() 5847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Thread::Current()->ProcessMessages(kForever); 5947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Clean up the autodetect socket, from the thread that created it 6047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org delete socket_; 6147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 6247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // TODO: If we found a proxy, try to use it to verify that it 6347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // works by sending a request to server_url. This could either be 6447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // done here or by the HttpPortAllocator. 6547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 6647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 6747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid AutoDetectProxy::OnMessage(Message *msg) { 6847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (MSG_UNRESOLVABLE == msg->message_id) { 6947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // If we can't resolve the proxy, skip straight to failure. 7047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Complete(PROXY_UNKNOWN); 7147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else if (MSG_TIMEOUT == msg->message_id) { 7247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org OnCloseEvent(socket_, ETIMEDOUT); 7347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else { 7447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // This must be the ST_MSG_WORKER_DONE message that deletes the 7547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // AutoDetectProxy object. We have observed crashes within this stack that 7647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // seem to be highly reproducible for a small subset of users and thus are 7747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // probably correlated with a specific proxy setting, so copy potentially 7847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // relevant information onto the stack to make it available in Windows 7947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // minidumps. 8047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 8147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Save the user agent and the number of auto-detection passes that we 8247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // needed. 8347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org char agent[kSavedStringLimit]; 8447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org SaveStringToStack(agent, agent_, sizeof agent); 8547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 8647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org int next = next_; 8747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 8847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Now the detected proxy config (minus the password field, which could be 8947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // sensitive). 9047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ProxyType type = proxy().type; 9147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 9247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org char address_hostname[kSavedStringLimit]; 9347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org SaveStringToStack(address_hostname, 9447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org proxy().address.hostname(), 9547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org sizeof address_hostname); 9647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 9747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org IPAddress address_ip = proxy().address.ipaddr(); 9847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 9947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org uint16 address_port = proxy().address.port(); 10047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 10147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org char autoconfig_url[kSavedStringLimit]; 10247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org SaveStringToStack(autoconfig_url, 10347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org proxy().autoconfig_url, 10447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org sizeof autoconfig_url); 10547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 10647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org bool autodetect = proxy().autodetect; 10747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 10847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org char bypass_list[kSavedStringLimit]; 10947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org SaveStringToStack(bypass_list, proxy().bypass_list, sizeof bypass_list); 11047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 11147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org char username[kSavedStringLimit]; 11247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org SaveStringToStack(username, proxy().username, sizeof username); 11347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 11447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org SignalThread::OnMessage(msg); 11547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 11647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Log the gathered data at a log level that will never actually be enabled 11747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // so that the compiler is forced to retain the data on the stack. 11847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG(LS_SENSITIVE) << agent << " " << next << " " << type << " " 11947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org << address_hostname << " " << address_ip << " " 12047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org << address_port << " " << autoconfig_url << " " 12147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org << autodetect << " " << bypass_list << " " << username; 12247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 12347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 12447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 12547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid AutoDetectProxy::OnResolveResult(AsyncResolverInterface* resolver) { 12647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (resolver != resolver_) { 12747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 12847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 12947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org int error = resolver_->GetError(); 13047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (error == 0) { 13147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG(LS_VERBOSE) << "Resolved " << proxy_.address << " to " 13247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org << resolver_->address(); 13347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org proxy_.address = resolver_->address(); 13447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (!DoConnect()) { 13547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Thread::Current()->Post(this, MSG_TIMEOUT); 13647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 13747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else { 13847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG(LS_INFO) << "Failed to resolve " << resolver_->address(); 13947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org resolver_->Destroy(false); 14047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org resolver_ = NULL; 14147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org proxy_.address = SocketAddress(); 14247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Thread::Current()->Post(this, MSG_UNRESOLVABLE); 14347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 14447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 14547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 14647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid AutoDetectProxy::Next() { 14747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (TEST_ORDER[next_] >= PROXY_UNKNOWN) { 14847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Complete(PROXY_UNKNOWN); 14947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 15047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 15147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 15247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG(LS_VERBOSE) << "AutoDetectProxy connecting to " 15347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org << proxy_.address.ToSensitiveString(); 15447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 15547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (socket_) { 15647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Thread::Current()->Clear(this, MSG_TIMEOUT); 15747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Thread::Current()->Clear(this, MSG_UNRESOLVABLE); 15847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org socket_->Close(); 15947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Thread::Current()->Dispose(socket_); 16047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org socket_ = NULL; 16147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 16247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org int timeout = 2000; 16347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (proxy_.address.IsUnresolvedIP()) { 16447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org // Launch an asyncresolver. This thread will spin waiting for it. 16547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org timeout += 2000; 16647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (!resolver_) { 16747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org resolver_ = new AsyncResolver(); 16847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 16947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org resolver_->SignalDone.connect(this, &AutoDetectProxy::OnResolveResult); 17047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org resolver_->Start(proxy_.address); 17147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } else { 17247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (!DoConnect()) { 17347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Thread::Current()->Post(this, MSG_TIMEOUT); 17447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 17547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 17647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 17747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Thread::Current()->PostDelayed(timeout, this, MSG_TIMEOUT); 17847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 17947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 18047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgbool AutoDetectProxy::DoConnect() { 18147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (resolver_) { 18247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org resolver_->Destroy(false); 18347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org resolver_ = NULL; 18447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 18547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org socket_ = 18647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Thread::Current()->socketserver()->CreateAsyncSocket( 18747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org proxy_.address.family(), SOCK_STREAM); 18847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (!socket_) { 18947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG(LS_VERBOSE) << "Unable to create socket for " << proxy_.address; 19047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return false; 19147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 19247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org socket_->SignalConnectEvent.connect(this, &AutoDetectProxy::OnConnectEvent); 19347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org socket_->SignalReadEvent.connect(this, &AutoDetectProxy::OnReadEvent); 19447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org socket_->SignalCloseEvent.connect(this, &AutoDetectProxy::OnCloseEvent); 19547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org socket_->Connect(proxy_.address); 19647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return true; 19747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 19847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 19947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid AutoDetectProxy::Complete(ProxyType type) { 20047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Thread::Current()->Clear(this, MSG_TIMEOUT); 20147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Thread::Current()->Clear(this, MSG_UNRESOLVABLE); 20247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (socket_) { 20347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org socket_->Close(); 20447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 20547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 20647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org proxy_.type = type; 20747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LoggingSeverity sev = (proxy_.type == PROXY_UNKNOWN) ? LS_ERROR : LS_INFO; 20847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG_V(sev) << "AutoDetectProxy detected " 20947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org << proxy_.address.ToSensitiveString() 21047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org << " as type " << proxy_.type; 21147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 21247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Thread::Current()->Quit(); 21347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 21447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 21547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid AutoDetectProxy::OnConnectEvent(AsyncSocket * socket) { 21647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org std::string probe; 21747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 21847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org switch (TEST_ORDER[next_]) { 21947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case PROXY_HTTPS: 22047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org probe.assign("CONNECT www.google.com:443 HTTP/1.0\r\n" 22147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org "User-Agent: "); 22247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org probe.append(agent_); 22347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org probe.append("\r\n" 22447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org "Host: www.google.com\r\n" 22547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org "Content-Length: 0\r\n" 22647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org "Proxy-Connection: Keep-Alive\r\n" 22747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org "\r\n"); 22847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org break; 22947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case PROXY_SOCKS5: 23047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org probe.assign("\005\001\000", 3); 23147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org break; 23247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org default: 23347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(false); 23447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 23547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 23647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 23747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG(LS_VERBOSE) << "AutoDetectProxy probing type " << TEST_ORDER[next_] 23847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org << " sending " << probe.size() << " bytes"; 23947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org socket_->Send(probe.data(), probe.size()); 24047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 24147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 24247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid AutoDetectProxy::OnReadEvent(AsyncSocket * socket) { 24347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org char data[257]; 24447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org int len = socket_->Recv(data, 256); 24547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if (len > 0) { 24647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org data[len] = 0; 24747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG(LS_VERBOSE) << "AutoDetectProxy read " << len << " bytes"; 24847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 24947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 25047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org switch (TEST_ORDER[next_]) { 25147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case PROXY_HTTPS: 25247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if ((len >= 2) && (data[0] == '\x05')) { 25347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Complete(PROXY_SOCKS5); 25447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 25547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 25647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if ((len >= 5) && (strncmp(data, "HTTP/", 5) == 0)) { 25747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Complete(PROXY_HTTPS); 25847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 25947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 26047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org break; 26147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org case PROXY_SOCKS5: 26247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org if ((len >= 2) && (data[0] == '\x05')) { 26347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Complete(PROXY_SOCKS5); 26447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 26547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 26647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org break; 26747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org default: 26847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ASSERT(false); 26947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org return; 27047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org } 27147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 27247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ++next_; 27347be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Next(); 27447be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 27547be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 27647be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.orgvoid AutoDetectProxy::OnCloseEvent(AsyncSocket * socket, int error) { 27747be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org LOG(LS_VERBOSE) << "AutoDetectProxy closed with error: " << error; 27847be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org ++next_; 27947be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org Next(); 28047be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} 28147be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org 28247be73b8629244d6bb63a28198f97f040ce53d21henrike@webrtc.org} // namespace rtc 283