| Index: webrtc/api/quicdatachannel.h
|
| diff --git a/webrtc/api/quicdatachannel.h b/webrtc/api/quicdatachannel.h
|
| index a6b987b144dd453766c0580b0da7e0f2e0d8b173..18a10acbdf66364f8caf21691e193e0e2cbb9802 100644
|
| --- a/webrtc/api/quicdatachannel.h
|
| +++ b/webrtc/api/quicdatachannel.h
|
| @@ -88,6 +88,7 @@ class QuicDataChannel : public rtc::RefCountedObject<DataChannelInterface>,
|
|
|
| QuicDataChannel(rtc::Thread* signaling_thread,
|
| rtc::Thread* worker_thread,
|
| + rtc::Thread* network_thread,
|
| const std::string& label,
|
| const DataChannelInit& config);
|
| ~QuicDataChannel() override;
|
| @@ -155,11 +156,13 @@ class QuicDataChannel : public rtc::RefCountedObject<DataChannelInterface>,
|
| void OnReadyToSend(cricket::TransportChannel* channel);
|
| void OnConnectionClosed();
|
|
|
| - // Worker thread methods.
|
| + // Network thread methods.
|
| // Sends the data buffer to the remote peer using an outgoing QUIC stream.
|
| // Returns true if the data buffer can be successfully sent, or if it is
|
| // queued to be sent later.
|
| - bool Send_w(const DataBuffer& buffer);
|
| + bool Send_n(const DataBuffer& buffer);
|
| +
|
| + // Worker thread methods.
|
| // Connects the |quic_transport_channel_| signals to this QuicDataChannel,
|
| // then returns the new QuicDataChannel state.
|
| DataState SetTransportChannel_w();
|
| @@ -185,8 +188,10 @@ class QuicDataChannel : public rtc::RefCountedObject<DataChannelInterface>,
|
| cricket::QuicTransportChannel* quic_transport_channel_ = nullptr;
|
| // Signaling thread for DataChannelInterface methods.
|
| rtc::Thread* const signaling_thread_;
|
| - // Worker thread for sending data and |quic_transport_channel_| callbacks.
|
| + // Worker thread for |quic_transport_channel_| callbacks.
|
| rtc::Thread* const worker_thread_;
|
| + // Network thread for sending data and |quic_transport_channel_| callbacks.
|
| + rtc::Thread* const network_thread_;
|
| rtc::AsyncInvoker invoker_;
|
| // Map of QUIC stream ID => ReliableQuicStream* for write blocked QUIC
|
| // streams.
|
|
|