Lines Matching refs:http_stream_
325 if (HM_RECV == base->mode_ && base->http_stream_) { in Close()
328 base->http_stream_->PostEvent(SE_READ, 0); in Close()
364 http_stream_(NULL), doc_stream_(NULL) { in HttpBase()
373 return (http_stream_ != NULL) && (http_stream_->GetState() == SS_OPEN); in isConnected()
378 if ((mode_ != HM_NONE) || (http_stream_ != NULL) || (stream == NULL)) { in attach()
382 http_stream_ = stream; in attach()
383 http_stream_->SignalEvent.connect(this, &HttpBase::OnHttpStreamEvent); in attach()
384 mode_ = (http_stream_->GetState() == SS_OPENING) ? HM_CONNECT : HM_NONE; in attach()
394 StreamInterface* stream = http_stream_; in detach()
395 http_stream_ = NULL; in detach()
408 OnHttpStreamEvent(http_stream_, SE_CLOSE, HE_DISCONNECTED); in send()
445 OnHttpStreamEvent(http_stream_, SE_CLOSE, HE_DISCONNECTED); in recv()
465 if (http_stream_ != NULL) { in abort()
466 http_stream_->Close(); in abort()
480 if (http_stream_ != NULL) { in HandleStreamClose()
481 http_stream_->Close(); in HandleStreamClose()
519 StreamResult read_result = http_stream_->Read(buffer_ + len_, in DoReceiveLoop()
686 StreamResult result = http_stream_->Write(buffer_, len_, &written, &error); in flush_data()
700 OnHttpStreamEvent(http_stream_, SE_CLOSE, error); in flush_data()
758 ASSERT(stream == http_stream_); in OnHttpStreamEvent()