Lines Matching defs:stream_id
539 SpdyStreamId stream_id, SpdyStreamId associated_stream_id, int priority,
543 DCHECK_GT(stream_id, static_cast<SpdyStreamId>(0));
544 DCHECK_EQ(0u, stream_id & ~kStreamIdMask);
550 frame.WriteUInt32(stream_id);
581 SpdySynReplyControlFrame* SpdyFramer::CreateSynReply(SpdyStreamId stream_id,
583 DCHECK_GT(stream_id, 0u);
584 DCHECK_EQ(0u, stream_id & ~kStreamIdMask);
591 frame.WriteUInt32(stream_id);
622 SpdyRstStreamControlFrame* SpdyFramer::CreateRstStream(SpdyStreamId stream_id,
624 DCHECK_GT(stream_id, 0u);
625 DCHECK_EQ(0u, stream_id & ~kStreamIdMask);
633 frame.WriteUInt32(stream_id);
691 SpdyHeadersControlFrame* SpdyFramer::CreateHeaders(SpdyStreamId stream_id,
694 DCHECK_GT(stream_id, 0u);
695 DCHECK_EQ(0u, stream_id & ~kStreamIdMask);
701 frame.WriteUInt32(stream_id);
733 SpdyStreamId stream_id,
735 DCHECK_GT(stream_id, 0u);
736 DCHECK_EQ(0u, stream_id & ~kStreamIdMask);
746 frame.WriteUInt32(stream_id);
771 SpdyDataFrame* SpdyFramer::CreateDataFrame(SpdyStreamId stream_id,
776 DCHECK_GT(stream_id, 0u);
777 DCHECK_EQ(0u, stream_id & ~kStreamIdMask);
778 frame.WriteUInt32(stream_id);
797 CleanupCompressorForStream(stream_id);
918 visitor_->OnStreamFrameData(data_frame.stream_id(), NULL, 0);
1047 &control_frame)->stream_id(),
1065 GetStreamDecompressor(current_data_frame.stream_id());
1089 visitor_->OnStreamFrameData(current_data_frame.stream_id(),
1097 visitor_->OnStreamFrameData(current_data_frame.stream_id(),
1109 visitor_->OnStreamFrameData(current_data_frame.stream_id(), NULL, 0);
1110 CleanupDecompressorForStream(current_data_frame.stream_id());
1168 z_stream* SpdyFramer::GetStreamCompressor(SpdyStreamId stream_id) {
1169 CompressorMap::iterator it = stream_compressors_.find(stream_id);
1186 return stream_compressors_[stream_id] = compressor.release();
1189 z_stream* SpdyFramer::GetStreamDecompressor(SpdyStreamId stream_id) {
1190 CompressorMap::iterator it = stream_decompressors_.find(stream_id);
1202 return stream_decompressors_[stream_id] = decompressor.release();
1215 z_stream* compressor = GetStreamCompressor(frame.stream_id());
1254 const SpdyStreamId stream_id = GetControlFrameStreamId(control_frame);
1255 DCHECK_LT(0u, stream_id);
1267 read_successfully = visitor_->OnControlFrameHeaderData(stream_id, buffer,
1301 const SpdyStreamId stream_id = GetControlFrameStreamId(control_frame);
1302 DCHECK_LT(0u, stream_id);
1315 stream_id, buffer, decompressed_len);
1330 const SpdyStreamId stream_id = GetControlFrameStreamId(control_frame);
1331 DCHECK_LT(0u, stream_id);
1334 read_successfully = visitor_->OnControlFrameHeaderData(stream_id, data,
1377 SpdyStreamId stream_id = kInvalidStream;
1381 stream_id = reinterpret_cast<const SpdySynStreamControlFrame*>(
1382 control_frame)->stream_id();
1385 stream_id = reinterpret_cast<const SpdySynReplyControlFrame*>(
1386 control_frame)->stream_id();
1389 stream_id = reinterpret_cast<const SpdyHeadersControlFrame*>(
1390 control_frame)->stream_id();
1393 stream_id = reinterpret_cast<const SpdyRstStreamControlFrame*>(
1394 control_frame)->stream_id();
1397 stream_id = reinterpret_cast<const SpdyWindowUpdateControlFrame*>(
1398 control_frame)->stream_id();
1412 return stream_id;
1420 z_stream* decompressor = GetStreamDecompressor(frame.stream_id());
