Lines Matching refs:ch
218 CandidateData(cricket::TransportChannel* ch, const cricket::Candidate& c)
219 : channel(ch), candidate(c) {
231 bool HasChannel(cricket::TransportChannel* ch) {
232 return (ch == cd1_.ch_.get() || ch == cd2_.ch_.get());
234 ChannelData* GetChannelData(cricket::TransportChannel* ch) {
235 if (!HasChannel(ch)) return NULL;
236 if (cd1_.ch_.get() == ch)
639 void OnCandidate(cricket::TransportChannelImpl* ch,
644 if (GetEndpoint(ch)->save_candidates_) {
645 GetEndpoint(ch)->saved_candidates_.push_back(new CandidateData(ch, c));
647 main_->Post(this, MSG_CANDIDATE, new CandidateData(ch, c));
721 cricket::P2PTransportChannel* ch) {
722 return (ch && ch->best_connection()) ?
723 &ch->best_connection()->local_candidate() : NULL;
726 cricket::P2PTransportChannel* ch) {
727 return (ch && ch->best_connection()) ?
728 &ch->best_connection()->remote_candidate() : NULL;
730 Endpoint* GetEndpoint(cricket::TransportChannel* ch) {
731 if (ep1_.HasChannel(ch)) {
733 } else if (ep2_.HasChannel(ch)) {
740 cricket::TransportChannel* ch) {
741 if (ch == ep1_ch1())
743 else if (ch == ep1_ch2())
745 else if (ch == ep2_ch1())
747 else if (ch == ep2_ch2())
752 std::list<std::string>& GetPacketList(cricket::TransportChannel* ch) {
753 return GetChannelData(ch)->ch_packets_;
1762 void PrepareChannel(cricket::P2PTransportChannel* ch) {
1763 ch->SetIceRole(cricket::ICEROLE_CONTROLLING);
1764 ch->SetIceCredentials(kIceUfrag[0], kIcePwd[0]);
1765 ch->SetRemoteIceCredentials(kIceUfrag[1], kIcePwd[1]);
1781 cricket::Connection* WaitForConnectionTo(cricket::P2PTransportChannel* ch,
1784 EXPECT_TRUE_WAIT(GetConnectionTo(ch, ip, port_num) != nullptr, 3000);
1785 return GetConnectionTo(ch, ip, port_num);
1788 cricket::Port* GetPort(cricket::P2PTransportChannel* ch) {
1789 if (ch->ports().empty()) {
1792 return static_cast<cricket::Port*>(ch->ports()[0]);
1795 cricket::Connection* GetConnectionTo(cricket::P2PTransportChannel* ch,
1798 cricket::Port* port = GetPort(ch);
1813 cricket::P2PTransportChannel ch("trigger checks", 1, nullptr, &pa);
1814 PrepareChannel(&ch);
1815 ch.Connect();
1816 ch.MaybeStartGathering();
1817 ch.AddRemoteCandidate(CreateCandidate("1.1.1.1", 1, 1));
1818 ch.AddRemoteCandidate(CreateCandidate("2.2.2.2", 2, 2));
1820 cricket::Connection* conn1 = WaitForConnectionTo(&ch, "1.1.1.1", 1);
1821 cricket::Connection* conn2 = WaitForConnectionTo(&ch, "2.2.2.2", 2);
1827 EXPECT_EQ(conn2, ch.FindNextPingableConnection());
1833 EXPECT_EQ(conn1, ch.FindNextPingableConnection());
1838 cricket::P2PTransportChannel ch("trigger checks", 1, nullptr, &pa);
1839 PrepareChannel(&ch);
1840 ch.Connect();
1841 ch.MaybeStartGathering();
1842 ch.AddRemoteCandidate(CreateCandidate("1.1.1.1", 1, 1));
1843 ch.AddRemoteCandidate(CreateCandidate("2.2.2.2", 2, 2));
1845 cricket::Connection* conn1 = WaitForConnectionTo(&ch, "1.1.1.1", 1);
1846 cricket::Connection* conn2 = WaitForConnectionTo(&ch, "2.2.2.2", 2);
1850 EXPECT_EQ(conn2, ch.FindNextPingableConnection());
1858 EXPECT_EQ(conn2, ch.FindNextPingableConnection());
1869 cricket::P2PTransportChannel ch("add candidate", 1, nullptr, &pa);
1870 PrepareChannel(&ch);
1871 ch.Connect();
1872 ch.MaybeStartGathering();
1874 ch.AddRemoteCandidate(CreateCandidate("1.1.1.1", 1, 1, kIceUfrag[2]));
1875 cricket::Connection* conn1 = WaitForConnectionTo(&ch, "1.1.1.1", 1);
1880 EXPECT_TRUE(ch.FindNextPingableConnection() == nullptr);
1885 ch.SetRemoteIceCredentials(kIceUfrag[2], kIcePwd[2]);
1888 EXPECT_EQ(conn1, ch.FindNextPingableConnection());
1891 ch.AddRemoteCandidate(CreateCandidate("2.2.2.2", 2, 2, kIceUfrag[1]));
1893 EXPECT_TRUE(GetConnectionTo(&ch, "2.2.2.2", 2) == nullptr);
1897 ch.AddRemoteCandidate(CreateCandidate("3.3.3.3", 3, 0, kIceUfrag[2]));
1899 ASSERT_TRUE_WAIT((conn3 = GetConnectionTo(&ch, "3.3.3.3", 3)) != nullptr,
1906 for (const cricket::RemoteCandidate& candidate : ch.remote_candidates()) {
1919 cricket::P2PTransportChannel ch("connection resurrection", 1, nullptr, &pa);
1920 PrepareChannel(&ch);
1921 ch.Connect();
1922 ch.MaybeStartGathering();
1925 ch.AddRemoteCandidate(CreateCandidate("1.1.1.1", 1, 1));
1926 cricket::Connection* conn1 = WaitForConnectionTo(&ch, "1.1.1.1", 1);
1932 ch.AddRemoteCandidate(CreateCandidate("2.2.2.2", 2, 2));
1933 cricket::Connection* conn2 = WaitForConnectionTo(&ch, "2.2.2.2", 2);
1942 EXPECT_TRUE_WAIT(GetConnectionTo(&ch, "1.1.1.1", 1) == nullptr, 1000);
1954 cricket::Port* port = GetPort(&ch);
1958 conn1 = WaitForConnectionTo(&ch, "1.1.1.1", 1);
1965 cricket::Connection* conn3 = WaitForConnectionTo(&ch, "3.3.3.3", 1);
1972 cricket::P2PTransportChannel ch("receiving state change", 1, nullptr, &pa);
1973 PrepareChannel(&ch);
1976 EXPECT_LE(1000, ch.receiving_timeout());
1977 EXPECT_LE(200, ch.check_receiving_delay());
1978 ch.SetIceConfig(CreateIceConfig(500, false));
1979 EXPECT_EQ(500, ch.receiving_timeout());
1980 EXPECT_EQ(50, ch.check_receiving_delay());
1981 ch.Connect();
1982 ch.MaybeStartGathering();
1983 ch.AddRemoteCandidate(CreateCandidate("1.1.1.1", 1, 1));
1984 cricket::Connection* conn1 = WaitForConnectionTo(&ch, "1.1.1.1", 1);
1989 EXPECT_TRUE_WAIT(ch.best_connection() != nullptr, 1000);
1990 EXPECT_TRUE_WAIT(ch.receiving(), 1000);
1991 EXPECT_TRUE_WAIT(!ch.receiving(), 1000);
2000 cricket::P2PTransportChannel ch("receiving state change", 1, nullptr, &pa);
2001 PrepareChannel(&ch);
2002 ch.SetIceRole(cricket::ICEROLE_CONTROLLED);
2003 ch.Connect();
2004 ch.MaybeStartGathering();
2005 ch.AddRemoteCandidate(CreateCandidate("1.1.1.1", 1, 1));
2006 cricket::Connection* conn1 = WaitForConnectionTo(&ch, "1.1.1.1", 1);
2008 EXPECT_EQ(conn1, ch.best_connection());
2012 ch.AddRemoteCandidate(CreateCandidate("2.2.2.2", 2, 10));
2013 cricket::Connection* conn2 = WaitForConnectionTo(&ch, "2.2.2.2", 2);
2015 EXPECT_EQ(conn2, ch.best_connection());
2020 ch.AddRemoteCandidate(CreateCandidate("3.3.3.3", 3, 1));
2021 cricket::Connection* conn3 = WaitForConnectionTo(&ch, "3.3.3.3", 3);
2024 EXPECT_EQ(conn2, ch.best_connection());
2030 EXPECT_EQ(conn3, ch.best_connection());
2035 ch.AddRemoteCandidate(CreateCandidate("4.4.4.4", 4, 100));
2036 cricket::Connection* conn4 = WaitForConnectionTo(&ch, "4.4.4.4", 4);
2038 EXPECT_EQ(conn3, ch.best_connection());
2044 EXPECT_EQ(conn3, ch.best_connection());
2047 EXPECT_EQ(conn4, ch.best_connection());
2057 cricket::P2PTransportChannel ch("receiving state change", 1, nullptr, &pa);
2058 PrepareChannel(&ch);
2059 ch.SetIceRole(cricket::ICEROLE_CONTROLLED);
2060 ch.Connect();
2061 ch.MaybeStartGathering();
2070 cricket::TestUDPPort* port = static_cast<cricket::TestUDPPort*>(GetPort(&ch));
2073 cricket::Connection* conn1 = WaitForConnectionTo(&ch, "1.1.1.1", 1);
2076 EXPECT_EQ(conn1, ch.best_connection());
2078 EXPECT_EQ(conn1, ch.best_connection());
2082 ch.AddRemoteCandidate(CreateCandidate("2.2.2.2", 2, 1));
2083 cricket::Connection* conn2 = WaitForConnectionTo(&ch, "2.2.2.2", 2);
2086 EXPECT_EQ(conn1, ch.best_connection());
2092 EXPECT_EQ(conn2, ch.best_connection());
2099 cricket::Connection* conn3 = WaitForConnectionTo(&ch, "3.3.3.3", 3);
2103 EXPECT_EQ(conn2, ch.best_connection());
2112 cricket::Connection* conn4 = WaitForConnectionTo(&ch, "4.4.4.4", 4);
2116 EXPECT_EQ(conn2, ch.best_connection());
2118 EXPECT_EQ(conn4, ch.best_connection());
2123 ch.SetRemoteIceCredentials(kIceUfrag[2], kIcePwd[2]);
2124 ch.SetRemoteIceCredentials(kIceUfrag[3], kIcePwd[3]);
2127 cricket::Connection* conn5 = WaitForConnectionTo(&ch, "5.5.5.5", 5);
2139 cricket::P2PTransportChannel ch("receiving state change", 1, nullptr, &pa);
2140 PrepareChannel(&ch);
2141 ch.SetIceRole(cricket::ICEROLE_CONTROLLED);
2142 ch.Connect();
2143 ch.MaybeStartGathering();
2144 ch.AddRemoteCandidate(CreateCandidate("1.1.1.1", 1, 10));
2145 cricket::Connection* conn1 = WaitForConnectionTo(&ch, "1.1.1.1", 1);
2147 EXPECT_EQ(conn1, ch.best_connection());
2152 ch.AddRemoteCandidate(CreateCandidate("2.2.2.2", 2, 1));
2153 cricket::Connection* conn2 = WaitForConnectionTo(&ch, "2.2.2.2", 2);
2158 EXPECT_EQ(conn1, ch.best_connection());
2163 EXPECT_EQ(conn2, ch.best_connection());
2176 cricket::Port* port = GetPort(&ch);
2179 cricket::Connection* conn3 = WaitForConnectionTo(&ch, "3.3.3.3", 3);
2181 EXPECT_EQ(conn2, ch.best_connection()); // Not writable yet.
2183 EXPECT_EQ(conn3, ch.best_connection());
2190 EXPECT_EQ(conn3, ch.best_connection());
2197 cricket::P2PTransportChannel ch("test channel", 1, nullptr, &pa);
2198 PrepareChannel(&ch);
2199 ch.SetIceRole(cricket::ICEROLE_CONTROLLED);
2200 ch.Connect();
2201 ch.MaybeStartGathering();
2202 ch.AddRemoteCandidate(CreateCandidate("1.1.1.1", 1, 1));
2203 cricket::Connection* conn1 = WaitForConnectionTo(&ch, "1.1.1.1", 1);
2205 EXPECT_EQ(conn1, ch.best_connection());
2210 ch.AddRemoteCandidate(CreateCandidate("2.2.2.2", 2, 10));
2211 cricket::Connection* conn2 = WaitForConnectionTo(&ch, "2.2.2.2", 2);
2218 ch.SetIceConfig(CreateIceConfig(500, false));
2222 ch.AddRemoteCandidate(CreateCandidate("3.3.3.3", 3, 1));
2223 cricket::Connection* conn3 = WaitForConnectionTo(&ch, "3.3.3.3", 3);
2235 cricket::P2PTransportChannel ch("test channel", 1, nullptr, &pa);
2236 PrepareChannel(&ch);
2237 ch.Connect();
2238 ch.MaybeStartGathering();
2239 EXPECT_EQ(cricket::TransportChannelState::STATE_INIT, ch.GetState());
2240 ch.AddRemoteCandidate(CreateCandidate("1.1.1.1", 1, 100));
2241 ch.AddRemoteCandidate(CreateCandidate("2.2.2.2", 2, 1));
2242 cricket::Connection* conn1 = WaitForConnectionTo(&ch, "1.1.1.1", 1);
2243 cricket::Connection* conn2 = WaitForConnectionTo(&ch, "2.2.2.2", 2);
2247 EXPECT_EQ(cricket::TransportChannelState::STATE_CONNECTING, ch.GetState());
2251 EXPECT_EQ(cricket::TransportChannelState::STATE_COMPLETED, ch.GetState());
2254 EXPECT_EQ_WAIT(cricket::TransportChannelState::STATE_FAILED, ch.GetState(),
2262 cricket::P2PTransportChannel ch("test channel", 1, nullptr, &pa);
2263 PrepareChannel(&ch);
2264 ch.SetIceConfig(CreateIceConfig(1000, false));
2265 ch.Connect();
2266 ch.MaybeStartGathering();
2267 ch.AddRemoteCandidate(CreateCandidate("1.1.1.1", 1, 100));
2268 cricket::Connection* conn1 = WaitForConnectionTo(&ch, "1.1.1.1", 1);
2270 EXPECT_EQ(conn1, ch.best_connection());
2277 ch.AddRemoteCandidate(CreateCandidate("2.2.2.2", 2, 1));
2278 cricket::Connection* conn2 = WaitForConnectionTo(&ch, "2.2.2.2", 2);
2283 EXPECT_EQ(cricket::TransportChannelState::STATE_COMPLETED, ch.GetState());
2287 conn2 = WaitForConnectionTo(&ch, "2.2.2.2", 2);
2291 EXPECT_EQ_WAIT(conn2, ch.best_connection(), 1000);
2292 EXPECT_EQ(cricket::TransportChannelState::STATE_CONNECTING, ch.GetState());
2296 EXPECT_EQ_WAIT(conn1, ch.best_connection(), 1000);
2298 EXPECT_EQ(cricket::TransportChannelState::STATE_COMPLETED, ch.GetState());
2305 cricket::P2PTransportChannel ch("test channel", 1, nullptr, &pa);
2306 PrepareChannel(&ch);
2307 ch.Connect();
2308 ch.MaybeStartGathering();
2310 ch.AddRemoteCandidate(CreateCandidate("1.1.1.1", 1, 100));
2311 cricket::Connection* conn1 = WaitForConnectionTo(&ch, "1.1.1.1", 1);
2315 EXPECT_TRUE_WAIT(ch.connections().empty(), 1000);
2318 ch.AddRemoteCandidate(CreateCandidate("2.2.2.2", 2, 1));
2319 cricket::Connection* conn2 = WaitForConnectionTo(&ch, "2.2.2.2", 2);
2322 ch.AddRemoteCandidate(CreateCandidate("3.3.3.3", 3, 2));
2323 cricket::Connection* conn3 = WaitForConnectionTo(&ch, "3.3.3.3", 3);
2329 EXPECT_TRUE_WAIT(ch.connections().empty(), 1000);
2337 cricket::P2PTransportChannel ch("test channel", 1, nullptr, &pa);
2338 PrepareChannel(&ch);
2339 ch.SetIceConfig(CreateIceConfig(2000, false));
2340 ch.Connect();
2341 ch.MaybeStartGathering();
2342 ch.AddRemoteCandidate(CreateCandidate("1.1.1.1", 1, 100));
2343 cricket::Connection* conn1 = WaitForConnectionTo(&ch, "1.1.1.1", 1);
2346 EXPECT_TRUE(!ch.allocator_session()->IsGettingPorts());
2351 ch.SetIceCredentials(kIceUfrag[1], kIcePwd[1]);
2352 ch.MaybeStartGathering();
2353 ch.AddRemoteCandidate(CreateCandidate("2.2.2.2", 2, 100));
2354 cricket::Connection* conn2 = WaitForConnectionTo(&ch, "2.2.2.2", 2);
2357 EXPECT_TRUE(!ch.allocator_session()->IsGettingPorts());
