15976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org/* 25976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * libjingle 35976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * Copyright 2004--2008, Google Inc. 45976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * 55976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * Redistribution and use in source and binary forms, with or without 65976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * modification, are permitted provided that the following conditions are met: 75976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * 85976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * 1. Redistributions of source code must retain the above copyright notice, 95976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * this list of conditions and the following disclaimer. 105976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * 2. Redistributions in binary form must reproduce the above copyright notice, 115976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * this list of conditions and the following disclaimer in the documentation 125976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * and/or other materials provided with the distribution. 135976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * 3. The name of the author may not be used to endorse or promote products 145976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * derived from this software without specific prior written permission. 155976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * 165976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED 175976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF 185976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO 195976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 205976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 215976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; 225976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 235976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR 245976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF 255976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 265976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org */ 275976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 285976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#ifndef TALK_P2P_CLIENT_HTTPPORTALLOCATOR_H_ 295976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#define TALK_P2P_CLIENT_HTTPPORTALLOCATOR_H_ 305976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 315976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include <list> 325976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include <string> 335976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include <vector> 345976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 355976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#include "talk/p2p/client/basicportallocator.h" 365976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 375976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgclass HttpPortAllocatorTest_TestSessionRequestUrl_Test; 385976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 395976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgnamespace talk_base { 405976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgclass AsyncHttpRequest; 415976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgclass SignalThread; 425976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} 435976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 445976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgnamespace cricket { 455976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 465976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgclass HttpPortAllocatorBase : public BasicPortAllocator { 475976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org public: 485976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // The number of HTTP requests we should attempt before giving up. 495976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org static const int kNumRetries; 505976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 515976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Records the URL that we will GET in order to create a session. 525976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org static const char kCreateSessionURL[]; 535976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 545976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpPortAllocatorBase(talk_base::NetworkManager* network_manager, 555976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& user_agent); 565976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpPortAllocatorBase(talk_base::NetworkManager* network_manager, 575976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::PacketSocketFactory* socket_factory, 585976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& user_agent); 595976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org virtual ~HttpPortAllocatorBase(); 605976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 615976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // CreateSession is defined in BasicPortAllocator but is 625976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // redefined here as pure virtual. 635976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org virtual PortAllocatorSession* CreateSessionInternal( 645976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& content_name, 655976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org int component, 665976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& ice_ufrag, 675976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& ice_pwd) = 0; 685976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 695976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org void SetStunHosts(const std::vector<talk_base::SocketAddress>& hosts) { 705976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!hosts.empty()) { 715976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org stun_hosts_ = hosts; 725976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 735976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 745976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org void SetRelayHosts(const std::vector<std::string>& hosts) { 755976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org if (!hosts.empty()) { 765976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org relay_hosts_ = hosts; 775976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 785976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 795976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org void SetRelayToken(const std::string& relay) { relay_token_ = relay; } 805976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 815976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::vector<talk_base::SocketAddress>& stun_hosts() const { 825976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return stun_hosts_; 835976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 845976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 855976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::vector<std::string>& relay_hosts() const { 865976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return relay_hosts_; 875976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 885976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 895976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& relay_token() const { 905976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return relay_token_; 915976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 925976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 935976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& user_agent() const { 945976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return agent_; 955976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 965976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 975976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org private: 985976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::vector<talk_base::SocketAddress> stun_hosts_; 995976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::vector<std::string> relay_hosts_; 1005976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string relay_token_; 1015976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string agent_; 1025976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org}; 1035976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1045976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgclass RequestData; 1055976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1065976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgclass HttpPortAllocatorSessionBase : public BasicPortAllocatorSession { 1075976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org public: 1085976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpPortAllocatorSessionBase( 1095976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpPortAllocatorBase* allocator, 1105976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& content_name, 1115976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org int component, 1125976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& ice_ufrag, 1135976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& ice_pwd, 1145976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::vector<talk_base::SocketAddress>& stun_hosts, 1155976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::vector<std::string>& relay_hosts, 1165976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& relay, 1175976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& agent); 1185976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org virtual ~HttpPortAllocatorSessionBase(); 1195976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1205976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& relay_token() const { 1215976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return relay_token_; 1225976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 1235976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1245976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& user_agent() const { 1255976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return agent_; 1265976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 1275976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1285976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org virtual void SendSessionRequest(const std::string& host, int port) = 0; 1295976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org virtual void ReceiveSessionResponse(const std::string& response); 1305976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 131204b178db6a965bcdee700f384174d4303e8e9d8stefan@webrtc.org // Made public for testing. Should be protected. 132204b178db6a965bcdee700f384174d4303e8e9d8stefan@webrtc.org std::string GetSessionRequestUrl(); 133204b178db6a965bcdee700f384174d4303e8e9d8stefan@webrtc.org 1345976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org protected: 1355976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org virtual void GetPortConfigurations(); 1365976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org void TryCreateRelaySession(); 1375976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org virtual HttpPortAllocatorBase* allocator() { 1385976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org return static_cast<HttpPortAllocatorBase*>( 1395976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org BasicPortAllocatorSession::allocator()); 1405976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org } 1415976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1425976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org private: 1435976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::vector<std::string> relay_hosts_; 1445976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::vector<talk_base::SocketAddress> stun_hosts_; 1455976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string relay_token_; 1465976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::string agent_; 1475976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org int attempts_; 1485976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org}; 1495976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1505976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgclass HttpPortAllocator : public HttpPortAllocatorBase { 1515976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org public: 1525976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpPortAllocator(talk_base::NetworkManager* network_manager, 1535976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& user_agent); 1545976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpPortAllocator(talk_base::NetworkManager* network_manager, 1555976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org talk_base::PacketSocketFactory* socket_factory, 1565976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& user_agent); 1575976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org virtual ~HttpPortAllocator(); 1585976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org virtual PortAllocatorSession* CreateSessionInternal( 1595976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& content_name, 1605976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org int component, 1615976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& ice_ufrag, const std::string& ice_pwd); 1625976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org}; 1635976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1645976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.orgclass HttpPortAllocatorSession : public HttpPortAllocatorSessionBase { 1655976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org public: 1665976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpPortAllocatorSession( 1675976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org HttpPortAllocator* allocator, 1685976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& content_name, 1695976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org int component, 1705976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& ice_ufrag, 1715976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& ice_pwd, 1725976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::vector<talk_base::SocketAddress>& stun_hosts, 1735976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::vector<std::string>& relay_hosts, 1745976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& relay, 1755976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org const std::string& agent); 1765976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org virtual ~HttpPortAllocatorSession(); 1775976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1785976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org virtual void SendSessionRequest(const std::string& host, int port); 1795976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1805976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org protected: 1815976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org // Protected for diagnostics. 1825976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org virtual void OnRequestDone(talk_base::SignalThread* request); 1835976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1845976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org private: 1855976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org std::list<talk_base::AsyncHttpRequest*> requests_; 1865976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org}; 1875976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1885976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org} // namespace cricket 1895976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org 1905976650443d68ccfadf1dea24999ee459dd2819mflodman@webrtc.org#endif // TALK_P2P_CLIENT_HTTPPORTALLOCATOR_H_ 191