stream_ 18 android_webview/browser/net/input_stream_reader.cc : stream_(stream) { stream_ 48 android_webview/browser/net/input_stream_reader.cc if (!stream_->Read(dest, dest_size, &bytes_read)) stream_ 58 android_webview/browser/net/input_stream_reader.cc if (!stream_->BytesAvailable(&size)) stream_ 85 android_webview/browser/net/input_stream_reader.cc if (!stream_->Skip(bytes_to_skip, &skipped)) stream_ 54 android_webview/browser/net/input_stream_reader.h android_webview::InputStream* stream_; stream_ 130 base/i18n/build_utf8_validator_tables.cc : stream_(stream), values_on_this_line_(0), current_offset_(0) {} stream_ 134 base/i18n/build_utf8_validator_tables.cc fputs(" ", stream_); stream_ 136 base/i18n/build_utf8_validator_tables.cc fprintf(stream_, " // 0x%02x\n ", current_offset_); stream_ 139 base/i18n/build_utf8_validator_tables.cc fprintf(stream_, " 0x%02x,", static_cast<int>(value)); stream_ 146 base/i18n/build_utf8_validator_tables.cc fputs(" ", stream_); stream_ 149 base/i18n/build_utf8_validator_tables.cc fprintf(stream_, " // 0x%02x\n", current_offset_); stream_ 155 base/i18n/build_utf8_validator_tables.cc FILE* stream_; stream_ 545 base/logging.cc stream_ << "Check failed: " << *result; stream_ 553 base/logging.cc stream_ << "Check failed: " << *result; stream_ 562 base/logging.cc stream_ << std::endl; // Newline to separate from log message. stream_ 563 base/logging.cc trace.OutputToStream(&stream_); stream_ 566 base/logging.cc stream_ << std::endl; stream_ 567 base/logging.cc std::string str_newline(stream_.str()); stream_ 647 base/logging.cc log_assert_handler(std::string(stream_.str())); stream_ 655 base/logging.cc DisplayDebugMessageInDialog(stream_.str()); stream_ 663 base/logging.cc log_report_handler(std::string(stream_.str())); stream_ 665 base/logging.cc DisplayDebugMessageInDialog(stream_.str()); stream_ 679 base/logging.cc stream_ << '['; stream_ 681 base/logging.cc stream_ << CurrentProcessId() << ':'; stream_ 683 base/logging.cc stream_ << base::PlatformThread::CurrentId() << ':'; stream_ 693 base/logging.cc stream_ << std::setfill('0') stream_ 703 base/logging.cc stream_ << TickCount() << ':'; stream_ 705 base/logging.cc stream_ << log_severity_name(severity_); stream_ 707 base/logging.cc stream_ << "VERBOSE" << -severity_; stream_ 709 base/logging.cc stream_ << ":" << filename << "(" << line << ")] "; stream_ 711 base/logging.cc message_start_ = stream_.tellp(); stream_ 764 base/logging.h std::ostream& stream() { return stream_; } stream_ 770 base/logging.h std::ostringstream stream_; stream_ 27 content/browser/loader/stream_resource_handler.cc stream_ = new Stream(registry, this, url); stream_ 31 content/browser/loader/stream_resource_handler.cc stream_->RemoveWriteObserver(this); stream_ 93 content/browser/loader/stream_resource_handler.cc stream_->AddData(buffer, bytes_read); stream_ 95 content/browser/loader/stream_resource_handler.cc if (!stream_->can_add_data()) stream_ 106 content/browser/loader/stream_resource_handler.cc stream_->Finalize(); stream_ 74 content/browser/loader/stream_resource_handler.h Stream* stream() { return stream_.get(); } stream_ 80 content/browser/loader/stream_resource_handler.h scoped_refptr<Stream> stream_; stream_ 20 content/browser/streams/stream_handle_impl.cc : stream_(stream), stream_ 29 content/browser/streams/stream_handle_impl.cc base::Bind(&Stream::CloseHandle, stream_)); stream_ 35 content/browser/streams/stream_handle_impl.h base::WeakPtr<Stream> stream_; stream_ 25 content/browser/streams/stream_url_request_job.cc stream_(stream), stream_ 31 content/browser/streams/stream_url_request_job.cc DCHECK(stream_.get()); stream_ 32 content/browser/streams/stream_url_request_job.cc stream_->SetReadObserver(this); stream_ 51 content/browser/streams/stream_url_request_job.cc switch (stream_->ReadRawData( stream_ 113 content/browser/streams/stream_url_request_job.cc switch (stream_->ReadRawData(buf, to_read, bytes_read)) { stream_ 242 content/browser/streams/stream_url_request_job.cc if (stream_.get()) { stream_ 243 content/browser/streams/stream_url_request_job.cc stream_->RemoveReadObserver(this); stream_ 244 content/browser/streams/stream_url_request_job.cc stream_ = NULL; stream_ 51 content/browser/streams/stream_url_request_job.h scoped_refptr<content::Stream> stream_; stream_ 36 content/child/npapi/plugin_stream.cc memset(&stream_, 0, sizeof(stream_)); stream_ 37 content/child/npapi/plugin_stream.cc stream_.url = base::strdup(url); stream_ 45 content/child/npapi/plugin_stream.cc free(const_cast<char*>(stream_.url)); stream_ 55 content/child/npapi/plugin_stream.cc stream_.end = length; stream_ 56 content/child/npapi/plugin_stream.cc stream_.lastmodified = last_modified; stream_ 57 content/child/npapi/plugin_stream.cc stream_.pdata = 0; stream_ 58 content/child/npapi/plugin_stream.cc stream_.ndata = id->ndata; stream_ 59 content/child/npapi/plugin_stream.cc stream_.notifyData = notify_data_; stream_ 61 content/child/npapi/plugin_stream.cc stream_.headers = headers_.c_str(); stream_ 76 content/child/npapi/plugin_stream.cc GURL gurl(stream_.url); stream_ 86 content/child/npapi/plugin_stream.cc &stream_, seekable_stream, stream_ 197 content/child/npapi/plugin_stream.cc int bytes_to_write = instance_->NPP_WriteReady(&stream_); stream_ 205 content/child/npapi/plugin_stream.cc &stream_, data_offset_, bytes_to_write, stream_ 253 content/child/npapi/plugin_stream.cc if (stream_.ndata != NULL) { stream_ 255 content/child/npapi/plugin_stream.cc NPError err = instance_->NPP_DestroyStream(&stream_, reason); stream_ 270 content/child/npapi/plugin_stream.cc instance_->NPP_URLNotify(stream_.url, reason, notify_data_); stream_ 62 content/child/npapi/plugin_stream.h NPStream* stream() { return &stream_; } stream_ 124 content/child/npapi/plugin_stream.h NPStream stream_; stream_ 26 content/child/npapi/plugin_stream_posix.cc instance_->NPP_StreamAsFile(&stream_, temp_file_path_.value().c_str()); stream_ 22 content/child/npapi/plugin_stream_win.cc instance_->NPP_StreamAsFile(&stream_, temp_file_name_); stream_ 36 content/renderer/media/webrtc/media_stream_track_metrics.cc MediaStreamInterface* stream() { return stream_; } stream_ 76 content/renderer/media/webrtc/media_stream_track_metrics.cc talk_base::scoped_refptr<MediaStreamInterface> stream_; stream_ 88 content/renderer/media/webrtc/media_stream_track_metrics.cc : stream_type(stream_type), stream_(stream) {} stream_ 90 content/renderer/media/webrtc/media_stream_track_metrics.cc return stream_ == observer->stream() && stream_ 94 content/renderer/media/webrtc/media_stream_track_metrics.cc MediaStreamInterface* stream_; stream_ 106 content/renderer/media/webrtc/media_stream_track_metrics.cc stream_(stream), stream_ 109 content/renderer/media/webrtc/media_stream_track_metrics.cc stream_->RegisterObserver(this); stream_ 113 content/renderer/media/webrtc/media_stream_track_metrics.cc stream_->UnregisterObserver(this); stream_ 151 content/renderer/media/webrtc/media_stream_track_metrics.cc AudioTrackVector all_audio_tracks = stream_->GetAudioTracks(); stream_ 154 content/renderer/media/webrtc/media_stream_track_metrics.cc VideoTrackVector all_video_tracks = stream_->GetVideoTracks(); stream_ 83 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_ = new talk_base::RefCountedObject<MockMediaStream>("stream"); stream_ 88 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_ = NULL; stream_ 100 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc scoped_refptr<MediaStreamInterface> stream_; stream_ 138 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(audio); stream_ 139 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(video); stream_ 140 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc metrics_->AddStream(MediaStreamTrackMetrics::RECEIVED_STREAM, stream_); stream_ 172 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(audio); stream_ 173 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(video); stream_ 174 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc metrics_->AddStream(MediaStreamTrackMetrics::SENT_STREAM, stream_); stream_ 205 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(initial); stream_ 206 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc metrics_->AddStream(MediaStreamTrackMetrics::RECEIVED_STREAM, stream_); stream_ 221 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(added); stream_ 239 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(first); stream_ 240 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(second); stream_ 241 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc metrics_->AddStream(MediaStreamTrackMetrics::SENT_STREAM, stream_); stream_ 261 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->RemoveTrack(first); stream_ 274 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(first); stream_ 275 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc metrics_->AddStream(MediaStreamTrackMetrics::SENT_STREAM, stream_); stream_ 280 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(second); stream_ 309 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->RemoveTrack(first); stream_ 314 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(audio); stream_ 315 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc metrics_->AddStream(MediaStreamTrackMetrics::RECEIVED_STREAM, stream_); stream_ 333 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->RemoveTrack(audio); stream_ 338 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(audio); stream_ 339 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc metrics_->AddStream(MediaStreamTrackMetrics::RECEIVED_STREAM, stream_); stream_ 359 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->RemoveTrack(audio); stream_ 365 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(audio); stream_ 366 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(video); stream_ 367 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc metrics_->AddStream(MediaStreamTrackMetrics::SENT_STREAM, stream_); stream_ 392 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc metrics_->RemoveStream(MediaStreamTrackMetrics::SENT_STREAM, stream_); stream_ 402 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(audio1); stream_ 403 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(video1); stream_ 404 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc metrics_->AddStream(MediaStreamTrackMetrics::SENT_STREAM, stream_); stream_ 424 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(audio2); stream_ 430 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(video2); stream_ 437 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->RemoveTrack(audio1); stream_ 444 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(audio3); stream_ 450 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(video3); stream_ 458 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->AddTrack(audio1); stream_ 465 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->RemoveTrack(audio2); stream_ 471 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->RemoveTrack(video2); stream_ 478 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->RemoveTrack(audio1); stream_ 484 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc stream_->RemoveTrack(video1); stream_ 496 content/renderer/media/webrtc/media_stream_track_metrics_unittest.cc metrics_->RemoveStream(MediaStreamTrackMetrics::SENT_STREAM, stream_); stream_ 89 content/renderer/media/webrtc_audio_renderer_unittest.cc stream_(new talk_base::RefCountedObject<MockMediaStream>("label")), stream_ 90 content/renderer/media/webrtc_audio_renderer_unittest.cc renderer_(new WebRtcAudioRenderer(stream_, 1, 1, 1, 44100, 441)) { stream_ 95 content/renderer/media/webrtc_audio_renderer_unittest.cc renderer_proxy_ = renderer_->CreateSharedAudioRendererProxy(stream_); stream_ 105 content/renderer/media/webrtc_audio_renderer_unittest.cc scoped_refptr<webrtc::MediaStreamInterface> stream_; stream_ 131 content/renderer/media/webrtc_audio_renderer_unittest.cc renderer_->CreateSharedAudioRendererProxy(stream_)); stream_ 40 media/audio/audio_input_controller.cc stream_(NULL), stream_ 188 media/audio/audio_input_controller.cc DCHECK(!stream_); stream_ 189 media/audio/audio_input_controller.cc stream_ = stream_to_control; stream_ 191 media/audio/audio_input_controller.cc if (!stream_) { stream_ 196 media/audio/audio_input_controller.cc if (stream_ && !stream_->Open()) { stream_ 197 media/audio/audio_input_controller.cc stream_->Close(); stream_ 198 media/audio/audio_input_controller.cc stream_ = NULL; stream_ 254 media/audio/audio_input_controller.cc stream_->Start(this); stream_ 296 media/audio/audio_input_controller.cc max_volume_ = stream_->GetMaxVolume(); stream_ 305 media/audio/audio_input_controller.cc stream_->SetVolume(max_volume_ * volume); stream_ 316 media/audio/audio_input_controller.cc stream_->SetAutomaticGainControl(enabled); stream_ 387 media/audio/audio_input_controller.cc if (stream_ != NULL) { stream_ 388 media/audio/audio_input_controller.cc stream_->Stop(); stream_ 389 media/audio/audio_input_controller.cc stream_->Close(); stream_ 390 media/audio/audio_input_controller.cc stream_ = NULL; stream_ 171 media/audio/audio_input_controller.h AudioInputStream* stream_for_testing() { return stream_; } stream_ 277 media/audio/audio_input_controller.h AudioInputStream* stream_; stream_ 40 media/audio/audio_output_controller.cc stream_(NULL), stream_ 136 media/audio/audio_output_controller.cc stream_ = diverting_to_stream_ ? stream_ 139 media/audio/audio_output_controller.cc if (!stream_) { stream_ 145 media/audio/audio_output_controller.cc if (!stream_->Open()) { stream_ 154 media/audio/audio_output_controller.cc if (stream_ != diverting_to_stream_) stream_ 158 media/audio/audio_output_controller.cc stream_->SetVolume(volume_); stream_ 182 media/audio/audio_output_controller.cc stream_->Start(this); stream_ 208 media/audio/audio_output_controller.cc stream_->Stop(); stream_ 261 media/audio/audio_output_controller.cc stream_->SetVolume(volume_); stream_ 289 media/audio/audio_output_controller.cc if (stream_ != diverting_to_stream_) stream_ 341 media/audio/audio_output_controller.cc if (stream_) { stream_ 344 media/audio/audio_output_controller.cc if (stream_ != diverting_to_stream_) stream_ 348 media/audio/audio_output_controller.cc stream_->Close(); stream_ 349 media/audio/audio_output_controller.cc if (stream_ == diverting_to_stream_) stream_ 351 media/audio/audio_output_controller.cc stream_ = NULL; stream_ 370 media/audio/audio_output_controller.cc if (!stream_ || state_ == kError) stream_ 227 media/audio/audio_output_controller.h AudioOutputStream* stream_; stream_ 40 media/audio/sounds/audio_stream_handler.cc : stream_(NULL), stream_ 54 media/audio/sounds/audio_stream_handler.cc if (!stream_) { stream_ 61 media/audio/sounds/audio_stream_handler.cc stream_ = AudioManager::Get()->MakeAudioOutputStreamProxy( stream_ 63 media/audio/sounds/audio_stream_handler.cc if (!stream_ || !stream_->Open()) { stream_ 67 media/audio/sounds/audio_stream_handler.cc stream_->SetVolume(kOutputVolumePercent); stream_ 88 media/audio/sounds/audio_stream_handler.cc stream_->Start(g_audio_source_for_testing); stream_ 90 media/audio/sounds/audio_stream_handler.cc stream_->Start(this); stream_ 99 media/audio/sounds/audio_stream_handler.cc if (stream_) stream_ 100 media/audio/sounds/audio_stream_handler.cc stream_->Close(); stream_ 101 media/audio/sounds/audio_stream_handler.cc stream_ = NULL; stream_ 142 media/audio/sounds/audio_stream_handler.cc if (stream_ && started_) { stream_ 143 media/audio/sounds/audio_stream_handler.cc stream_->Stop(); stream_ 150 media/audio/sounds/audio_stream_handler.cc AudioOutputStream* stream_; stream_ 175 media/audio/sounds/audio_stream_handler.cc stream_.reset(new AudioStreamContainer(wav_audio_)); stream_ 183 media/audio/sounds/audio_stream_handler.cc base::Bind(&AudioStreamContainer::Stop, base::Unretained(stream_.get()))); stream_ 185 media/audio/sounds/audio_stream_handler.cc stream_.release()); stream_ 202 media/audio/sounds/audio_stream_handler.cc base::Unretained(stream_.get()))); stream_ 210 media/audio/sounds/audio_stream_handler.cc base::Bind(&AudioStreamContainer::Stop, base::Unretained(stream_.get()))); stream_ 69 media/audio/sounds/audio_stream_handler.h scoped_ptr<AudioStreamContainer> stream_; stream_ 103 media/audio/virtual_audio_input_stream_unittest.cc stream_(NULL), stream_ 118 media/audio/virtual_audio_input_stream_unittest.cc stream_ = new VirtualAudioInputStream( stream_ 121 media/audio/virtual_audio_input_stream_unittest.cc stream_->Open(); stream_ 128 media/audio/virtual_audio_input_stream_unittest.cc ASSERT_TRUE(!!stream_); stream_ 129 media/audio/virtual_audio_input_stream_unittest.cc stream_->Start(&input_callback_); stream_ 133 media/audio/virtual_audio_input_stream_unittest.cc ASSERT_TRUE(!!stream_); stream_ 136 media/audio/virtual_audio_input_stream_unittest.cc stream_, stream_ 145 media/audio/virtual_audio_input_stream_unittest.cc ASSERT_TRUE(!!stream_); stream_ 146 media/audio/virtual_audio_input_stream_unittest.cc stream_->Stop(); stream_ 150 media/audio/virtual_audio_input_stream_unittest.cc ASSERT_TRUE(!!stream_); stream_ 151 media/audio/virtual_audio_input_stream_unittest.cc stream_->Close(); stream_ 152 media/audio/virtual_audio_input_stream_unittest.cc stream_ = NULL; stream_ 240 media/audio/virtual_audio_input_stream_unittest.cc VirtualAudioInputStream* stream_; stream_ 223 media/audio/win/audio_low_latency_input_win_unittest.cc : stream_(stream) {} stream_ 226 media/audio/win/audio_low_latency_input_win_unittest.cc if (stream_) stream_ 227 media/audio/win/audio_low_latency_input_win_unittest.cc stream_->Close(); stream_ 231 media/audio/win/audio_low_latency_input_win_unittest.cc if (stream_) stream_ 232 media/audio/win/audio_low_latency_input_win_unittest.cc stream_->Close(); stream_ 233 media/audio/win/audio_low_latency_input_win_unittest.cc stream_ = NULL; stream_ 237 media/audio/win/audio_low_latency_input_win_unittest.cc return stream_; stream_ 240 media/audio/win/audio_low_latency_input_win_unittest.cc AudioInputStream* get() const { return stream_; } stream_ 244 media/audio/win/audio_low_latency_input_win_unittest.cc stream_ = new_stream; stream_ 248 media/audio/win/audio_low_latency_input_win_unittest.cc AudioInputStream* stream_; stream_ 110 media/base/media_log.cc log_cb_.Run(stream_.str()); stream_ 30 media/base/media_log.h std::ostream& stream() { return stream_; } stream_ 34 media/base/media_log.h std::stringstream stream_; stream_ 132 media/cast/rtcp/rtcp_sender.cc stream_ << "-" << last_packet_id_; stream_ 134 media/cast/rtcp/rtcp_sender.cc stream_ << ", "; stream_ 136 media/cast/rtcp/rtcp_sender.cc stream_ << frame_id; stream_ 147 media/cast/rtcp/rtcp_sender.cc stream_ << ":" << packet_id; stream_ 152 media/cast/rtcp/rtcp_sender.cc stream_ << "-" << last_packet_id_; stream_ 155 media/cast/rtcp/rtcp_sender.cc stream_ << "," << packet_id; stream_ 163 media/cast/rtcp/rtcp_sender.cc stream_ << "-" << last_packet_id_; stream_ 166 media/cast/rtcp/rtcp_sender.cc return stream_.str(); stream_ 170 media/cast/rtcp/rtcp_sender.cc std::ostringstream stream_; stream_ 94 media/cdm/ppapi/cdm_logging.cc stream_ << '['; stream_ 97 media/cdm/ppapi/cdm_logging.cc stream_ << CurrentProcessId() << ':'; stream_ 98 media/cdm/ppapi/cdm_logging.cc stream_ << CurrentThreadId() << ':'; stream_ 109 media/cdm/ppapi/cdm_logging.cc stream_ << std::setfill('0') stream_ 117 media/cdm/ppapi/cdm_logging.cc stream_ << TickCount() << ':'; stream_ 120 media/cdm/ppapi/cdm_logging.cc stream_ << filename << "(" << line << ")] "; stream_ 44 media/cdm/ppapi/cdm_logging.h std::string message() { return stream_.str(); } stream_ 47 media/cdm/ppapi/cdm_logging.h std::ostringstream stream_; stream_ 36 media/ffmpeg/ffmpeg_common_unittest.cc AVStream stream_; stream_ 53 media/ffmpeg/ffmpeg_common_unittest.cc stream_.time_base = kTimeBase; stream_ 54 media/ffmpeg/ffmpeg_common_unittest.cc stream_.index_entries = kIndexEntries; stream_ 55 media/ffmpeg/ffmpeg_common_unittest.cc stream_.index_entries_allocated_size = sizeof(kIndexEntries); stream_ 56 media/ffmpeg/ffmpeg_common_unittest.cc stream_.nb_index_entries = arraysize(kIndexEntries); stream_ 753 media/filters/chunk_demuxer.cc return stream_->IsSeekPending(); stream_ 763 media/filters/chunk_demuxer.cc stream_->Seek(time); stream_ 772 media/filters/chunk_demuxer.cc if (!stream_->Append(buffers)) { stream_ 786 media/filters/chunk_demuxer.cc stream_->Remove(start, end, duration); stream_ 791 media/filters/chunk_demuxer.cc stream_->OnSetDuration(duration); stream_ 808 media/filters/chunk_demuxer.cc Ranges<TimeDelta> range = stream_->GetBufferedTime(); stream_ 822 media/filters/chunk_demuxer.cc return stream_->GetBufferedDuration(); stream_ 829 media/filters/chunk_demuxer.cc stream_->OnNewMediaSegment(start_timestamp); stream_ 837 media/filters/chunk_demuxer.cc if (!stream_) { stream_ 839 media/filters/chunk_demuxer.cc stream_.reset( stream_ 844 media/filters/chunk_demuxer.cc return stream_->UpdateAudioConfig(config); stream_ 853 media/filters/chunk_demuxer.cc if (!stream_) { stream_ 855 media/filters/chunk_demuxer.cc stream_.reset( stream_ 860 media/filters/chunk_demuxer.cc return stream_->UpdateVideoConfig(config); stream_ 867 media/filters/chunk_demuxer.cc DCHECK(!stream_); stream_ 869 media/filters/chunk_demuxer.cc stream_.reset(new SourceBufferStream(config, log_cb, splice_frames_enabled_)); stream_ 874 media/filters/chunk_demuxer.cc stream_->MarkEndOfStream(); stream_ 879 media/filters/chunk_demuxer.cc stream_->UnmarkEndOfStream(); stream_ 899 media/filters/chunk_demuxer.cc return stream_->GetCurrentAudioDecoderConfig(); stream_ 905 media/filters/chunk_demuxer.cc return stream_->GetCurrentVideoDecoderConfig(); stream_ 913 media/filters/chunk_demuxer.cc return stream_->GetCurrentTextTrackConfig(); stream_ 938 media/filters/chunk_demuxer.cc switch (stream_->GetNextBuffer(&buffer)) { stream_ 96 media/filters/chunk_demuxer.h stream_->set_memory_limit_for_testing(memory_limit); stream_ 115 media/filters/chunk_demuxer.h scoped_ptr<SourceBufferStream> stream_; stream_ 48 media/filters/decoder_stream.cc stream_(NULL), stream_ 72 media/filters/decoder_stream.cc stream_ = stream; stream_ 194 media/filters/decoder_stream.cc stream_ = NULL; stream_ 225 media/filters/decoder_stream.cc stream_ = decrypting_demuxer_stream.get(); stream_ 230 media/filters/decoder_stream.cc base::ResetAndReturn(&init_cb_), selected_decoder.get(), stream_); stream_ 236 media/filters/decoder_stream.cc base::ResetAndReturn(&init_cb_), decoder_.get(), stream_); stream_ 359 media/filters/decoder_stream.cc stream_->Read(base::Bind(&DecoderStream<StreamType>::OnBufferReady, stream_ 378 media/filters/decoder_stream.cc DCHECK(stream_->SupportsConfigChanges()); stream_ 426 media/filters/decoder_stream.cc DCHECK(StreamTraits::GetDecoderConfig(*stream_).IsValidConfig()); stream_ 429 media/filters/decoder_stream.cc StreamTraits::GetDecoderConfig(*stream_), stream_ 508 media/filters/decoder_stream.cc stream_ = NULL; stream_ 172 media/filters/decoder_stream.h DemuxerStream* stream_; stream_ 47 media/filters/fake_demuxer_stream_unittest.cc stream_.reset( stream_ 54 media/filters/fake_demuxer_stream_unittest.cc stream_.reset(new FakeDemuxerStream(1, kNumBuffersInOneConfig, false)); stream_ 75 media/filters/fake_demuxer_stream_unittest.cc EXPECT_TRUE(stream_->SupportsConfigChanges()); stream_ 97 media/filters/fake_demuxer_stream_unittest.cc stream_->Read(base::Bind(&FakeDemuxerStreamTest::BufferReady, stream_ 106 media/filters/fake_demuxer_stream_unittest.cc stream_->Read(base::Bind(&FakeDemuxerStreamTest::BufferReady, stream_ 116 media/filters/fake_demuxer_stream_unittest.cc stream_->SatisfyRead(); stream_ 123 media/filters/fake_demuxer_stream_unittest.cc stream_->Reset(); stream_ 134 media/filters/fake_demuxer_stream_unittest.cc stream_.reset(new FakeDemuxerStream( stream_ 139 media/filters/fake_demuxer_stream_unittest.cc const VideoDecoderConfig& config = stream_->video_decoder_config(); stream_ 147 media/filters/fake_demuxer_stream_unittest.cc EXPECT_EQ(num_buffers_received, stream_->num_buffers_returned()); stream_ 163 media/filters/fake_demuxer_stream_unittest.cc scoped_ptr<FakeDemuxerStream> stream_; stream_ 192 media/filters/fake_demuxer_stream_unittest.cc stream_->HoldNextRead(); stream_ 199 media/filters/fake_demuxer_stream_unittest.cc stream_->HoldNextConfigChangeRead(); stream_ 206 media/filters/fake_demuxer_stream_unittest.cc stream_->HoldNextRead(); stream_ 219 media/filters/fake_demuxer_stream_unittest.cc stream_->HoldNextRead(); stream_ 226 media/filters/fake_demuxer_stream_unittest.cc stream_->HoldNextRead(); stream_ 234 media/filters/fake_demuxer_stream_unittest.cc stream_->HoldNextConfigChangeRead(); stream_ 242 media/filters/fake_demuxer_stream_unittest.cc stream_->HoldNextRead(); stream_ 249 media/filters/fake_demuxer_stream_unittest.cc stream_.reset( stream_ 251 media/filters/fake_demuxer_stream_unittest.cc EXPECT_FALSE(stream_->SupportsConfigChanges()); stream_ 45 media/filters/ffmpeg_demuxer.cc stream_(stream), stream_ 77 media/filters/ffmpeg_demuxer.cc if (stream_->codec->codec_id == AV_CODEC_ID_H264) { stream_ 79 media/filters/ffmpeg_demuxer.cc new FFmpegH264ToAnnexBBitstreamConverter(stream_->codec)); stream_ 197 media/filters/ffmpeg_demuxer.cc stream_->time_base, packet->pts)); stream_ 199 media/filters/ffmpeg_demuxer.cc stream_->time_base, packet->duration)); stream_ 234 media/filters/ffmpeg_demuxer.cc stream_ = NULL; stream_ 292 media/filters/ffmpeg_demuxer.cc return ConvertStreamTimestamp(stream_->time_base, stream_->cur_dts); stream_ 337 media/filters/ffmpeg_demuxer.cc if (stream_->disposition & AV_DISPOSITION_CAPTIONS) stream_ 340 media/filters/ffmpeg_demuxer.cc if (stream_->disposition & AV_DISPOSITION_DESCRIPTIONS) stream_ 343 media/filters/ffmpeg_demuxer.cc if (stream_->disposition & AV_DISPOSITION_METADATA) stream_ 351 media/filters/ffmpeg_demuxer.cc av_dict_get(stream_->metadata, key, NULL, 0); stream_ 120 media/filters/ffmpeg_demuxer.h AVStream* stream_; stream_ 15 media/filters/frame_processor_base.cc DCHECK(stream_); stream_ 37 media/filters/frame_processor_base.h ChunkDemuxerStream* stream() const { return stream_; } stream_ 53 media/filters/frame_processor_base.h ChunkDemuxerStream* const stream_; stream_ 134 media/filters/h264_parser.cc stream_ = NULL; stream_ 142 media/filters/h264_parser.cc stream_ = stream; stream_ 198 media/filters/h264_parser.cc if (!FindStartCode(stream_, bytes_left_, stream_ 205 media/filters/h264_parser.cc stream_ += nalu_start_off; stream_ 208 media/filters/h264_parser.cc const uint8* nalu_data = stream_ + annexb_start_code_size; stream_ 283 media/filters/h264_parser.cc nalu->data = stream_ + start_code_size; stream_ 295 media/filters/h264_parser.cc stream_ += nalu_size_with_start_code; stream_ 381 media/filters/h264_parser.h const uint8* stream_; stream_ 38 media/filters/source_buffer_stream_unittest.cc stream_.reset(new SourceBufferStream(video_config_, log_cb(), true)); stream_ 42 media/filters/source_buffer_stream_unittest.cc stream_->set_memory_limit_for_testing(buffers_of_data * kDataSize); stream_ 54 media/filters/source_buffer_stream_unittest.cc stream_.reset(new SourceBufferStream(config, LogCB(), true)); stream_ 68 media/filters/source_buffer_stream_unittest.cc stream_.reset(new SourceBufferStream(config, LogCB(), true)); stream_ 139 media/filters/source_buffer_stream_unittest.cc stream_->Seek(position * frame_duration_); stream_ 143 media/filters/source_buffer_stream_unittest.cc stream_->Seek(timestamp); stream_ 154 media/filters/source_buffer_stream_unittest.cc stream_->Remove(start, end, duration); stream_ 161 media/filters/source_buffer_stream_unittest.cc int bytes_removed = stream_->GetRemovalRange( stream_ 170 media/filters/source_buffer_stream_unittest.cc Ranges<base::TimeDelta> r = stream_->GetBufferedTime(); stream_ 184 media/filters/source_buffer_stream_unittest.cc Ranges<base::TimeDelta> r = stream_->GetBufferedTime(); stream_ 227 media/filters/source_buffer_stream_unittest.cc SourceBufferStream::Status status = stream_->GetNextBuffer(&buffer); stream_ 256 media/filters/source_buffer_stream_unittest.cc const SourceBufferStream::Type type = stream_->GetType(); stream_ 259 media/filters/source_buffer_stream_unittest.cc SourceBufferStream::Status status = stream_->GetNextBuffer(&buffer); stream_ 267 media/filters/source_buffer_stream_unittest.cc stream_->GetCurrentVideoDecoderConfig(); stream_ 270 media/filters/source_buffer_stream_unittest.cc stream_->GetCurrentAudioDecoderConfig(); stream_ 273 media/filters/source_buffer_stream_unittest.cc stream_->GetCurrentTextTrackConfig(); stream_ 297 media/filters/source_buffer_stream_unittest.cc EXPECT_EQ(SourceBufferStream::kNeedBuffer, stream_->GetNextBuffer(&buffer)); stream_ 301 media/filters/source_buffer_stream_unittest.cc const VideoDecoderConfig& actual = stream_->GetCurrentVideoDecoderConfig(); stream_ 314 media/filters/source_buffer_stream_unittest.cc scoped_ptr<SourceBufferStream> stream_; stream_ 331 media/filters/source_buffer_stream_unittest.cc stream_->OnNewMediaSegment(starting_position * frame_duration_); stream_ 369 media/filters/source_buffer_stream_unittest.cc EXPECT_EQ(expect_success, stream_->Append(queue)); stream_ 394 media/filters/source_buffer_stream_unittest.cc size_t splice_config_id = stream_->append_config_index_; stream_ 416 media/filters/source_buffer_stream_unittest.cc CHECK(splice_config_id < stream_->audio_configs_.size() || stream_ 417 media/filters/source_buffer_stream_unittest.cc splice_config_id < stream_->video_configs_.size()); stream_ 479 media/filters/source_buffer_stream_unittest.cc stream_->OnNewMediaSegment(start_timestamp); stream_ 483 media/filters/source_buffer_stream_unittest.cc EXPECT_EQ(expect_success, stream_->Append(buffers)); stream_ 491 media/filters/source_buffer_stream_unittest.cc EXPECT_TRUE(stream_->Append(wrapper)); stream_ 1753 media/filters/source_buffer_stream_unittest.cc stream_->Seek(5 * frame_duration() + bump); stream_ 1757 media/filters/source_buffer_stream_unittest.cc stream_->Seek(5 * frame_duration() - bump); stream_ 1798 media/filters/source_buffer_stream_unittest.cc EXPECT_EQ(stream_->GetNextBuffer(&buffer), SourceBufferStream::kSuccess); stream_ 1812 media/filters/source_buffer_stream_unittest.cc EXPECT_EQ(stream_->GetNextBuffer(&buffer), SourceBufferStream::kSuccess); stream_ 2170 media/filters/source_buffer_stream_unittest.cc ASSERT_EQ(stream_->GetNextBuffer(&buffer), SourceBufferStream::kSuccess); stream_ 2848 media/filters/source_buffer_stream_unittest.cc stream_->UpdateVideoConfig(new_config); stream_ 2860 media/filters/source_buffer_stream_unittest.cc EXPECT_EQ(stream_->GetNextBuffer(&buffer), SourceBufferStream::kSuccess); stream_ 2866 media/filters/source_buffer_stream_unittest.cc EXPECT_EQ(stream_->GetNextBuffer(&buffer), SourceBufferStream::kConfigChange); stream_ 2874 media/filters/source_buffer_stream_unittest.cc EXPECT_EQ(stream_->GetNextBuffer(&buffer), SourceBufferStream::kSuccess); stream_ 2884 media/filters/source_buffer_stream_unittest.cc stream_->UpdateVideoConfig(new_config); stream_ 2892 media/filters/source_buffer_stream_unittest.cc EXPECT_EQ(stream_->GetNextBuffer(&buffer), SourceBufferStream::kConfigChange); stream_ 2910 media/filters/source_buffer_stream_unittest.cc EXPECT_EQ(stream_->GetNextBuffer(&buffer), SourceBufferStream::kConfigChange); stream_ 2929 media/filters/source_buffer_stream_unittest.cc stream_->OnSetDuration(frame_duration() * 8); stream_ 2950 media/filters/source_buffer_stream_unittest.cc stream_->OnSetDuration(frame_duration() * 25); stream_ 2970 media/filters/source_buffer_stream_unittest.cc stream_->OnSetDuration(frame_duration() * 14); stream_ 2993 media/filters/source_buffer_stream_unittest.cc stream_->OnSetDuration(frame_duration() * 4); stream_ 3023 media/filters/source_buffer_stream_unittest.cc stream_->OnSetDuration(frame_duration() * 25); stream_ 3032 media/filters/source_buffer_stream_unittest.cc stream_->OnSetDuration(frame_duration() * 11); stream_ 3053 media/filters/source_buffer_stream_unittest.cc stream_->OnSetDuration(base::TimeDelta::FromMilliseconds(60)); stream_ 3079 media/filters/source_buffer_stream_unittest.cc stream_->OnSetDuration(base::TimeDelta::FromMilliseconds(120)); stream_ 3198 media/filters/source_buffer_stream_unittest.cc stream_.reset(new SourceBufferStream(config, log_cb(), true)); stream_ 3207 media/filters/source_buffer_stream_unittest.cc stream_.reset(new SourceBufferStream(config, log_cb(), true)); stream_ 3220 media/filters/source_buffer_stream_unittest.cc EXPECT_TRUE(stream_->IsSeekPending()); stream_ 3221 media/filters/source_buffer_stream_unittest.cc stream_->MarkEndOfStream(); stream_ 3222 media/filters/source_buffer_stream_unittest.cc EXPECT_FALSE(stream_->IsSeekPending()); stream_ 3235 media/filters/source_buffer_stream_unittest.cc EXPECT_TRUE(stream_->IsSeekPending()); stream_ 3236 media/filters/source_buffer_stream_unittest.cc stream_->MarkEndOfStream(); stream_ 3237 media/filters/source_buffer_stream_unittest.cc EXPECT_TRUE(stream_->IsSeekPending()); stream_ 3574 media/filters/source_buffer_stream_unittest.cc stream_->UpdateVideoConfig(new_config); stream_ 3575 media/filters/source_buffer_stream_unittest.cc stream_->UpdateVideoConfig(video_config_); stream_ 3606 media/filters/source_buffer_stream_unittest.cc stream_->UpdateVideoConfig(new_config); stream_ 3607 media/filters/source_buffer_stream_unittest.cc stream_->UpdateVideoConfig(video_config_); stream_ 134 media/formats/mp2t/es_parser_h264_unittest.cc std::vector<uint8> stream_; stream_ 164 media/formats/mp2t/es_parser_h264_unittest.cc stream_, access_units_); stream_ 214 media/formats/mp2t/es_parser_h264_unittest.cc es_parser.Parse(&stream_[cur_pes_offset], cur_pes_size, pts, dts)); stream_ 254 media/formats/mp2t/es_parser_h264_unittest.cc ComputePacketSize(pes_packets, stream_.size()); stream_ 266 media/formats/mp2t/es_parser_h264_unittest.cc size_t min_access_unit_size = stream_.size(); stream_ 281 media/formats/mp2t/es_parser_h264_unittest.cc while (cur_pes_packet.offset < stream_.size()) { stream_ 285 media/formats/mp2t/es_parser_h264_unittest.cc ComputePacketSize(pes_packets, stream_.size()); stream_ 75 media/midi/usb_midi_input_stream_unittest.cc stream_.reset(new UsbMidiInputStream(jacks, &delegate_)); stream_ 81 media/midi/usb_midi_input_stream_unittest.cc scoped_ptr<UsbMidiInputStream> stream_; stream_ 93 media/midi/usb_midi_input_stream_unittest.cc stream_->OnReceivedData(&device1_, 7, data, arraysize(data), 0); stream_ 104 media/midi/usb_midi_input_stream_unittest.cc stream_->OnReceivedData(&device1_, 7, data, arraysize(data), 0); stream_ 118 media/midi/usb_midi_input_stream_unittest.cc stream_->OnReceivedData(&device1_, 7, data, arraysize(data), 0); stream_ 136 media/midi/usb_midi_input_stream_unittest.cc stream_->OnReceivedData(&device1_, 7, data, arraysize(data), 0); stream_ 151 media/midi/usb_midi_input_stream_unittest.cc stream_->OnReceivedData(&device1_, 7, data, arraysize(data), 0); stream_ 162 media/midi/usb_midi_input_stream_unittest.cc stream_->OnReceivedData(&device1_, 7, data, arraysize(data), 99); stream_ 169 media/midi/usb_midi_input_stream_unittest.cc stream_->OnReceivedData(&device2_, 7, data, arraysize(data), 99); stream_ 55 media/midi/usb_midi_output_stream_unittest.cc stream_.reset(new UsbMidiOutputStream(jack)); stream_ 59 media/midi/usb_midi_output_stream_unittest.cc scoped_ptr<UsbMidiOutputStream> stream_; stream_ 66 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(std::vector<uint8>()); stream_ 74 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 79 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(std::vector<uint8>(1, 0x90)); stream_ 80 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(std::vector<uint8>(1, 0x45)); stream_ 83 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(std::vector<uint8>(1, 0x7f)); stream_ 87 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(std::vector<uint8>(1, 0x90)); stream_ 88 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(std::vector<uint8>(1, 0x45)); stream_ 96 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data1)); stream_ 97 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data2)); stream_ 106 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 113 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 120 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 127 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 134 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 141 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 148 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 155 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 162 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 170 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 178 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 188 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data1)); stream_ 191 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data2)); stream_ 195 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data3)); stream_ 203 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 212 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 219 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 226 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 233 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 241 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data1)); stream_ 244 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data2)); stream_ 251 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 267 media/midi/usb_midi_output_stream_unittest.cc stream_->Send(ToVector(data)); stream_ 16 native_client_sdk/src/libraries/nacl_io/stream/stream_event_emitter.cc StreamEventEmitter::StreamEventEmitter() : stream_(NULL) {} stream_ 20 native_client_sdk/src/libraries/nacl_io/stream/stream_event_emitter.cc stream_ = stream; stream_ 27 native_client_sdk/src/libraries/nacl_io/stream/stream_event_emitter.cc stream_ = NULL; stream_ 28 native_client_sdk/src/libraries/nacl_io/stream/stream_event_emitter.h StreamNode* stream() { return stream_; } stream_ 39 native_client_sdk/src/libraries/nacl_io/stream/stream_event_emitter.h StreamNode* stream_; stream_ 755 net/base/file_stream_unittest.cc stream_(stream), stream_ 789 net/base/file_stream_unittest.cc stream_, &total_bytes_written, &total_bytes_read, &data_read); stream_ 790 net/base/file_stream_unittest.cc rv = stream_->Write( stream_ 799 net/base/file_stream_unittest.cc stream_->SeekSync(FROM_BEGIN, 0); stream_ 804 net/base/file_stream_unittest.cc rv = stream_->Read(buf.get(), buf->size(), callback.callback()); stream_ 827 net/base/file_stream_unittest.cc FileStream* stream_; stream_ 887 net/base/file_stream_unittest.cc stream_(stream), stream_ 917 net/base/file_stream_unittest.cc TestWriteCloseCompletionCallback callback(stream_, &total_bytes_written); stream_ 918 net/base/file_stream_unittest.cc rv = stream_->Write( stream_ 935 net/base/file_stream_unittest.cc FileStream* stream_; stream_ 152 net/http/http_network_transaction.cc if (stream_.get()) { stream_ 159 net/http/http_network_transaction.cc stream_->CanFindEndOfResponse() && stream_ 162 net/http/http_network_transaction.cc stream_->Close(true /* not reusable */); stream_ 164 net/http/http_network_transaction.cc if (stream_->IsResponseBodyComplete()) { stream_ 166 net/http/http_network_transaction.cc stream_->Close(false /* reusable */); stream_ 167 net/http/http_network_transaction.cc } else if (stream_->IsSpdyHttpStream()) { stream_ 169 net/http/http_network_transaction.cc stream_->Close(true /* not reusable */); stream_ 172 net/http/http_network_transaction.cc HttpStreamBase* stream = stream_.release(); stream_ 211 net/http/http_network_transaction.cc DCHECK(!stream_.get()); stream_ 228 net/http/http_network_transaction.cc DCHECK(!stream_.get()); stream_ 290 net/http/http_network_transaction.cc stream_->CanFindEndOfResponse()) { stream_ 293 net/http/http_network_transaction.cc if (!stream_->IsResponseBodyComplete()) { stream_ 310 net/http/http_network_transaction.cc if (stream_.get()) { stream_ 311 net/http/http_network_transaction.cc total_received_bytes_ += stream_->GetTotalReceivedBytes(); stream_ 313 net/http/http_network_transaction.cc if (keep_alive && stream_->IsConnectionReusable()) { stream_ 316 net/http/http_network_transaction.cc stream_->SetConnectionReused(); stream_ 318 net/http/http_network_transaction.cc static_cast<HttpStream*>(stream_.get())->RenewStreamForAuth(); stream_ 325 net/http/http_network_transaction.cc stream_->Close(true); stream_ 332 net/http/http_network_transaction.cc stream_.reset(new_stream); stream_ 394 net/http/http_network_transaction.cc if (stream_) stream_ 395 net/http/http_network_transaction.cc total_received_bytes += stream_->GetTotalReceivedBytes(); stream_ 430 net/http/http_network_transaction.cc if (!stream_.get()) stream_ 434 net/http/http_network_transaction.cc return static_cast<HttpStream*>(stream_.get())->GetUploadProgress(); stream_ 442 net/http/http_network_transaction.cc if (!stream_ || !stream_->GetLoadTimingInfo(load_timing_info)) stream_ 457 net/http/http_network_transaction.cc if (stream_) stream_ 458 net/http/http_network_transaction.cc stream_->SetPriority(priority); stream_ 482 net/http/http_network_transaction.cc if (stream_) stream_ 483 net/http/http_network_transaction.cc total_received_bytes_ += stream_->GetTotalReceivedBytes(); stream_ 484 net/http/http_network_transaction.cc stream_.reset(stream); stream_ 508 net/http/http_network_transaction.cc DCHECK(!stream_.get()); stream_ 521 net/http/http_network_transaction.cc DCHECK(!stream_.get()); stream_ 577 net/http/http_network_transaction.cc if (stream_) stream_ 578 net/http/http_network_transaction.cc total_received_bytes_ += stream_->GetTotalReceivedBytes(); stream_ 579 net/http/http_network_transaction.cc stream_.reset(stream); stream_ 749 net/http/http_network_transaction.cc DCHECK(stream_.get()); stream_ 768 net/http/http_network_transaction.cc DCHECK(stream_.get()); stream_ 770 net/http/http_network_transaction.cc return stream_->InitializeStream(request_, priority_, net_log_, io_callback_); stream_ 781 net/http/http_network_transaction.cc if (stream_) stream_ 782 net/http/http_network_transaction.cc total_received_bytes_ += stream_->GetTotalReceivedBytes(); stream_ 783 net/http/http_network_transaction.cc stream_.reset(); stream_ 929 net/http/http_network_transaction.cc return stream_->SendRequest(request_headers_, &response_, io_callback_); stream_ 943 net/http/http_network_transaction.cc return stream_->ReadResponseHeaders(io_callback_); stream_ 958 net/http/http_network_transaction.cc DCHECK(stream_.get()); stream_ 961 net/http/http_network_transaction.cc stream_->GetSSLCertRequestInfo(response_.cert_request_info.get()); stream_ 1097 net/http/http_network_transaction.cc stream_->GetSSLInfo(&response_.ssl_info); stream_ 1106 net/http/http_network_transaction.cc DCHECK(stream_ != NULL); stream_ 1109 net/http/http_network_transaction.cc return stream_->ReadResponseBody( stream_ 1122 net/http/http_network_transaction.cc if (stream_->IsResponseBodyComplete()) { stream_ 1132 net/http/http_network_transaction.cc if (stream_->CanFindEndOfResponse()) { stream_ 1142 net/http/http_network_transaction.cc stream_->Close(!keep_alive); stream_ 1179 net/http/http_network_transaction.cc } else if (stream_->IsResponseBodyComplete()) { stream_ 1207 net/http/http_network_transaction.cc bool reused_socket = stream_->IsConnectionReused(); stream_ 1251 net/http/http_network_transaction.cc if (!stream_->IsConnectionReused()) { stream_ 1272 net/http/http_network_transaction.cc if (stream_.get()) { stream_ 1276 net/http/http_network_transaction.cc total_received_bytes_ += stream_->GetTotalReceivedBytes(); stream_ 1277 net/http/http_network_transaction.cc stream_->Close(true); stream_ 1278 net/http/http_network_transaction.cc stream_.reset(); stream_ 1458 net/http/http_network_transaction.cc if (stream_) stream_ 1459 net/http/http_network_transaction.cc total_received_bytes_ += stream_->GetTotalReceivedBytes(); stream_ 1460 net/http/http_network_transaction.cc stream_.reset(); stream_ 1481 net/http/http_network_transaction.cc bool connection_is_proven = stream_->IsConnectionReused(); stream_ 1493 net/http/http_network_transaction.cc if (stream_.get()) { stream_ 1494 net/http/http_network_transaction.cc stream_->Close(true); stream_ 1495 net/http/http_network_transaction.cc stream_.reset(); stream_ 283 net/http/http_network_transaction.h scoped_ptr<HttpStreamBase> stream_; stream_ 71 net/http/http_pipelined_connection_impl_unittest.cc : stream_(stream), stream_ 78 net/http/http_pipelined_connection_impl_unittest.cc stream_->Close(false); stream_ 86 net/http/http_pipelined_connection_impl_unittest.cc HttpStream* stream_; stream_ 991 net/http/http_pipelined_connection_impl_unittest.cc : stream_(stream), stream_ 997 net/http/http_pipelined_connection_impl_unittest.cc EXPECT_FALSE(stream_); stream_ 1004 net/http/http_pipelined_connection_impl_unittest.cc stream_->Close(true); stream_ 1005 net/http/http_pipelined_connection_impl_unittest.cc stream_.reset(); stream_ 1008 net/http/http_pipelined_connection_impl_unittest.cc scoped_ptr<HttpStream> stream_; stream_ 18 net/http/http_response_body_drainer.cc stream_(stream), stream_ 89 net/http/http_response_body_drainer.cc return stream_->ReadResponseBody( stream_ 103 net/http/http_response_body_drainer.cc if (stream_->IsResponseBodyComplete()) stream_ 136 net/http/http_response_body_drainer.cc stream_->Close(true /* no keep-alive */); stream_ 139 net/http/http_response_body_drainer.cc stream_->Close(false /* keep-alive */); stream_ 59 net/http/http_response_body_drainer.h const scoped_ptr<HttpStreamBase> stream_; stream_ 130 net/http/http_stream_factory_impl_job.cc if (stream_.get() && next_state_ != STATE_DONE) stream_ 131 net/http/http_stream_factory_impl_job.cc stream_->Close(true /* not reusable */); stream_ 160 net/http/http_stream_factory_impl_job.cc stream_.reset(); stream_ 302 net/http/http_stream_factory_impl_job.cc DCHECK(stream_.get()); stream_ 313 net/http/http_stream_factory_impl_job.cc stream_.release()); stream_ 337 net/http/http_stream_factory_impl_job.cc DCHECK(stream_.get()); stream_ 353 net/http/http_stream_factory_impl_job.cc this, stream_.Pass(), spdy_session, spdy_session_direct_); stream_ 529 net/http/http_stream_factory_impl_job.cc DCHECK(stream_.get()); stream_ 987 net/http/http_stream_factory_impl_job.cc stream_ = quic_request_.ReleaseStream(); stream_ 1060 net/http/http_stream_factory_impl_job.cc stream_.reset(stream_factory_->http_pipelined_host_pool_. stream_ 1063 net/http/http_stream_factory_impl_job.cc CHECK(stream_.get()); stream_ 1072 net/http/http_stream_factory_impl_job.cc stream_.reset( stream_ 1081 net/http/http_stream_factory_impl_job.cc CHECK(stream_.get()); stream_ 1083 net/http/http_stream_factory_impl_job.cc stream_.reset(new HttpBasicStream(connection_.release(), using_proxy)); stream_ 1088 net/http/http_stream_factory_impl_job.cc CHECK(!stream_.get()); stream_ 1134 net/http/http_stream_factory_impl_job.cc stream_.reset(new SpdyHttpStream(new_spdy_session_, use_relative_url)); stream_ 1152 net/http/http_stream_factory_impl_job.cc stream_.reset(new SpdyHttpStream(spdy_session, use_relative_url)); stream_ 299 net/http/http_stream_factory_impl_job.h scoped_ptr<HttpStream> stream_; stream_ 173 net/http/http_stream_factory_impl_unittest.cc stream_.reset(stream); stream_ 229 net/http/http_stream_factory_impl_unittest.cc return stream_.get(); stream_ 241 net/http/http_stream_factory_impl_unittest.cc scoped_ptr<HttpStreamBase> stream_; stream_ 76 net/quic/quic_client_session.cc QuicClientSession::StreamRequest::StreamRequest() : stream_(NULL) {} stream_ 87 net/quic/quic_client_session.cc stream_ = stream; stream_ 88 net/quic/quic_client_session.cc int rv = session_->TryCreateStream(this, stream_); stream_ 106 net/quic/quic_client_session.cc *stream_ = stream; stream_ 84 net/quic/quic_client_session.h QuicReliableClientStream** stream_; stream_ 19 net/quic/quic_crypto_client_stream.cc : stream_(stream) {} stream_ 28 net/quic/quic_crypto_client_stream.cc if (stream_ == NULL) { stream_ 32 net/quic/quic_crypto_client_stream.cc stream_->verify_ok_ = ok; stream_ 33 net/quic/quic_crypto_client_stream.cc stream_->verify_error_details_ = error_details; stream_ 34 net/quic/quic_crypto_client_stream.cc stream_->verify_details_.reset(details->release()); stream_ 35 net/quic/quic_crypto_client_stream.cc stream_->proof_verify_callback_ = NULL; stream_ 36 net/quic/quic_crypto_client_stream.cc stream_->DoHandshakeLoop(NULL); stream_ 43 net/quic/quic_crypto_client_stream.cc stream_ = NULL; stream_ 65 net/quic/quic_crypto_client_stream.h QuicCryptoClientStream* stream_; stream_ 35 net/quic/quic_crypto_client_stream_test.cc session_->SetCryptoStream(stream_.get()); stream_ 41 net/quic/quic_crypto_client_stream_test.cc EXPECT_TRUE(stream_->CryptoConnect()); stream_ 42 net/quic/quic_crypto_client_stream_test.cc CryptoTestUtils::HandshakeWithFakeServer(connection_, stream_.get()); stream_ 53 net/quic/quic_crypto_client_stream_test.cc scoped_ptr<QuicCryptoClientStream> stream_; stream_ 60 net/quic/quic_crypto_client_stream_test.cc EXPECT_FALSE(stream_->encryption_established()); stream_ 61 net/quic/quic_crypto_client_stream_test.cc EXPECT_FALSE(stream_->handshake_confirmed()); stream_ 66 net/quic/quic_crypto_client_stream_test.cc EXPECT_TRUE(stream_->encryption_established()); stream_ 67 net/quic/quic_crypto_client_stream_test.cc EXPECT_TRUE(stream_->handshake_confirmed()); stream_ 77 net/quic/quic_crypto_client_stream_test.cc stream_->ProcessRawData(message_data_->data(), message_data_->length()); stream_ 81 net/quic/quic_crypto_client_stream_test.cc EXPECT_TRUE(stream_->CryptoConnect()); stream_ 88 net/quic/quic_crypto_client_stream_test.cc stream_->ProcessRawData(message_data_->data(), message_data_->length()); stream_ 104 net/quic/quic_crypto_client_stream_test.cc stream_->crypto_negotiated_params()); stream_ 111 net/quic/quic_crypto_client_stream_test.cc stream_.reset(new QuicCryptoClientStream(server_id, session_.get(), NULL, stream_ 113 net/quic/quic_crypto_client_stream_test.cc session_->SetCryptoStream(stream_.get()); stream_ 116 net/quic/quic_crypto_client_stream_test.cc EXPECT_TRUE(stream_->encryption_established()); stream_ 117 net/quic/quic_crypto_client_stream_test.cc EXPECT_TRUE(stream_->handshake_confirmed()); stream_ 126 net/quic/quic_crypto_client_stream_test.cc stream_.reset(new QuicCryptoClientStream(server_id_, session_.get(), NULL, stream_ 129 net/quic/quic_crypto_client_stream_test.cc session_->SetCryptoStream(stream_.get()); stream_ 139 net/quic/quic_crypto_client_stream_test.cc EXPECT_TRUE(stream_->CryptoConnect()); stream_ 62 net/quic/quic_crypto_server_stream_test.cc stream_(crypto_config_, &session_), stream_ 66 net/quic/quic_crypto_server_stream_test.cc session_.SetCryptoStream(&stream_); stream_ 102 net/quic/quic_crypto_server_stream_test.cc return CryptoTestUtils::HandshakeWithFakeClient(connection_, &stream_, stream_ 111 net/quic/quic_crypto_server_stream_test.cc QuicCryptoServerStream stream_; stream_ 121 net/quic/quic_crypto_server_stream_test.cc EXPECT_FALSE(stream_.encryption_established()); stream_ 122 net/quic/quic_crypto_server_stream_test.cc EXPECT_FALSE(stream_.handshake_confirmed()); stream_ 131 net/quic/quic_crypto_server_stream_test.cc EXPECT_TRUE(stream_.encryption_established()); stream_ 132 net/quic/quic_crypto_server_stream_test.cc EXPECT_TRUE(stream_.handshake_confirmed()); stream_ 233 net/quic/quic_crypto_server_stream_test.cc stream_.ProcessRawData(message_data_->data(), message_data_->length()); stream_ 241 net/quic/quic_crypto_server_stream_test.cc stream_.ProcessRawData(message_data_->data(), message_data_->length()); stream_ 251 net/quic/quic_crypto_server_stream_test.cc EXPECT_TRUE(stream_.encryption_established()); stream_ 252 net/quic/quic_crypto_server_stream_test.cc EXPECT_TRUE(stream_.handshake_confirmed()); stream_ 260 net/quic/quic_crypto_server_stream_test.cc EXPECT_TRUE(stream_.encryption_established()); stream_ 261 net/quic/quic_crypto_server_stream_test.cc EXPECT_TRUE(stream_.handshake_confirmed()); stream_ 67 net/quic/quic_crypto_stream_test.cc MockQuicCryptoStream stream_; stream_ 76 net/quic/quic_crypto_stream_test.cc EXPECT_FALSE(stream_.encryption_established()); stream_ 77 net/quic/quic_crypto_stream_test.cc EXPECT_FALSE(stream_.handshake_confirmed()); stream_ 82 net/quic/quic_crypto_stream_test.cc stream_.ProcessRawData(message_data_->data(), stream_ 84 net/quic/quic_crypto_stream_test.cc ASSERT_EQ(1u, stream_.messages()->size()); stream_ 85 net/quic/quic_crypto_stream_test.cc const CryptoHandshakeMessage& message = (*stream_.messages())[0]; stream_ 102 net/quic/quic_crypto_stream_test.cc EXPECT_EQ(0u, stream_.ProcessRawData(bad.data(), bad.length())); stream_ 107 net/quic/quic_crypto_stream_test.cc EXPECT_FALSE(stream_.IsFlowControlEnabled()); stream_ 98 net/quic/quic_data_stream_test.cc stream_.reset(new TestStream(kStreamId, session_.get(), stream_ 109 net/quic/quic_data_stream_test.cc scoped_ptr<TestStream> stream_; stream_ 122 net/quic/quic_data_stream_test.cc stream_->OnStreamHeadersPriority(QuicUtils::HighestPriority()); stream_ 123 net/quic/quic_data_stream_test.cc stream_->OnStreamHeaders(headers); stream_ 124 net/quic/quic_data_stream_test.cc EXPECT_EQ(headers, stream_->data()); stream_ 125 net/quic/quic_data_stream_test.cc stream_->OnStreamHeadersComplete(false, headers.size()); stream_ 126 net/quic/quic_data_stream_test.cc EXPECT_EQ(QuicUtils::HighestPriority(), stream_->EffectivePriority()); stream_ 127 net/quic/quic_data_stream_test.cc EXPECT_EQ(headers, stream_->data()); stream_ 128 net/quic/quic_data_stream_test.cc EXPECT_FALSE(stream_->IsDoneReading()); stream_ 137 net/quic/quic_data_stream_test.cc stream_->OnStreamHeaders(headers); stream_ 138 net/quic/quic_data_stream_test.cc EXPECT_EQ(headers, stream_->data()); stream_ 139 net/quic/quic_data_stream_test.cc stream_->OnStreamHeadersComplete(false, headers.size()); stream_ 141 net/quic/quic_data_stream_test.cc stream_->OnStreamFrame(frame); stream_ 143 net/quic/quic_data_stream_test.cc EXPECT_EQ(headers + body, stream_->data()); stream_ 158 net/quic/quic_data_stream_test.cc stream_->OnStreamHeaders(fragment); stream_ 160 net/quic/quic_data_stream_test.cc stream_->OnStreamHeadersComplete(false, headers.size()); stream_ 166 net/quic/quic_data_stream_test.cc stream_->OnStreamFrame(frame); stream_ 169 net/quic/quic_data_stream_test.cc stream_->data()) << "fragment_size: " << fragment_size; stream_ 180 net/quic/quic_data_stream_test.cc stream_->OnStreamHeaders(headers1); stream_ 184 net/quic/quic_data_stream_test.cc stream_->OnStreamHeaders(headers2); stream_ 185 net/quic/quic_data_stream_test.cc stream_->OnStreamHeadersComplete(false, headers.size()); stream_ 189 net/quic/quic_data_stream_test.cc stream_->OnStreamFrame(frame1); stream_ 195 net/quic/quic_data_stream_test.cc stream_->OnStreamFrame(frame2); stream_ 198 net/quic/quic_data_stream_test.cc stream_->data()) << "split_point: " << split_point; stream_ 208 net/quic/quic_data_stream_test.cc stream_->OnStreamHeaders(headers); stream_ 209 net/quic/quic_data_stream_test.cc EXPECT_EQ(headers, stream_->data()); stream_ 210 net/quic/quic_data_stream_test.cc stream_->OnStreamHeadersComplete(false, headers.size()); stream_ 212 net/quic/quic_data_stream_test.cc stream_->OnStreamFrame(frame); stream_ 220 net/quic/quic_data_stream_test.cc size_t bytes_read = stream_->Readv(&vec, 1); stream_ 224 net/quic/quic_data_stream_test.cc bytes_read = stream_->Readv(&vec, 1); stream_ 234 net/quic/quic_data_stream_test.cc stream_->OnStreamHeaders(headers); stream_ 235 net/quic/quic_data_stream_test.cc EXPECT_EQ(headers, stream_->data()); stream_ 236 net/quic/quic_data_stream_test.cc stream_->OnStreamHeadersComplete(false, headers.size()); stream_ 238 net/quic/quic_data_stream_test.cc stream_->OnStreamFrame(frame); stream_ 248 net/quic/quic_data_stream_test.cc size_t bytes_read = stream_->Readv(&vec, 1); stream_ 259 net/quic/quic_data_stream_test.cc stream_->OnStreamHeaders(headers); stream_ 260 net/quic/quic_data_stream_test.cc EXPECT_EQ(headers, stream_->data()); stream_ 261 net/quic/quic_data_stream_test.cc stream_->OnStreamHeadersComplete(false, headers.size()); stream_ 263 net/quic/quic_data_stream_test.cc stream_->OnStreamFrame(frame); stream_ 275 net/quic/quic_data_stream_test.cc size_t bytes_read = stream_->Readv(vec, 2); stream_ 294 net/quic/quic_data_stream_test.cc ReliableQuicStreamPeer::SetFlowControlSendOffset(stream_.get(), kWindow); stream_ 295 net/quic/quic_data_stream_test.cc EXPECT_EQ(kWindow, ReliableQuicStreamPeer::SendWindowSize(stream_.get())); stream_ 306 net/quic/quic_data_stream_test.cc stream_->WriteOrBufferData(body, false, NULL); stream_ 309 net/quic/quic_data_stream_test.cc EXPECT_EQ(0u, ReliableQuicStreamPeer::SendWindowSize(stream_.get())); stream_ 313 net/quic/quic_data_stream_test.cc ReliableQuicStreamPeer::SizeOfQueuedData(stream_.get())); stream_ 334 net/quic/quic_data_stream_test.cc ReliableQuicStreamPeer::SetFlowControlReceiveOffset(stream_.get(), stream_ 336 net/quic/quic_data_stream_test.cc ReliableQuicStreamPeer::SetFlowControlMaxReceiveWindow(stream_.get(), stream_ 338 net/quic/quic_data_stream_test.cc EXPECT_EQ(kWindow, ReliableQuicStreamPeer::ReceiveWindowSize(stream_.get())); stream_ 344 net/quic/quic_data_stream_test.cc stream_->OnStreamHeaders(headers); stream_ 345 net/quic/quic_data_stream_test.cc EXPECT_EQ(headers, stream_->data()); stream_ 346 net/quic/quic_data_stream_test.cc stream_->OnStreamHeadersComplete(false, headers.size()); stream_ 349 net/quic/quic_data_stream_test.cc stream_->OnStreamFrame(frame1); stream_ 351 net/quic/quic_data_stream_test.cc ReliableQuicStreamPeer::ReceiveWindowSize(stream_.get())); stream_ 357 net/quic/quic_data_stream_test.cc stream_->OnStreamFrame(frame2); stream_ 359 net/quic/quic_data_stream_test.cc ReliableQuicStreamPeer::ReceiveWindowSize(stream_.get())); stream_ 375 net/quic/quic_data_stream_test.cc ReliableQuicStreamPeer::SetFlowControlReceiveOffset(stream_.get(), stream_ 377 net/quic/quic_data_stream_test.cc ReliableQuicStreamPeer::SetFlowControlMaxReceiveWindow(stream_.get(), stream_ 379 net/quic/quic_data_stream_test.cc EXPECT_EQ(kWindow, ReliableQuicStreamPeer::ReceiveWindowSize(stream_.get())); stream_ 385 net/quic/quic_data_stream_test.cc stream_->OnStreamHeaders(headers); stream_ 386 net/quic/quic_data_stream_test.cc EXPECT_EQ(headers, stream_->data()); stream_ 387 net/quic/quic_data_stream_test.cc stream_->OnStreamHeadersComplete(false, headers.size()); stream_ 390 net/quic/quic_data_stream_test.cc stream_->OnStreamFrame(frame1); stream_ 392 net/quic/quic_data_stream_test.cc ReliableQuicStreamPeer::ReceiveWindowSize(stream_.get())); stream_ 403 net/quic/quic_data_stream_test.cc ReliableQuicStreamPeer::ReceiveWindowSize(stream_.get()) + kWindow)); stream_ 404 net/quic/quic_data_stream_test.cc stream_->OnStreamFrame(frame2); stream_ 406 net/quic/quic_data_stream_test.cc ReliableQuicStreamPeer::ReceiveWindowSize(stream_.get())); stream_ 423 net/quic/quic_data_stream_test.cc ReliableQuicStreamPeer::SetFlowControlReceiveOffset(stream_.get(), stream_ 430 net/quic/quic_data_stream_test.cc stream_->OnStreamHeaders(headers); stream_ 431 net/quic/quic_data_stream_test.cc EXPECT_EQ(headers, stream_->data()); stream_ 432 net/quic/quic_data_stream_test.cc stream_->OnStreamHeadersComplete(false, headers.size()); stream_ 437 net/quic/quic_data_stream_test.cc EXPECT_DFATAL(stream_->OnStreamFrame(frame), stream_ 454 net/quic/quic_data_stream_test.cc ReliableQuicStreamPeer::SetFlowControlReceiveOffset(stream_.get(), 0); stream_ 455 net/quic/quic_data_stream_test.cc EXPECT_EQ(0u, ReliableQuicStreamPeer::ReceiveWindowSize(stream_.get())); stream_ 465 net/quic/quic_data_stream_test.cc stream_->WriteOrBufferData(body, fin, NULL); stream_ 26 net/quic/quic_headers_stream.cc explicit SpdyFramerVisitor(QuicHeadersStream* stream) : stream_(stream) {} stream_ 34 net/quic/quic_headers_stream.cc if (!stream_->IsConnected()) { stream_ 48 net/quic/quic_headers_stream.cc stream_->OnSynStream(stream_id, priority, fin); stream_ 52 net/quic/quic_headers_stream.cc if (!stream_->IsConnected()) { stream_ 56 net/quic/quic_headers_stream.cc stream_->OnSynReply(stream_id, fin); stream_ 62 net/quic/quic_headers_stream.cc if (!stream_->IsConnected()) { stream_ 65 net/quic/quic_headers_stream.cc stream_->OnControlFrameHeaderData(stream_id, header_data, len); stream_ 149 net/quic/quic_headers_stream.cc if (stream_->IsConnected()) { stream_ 150 net/quic/quic_headers_stream.cc stream_->OnCompressedFrameSize(frame_len); stream_ 156 net/quic/quic_headers_stream.cc if (stream_->IsConnected()) { stream_ 157 net/quic/quic_headers_stream.cc stream_->CloseConnectionWithDetails( stream_ 163 net/quic/quic_headers_stream.cc QuicHeadersStream* stream_; stream_ 33 net/quic/quic_http_stream.cc stream_(NULL), stream_ 58 net/quic/quic_http_stream.cc DCHECK(!stream_); stream_ 77 net/quic/quic_http_stream.cc session_, &stream_, base::Bind(&QuicHttpStream::OnStreamReady, stream_ 82 net/quic/quic_http_stream.cc stream_->SetDelegate(this); stream_ 91 net/quic/quic_http_stream.cc DCHECK(rv == OK || !stream_); stream_ 93 net/quic/quic_http_stream.cc stream_->SetDelegate(this); stream_ 104 net/quic/quic_http_stream.cc CHECK(stream_); stream_ 111 net/quic/quic_http_stream.cc stream_->set_priority(priority); stream_ 156 net/quic/quic_http_stream.cc if (stream_ == NULL) stream_ 202 net/quic/quic_http_stream.cc if (!stream_) { stream_ 219 net/quic/quic_http_stream.cc if (stream_) { stream_ 220 net/quic/quic_http_stream.cc closed_stream_received_bytes_ = stream_->stream_bytes_read(); stream_ 221 net/quic/quic_http_stream.cc stream_->SetDelegate(NULL); stream_ 222 net/quic/quic_http_stream.cc stream_->Reset(QUIC_STREAM_CANCELLED); stream_ 223 net/quic/quic_http_stream.cc stream_ = NULL; stream_ 232 net/quic/quic_http_stream.cc return next_state_ == STATE_OPEN && !stream_; stream_ 241 net/quic/quic_http_stream.cc return stream_ && stream_->id() > 1; stream_ 254 net/quic/quic_http_stream.cc if (stream_) { stream_ 255 net/quic/quic_http_stream.cc return stream_->stream_bytes_read(); stream_ 267 net/quic/quic_http_stream.cc DCHECK(stream_); stream_ 268 net/quic/quic_http_stream.cc stream_->GetSSLInfo(ssl_info); stream_ 273 net/quic/quic_http_stream.cc DCHECK(stream_); stream_ 338 net/quic/quic_http_stream.cc closed_stream_received_bytes_ = stream_->stream_bytes_read(); stream_ 339 net/quic/quic_http_stream.cc stream_ = NULL; stream_ 345 net/quic/quic_http_stream.cc stream_ = NULL; stream_ 422 net/quic/quic_http_stream.cc if (!stream_) stream_ 430 net/quic/quic_http_stream.cc stream_->net_log().AddEvent( stream_ 437 net/quic/quic_http_stream.cc int rv = stream_->WriteHeaders(request_headers_, !has_upload_data, NULL); stream_ 476 net/quic/quic_http_stream.cc if (!stream_) stream_ 486 net/quic/quic_http_stream.cc return stream_->WriteStreamData( stream_ 530 net/quic/quic_http_stream.cc stream_->net_log().AddEvent( stream_ 539 net/quic/quic_http_stream.cc IPEndPoint address = stream_->GetPeerAddress(); stream_ 113 net/quic/quic_http_stream.h QuicReliableClientStream* stream_; // Non-owning. stream_ 106 net/quic/quic_http_stream_test.cc return stream->stream_; stream_ 216 net/quic/quic_http_stream_test.cc stream_.reset(use_closing_stream_ ? stream_ 288 net/quic/quic_http_stream_test.cc scoped_ptr<QuicHttpStream> stream_; stream_ 319 net/quic/quic_http_stream_test.cc EXPECT_EQ(NULL, stream_->RenewStreamForAuth()); stream_ 324 net/quic/quic_http_stream_test.cc EXPECT_TRUE(stream_->CanFindEndOfResponse()); stream_ 329 net/quic/quic_http_stream_test.cc EXPECT_FALSE(stream_->IsConnectionReusable()); stream_ 340 net/quic/quic_http_stream_test.cc EXPECT_EQ(OK, stream_->InitializeStream(&request_, DEFAULT_PRIORITY, stream_ 342 net/quic/quic_http_stream_test.cc EXPECT_EQ(OK, stream_->SendRequest(headers_, &response_, stream_ 344 net/quic/quic_http_stream_test.cc EXPECT_EQ(&response_, stream_->GetResponseInfo()); stream_ 350 net/quic/quic_http_stream_test.cc stream_->ReadResponseHeaders(callback_.callback())); stream_ 362 net/quic/quic_http_stream_test.cc EXPECT_EQ(0, stream_->ReadResponseBody(read_buffer_.get(), stream_ 365 net/quic/quic_http_stream_test.cc EXPECT_TRUE(stream_->IsResponseBodyComplete()); stream_ 378 net/quic/quic_http_stream_test.cc EXPECT_EQ(OK, stream_->InitializeStream(&request_, DEFAULT_PRIORITY, stream_ 380 net/quic/quic_http_stream_test.cc EXPECT_EQ(OK, stream_->SendRequest(headers_, &response_, stream_ 382 net/quic/quic_http_stream_test.cc EXPECT_EQ(&response_, stream_->GetResponseInfo()); stream_ 388 net/quic/quic_http_stream_test.cc stream_->ReadResponseHeaders(callback_.callback())); stream_ 398 net/quic/quic_http_stream_test.cc stream_->OnDataReceived(response.data(), response.length()); stream_ 399 net/quic/quic_http_stream_test.cc stream_->OnClose(QUIC_NO_ERROR); stream_ 408 net/quic/quic_http_stream_test.cc EXPECT_EQ(0, stream_->ReadResponseBody(read_buffer_.get(), stream_ 411 net/quic/quic_http_stream_test.cc EXPECT_TRUE(stream_->IsResponseBodyComplete()); stream_ 432 net/quic/quic_http_stream_test.cc EXPECT_EQ(OK, stream_->InitializeStream(&request_, DEFAULT_PRIORITY, stream_ 434 net/quic/quic_http_stream_test.cc EXPECT_EQ(OK, stream_->SendRequest(headers_, &response_, stream_ 436 net/quic/quic_http_stream_test.cc EXPECT_EQ(&response_, stream_->GetResponseInfo()); stream_ 446 net/quic/quic_http_stream_test.cc EXPECT_EQ(OK, stream_->ReadResponseHeaders(callback_.callback())); stream_ 456 net/quic/quic_http_stream_test.cc stream_->ReadResponseBody(read_buffer_.get(), read_buffer_->size(), stream_ 459 net/quic/quic_http_stream_test.cc EXPECT_TRUE(stream_->IsResponseBodyComplete()); stream_ 481 net/quic/quic_http_stream_test.cc ASSERT_EQ(OK, stream_->InitializeStream(&request_, DEFAULT_PRIORITY, stream_ 483 net/quic/quic_http_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->SendRequest(headers_, &response_, stream_ 485 net/quic/quic_http_stream_test.cc EXPECT_EQ(&response_, stream_->GetResponseInfo()); stream_ 497 net/quic/quic_http_stream_test.cc ASSERT_EQ(OK, stream_->ReadResponseHeaders(callback_.callback())); stream_ 509 net/quic/quic_http_stream_test.cc stream_->ReadResponseBody(read_buffer_.get(), read_buffer_->size(), stream_ 512 net/quic/quic_http_stream_test.cc EXPECT_TRUE(stream_->IsResponseBodyComplete()); stream_ 526 net/quic/quic_http_stream_test.cc EXPECT_EQ(OK, stream_->InitializeStream(&request_, DEFAULT_PRIORITY, stream_ 528 net/quic/quic_http_stream_test.cc EXPECT_EQ(OK, stream_->SendRequest(headers_, &response_, stream_ 530 net/quic/quic_http_stream_test.cc EXPECT_EQ(&response_, stream_->GetResponseInfo()); stream_ 535 net/quic/quic_http_stream_test.cc stream_->ReadResponseHeaders(callback_.callback())); stream_ 555 net/quic/quic_http_stream_test.cc EXPECT_EQ(OK, stream_->InitializeStream(&request_, MEDIUM, stream_ 560 net/quic/quic_http_stream_test.cc QuicHttpStreamPeer::GetQuicReliableClientStream(stream_.get()); stream_ 565 net/quic/quic_http_stream_test.cc EXPECT_EQ(OK, stream_->SendRequest(headers_, &response_, stream_ 567 net/quic/quic_http_stream_test.cc EXPECT_EQ(&response_, stream_->GetResponseInfo()); stream_ 576 net/quic/quic_http_stream_test.cc stream_->ReadResponseHeaders(callback_.callback())); stream_ 600 net/quic/quic_http_stream_test.cc EXPECT_EQ(OK, stream_->InitializeStream(&request_, MEDIUM, stream_ 605 net/quic/quic_http_stream_test.cc QuicHttpStreamPeer::GetQuicReliableClientStream(stream_.get()); stream_ 46 net/quic/quic_reliable_client_stream_test.cc stream_ = new QuicReliableClientStream(kStreamId, &session_, BoundNetLog()); stream_ 47 net/quic/quic_reliable_client_stream_test.cc session_.ActivateStream(stream_); stream_ 48 net/quic/quic_reliable_client_stream_test.cc stream_->SetDelegate(&delegate_); stream_ 83 net/quic/quic_reliable_client_stream_test.cc QuicReliableClientStream* stream_; stream_ 98 net/quic/quic_reliable_client_stream_test.cc stream_->OnStreamHeaders(uncompressed_headers); stream_ 99 net/quic/quic_reliable_client_stream_test.cc stream_->OnStreamHeadersComplete(false, uncompressed_headers.length()); stream_ 104 net/quic/quic_reliable_client_stream_test.cc stream_->OnStreamFrame(frame2); stream_ 112 net/quic/quic_reliable_client_stream_test.cc EXPECT_EQ(arraysize(data), stream_->ProcessData(data, arraysize(data))); stream_ 123 net/quic/quic_reliable_client_stream_test.cc EXPECT_EQ(0u, stream_->ProcessData(data, arraysize(data))); stream_ 129 net/quic/quic_reliable_client_stream_test.cc stream_->OnError(ERR_INTERNET_DISCONNECTED); stream_ 130 net/quic/quic_reliable_client_stream_test.cc EXPECT_FALSE(stream_->GetDelegate()); stream_ 140 net/quic/quic_reliable_client_stream_test.cc EXPECT_CALL(session_, WritevData(stream_->id(), _, _, _, _)).WillOnce( stream_ 143 net/quic/quic_reliable_client_stream_test.cc EXPECT_EQ(OK, stream_->WriteStreamData(base::StringPiece(kData1, kDataLen), stream_ 155 net/quic/quic_reliable_client_stream_test.cc EXPECT_CALL(session_, WritevData(stream_->id(), _, _, _, _)).WillOnce( stream_ 159 net/quic/quic_reliable_client_stream_test.cc stream_->WriteStreamData(base::StringPiece(kData1, kDataLen), stream_ 164 net/quic/quic_reliable_client_stream_test.cc EXPECT_CALL(session_, WritevData(stream_->id(), _, _, _, _)).WillOnce( stream_ 166 net/quic/quic_reliable_client_stream_test.cc stream_->OnCanWrite(); stream_ 345 net/quic/quic_stream_factory.cc DCHECK(!stream_); stream_ 359 net/quic/quic_stream_factory.cc DCHECK(stream_); stream_ 365 net/quic/quic_stream_factory.cc stream_ = stream.Pass(); stream_ 374 net/quic/quic_stream_factory.cc DCHECK(stream_); stream_ 375 net/quic/quic_stream_factory.cc return stream_.Pass(); stream_ 78 net/quic/quic_stream_factory.h scoped_ptr<QuicHttpStream> stream_; stream_ 19 net/quic/quic_stream_sequencer.cc : stream_(quic_stream), stream_ 29 net/quic/quic_stream_sequencer.cc : stream_(quic_stream), stream_ 89 net/quic/quic_stream_sequencer.cc stream_->CloseConnectionWithDetails(QUIC_INVALID_STREAM_FRAME, stream_ 110 net/quic/quic_stream_sequencer.cc bytes_consumed += stream_->ProcessRawData( stream_ 115 net/quic/quic_stream_sequencer.cc stream_->MaybeSendWindowUpdate(); stream_ 121 net/quic/quic_stream_sequencer.cc stream_->Reset(QUIC_ERROR_PROCESSING_STREAM); stream_ 152 net/quic/quic_stream_sequencer.cc stream_->Reset(QUIC_MULTIPLE_TERMINATION_OFFSETS); stream_ 168 net/quic/quic_stream_sequencer.cc stream_->OnFinRead(); stream_ 267 net/quic/quic_stream_sequencer.cc size_t bytes_consumed = stream_->ProcessRawData(data->c_str(), stream_ 274 net/quic/quic_stream_sequencer.cc stream_->Reset(QUIC_ERROR_PROCESSING_STREAM); // Programming error stream_ 293 net/quic/quic_stream_sequencer.cc stream_->MaybeSendWindowUpdate(); stream_ 94 net/quic/quic_stream_sequencer.h ReliableQuicStream* stream_; stream_ 99 net/quic/quic_stream_sequencer_test.cc stream_(&session_, 1), stream_ 100 net/quic/quic_stream_sequencer_test.cc sequencer_(new QuicStreamSequencerPeer(&stream_)) { stream_ 143 net/quic/quic_stream_sequencer_test.cc testing::StrictMock<MockStream> stream_; stream_ 148 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)) stream_ 161 net/quic/quic_stream_sequencer_test.cc EXPECT_DFATAL(sequencer_.reset(new QuicStreamSequencerPeer(2, &stream_)), stream_ 176 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)); stream_ 188 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)).WillOnce(Return(3)); stream_ 202 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)).WillOnce(Return(3)); stream_ 207 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("def"), 3)).WillOnce(Return(3)); stream_ 208 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, OnFinRead()); stream_ 219 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)).WillOnce(Return(3)); stream_ 220 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, OnFinRead()); stream_ 227 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, stream_ 235 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, OnFinRead()); stream_ 242 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)).WillOnce(Return(2)); stream_ 251 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)).WillOnce(Return(0)); stream_ 279 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)).WillOnce(Return(3)); stream_ 280 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("def"), 3)).WillOnce(Return(3)); stream_ 281 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("ghi"), 3)).WillOnce(Return(3)); stream_ 303 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)).WillOnce(Return(3)); stream_ 315 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("def"), 3)).WillOnce(Return(3)); stream_ 316 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("ghi"), 3)).WillOnce(Return(3)); stream_ 317 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("jkl"), 3)).WillOnce(Return(3)); stream_ 345 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)).WillOnce(Return(3)); stream_ 346 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("def"), 3)).WillOnce(Return(0)); stream_ 347 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("pqr"), 3)).WillOnce(Return(3)); stream_ 381 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)).WillOnce(Return(3)); stream_ 382 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("def"), 3)).WillOnce(Return(0)); stream_ 383 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("pqr"), 3)).WillOnce(Return(3)); stream_ 419 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)).WillOnce(Return(3)); stream_ 420 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, OnFinRead()); stream_ 430 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)).WillOnce(Return(3)); stream_ 431 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("def"), 3)).WillOnce(Return(3)); stream_ 432 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, OnFinRead()); stream_ 442 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)).WillOnce(Return(3)); stream_ 443 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, OnFinRead()); stream_ 456 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq("abc"), 3)).WillOnce(Return(0)); stream_ 469 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, Reset(QUIC_MULTIPLE_TERMINATION_OFFSETS)); stream_ 473 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, Reset(QUIC_MULTIPLE_TERMINATION_OFFSETS)); stream_ 524 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq(*data), data->size())) stream_ 547 net/quic/quic_stream_sequencer_test.cc EXPECT_CALL(stream_, ProcessRawData(StrEq(*data), data->size())) stream_ 117 net/quic/reliable_quic_stream_test.cc stream_.reset(new TestStream(kStreamId, session_.get(), stream_ 125 net/quic/reliable_quic_stream_test.cc bool fin_sent() { return ReliableQuicStreamPeer::FinSent(stream_.get()); } stream_ 126 net/quic/reliable_quic_stream_test.cc bool rst_sent() { return ReliableQuicStreamPeer::RstSent(stream_.get()); } stream_ 135 net/quic/reliable_quic_stream_test.cc scoped_ptr<TestStream> stream_; stream_ 151 net/quic/reliable_quic_stream_test.cc stream_->WriteOrBufferData(kData1, false, NULL); stream_ 160 net/quic/reliable_quic_stream_test.cc EXPECT_DFATAL(stream_->WriteOrBufferData(StringPiece(), false, NULL), ""); stream_ 171 net/quic/reliable_quic_stream_test.cc stream_->WriteOrBufferData(StringPiece(kData1, 2), false, NULL); stream_ 185 net/quic/reliable_quic_stream_test.cc stream_->WriteOrBufferData(StringPiece(kData1, 2), true, NULL); stream_ 196 net/quic/reliable_quic_stream_test.cc stream_->WriteOrBufferData(StringPiece(), true, NULL); stream_ 210 net/quic/reliable_quic_stream_test.cc stream_->WriteOrBufferData(kData1, false, NULL); stream_ 214 net/quic/reliable_quic_stream_test.cc stream_->WriteOrBufferData(kData2, false, NULL); stream_ 222 net/quic/reliable_quic_stream_test.cc stream_->OnCanWrite(); stream_ 227 net/quic/reliable_quic_stream_test.cc stream_->OnCanWrite(); stream_ 233 net/quic/reliable_quic_stream_test.cc stream_->CloseReadSide(); stream_ 234 net/quic/reliable_quic_stream_test.cc stream_->CloseWriteSide(); stream_ 235 net/quic/reliable_quic_stream_test.cc EXPECT_EQ(QUIC_STREAM_NO_ERROR, stream_->stream_error()); stream_ 236 net/quic/reliable_quic_stream_test.cc EXPECT_EQ(QUIC_NO_ERROR, stream_->connection_error()); stream_ 237 net/quic/reliable_quic_stream_test.cc stream_->OnConnectionClosed(QUIC_INTERNAL_ERROR, false); stream_ 238 net/quic/reliable_quic_stream_test.cc EXPECT_EQ(QUIC_STREAM_NO_ERROR, stream_->stream_error()); stream_ 239 net/quic/reliable_quic_stream_test.cc EXPECT_EQ(QUIC_NO_ERROR, stream_->connection_error()); stream_ 254 net/quic/reliable_quic_stream_test.cc stream_->WriteOrBufferData(StringPiece(kData1, 1), false, NULL); stream_ 260 net/quic/reliable_quic_stream_test.cc stream_->OnClose(); stream_ 277 net/quic/reliable_quic_stream_test.cc stream_->WriteOrBufferData(StringPiece(kData1, 1), true, NULL); stream_ 282 net/quic/reliable_quic_stream_test.cc stream_->OnClose(); stream_ 300 net/quic/reliable_quic_stream_test.cc stream_->Reset(QUIC_STREAM_CANCELLED); stream_ 306 net/quic/reliable_quic_stream_test.cc stream_->OnClose(); stream_ 322 net/quic/reliable_quic_stream_test.cc ReliableQuicStreamPeer::SendWindowOffset(stream_.get())); stream_ 325 net/quic/reliable_quic_stream_test.cc QuicWindowUpdateFrame window_update_1(stream_->id(), 1234); stream_ 326 net/quic/reliable_quic_stream_test.cc stream_->OnWindowUpdateFrame(window_update_1); stream_ 328 net/quic/reliable_quic_stream_test.cc ReliableQuicStreamPeer::SendWindowOffset(stream_.get())); stream_ 332 net/quic/reliable_quic_stream_test.cc QuicWindowUpdateFrame window_update_2(stream_->id(), 1); stream_ 333 net/quic/reliable_quic_stream_test.cc QuicWindowUpdateFrame window_update_3(stream_->id(), 9999); stream_ 334 net/quic/reliable_quic_stream_test.cc QuicWindowUpdateFrame window_update_4(stream_->id(), 5678); stream_ 335 net/quic/reliable_quic_stream_test.cc stream_->OnWindowUpdateFrame(window_update_2); stream_ 336 net/quic/reliable_quic_stream_test.cc stream_->OnWindowUpdateFrame(window_update_3); stream_ 337 net/quic/reliable_quic_stream_test.cc stream_->OnWindowUpdateFrame(window_update_4); stream_ 339 net/quic/reliable_quic_stream_test.cc ReliableQuicStreamPeer::SendWindowOffset(stream_.get())); stream_ 366 net/quic/reliable_quic_stream_test.cc stream_->WriteOrBufferData(kData, false, delegate.get()); stream_ 372 net/quic/reliable_quic_stream_test.cc stream_->OnCanWrite(); stream_ 378 net/quic/reliable_quic_stream_test.cc stream_->OnCanWrite(); stream_ 383 net/quic/reliable_quic_stream_test.cc stream_->OnCanWrite(); stream_ 415 net/quic/reliable_quic_stream_test.cc stream_->WriteOrBufferData(kData, false, delegate.get()); stream_ 426 net/quic/reliable_quic_stream_test.cc stream_->OnCanWrite(); stream_ 446 net/quic/reliable_quic_stream_test.cc stream_->WriteOrBufferData(kData1, true, delegate.get()); stream_ 465 net/quic/reliable_quic_stream_test.cc stream_->WriteOrBufferData(kData1, true, delegate.get()); stream_ 472 net/quic/reliable_quic_stream_test.cc stream_->OnCanWrite(); stream_ 493 net/quic/reliable_quic_stream_test.cc stream_->WriteOrBufferData(kData1, true, delegate.get()); stream_ 500 net/quic/reliable_quic_stream_test.cc stream_->OnCanWrite(); stream_ 49 net/spdy/spdy_http_stream.cc if (stream_.get()) { stream_ 50 net/spdy/spdy_http_stream.cc stream_->DetachDelegate(); stream_ 51 net/spdy/spdy_http_stream.cc DCHECK(!stream_.get()); stream_ 59 net/spdy/spdy_http_stream.cc DCHECK(!stream_); stream_ 65 net/spdy/spdy_http_stream.cc int error = spdy_session_->GetPushStream(request_info_->url, &stream_, stream_ 71 net/spdy/spdy_http_stream.cc if (stream_.get()) { stream_ 72 net/spdy/spdy_http_stream.cc DCHECK_EQ(stream_->type(), SPDY_PUSH_STREAM); stream_ 73 net/spdy/spdy_http_stream.cc stream_->SetDelegate(this); stream_ 85 net/spdy/spdy_http_stream.cc stream_ = stream_request_.ReleaseStream(); stream_ 86 net/spdy/spdy_http_stream.cc stream_->SetDelegate(this); stream_ 109 net/spdy/spdy_http_stream.cc CHECK(stream_.get()); stream_ 113 net/spdy/spdy_http_stream.cc CHECK(!stream_->IsIdle()); stream_ 125 net/spdy/spdy_http_stream.cc if (stream_.get()) stream_ 126 net/spdy/spdy_http_stream.cc CHECK(!stream_->IsIdle()); stream_ 153 net/spdy/spdy_http_stream.cc DCHECK(!stream_.get()); stream_ 185 net/spdy/spdy_http_stream.cc if (!stream_) stream_ 188 net/spdy/spdy_http_stream.cc return stream_->raw_received_bytes(); stream_ 203 net/spdy/spdy_http_stream.cc if (!stream_ || stream_->stream_id() == 0) stream_ 206 net/spdy/spdy_http_stream.cc return stream_->GetLoadTimingInfo(load_timing_info); stream_ 217 net/spdy/spdy_http_stream.cc CHECK(stream_.get()); stream_ 219 net/spdy/spdy_http_stream.cc stream_->SetRequestTime(request_time); stream_ 255 net/spdy/spdy_http_stream.cc int result = stream_->GetPeerAddress(&address); stream_ 260 net/spdy/spdy_http_stream.cc if (stream_->type() == SPDY_PUSH_STREAM) { stream_ 270 net/spdy/spdy_http_stream.cc headers.get(), stream_->GetProtocolVersion(), stream_ 272 net/spdy/spdy_http_stream.cc stream_->net_log().AddEvent( stream_ 276 net/spdy/spdy_http_stream.cc stream_->SendRequestHeaders( stream_ 290 net/spdy/spdy_http_stream.cc if (stream_.get()) { stream_ 291 net/spdy/spdy_http_stream.cc stream_->Cancel(); stream_ 292 net/spdy/spdy_http_stream.cc DCHECK(!stream_.get()); stream_ 311 net/spdy/spdy_http_stream.cc DCHECK_EQ(stream_->type(), SPDY_PUSH_STREAM); stream_ 317 net/spdy/spdy_http_stream.cc response_headers, stream_->GetProtocolVersion(), response_info_)) { stream_ 322 net/spdy/spdy_http_stream.cc response_info_->response_time = stream_->response_time(); stream_ 328 net/spdy/spdy_http_stream.cc stream_->GetSSLInfo(&ssl_info, stream_ 333 net/spdy/spdy_http_stream.cc response_info_->request_time = stream_->GetRequestTime(); stream_ 335 net/spdy/spdy_http_stream.cc HttpResponseInfo::ConnectionInfoFromNextProto(stream_->GetProtocol()); stream_ 351 net/spdy/spdy_http_stream.cc DCHECK(stream_.get()); stream_ 352 net/spdy/spdy_http_stream.cc DCHECK(!stream_->IsClosed() || stream_->type() == SPDY_PUSH_STREAM); stream_ 370 net/spdy/spdy_http_stream.cc if (stream_.get()) { stream_ 373 net/spdy/spdy_http_stream.cc closed_stream_id_ = stream_->stream_id(); stream_ 375 net/spdy/spdy_http_stream.cc stream_->GetLoadTimingInfo(&closed_stream_load_timing_info_); stream_ 376 net/spdy/spdy_http_stream.cc closed_stream_received_bytes_ = stream_->raw_received_bytes(); stream_ 378 net/spdy/spdy_http_stream.cc stream_.reset(); stream_ 400 net/spdy/spdy_http_stream.cc stream_ = stream_request_.ReleaseStream(); stream_ 401 net/spdy/spdy_http_stream.cc stream_->SetDelegate(this); stream_ 436 net/spdy/spdy_http_stream.cc stream_->SendData(request_body_buf_.get(), stream_ 476 net/spdy/spdy_http_stream.cc if (!stream_.get() && !stream_closed_) stream_ 480 net/spdy/spdy_http_stream.cc stream_closed_ ? closed_stream_status_ : stream_->response_status(); stream_ 515 net/spdy/spdy_http_stream.cc DCHECK(stream_.get()); stream_ 518 net/spdy/spdy_http_stream.cc stream_->GetSSLInfo(ssl_info, &using_npn, &protocol_negotiated); stream_ 523 net/spdy/spdy_http_stream.cc DCHECK(stream_.get()); stream_ 524 net/spdy/spdy_http_stream.cc stream_->GetSSLCertRequestInfo(cert_request_info); stream_ 37 net/spdy/spdy_http_stream.h SpdyStream* stream() { return stream_.get(); } stream_ 117 net/spdy/spdy_http_stream.h base::WeakPtr<SpdyStream> stream_; stream_ 6020 net/spdy/spdy_network_transaction_unittest.cc SpdyHttpStream* stream = static_cast<SpdyHttpStream*>(trans->stream_.get()); stream_ 6091 net/spdy/spdy_network_transaction_unittest.cc static_cast<SpdyHttpStream*>(trans->stream_.get()); stream_ 6297 net/spdy/spdy_network_transaction_unittest.cc SpdyHttpStream* stream = static_cast<SpdyHttpStream*>(trans->stream_.get()); stream_ 6412 net/spdy/spdy_network_transaction_unittest.cc SpdyHttpStream* stream = static_cast<SpdyHttpStream*>(trans->stream_.get()); stream_ 6536 net/spdy/spdy_network_transaction_unittest.cc SpdyHttpStream* stream = static_cast<SpdyHttpStream*>(trans->stream_.get()); stream_ 351 net/spdy/spdy_session.cc DCHECK(!stream_); stream_ 365 net/spdy/spdy_session.cc stream_ = stream; stream_ 380 net/spdy/spdy_session.cc base::WeakPtr<SpdyStream> stream = stream_; stream_ 389 net/spdy/spdy_session.cc DCHECK(!stream_); stream_ 394 net/spdy/spdy_session.cc stream_ = stream; stream_ 400 net/spdy/spdy_session.cc DCHECK(!stream_); stream_ 411 net/spdy/spdy_session.cc stream_.reset(); stream_ 182 net/spdy/spdy_session.h base::WeakPtr<SpdyStream> stream_; stream_ 60 net/spdy/spdy_stream.cc : stream_(stream) { stream_ 61 net/spdy/spdy_stream.cc DCHECK(stream_.get()); stream_ 67 net/spdy/spdy_stream.cc if (!stream_.get()) { stream_ 71 net/spdy/spdy_stream.cc DCHECK_GT(stream_->stream_id(), 0u); stream_ 73 net/spdy/spdy_stream.cc new SpdyBuffer(stream_->ProduceSynStreamFrame())); stream_ 77 net/spdy/spdy_stream.cc const base::WeakPtr<SpdyStream> stream_; stream_ 19 net/spdy/spdy_stream_test_util.cc const base::WeakPtr<SpdyStream>& stream) : stream_(stream) { stream_ 20 net/spdy/spdy_stream_test_util.cc DCHECK(stream_); stream_ 37 net/spdy/spdy_stream_test_util.cc DCHECK(stream_); stream_ 38 net/spdy/spdy_stream_test_util.cc stream_->Close(); stream_ 44 net/spdy/spdy_stream_test_util.cc : stream_(stream), stream_ 53 net/spdy/spdy_stream_test_util.cc stream_id_ = stream_->stream_id(); stream_ 60 net/spdy/spdy_stream_test_util.cc EXPECT_EQ(stream_->type() != SPDY_PUSH_STREAM, send_headers_completed_); stream_ 73 net/spdy/spdy_stream_test_util.cc if (!stream_.get()) stream_ 75 net/spdy/spdy_stream_test_util.cc stream_id_ = stream_->stream_id(); stream_ 76 net/spdy/spdy_stream_test_util.cc stream_.reset(); stream_ 82 net/spdy/spdy_stream_test_util.cc EXPECT_TRUE(!stream_.get()); stream_ 37 net/spdy/spdy_stream_test_util.h bool StreamIsClosed() const { return !stream_.get(); } stream_ 40 net/spdy/spdy_stream_test_util.h base::WeakPtr<SpdyStream> stream_; stream_ 66 net/spdy/spdy_stream_test_util.h bool StreamIsClosed() const { return !stream_.get(); } stream_ 76 net/spdy/spdy_stream_test_util.h const base::WeakPtr<SpdyStream>& stream() { return stream_; } stream_ 79 net/spdy/spdy_stream_test_util.h base::WeakPtr<SpdyStream> stream_; stream_ 47 net/spdy/spdy_websocket_stream.cc stream_ = stream_request_.ReleaseStream(); stream_ 48 net/spdy/spdy_websocket_stream.cc DCHECK(stream_.get()); stream_ 49 net/spdy/spdy_websocket_stream.cc stream_->SetDelegate(this); stream_ 55 net/spdy/spdy_websocket_stream.cc if (!stream_.get()) { stream_ 59 net/spdy/spdy_websocket_stream.cc int result = stream_->SendRequestHeaders(headers.Pass(), MORE_DATA_TO_SEND); stream_ 66 net/spdy/spdy_websocket_stream.cc if (!stream_.get()) { stream_ 74 net/spdy/spdy_websocket_stream.cc stream_->SendData(buf.get(), length, MORE_DATA_TO_SEND); stream_ 79 net/spdy/spdy_websocket_stream.cc if (stream_.get()) { stream_ 80 net/spdy/spdy_websocket_stream.cc stream_->Close(); stream_ 81 net/spdy/spdy_websocket_stream.cc DCHECK(!stream_.get()); stream_ 109 net/spdy/spdy_websocket_stream.cc stream_.reset(); stream_ 122 net/spdy/spdy_websocket_stream.cc stream_ = stream_request_.ReleaseStream(); stream_ 123 net/spdy/spdy_websocket_stream.cc DCHECK(stream_.get()); stream_ 124 net/spdy/spdy_websocket_stream.cc stream_->SetDelegate(this); stream_ 93 net/spdy/spdy_websocket_stream.h base::WeakPtr<SpdyStream> stream_; stream_ 172 net/spdy/spdy_websocket_stream_unittest.cc created_stream_id_ = websocket_stream_->stream_->stream_id(); stream_ 342 net/spdy/spdy_websocket_stream_unittest.cc ASSERT_TRUE(websocket_stream_->stream_.get()); stream_ 262 net/tools/dump_cache/upgrade_win.cc int stream_; stream_ 431 net/tools/dump_cache/upgrade_win.cc stream_ = 0; stream_ 436 net/tools/dump_cache/upgrade_win.cc DEBUGMSG("Master SendGetDataSize (%d)\n", stream_); stream_ 440 net/tools/dump_cache/upgrade_win.cc msg.arg1 = stream_; stream_ 472 net/tools/dump_cache/upgrade_win.cc DEBUGMSG("Master SendReadData (%d): %d bytes at %d\n", stream_, read_size, stream_ 475 net/tools/dump_cache/upgrade_win.cc stream_++; stream_ 476 net/tools/dump_cache/upgrade_win.cc if (stream_ >= kNumStreams) stream_ 484 net/tools/dump_cache/upgrade_win.cc msg.arg1 = stream_; stream_ 508 net/tools/dump_cache/upgrade_win.cc entry_, stream_, offset_, buf, read_size, stream_ 49 net/tools/quic/quic_spdy_client_stream_test.cc stream_.reset(new QuicSpdyClientStream(3, &session_)); stream_ 54 net/tools/quic/quic_spdy_client_stream_test.cc scoped_ptr<QuicSpdyClientStream> stream_; stream_ 65 net/tools/quic/quic_spdy_client_stream_test.cc EXPECT_EQ(headers_string_.size(), stream_->ProcessData( stream_ 68 net/tools/quic/quic_spdy_client_stream_test.cc stream_->ProcessData(body_.c_str(), body_.size())); stream_ 69 net/tools/quic/quic_spdy_client_stream_test.cc EXPECT_EQ(200u, stream_->headers().parsed_response_code()); stream_ 70 net/tools/quic/quic_spdy_client_stream_test.cc EXPECT_EQ(body_, stream_->data()); stream_ 76 net/tools/quic/quic_spdy_client_stream_test.cc EXPECT_EQ(message.size(), stream_->ProcessData( stream_ 78 net/tools/quic/quic_spdy_client_stream_test.cc EXPECT_EQ(200u, stream_->headers().parsed_response_code()); stream_ 79 net/tools/quic/quic_spdy_client_stream_test.cc EXPECT_EQ(body_, stream_->data()); stream_ 85 net/tools/quic/quic_spdy_client_stream_test.cc EXPECT_EQ(headers_string_.size(), stream_->ProcessData( stream_ 88 net/tools/quic/quic_spdy_client_stream_test.cc EXPECT_EQ(QUIC_STREAM_NO_ERROR, stream_->stream_error()); stream_ 89 net/tools/quic/quic_spdy_client_stream_test.cc EXPECT_EQ(200u, stream_->headers().parsed_response_code()); stream_ 92 net/tools/quic/quic_spdy_client_stream_test.cc SendRstStream(stream_->id(), QUIC_BAD_APPLICATION_PAYLOAD, 0)); stream_ 93 net/tools/quic/quic_spdy_client_stream_test.cc stream_->ProcessData(large_body.c_str(), large_body.size()); stream_ 95 net/tools/quic/quic_spdy_client_stream_test.cc EXPECT_NE(QUIC_STREAM_NO_ERROR, stream_->stream_error()); stream_ 101 net/tools/quic/quic_spdy_client_stream_test.cc EXPECT_FALSE(stream_->write_side_closed()); stream_ 102 net/tools/quic/quic_spdy_client_stream_test.cc EXPECT_TRUE(stream_->OnStreamFrame(frame)); stream_ 103 net/tools/quic/quic_spdy_client_stream_test.cc EXPECT_TRUE(stream_->write_side_closed()); stream_ 90 net/tools/quic/quic_spdy_server_stream_test.cc stream_.reset(new QuicSpdyServerStreamPeer(3, &session_)); stream_ 128 net/tools/quic/quic_spdy_server_stream_test.cc return QuicSpdyServerStreamPeer::body(stream_.get()); stream_ 132 net/tools/quic/quic_spdy_server_stream_test.cc return QuicSpdyServerStreamPeer::headers(stream_.get()); stream_ 139 net/tools/quic/quic_spdy_server_stream_test.cc scoped_ptr<QuicSpdyServerStreamPeer> stream_; stream_ 160 net/tools/quic/quic_spdy_server_stream_test.cc EXPECT_EQ(headers_string_.size(), stream_->ProcessData( stream_ 162 net/tools/quic/quic_spdy_server_stream_test.cc EXPECT_EQ(body_.size(), stream_->ProcessData(body_.c_str(), body_.size())); stream_ 175 net/tools/quic/quic_spdy_server_stream_test.cc EXPECT_EQ(message.size(), stream_->ProcessData( stream_ 190 net/tools/quic/quic_spdy_server_stream_test.cc EXPECT_EQ(headers_string_.size(), stream_->ProcessData( stream_ 194 net/tools/quic/quic_spdy_server_stream_test.cc stream_->ProcessData(large_body.c_str(), large_body.size()); stream_ 201 net/tools/quic/quic_spdy_server_stream_test.cc BalsaHeaders* request_headers = stream_->mutable_headers(); stream_ 219 net/tools/quic/quic_spdy_server_stream_test.cc QuicSpdyServerStreamPeer::SendResponse(stream_.get()); stream_ 220 net/tools/quic/quic_spdy_server_stream_test.cc EXPECT_TRUE(stream_->read_side_closed()); stream_ 221 net/tools/quic/quic_spdy_server_stream_test.cc EXPECT_TRUE(stream_->write_side_closed()); stream_ 236 net/tools/quic/quic_spdy_server_stream_test.cc QuicSpdyServerStreamPeer::SendErrorResponse(stream_.get()); stream_ 237 net/tools/quic/quic_spdy_server_stream_test.cc EXPECT_TRUE(stream_->read_side_closed()); stream_ 238 net/tools/quic/quic_spdy_server_stream_test.cc EXPECT_TRUE(stream_->write_side_closed()); stream_ 266 net/tools/quic/quic_spdy_server_stream_test.cc QuicStreamFrame frame(stream_->id(), true, 0, MakeIOVector(data)); stream_ 268 net/tools/quic/quic_spdy_server_stream_test.cc stream_->OnStreamFrame(frame); stream_ 206 net/tools/quic/test_tools/quic_test_client.cc if (stream_) { stream_ 207 net/tools/quic/test_tools/quic_test_client.cc stream_->set_visitor(NULL); stream_ 240 net/tools/quic/test_tools/quic_test_client.cc stream_ = NULL; // Always force creation of a stream for SendMessage. stream_ 332 net/tools/quic/test_tools/quic_test_client.cc if (!stream_) { stream_ 333 net/tools/quic/test_tools/quic_test_client.cc stream_ = client_->CreateReliableClientStream(); stream_ 334 net/tools/quic/test_tools/quic_test_client.cc if (stream_ == NULL) { stream_ 337 net/tools/quic/test_tools/quic_test_client.cc stream_->set_visitor(this); stream_ 338 net/tools/quic/test_tools/quic_test_client.cc reinterpret_cast<QuicSpdyClientStream*>(stream_)->set_priority(priority_); stream_ 341 net/tools/quic/test_tools/quic_test_client.cc return stream_; stream_ 397 net/tools/quic/test_tools/quic_test_client.cc stream_ = NULL; stream_ 419 net/tools/quic/test_tools/quic_test_client.cc while (stream_ != NULL && stream_ 420 net/tools/quic/test_tools/quic_test_client.cc !client_->session()->IsClosedStream(stream_->id()) && stream_ 440 net/tools/quic/test_tools/quic_test_client.cc while (stream_ != NULL && stream_ 441 net/tools/quic/test_tools/quic_test_client.cc !client_->session()->IsClosedStream(stream_->id()) && stream_ 442 net/tools/quic/test_tools/quic_test_client.cc stream_->stream_bytes_read() == 0 && stream_ 456 net/tools/quic/test_tools/quic_test_client.cc if (stream_ != NULL) { stream_ 457 net/tools/quic/test_tools/quic_test_client.cc return stream_->headers_decompressed(); stream_ 464 net/tools/quic/test_tools/quic_test_client.cc if (stream_ != NULL) { stream_ 465 net/tools/quic/test_tools/quic_test_client.cc return &stream_->headers(); stream_ 484 net/tools/quic/test_tools/quic_test_client.cc if (stream_ != stream) { stream_ 489 net/tools/quic/test_tools/quic_test_client.cc response_ = stream_->data(); stream_ 492 net/tools/quic/test_tools/quic_test_client.cc response_headers_complete_ = stream_->headers_decompressed(); stream_ 493 net/tools/quic/test_tools/quic_test_client.cc headers_.CopyFrom(stream_->headers()); stream_ 494 net/tools/quic/test_tools/quic_test_client.cc stream_error_ = stream_->stream_error(); stream_ 495 net/tools/quic/test_tools/quic_test_client.cc bytes_read_ = stream_->stream_bytes_read() + stream_->header_bytes_read(); stream_ 497 net/tools/quic/test_tools/quic_test_client.cc stream_->stream_bytes_written() + stream_->header_bytes_written(); stream_ 499 net/tools/quic/test_tools/quic_test_client.cc response_body_size_ = stream_->data().size(); stream_ 500 net/tools/quic/test_tools/quic_test_client.cc stream_ = NULL; stream_ 169 net/tools/quic/test_tools/quic_test_client.h QuicSpdyClientStream* stream_; stream_ 63 net/url_request/url_request_file_job.cc stream_(new FileStream(NULL, file_task_runner)), stream_ 80 net/url_request/url_request_file_job.cc stream_.reset(); stream_ 102 net/url_request/url_request_file_job.cc int rv = stream_->Read(dest, dest_size, stream_ 235 net/url_request/url_request_file_job.cc int rv = stream_->Open(file_path_, flags, stream_ 259 net/url_request/url_request_file_job.cc int rv = stream_->Seek(FROM_BEGIN, byte_range_.first_byte_position(), stream_ 94 net/url_request/url_request_file_job.h scoped_ptr<FileStream> stream_; stream_ 77 net/websockets/websocket_basic_stream_test.cc scoped_ptr<WebSocketBasicStream> stream_; stream_ 116 net/websockets/websocket_basic_stream_test.cc stream_.reset(); stream_ 150 net/websockets/websocket_basic_stream_test.cc stream_ = WebSocketBasicStream::CreateWebSocketBasicStreamForTesting( stream_ 274 net/websockets/websocket_basic_stream_test.cc int result = stream_->ReadFrames(&frames_, cb_.callback()); stream_ 283 net/websockets/websocket_basic_stream_test.cc int result = stream_->ReadFrames(&frames_, cb_.callback()); stream_ 296 net/websockets/websocket_basic_stream_test.cc int result = stream_->ReadFrames(&frames_, cb_.callback()); stream_ 306 net/websockets/websocket_basic_stream_test.cc int result = stream_->ReadFrames(&frames_, cb_.callback()); stream_ 319 net/websockets/websocket_basic_stream_test.cc int result = stream_->ReadFrames(&frames_, cb_.callback()); stream_ 333 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 340 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 352 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 368 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 373 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 393 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[0].callback())); stream_ 400 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[1].callback())); stream_ 417 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[0].callback())); stream_ 423 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[1].callback())); stream_ 443 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[0].callback())); stream_ 452 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[i].callback())); stream_ 464 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 476 net/websockets/websocket_basic_stream_test.cc stream_->ReadFrames(&frames_, cb_.callback())); stream_ 482 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 494 net/websockets/websocket_basic_stream_test.cc stream_->ReadFrames(&frames_, cb_.callback())); stream_ 500 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 510 net/websockets/websocket_basic_stream_test.cc stream_->ReadFrames(&frames_, cb_.callback())); stream_ 516 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 531 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 535 net/websockets/websocket_basic_stream_test.cc stream_->ReadFrames(&frames_, cb_.callback())); stream_ 545 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 556 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 564 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 578 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 581 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 595 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 598 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 609 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 625 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 629 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 640 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 653 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 671 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 691 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 701 net/websockets/websocket_basic_stream_test.cc stream_->ReadFrames(&frames_, cb_.callback())); stream_ 707 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 719 net/websockets/websocket_basic_stream_test.cc stream_->ReadFrames(&frames_, cb_.callback())); stream_ 731 net/websockets/websocket_basic_stream_test.cc stream_->ReadFrames(&frames_, cb_.callback())); stream_ 748 net/websockets/websocket_basic_stream_test.cc stream_->ReadFrames(&frames_, cb_.callback())); stream_ 763 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 777 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 789 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 818 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback())); stream_ 846 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[0].callback())); stream_ 852 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[1].callback())); stream_ 863 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(OK, stream_->WriteFrames(&frames_, cb_.callback())); stream_ 871 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->WriteFrames(&frames_, cb_.callback())); stream_ 884 net/websockets/websocket_basic_stream_test.cc ASSERT_EQ(ERR_IO_PENDING, stream_->WriteFrames(&frames_, cb_.callback())); stream_ 902 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(OK, stream_->WriteFrames(&frames, cb_.callback())); stream_ 927 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ(OK, stream_->WriteFrames(&frames_, cb_.callback())); stream_ 934 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ("inflate-uuencode", stream_->GetExtensions()); stream_ 941 net/websockets/websocket_basic_stream_test.cc EXPECT_EQ("cyberchat", stream_->GetSubProtocol()); stream_ 304 net/websockets/websocket_channel.cc stream_.reset(); stream_ 337 net/websockets/websocket_channel.cc if (stream_ == NULL) { stream_ 521 net/websockets/websocket_channel.cc stream_ = stream.Pass(); stream_ 524 net/websockets/websocket_channel.cc false, stream_->GetSubProtocol(), stream_->GetExtensions()) == stream_ 588 net/websockets/websocket_channel.cc result = stream_->WriteFrames( stream_ 638 net/websockets/websocket_channel.cc stream_->Close(); stream_ 651 net/websockets/websocket_channel.cc result = stream_->ReadFrames( stream_ 700 net/websockets/websocket_channel.cc stream_->Close(); stream_ 916 net/websockets/websocket_channel.cc DCHECK(stream_); stream_ 955 net/websockets/websocket_channel.cc stream_->Close(); stream_ 1061 net/websockets/websocket_channel.cc stream_->Close(); stream_ 325 net/websockets/websocket_channel.h scoped_ptr<WebSocketStream> stream_; stream_ 719 net/websockets/websocket_channel_test.cc WebSocketChannelTest() : stream_(new FakeWebSocketStream) {} stream_ 741 net/websockets/websocket_channel_test.cc connect_data_.creator.connect_delegate->OnSuccess(stream_.Pass()); stream_ 759 net/websockets/websocket_channel_test.cc stream_ = stream.template PassAs<WebSocketStream>(); stream_ 786 net/websockets/websocket_channel_test.cc scoped_ptr<WebSocketStream> stream_; stream_ 963 net/websockets/websocket_channel_test.cc connect_data_.creator.connect_delegate->OnSuccess(stream_.Pass()); stream_ 1307 net/websockets/websocket_channel_test.cc connect_data_.creator.connect_delegate->OnSuccess(stream_.Pass()); stream_ 2184 net/websockets/websocket_channel_test.cc connect_data_.creator.connect_delegate->OnSuccess(stream_.Pass()); stream_ 2207 net/websockets/websocket_channel_test.cc connect_data_.creator.connect_delegate->OnSuccess(stream_.Pass()); stream_ 2226 net/websockets/websocket_channel_test.cc connect_data_.creator.connect_delegate->OnSuccess(stream_.Pass()); stream_ 2249 net/websockets/websocket_channel_test.cc connect_data_.creator.connect_delegate->OnSuccess(stream_.Pass()); stream_ 2276 net/websockets/websocket_channel_test.cc connect_data_.creator.connect_delegate->OnSuccess(stream_.Pass()); stream_ 3272 net/websockets/websocket_channel_test.cc connect_data_.creator.connect_delegate->OnSuccess(stream_.Pass()); stream_ 41 net/websockets/websocket_deflate_stream.cc : stream_(stream.Pass()), stream_ 49 net/websockets/websocket_deflate_stream.cc DCHECK(stream_); stream_ 60 net/websockets/websocket_deflate_stream.cc int result = stream_->ReadFrames( stream_ 81 net/websockets/websocket_deflate_stream.cc return stream_->WriteFrames(frames, callback); stream_ 84 net/websockets/websocket_deflate_stream.cc void WebSocketDeflateStream::Close() { stream_->Close(); } stream_ 87 net/websockets/websocket_deflate_stream.cc return stream_->GetSubProtocol(); stream_ 91 net/websockets/websocket_deflate_stream.cc return stream_->GetExtensions(); stream_ 374 net/websockets/websocket_deflate_stream.cc result = stream_->ReadFrames( stream_ 91 net/websockets/websocket_deflate_stream.h const scoped_ptr<WebSocketStream> stream_; stream_ 22 net/websockets/websocket_deflater.cc if (stream_) { stream_ 23 net/websockets/websocket_deflater.cc deflateEnd(stream_.get()); stream_ 24 net/websockets/websocket_deflater.cc stream_.reset(NULL); stream_ 29 net/websockets/websocket_deflater.cc DCHECK(!stream_); stream_ 30 net/websockets/websocket_deflater.cc stream_.reset(new z_stream); stream_ 34 net/websockets/websocket_deflater.cc memset(stream_.get(), 0, sizeof(*stream_)); stream_ 35 net/websockets/websocket_deflater.cc int result = deflateInit2(stream_.get(), stream_ 42 net/websockets/websocket_deflater.cc deflateEnd(stream_.get()); stream_ 43 net/websockets/websocket_deflater.cc stream_.reset(); stream_ 56 net/websockets/websocket_deflater.cc stream_->next_in = reinterpret_cast<Bytef*>(const_cast<char*>(data)); stream_ 57 net/websockets/websocket_deflater.cc stream_->avail_in = size; stream_ 60 net/websockets/websocket_deflater.cc DCHECK(result != Z_BUF_ERROR || !stream_->avail_in); stream_ 73 net/websockets/websocket_deflater.cc stream_->next_in = NULL; stream_ 74 net/websockets/websocket_deflater.cc stream_->avail_in = 0; stream_ 111 net/websockets/websocket_deflater.cc deflateReset(stream_.get()); stream_ 118 net/websockets/websocket_deflater.cc stream_->next_out = reinterpret_cast<Bytef*>(&fixed_buffer_[0]); stream_ 119 net/websockets/websocket_deflater.cc stream_->avail_out = fixed_buffer_.size(); stream_ 120 net/websockets/websocket_deflater.cc result = deflate(stream_.get(), flush); stream_ 121 net/websockets/websocket_deflater.cc size_t size = fixed_buffer_.size() - stream_->avail_out; stream_ 63 net/websockets/websocket_deflater.h scoped_ptr<z_stream_s> stream_; stream_ 20 net/websockets/websocket_handshake_stream_create_helper.cc stream_(NULL), stream_ 34 net/websockets/websocket_handshake_stream_create_helper.cc return stream_ = stream_ 47 net/websockets/websocket_handshake_stream_create_helper.h WebSocketHandshakeStreamBase* stream() { return stream_; } stream_ 56 net/websockets/websocket_handshake_stream_create_helper.h WebSocketHandshakeStreamBase* stream_; stream_ 50 net/websockets/websocket_inflater.cc stream_.reset(new z_stream); stream_ 51 net/websockets/websocket_inflater.cc memset(stream_.get(), 0, sizeof(*stream_)); stream_ 52 net/websockets/websocket_inflater.cc int result = inflateInit2(stream_.get(), -window_bits); stream_ 54 net/websockets/websocket_inflater.cc inflateEnd(stream_.get()); stream_ 55 net/websockets/websocket_inflater.cc stream_.reset(); stream_ 62 net/websockets/websocket_inflater.cc if (stream_) { stream_ 63 net/websockets/websocket_inflater.cc inflateEnd(stream_.get()); stream_ 64 net/websockets/websocket_inflater.cc stream_.reset(); stream_ 79 net/websockets/websocket_inflater.cc if (stream_->avail_in > 0) stream_ 80 net/websockets/websocket_inflater.cc input_queue_.Push(&data[size - stream_->avail_in], stream_->avail_in); stream_ 116 net/websockets/websocket_inflater.cc return Inflate(reinterpret_cast<const char*>(stream_->next_in), stream_ 117 net/websockets/websocket_inflater.cc stream_->avail_in, stream_ 124 net/websockets/websocket_inflater.cc stream_->next_in = reinterpret_cast<Bytef*>(const_cast<char*>(next_in)); stream_ 125 net/websockets/websocket_inflater.cc stream_->avail_in = avail_in; stream_ 133 net/websockets/websocket_inflater.cc stream_->next_out = reinterpret_cast<Bytef*>(tail.first); stream_ 134 net/websockets/websocket_inflater.cc stream_->avail_out = tail.second; stream_ 135 net/websockets/websocket_inflater.cc result = inflate(stream_.get(), flush); stream_ 136 net/websockets/websocket_inflater.cc output_buffer_.AdvanceTail(tail.second - stream_->avail_out); stream_ 139 net/websockets/websocket_inflater.cc result = inflateReset(stream_.get()); stream_ 140 net/websockets/websocket_inflater.cc } else if (tail.second == stream_->avail_out) { stream_ 156 net/websockets/websocket_inflater.cc input_queue_.Consume(top.second - stream_->avail_in); stream_ 161 net/websockets/websocket_inflater.cc if (stream_->avail_in > 0) { stream_ 121 net/websockets/websocket_inflater.h scoped_ptr<z_stream_s> stream_; stream_ 158 net/websockets/websocket_stream_test.cc stream.swap(owner_->stream_); stream_ 186 net/websockets/websocket_stream_test.cc scoped_ptr<WebSocketStream> stream_; stream_ 244 net/websockets/websocket_stream_test.cc EXPECT_TRUE(stream_); stream_ 270 net/websockets/websocket_stream_test.cc EXPECT_TRUE(stream_); stream_ 321 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 334 net/websockets/websocket_stream_test.cc EXPECT_TRUE(stream_); stream_ 347 net/websockets/websocket_stream_test.cc EXPECT_TRUE(stream_); stream_ 363 net/websockets/websocket_stream_test.cc EXPECT_TRUE(stream_); stream_ 365 net/websockets/websocket_stream_test.cc EXPECT_EQ("chatv20.chromium.org", stream_->GetSubProtocol()); stream_ 377 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 396 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 418 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 439 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 450 net/websockets/websocket_stream_test.cc EXPECT_TRUE(stream_); stream_ 460 net/websockets/websocket_stream_test.cc EXPECT_TRUE(stream_); stream_ 481 net/websockets/websocket_stream_test.cc ASSERT_TRUE(stream_); stream_ 484 net/websockets/websocket_stream_test.cc ASSERT_EQ(OK, stream_->ReadFrames(&frames, callback)); stream_ 493 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 505 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 517 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 530 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 543 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 556 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 568 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 579 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 591 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 603 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 615 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 627 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 639 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 661 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 848 net/websockets/websocket_stream_test.cc EXPECT_TRUE(stream_); stream_ 899 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 946 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 967 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 991 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 1029 net/websockets/websocket_stream_test.cc EXPECT_FALSE(stream_); stream_ 155 ppapi/examples/video_decode/video_decode.cc const std::string& msg = stream_.str(); stream_ 163 ppapi/examples/video_decode/video_decode.cc std::ostringstream& s() { return stream_; } stream_ 166 ppapi/examples/video_decode/video_decode.cc std::ostringstream stream_; stream_ 34 sync/util/nigori.cc stream_.write((char *) &size, sizeof(uint32)); stream_ 35 sync/util/nigori.cc stream_ << value; stream_ 44 sync/util/nigori.cc stream_.write((char *) &size, sizeof(uint32)); stream_ 46 sync/util/nigori.cc stream_.write((char *) &value, sizeof(uint32)); stream_ 51 sync/util/nigori.cc return stream_.str(); stream_ 55 sync/util/nigori.cc std::ostringstream stream_; stream_ 965 third_party/cld/base/logging.h ostream& stream() { return *(data_->stream_); } stream_ 1000 third_party/cld/base/logging.h LogStream* stream_;