Lines Matching defs:stream_id
109 NetLogSpdyWindowUpdateParameter(spdy::SpdyStreamId stream_id,
112 : stream_id_(stream_id), delta_(delta), window_size_(window_size) {}
116 dict->SetInteger("stream_id", static_cast<int>(stream_id_));
133 NetLogSpdyDataParameter(spdy::SpdyStreamId stream_id,
136 : stream_id_(stream_id), size_(size), flags_(flags) {}
140 dict->SetInteger("stream_id", static_cast<int>(stream_id_));
157 NetLogSpdyRstParameter(spdy::SpdyStreamId stream_id, int status)
158 : stream_id_(stream_id), status_(status) {}
162 dict->SetInteger("stream_id", static_cast<int>(stream_id_));
469 const spdy::SpdyStreamId stream_id = GetNewStreamId();
472 stream_id,
489 DCHECK_EQ(active_streams_[stream_id].get(), stream.get());
494 spdy::SpdyStreamId stream_id,
499 if (!IsStreamActive(stream_id))
501 const scoped_refptr<SpdyStream>& stream = active_streams_[stream_id];
502 CHECK_EQ(stream->stream_id(), stream_id);
508 stream_id, 0,
521 new NetLogSpdySynParameter(headers, flags, stream_id, 0)));
533 int SpdySession::WriteStreamData(spdy::SpdyStreamId stream_id,
537 DCHECK(IsStreamActive(stream_id));
538 scoped_refptr<SpdyStream> stream = active_streams_[stream_id];
539 CHECK_EQ(stream->stream_id(), stream_id);
563 new NetLogIntegerParameter("stream_id", stream_id)));
577 make_scoped_refptr(new NetLogSpdyDataParameter(stream_id, len, flags)));
582 spdy_framer_.CreateDataFrame(stream_id, data->data(), len, flags));
587 void SpdySession::CloseStream(spdy::SpdyStreamId stream_id, int status) {
591 DeleteStream(stream_id, status);
595 spdy::SpdyStreamId stream_id, spdy::SpdyStatusCodes status) {
599 make_scoped_refptr(new NetLogSpdyRstParameter(stream_id, status)));
602 spdy_framer_.CreateRstStream(stream_id, status));
606 if(IsStreamActive(stream_id)) {
607 scoped_refptr<SpdyStream> stream = active_streams_[stream_id];
611 DeleteStream(stream_id, ERR_SPDY_PROTOCOL_ERROR);
614 bool SpdySession::IsStreamActive(spdy::SpdyStreamId stream_id) const {
615 return ContainsKey(active_streams_, stream_id);
867 LOG(WARNING) << "ABANDONED (stream_id=" << stream->stream_id()
869 DeleteStream(stream->stream_id(), status);
963 const spdy::SpdyStreamId id = stream->stream_id();
978 if (id == curr->stream_id()) {
1046 void SpdySession::OnStreamFrameData(spdy::SpdyStreamId stream_id,
1053 stream_id, len, spdy::SpdyDataFlags())));
1056 if (!IsStreamActive(stream_id)) {
1058 LOG(WARNING) << "Received data frame for invalid stream " << stream_id;
1062 scoped_refptr<SpdyStream> stream = active_streams_[stream_id];
1072 const spdy::SpdyStreamId stream_id = stream->stream_id();
1073 DeleteStream(stream_id, rv);
1081 spdy::SpdyStreamId stream_id = frame.stream_id();
1089 stream_id, associated_stream_id)));
1093 if ((stream_id & 0x1) != 0) {
1094 LOG(WARNING) << "Received invalid OnSyn stream id " << stream_id;
1098 if (IsStreamActive(stream_id)) {
1099 LOG(WARNING) << "Received OnSyn for active stream " << stream_id;
1106 << " for stream " << stream_id;
1107 ResetStream(stream_id, spdy::INVALID_STREAM);
1119 ResetStream(stream_id, spdy::PROTOCOL_ERROR);
1126 ResetStream(stream_id, spdy::PROTOCOL_ERROR);
1135 ResetStream(stream_id, spdy::INVALID_ASSOCIATED_STREAM);
1145 ResetStream(stream_id, spdy::REFUSED_STREAM);
1153 ResetStream(stream_id, spdy::PROTOCOL_ERROR);
1158 new SpdyStream(this, stream_id, true, net_log_));
1177 spdy::SpdyStreamId stream_id = frame.stream_id();
1179 bool valid_stream = IsStreamActive(stream_id);
1182 LOG(WARNING) << "Received SYN_REPLY for invalid stream " << stream_id;
1186 scoped_refptr<SpdyStream> stream = active_streams_[stream_id];
1187 CHECK_EQ(stream->stream_id(), stream_id);
1191 LOG(WARNING) << "Received duplicate SYN_REPLY for stream " << stream_id;
1192 CloseStream(stream->stream_id(), ERR_SPDY_PROTOCOL_ERROR);
1202 stream_id, 0)));
1210 spdy::SpdyStreamId stream_id = frame.stream_id();
1212 bool valid_stream = IsStreamActive(stream_id);
1215 LOG(WARNING) << "Received HEADERS for invalid stream " << stream_id;
1219 scoped_refptr<SpdyStream> stream = active_streams_[stream_id];
1220 CHECK_EQ(stream->stream_id(), stream_id);
1228 stream_id, 0)));
1234 const spdy::SpdyStreamId stream_id = stream->stream_id();
1235 DeleteStream(stream_id, rv);
1247 int stream_id = 0;
1249 stream_id = (reinterpret_cast<const spdy::SpdySynStreamControlFrame*>
1250 (frame))->stream_id();
1252 stream_id = (reinterpret_cast<const spdy::SpdySynReplyControlFrame*>
1253 (frame))->stream_id();
1255 stream_id = (reinterpret_cast<const spdy::SpdyHeadersControlFrame*>
1256 (frame))->stream_id();
1258 if(IsStreamActive(stream_id))
1259 ResetStream(stream_id, spdy::PROTOCOL_ERROR);
1302 bool SpdySession::OnControlFrameHeaderData(spdy::SpdyStreamId stream_id,
1314 spdy::SpdyStreamId stream_id = frame.stream_id();
1319 new NetLogSpdyRstParameter(stream_id, frame.status())));
1321 bool valid_stream = IsStreamActive(stream_id);
1324 LOG(WARNING) << "Received RST for invalid stream" << stream_id;
1327 scoped_refptr<SpdyStream> stream = active_streams_[stream_id];
1328 CHECK_EQ(stream->stream_id(), stream_id);
1337 DeleteStream(stream_id, ERR_SPDY_PROTOCOL_ERROR);
1401 spdy::SpdyStreamId stream_id = frame.stream_id();
1402 if (!IsStreamActive(stream_id)) {
1403 LOG(WARNING) << "Received WINDOW_UPDATE for invalid stream " << stream_id;
1411 ResetStream(stream_id, spdy::FLOW_CONTROL_ERROR);
1415 scoped_refptr<SpdyStream> stream = active_streams_[stream_id];
1416 CHECK_EQ(stream->stream_id(), stream_id);
1425 stream_id, delta_window_size, stream->send_window_size())));
1428 void SpdySession::SendWindowUpdate(spdy::SpdyStreamId stream_id,
1430 DCHECK(IsStreamActive(stream_id));
1431 scoped_refptr<SpdyStream> stream = active_streams_[stream_id];
1432 CHECK_EQ(stream->stream_id(), stream_id);
1437 stream_id, delta_window_size, stream->recv_window_size())));
1440 spdy_framer_.CreateWindowUpdate(stream_id, delta_window_size));
