Cross Reference: /external/chromium_org/net/quic/quic_data_stream

Lines Matching refs:stream_
97     stream_.reset(new TestStream(kClientDataStreamId1, session_.get(),
108   scoped_ptr<TestStream> stream_;
121   stream_->OnStreamHeadersPriority(QuicUtils::HighestPriority());
122   stream_->OnStreamHeaders(headers);
123   EXPECT_EQ(headers, stream_->data());
124   stream_->OnStreamHeadersComplete(false, headers.size());
125   EXPECT_EQ(QuicUtils::HighestPriority(), stream_->EffectivePriority());
126   EXPECT_EQ(headers, stream_->data());
127   EXPECT_FALSE(stream_->IsDoneReading());
136   stream_->OnStreamHeaders(headers);
137   EXPECT_EQ(headers, stream_->data());
138   stream_->OnStreamHeadersComplete(false, headers.size());
140   stream_->OnStreamFrame(frame);
142   EXPECT_EQ(headers + body, stream_->data());
157       stream_->OnStreamHeaders(fragment);
159     stream_->OnStreamHeadersComplete(false, headers.size());
166       stream_->OnStreamFrame(frame);
169               stream_->data()) << "fragment_size: " << fragment_size;
180     stream_->OnStreamHeaders(headers1);
184     stream_->OnStreamHeaders(headers2);
185     stream_->OnStreamHeadersComplete(false, headers.size());
190     stream_->OnStreamFrame(frame1);
196     stream_->OnStreamFrame(frame2);
199               stream_->data()) << "split_point: " << split_point;
209   stream_->OnStreamHeaders(headers);
210   EXPECT_EQ(headers, stream_->data());
211   stream_->OnStreamHeadersComplete(false, headers.size());
213   stream_->OnStreamFrame(frame);
221   size_t bytes_read = stream_->Readv(&vec, 1);
225   bytes_read = stream_->Readv(&vec, 1);
235   stream_->OnStreamHeaders(headers);
236   EXPECT_EQ(headers, stream_->data());
237   stream_->OnStreamHeadersComplete(false, headers.size());
239   stream_->OnStreamFrame(frame);
248     size_t bytes_read = stream_->Readv(&vec, 1);
259   stream_->OnStreamHeaders(headers);
260   EXPECT_EQ(headers, stream_->data());
261   stream_->OnStreamHeadersComplete(false, headers.size());
263   stream_->OnStreamFrame(frame);
274     size_t bytes_read = stream_->Readv(vec, 2);
292   QuicFlowControllerPeer::SetSendWindowOffset(stream_->flow_controller(),
295                          stream_->flow_controller()));
306   stream_->WriteOrBufferData(body, false, NULL);
310             QuicFlowControllerPeer::SendWindowSize(stream_->flow_controller()));
314             ReliableQuicStreamPeer::SizeOfQueuedData(stream_.get()));
334   QuicFlowControllerPeer::SetReceiveWindowOffset(stream_->flow_controller(),
336   QuicFlowControllerPeer::SetMaxReceiveWindow(stream_->flow_controller(),
339                          stream_->flow_controller()));
345   stream_->OnStreamHeaders(headers);
346   EXPECT_EQ(headers, stream_->data());
347   stream_->OnStreamHeadersComplete(false, headers.size());
350   stream_->OnStreamFrame(frame1);
352                                          stream_->flow_controller()));
359   stream_->OnStreamFrame(frame2);
362       QuicFlowControllerPeer::ReceiveWindowSize(stream_->flow_controller()));
377   QuicFlowControllerPeer::SetReceiveWindowOffset(stream_->flow_controller(),
379   QuicFlowControllerPeer::SetMaxReceiveWindow(stream_->flow_controller(),
382                          stream_->flow_controller()));
388   stream_->OnStreamHeaders(headers);
389   EXPECT_EQ(headers, stream_->data());
390   stream_->OnStreamHeadersComplete(false, headers.size());
393   stream_->OnStreamFrame(frame1);
395                                          stream_->flow_controller()));
406                                    stream_->flow_controller()) +
408   stream_->OnStreamFrame(frame2);
410                          stream_->flow_controller()));
424   QuicFlowControllerPeer::SetReceiveWindowOffset(stream_->flow_controller(),
426   QuicFlowControllerPeer::SetMaxReceiveWindow(stream_->flow_controller(),
439   stream_->OnStreamHeaders(headers);
440   stream_->OnStreamHeadersComplete(false, headers.size());
449   stream_->OnStreamFrame(frame1);
464   stream_->OnStreamFrame(frame3);
480   QuicFlowControllerPeer::SetReceiveWindowOffset(stream_->flow_controller(),
484   stream_->OnStreamHeaders(headers);
485   EXPECT_EQ(headers, stream_->data());
486   stream_->OnStreamHeadersComplete(false, headers.size());
494   stream_->OnStreamFrame(frame);
512   QuicFlowControllerPeer::SetReceiveWindowOffset(stream_->flow_controller(),
518   stream_->OnStreamHeaders(headers);
519   EXPECT_EQ(headers, stream_->data());
520   stream_->OnStreamHeadersComplete(false, headers.size());
530   stream_->OnStreamFrame(frame);
543   QuicFlowControllerPeer::SetReceiveWindowOffset(stream_->flow_controller(), 0);
545                     stream_->flow_controller()));
555   stream_->WriteOrBufferData(body, fin, NULL);