OLD | NEW |
---|---|
1 /* | 1 /* |
2 * libjingle | 2 * libjingle |
3 * Copyright 2012 Google Inc. | 3 * Copyright 2012 Google Inc. |
4 * | 4 * |
5 * Redistribution and use in source and binary forms, with or without | 5 * Redistribution and use in source and binary forms, with or without |
6 * modification, are permitted provided that the following conditions are met: | 6 * modification, are permitted provided that the following conditions are met: |
7 * | 7 * |
8 * 1. Redistributions of source code must retain the above copyright notice, | 8 * 1. Redistributions of source code must retain the above copyright notice, |
9 * this list of conditions and the following disclaimer. | 9 * this list of conditions and the following disclaimer. |
10 * 2. Redistributions in binary form must reproduce the above copyright notice, | 10 * 2. Redistributions in binary form must reproduce the above copyright notice, |
(...skipping 1414 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
1425 void WebRtcSession::SetIceConnectionReceiving(bool receiving) { | 1425 void WebRtcSession::SetIceConnectionReceiving(bool receiving) { |
1426 if (ice_connection_receiving_ == receiving) { | 1426 if (ice_connection_receiving_ == receiving) { |
1427 return; | 1427 return; |
1428 } | 1428 } |
1429 ice_connection_receiving_ = receiving; | 1429 ice_connection_receiving_ = receiving; |
1430 if (ice_observer_) { | 1430 if (ice_observer_) { |
1431 ice_observer_->OnIceConnectionReceivingChange(receiving); | 1431 ice_observer_->OnIceConnectionReceivingChange(receiving); |
1432 } | 1432 } |
1433 } | 1433 } |
1434 | 1434 |
1435 void WebRtcSession::SetIceConnectionReceivingTimeout(int timeout_ms) { | |
1436 for (const auto& kv : transport_proxies()) { | |
1437 cricket::Transport* transport = kv.second->impl(); | |
1438 if (transport && transport->HasChannels()) { | |
1439 transport->SetChannelReceivingTimeout(timeout_ms); | |
pthatcher1
2015/07/09 22:21:41
We should pass down the value to each Transport ev
honghaiz3
2015/08/05 23:57:39
Done.
| |
1440 } | |
1441 } | |
pthatcher1
2015/07/09 22:21:41
I think we need to store the value and then apply
honghaiz3
2015/08/05 23:57:39
Done.
| |
1442 } | |
1443 | |
1444 | |
1435 void WebRtcSession::OnTransportProxyCandidatesReady( | 1445 void WebRtcSession::OnTransportProxyCandidatesReady( |
1436 cricket::TransportProxy* proxy, const cricket::Candidates& candidates) { | 1446 cricket::TransportProxy* proxy, const cricket::Candidates& candidates) { |
1437 ASSERT(signaling_thread()->IsCurrent()); | 1447 ASSERT(signaling_thread()->IsCurrent()); |
1438 ProcessNewLocalCandidate(proxy->content_name(), candidates); | 1448 ProcessNewLocalCandidate(proxy->content_name(), candidates); |
1439 } | 1449 } |
1440 | 1450 |
1441 void WebRtcSession::OnCandidatesAllocationDone() { | 1451 void WebRtcSession::OnCandidatesAllocationDone() { |
1442 ASSERT(signaling_thread()->IsCurrent()); | 1452 ASSERT(signaling_thread()->IsCurrent()); |
1443 if (ice_observer_) { | 1453 if (ice_observer_) { |
1444 ice_observer_->OnIceGatheringChange( | 1454 ice_observer_->OnIceGatheringChange( |
(...skipping 514 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
1959 | 1969 |
1960 if (!srtp_cipher.empty()) { | 1970 if (!srtp_cipher.empty()) { |
1961 metrics_observer_->AddHistogramSample(srtp_name, srtp_cipher); | 1971 metrics_observer_->AddHistogramSample(srtp_name, srtp_cipher); |
1962 } | 1972 } |
1963 if (!ssl_cipher.empty()) { | 1973 if (!ssl_cipher.empty()) { |
1964 metrics_observer_->AddHistogramSample(ssl_name, ssl_cipher); | 1974 metrics_observer_->AddHistogramSample(ssl_name, ssl_cipher); |
1965 } | 1975 } |
1966 } | 1976 } |
1967 | 1977 |
1968 } // namespace webrtc | 1978 } // namespace webrtc |
OLD | NEW |