Lines Matching full:stream
25 // To avoid deleting a stream in mid-operation, we have a simple shim between
26 // us and the stream, so we can delete any streams when we return from
113 // TODO(rch) deal with the error case of stream id 0
115 // If we get additional frames for a stream where we didn't process
127 ReliableQuicStream* stream = GetStream(frames[i].stream_id);
128 if (stream == NULL) return false;
129 if (!stream->WillAcceptStreamFrame(frames[i])) return false;
136 ReliableQuicStream* stream = GetStream(frames[i].stream_id);
137 if (stream) {
138 stream->OnStreamFrame(frames[i]);
149 ReliableQuicStream* stream = GetStream(stream_id);
150 if (!stream) {
155 stream->OnDecompressorAvailable();
161 ReliableQuicStream* stream = GetStream(frame.stream_id);
162 if (!stream) {
165 stream->OnStreamReset(frame.error_code);
182 // The stream should call CloseStream as part of ConnectionClose.
184 LOG(DFATAL) << ENDPOINT << "Stream failed to close under ConnectionClose";
198 ReliableQuicStream* stream =
200 if (stream != NULL) {
201 // If the stream can't write all bytes, it'll re-add itself to the blocked
203 stream->OnCanWrite();
230 DLOG(INFO) << ENDPOINT << "Closing stream " << stream_id;
234 DLOG(INFO) << ENDPOINT << "Stream is already closed: " << stream_id;
237 ReliableQuicStream* stream = it->second;
238 if (!stream->headers_decompressed()) {
243 prematurely_closed_streams_.insert(make_pair(stream->id(), true));
247 stream->OnClose();
290 void QuicSession::ActivateStream(ReliableQuicStream* stream) {
292 << ". activating " << stream->id();
293 DCHECK(stream_map_.count(stream->id()) == 0);
294 stream_map_[stream->id()] = stream;
318 // We've received a frame for a locally-created stream that is not
355 ReliableQuicStream* stream = CreateIncomingReliableStream(stream_id);
356 if (stream == NULL) {
359 ActivateStream(stream);
360 return stream;
369 // Stream is active
