Lines Matching refs:stream_
120 if (stream_.get()) {
122 // TODO(mbelshe): The stream_ should be able to compute whether or not the
127 stream_->CanFindEndOfResponse() &&
130 stream_->Close(true /* not reusable */);
132 if (stream_->IsResponseBodyComplete()) {
134 stream_->Close(false /* reusable */);
135 } else if (stream_->IsSpdyHttpStream()) {
137 stream_->Close(true /* not reusable */);
146 new HttpResponseBodyDrainer(stream_.release());
174 DCHECK(!stream_.get());
192 DCHECK(!stream_.get());
254 stream_->CanFindEndOfResponse()) {
257 if (!stream_->IsResponseBodyComplete()) {
274 if (stream_.get()) {
276 if (keep_alive && stream_->IsConnectionReusable()) {
279 stream_->SetConnectionReused();
280 new_stream = stream_->RenewStreamForAuth();
285 // keep_alive case, we've determined that the stream_ is not
287 stream_->Close(true);
292 stream_.reset(new_stream);
368 if (!stream_.get())
371 return stream_->GetUploadProgress();
380 stream_.reset(stream);
395 DCHECK(!stream_.get());
408 DCHECK(!stream_.get());
464 stream_.reset(stream);
599 DCHECK(stream_.get());
618 DCHECK(stream_.get());
620 return stream_->InitializeStream(request_, net_log_, &io_callback_);
631 stream_.reset();
794 return stream_->SendRequest(
807 return stream_->ReadResponseHeaders(&io_callback_);
811 if (!response_.headers && !stream_->IsConnectionReused()) {
832 DCHECK(stream_.get());
835 stream_->GetSSLCertRequestInfo(response_.cert_request_info);
900 stream_->GetSSLInfo(&response_.ssl_info);
909 DCHECK(stream_ != NULL);
912 return stream_->ReadResponseBody(read_buf_, read_buf_len_, &io_callback_);
924 if (stream_->IsResponseBodyComplete()) {
932 if (stream_->CanFindEndOfResponse())
939 stream_->Close(!keep_alive);
976 } else if (stream_->IsResponseBodyComplete()) {
1004 bool reused_socket = stream_->IsConnectionReused();
1078 if (!stream_->IsConnectionReused()) {
1099 if (stream_.get()) {
1103 stream_->Close(true);
1104 stream_.reset();
1218 stream_.reset();
1236 bool connection_is_proven = stream_->IsConnectionReused();
1248 if (stream_.get()) {
1249 stream_->Close(true);
1250 stream_.reset();
