| Index: net/quic/chromium/bidirectional_stream_quic_impl.cc
|
| diff --git a/net/quic/chromium/bidirectional_stream_quic_impl.cc b/net/quic/chromium/bidirectional_stream_quic_impl.cc
|
| index 8a714f0725ed11d38ae94594f92fda8a8c7ae952..c3864fce8561b7ad838f3baef728c3a58ca391ac 100644
|
| --- a/net/quic/chromium/bidirectional_stream_quic_impl.cc
|
| +++ b/net/quic/chromium/bidirectional_stream_quic_impl.cc
|
| @@ -266,27 +266,29 @@ void BidirectionalStreamQuicImpl::OnError(int error) {
|
| void BidirectionalStreamQuicImpl::OnStreamReady(int rv) {
|
| DCHECK_NE(ERR_IO_PENDING, rv);
|
| DCHECK(rv == OK || !stream_);
|
| - if (rv == OK) {
|
| - stream_ = session_->ReleaseStream(this);
|
| -
|
| - base::ThreadTaskRunnerHandle::Get()->PostTask(
|
| - FROM_HERE, base::Bind(&BidirectionalStreamQuicImpl::ReadInitialHeaders,
|
| - weak_factory_.GetWeakPtr()));
|
| -
|
| - NotifyStreamReady();
|
| - } else {
|
| + if (rv != OK) {
|
| NotifyError(rv);
|
| + return;
|
| }
|
| +
|
| + stream_ = session_->ReleaseStream(this);
|
| +
|
| + base::ThreadTaskRunnerHandle::Get()->PostTask(
|
| + FROM_HERE, base::Bind(&BidirectionalStreamQuicImpl::ReadInitialHeaders,
|
| + weak_factory_.GetWeakPtr()));
|
| +
|
| + NotifyStreamReady();
|
| }
|
|
|
| void BidirectionalStreamQuicImpl::OnSendDataComplete(int rv) {
|
| DCHECK(rv == OK || !stream_);
|
| - if (rv == OK) {
|
| - if (delegate_)
|
| - delegate_->OnDataSent();
|
| - } else {
|
| + if (rv != 0) {
|
| NotifyError(rv);
|
| + return;
|
| }
|
| +
|
| + if (delegate_)
|
| + delegate_->OnDataSent();
|
| }
|
|
|
| void BidirectionalStreamQuicImpl::OnReadInitialHeadersComplete(int rv) {
|
|
|