| Index: webrtc/p2p/quic/quictransportchannel.cc
|
| diff --git a/webrtc/p2p/quic/quictransportchannel.cc b/webrtc/p2p/quic/quictransportchannel.cc
|
| index cc0576ddb239a50bea2fbadc8cd541e3a6eb33aa..446fd4201cc8de964513b4435d7b0b4605c46f7a 100644
|
| --- a/webrtc/p2p/quic/quictransportchannel.cc
|
| +++ b/webrtc/p2p/quic/quictransportchannel.cc
|
| @@ -443,6 +443,8 @@ bool QuicTransportChannel::CreateQuicSession() {
|
| this, &QuicTransportChannel::OnHandshakeComplete);
|
| quic_->SignalConnectionClosed.connect(
|
| this, &QuicTransportChannel::OnConnectionClosed);
|
| + quic_->SignalIncomingStream.connect(this,
|
| + &QuicTransportChannel::OnIncomingStream);
|
| return true;
|
| }
|
|
|
| @@ -541,6 +543,7 @@ void QuicTransportChannel::OnConnectionClosed(net::QuicErrorCode error,
|
| // does not close due to failure.
|
| set_quic_state(QUIC_TRANSPORT_CLOSED);
|
| set_writable(false);
|
| + SignalClosed();
|
| }
|
|
|
| void QuicTransportChannel::OnProofValid(
|
| @@ -569,4 +572,16 @@ void QuicTransportChannel::set_quic_state(QuicTransportState state) {
|
| quic_state_ = state;
|
| }
|
|
|
| +ReliableQuicStream* QuicTransportChannel::CreateQuicStream() {
|
| + if (quic_) {
|
| + net::SpdyPriority priority = 0; // Priority of the QUIC stream (not used)
|
| + return quic_->CreateOutgoingDynamicStream(priority);
|
| + }
|
| + return nullptr;
|
| +}
|
| +
|
| +void QuicTransportChannel::OnIncomingStream(ReliableQuicStream* stream) {
|
| + SignalIncomingStream(stream);
|
| +}
|
| +
|
| } // namespace cricket
|
|
|