Lines Matching defs:stream_id
329 const flip::FlipStreamId stream_id = GetNewStreamId();
332 stream = new FlipStream(this, stream_id, false, log);
340 LOG(INFO) << "FlipStream: Creating stream " << stream_id << " for " << url;
356 flip_framer_.CreateSynStream(stream_id, request.priority, flags, false,
383 int FlipSession::WriteStreamData(flip::FlipStreamId stream_id,
385 LOG(INFO) << "Writing Stream Data for stream " << stream_id << " (" << len
395 DCHECK(IsStreamActive(stream_id));
396 scoped_refptr<FlipStream> stream = active_streams_[stream_id];
397 CHECK(stream->stream_id() == stream_id);
413 flip_framer_.CreateDataFrame(stream_id, data->data(), len, flags));
426 bool FlipSession::CancelStream(flip::FlipStreamId stream_id) {
427 LOG(INFO) << "Cancelling stream " << stream_id;
428 if (!IsStreamActive(stream_id))
437 scoped_refptr<FlipStream> stream = active_streams_[stream_id];
438 DeactivateStream(stream_id);
442 bool FlipSession::IsStreamActive(flip::FlipStreamId stream_id) const {
443 return ContainsKey(active_streams_, stream_id);
569 << in_flight_write_.stream()->stream_id();
739 LOG(ERROR) << "ABANDONED (stream_id=" << list[index]->stream_id()
781 const flip::FlipStreamId id = stream->stream_id();
794 if (id == curr->stream_id()) {
839 void FlipSession::OnStreamFrameData(flip::FlipStreamId stream_id,
842 LOG(INFO) << "Flip data for stream " << stream_id << ", " << len << " bytes";
843 bool valid_stream = IsStreamActive(stream_id);
846 LOG(WARNING) << "Received data frame for invalid stream " << stream_id;
850 scoped_refptr<FlipStream> stream = active_streams_[stream_id];
854 DeactivateStream(stream_id);
859 flip::FlipStreamId stream_id = frame->stream_id();
862 if ((stream_id & 0x1) != 0) {
863 LOG(ERROR) << "Received invalid OnSyn stream id " << stream_id;
867 if (IsStreamActive(stream_id)) {
868 LOG(ERROR) << "Received OnSyn for active stream " << stream_id;
874 LOG(INFO) << "FlipSession: Syn received for stream: " << stream_id;
907 CHECK(stream->stream_id() == 0);
908 stream->set_stream_id(stream_id);
911 stream = new FlipStream(this, stream_id, true, NULL);
928 DeactivateStream(stream_id);
941 flip::FlipStreamId stream_id = frame->stream_id();
942 bool valid_stream = IsStreamActive(stream_id);
945 LOG(WARNING) << "Received SYN_REPLY for invalid stream " << stream_id;
949 LOG(INFO) << "FLIP SYN_REPLY RESPONSE HEADERS for stream: " << stream_id;
980 scoped_refptr<FlipStream> stream = active_streams_[stream_id];
981 CHECK(stream->stream_id() == stream_id);
989 DeactivateStream(stream_id);
1006 LOG(INFO) << "Flip SynStream for stream " << frame->stream_id();
1011 LOG(INFO) << "Flip SynReply for stream " << frame->stream_id();
1017 LOG(INFO) << "Flip Fin for stream " << frame->stream_id();
1026 flip::FlipStreamId stream_id = frame->stream_id();
1027 bool valid_stream = IsStreamActive(stream_id);
1030 LOG(WARNING) << "Received FIN for invalid stream" << stream_id;
1033 scoped_refptr<FlipStream> stream = active_streams_[stream_id];
1034 CHECK(stream->stream_id() == stream_id);
1045 DeactivateStream(stream_id);
