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 |