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

Lines Matching refs:stream_
123     stream_.reset(new TestStream(kHeadersStreamId, session_.get(),
129   bool fin_sent() { return ReliableQuicStreamPeer::FinSent(stream_.get()); }
130   bool rst_sent() { return ReliableQuicStreamPeer::RstSent(stream_.get()); }
144   scoped_ptr<TestStream> stream_;
163   stream_->WriteOrBufferData(kData1, false, NULL);
172   EXPECT_DFATAL(stream_->WriteOrBufferData(StringPiece(), false, NULL), "");
183   stream_->WriteOrBufferData(StringPiece(kData1, 2), false, NULL);
196   stream_->WriteOrBufferData(StringPiece(kData1, 2), true, NULL);
207   stream_->WriteOrBufferData(StringPiece(), true, NULL);
223   stream_->WriteOrBufferData(kData1, false, NULL);
227   stream_->WriteOrBufferData(kData2, false, NULL);
235   stream_->OnCanWrite();
240   stream_->OnCanWrite();
247   ReliableQuicStreamPeer::SetFecPolicy(stream_.get(), FEC_PROTECT_ALWAYS);
259   stream_->WriteOrBufferData(kData1, false, NULL);
263   stream_->WriteOrBufferData(kData2, false, NULL);
271   stream_->OnCanWrite();
276   stream_->OnCanWrite();
283   ReliableQuicStreamPeer::SetFecPolicy(stream_.get(), FEC_PROTECT_OPTIONAL);
295   stream_->WriteOrBufferData(kData1, false, NULL);
299   stream_->WriteOrBufferData(kData2, false, NULL);
307   stream_->OnCanWrite();
312   stream_->OnCanWrite();
318   stream_->CloseReadSide();
319   stream_->CloseWriteSide();
320   EXPECT_EQ(QUIC_STREAM_NO_ERROR, stream_->stream_error());
321   EXPECT_EQ(QUIC_NO_ERROR, stream_->connection_error());
322   stream_->OnConnectionClosed(QUIC_INTERNAL_ERROR, false);
323   EXPECT_EQ(QUIC_STREAM_NO_ERROR, stream_->stream_error());
324   EXPECT_EQ(QUIC_NO_ERROR, stream_->connection_error());
339   stream_->WriteOrBufferData(StringPiece(kData1, 1), false, NULL);
345   stream_->OnClose();
362   stream_->WriteOrBufferData(StringPiece(kData1, 1), true, NULL);
367   stream_->OnClose();
385   stream_->Reset(QUIC_STREAM_CANCELLED);
391   stream_->OnClose();
407       QuicFlowControllerPeer::SendWindowOffset(stream_->flow_controller()));
410   QuicWindowUpdateFrame window_update_1(stream_->id(), 1234);
411   stream_->OnWindowUpdateFrame(window_update_1);
414       QuicFlowControllerPeer::SendWindowOffset(stream_->flow_controller()));
418   QuicWindowUpdateFrame window_update_2(stream_->id(), 1);
419   QuicWindowUpdateFrame window_update_3(stream_->id(), 9999);
420   QuicWindowUpdateFrame window_update_4(stream_->id(), 5678);
421   stream_->OnWindowUpdateFrame(window_update_2);
422   stream_->OnWindowUpdateFrame(window_update_3);
423   stream_->OnWindowUpdateFrame(window_update_4);
426       QuicFlowControllerPeer::SendWindowOffset(stream_->flow_controller()));
449   EXPECT_FALSE(stream_->flow_controller()->IsBlocked());
472   stream_->flow_controller()->UpdateSendWindowOffset(kDataSize + 1);
481   stream_->WriteOrBufferData(kData, false, delegate.get());
487   stream_->OnCanWrite();
493   stream_->OnCanWrite();
498   stream_->OnCanWrite();
525   stream_->flow_controller()->UpdateSendWindowOffset(kDataSize + 1);
534   stream_->WriteOrBufferData(kData, false, delegate.get());
545   stream_->OnCanWrite();
565   stream_->WriteOrBufferData(kData1, true, delegate.get());
584   stream_->WriteOrBufferData(kData1, true, delegate.get());
591   stream_->OnCanWrite();
612   stream_->WriteOrBufferData(kData1, true, delegate.get());
619   stream_->OnCanWrite();
636   QuicStreamFrame frame(stream_->id(), false,
640                               stream_->flow_controller()));
645   stream_->OnStreamFrame(frame);
651   EXPECT_FALSE(stream_->HasFinalReceivedByteOffset());
653   QuicStreamFrame stream_frame_no_fin(stream_->id(), false, 1234,
655   stream_->OnStreamFrame(stream_frame_no_fin);
656   EXPECT_FALSE(stream_->HasFinalReceivedByteOffset());
658   QuicStreamFrame stream_frame_with_fin(stream_->id(), true, 1234,
660   stream_->OnStreamFrame(stream_frame_with_fin);
661   EXPECT_TRUE(stream_->HasFinalReceivedByteOffset());
667   EXPECT_FALSE(stream_->HasFinalReceivedByteOffset());
668   QuicRstStreamFrame rst_frame(stream_->id(), QUIC_STREAM_CANCELLED, 1234);
669   stream_->OnStreamReset(rst_frame);
670   EXPECT_TRUE(stream_->HasFinalReceivedByteOffset());