sequencer_ 105 net/quic/quic_stream_sequencer_test.cc size_t num_iovecs = sequencer_->GetReadableRegions(iovecs, sequencer_ 144 net/quic/quic_stream_sequencer_test.cc scoped_ptr<QuicStreamSequencerPeer> sequencer_; sequencer_ 151 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(0, "abc")); sequencer_ 152 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->frames()->size()); sequencer_ 153 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(3u, sequencer_->num_bytes_consumed()); sequencer_ 156 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(0, "def")); sequencer_ 157 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->frames()->size()); sequencer_ 161 net/quic/quic_stream_sequencer_test.cc EXPECT_DFATAL(sequencer_.reset(new QuicStreamSequencerPeer(2, &stream_)), sequencer_ 165 net/quic/quic_stream_sequencer_test.cc EXPECT_DFATAL(sequencer_->OnFrame(0, "abc"), sequencer_ 170 net/quic/quic_stream_sequencer_test.cc sequencer_->SetMemoryLimit(3); sequencer_ 172 net/quic/quic_stream_sequencer_test.cc EXPECT_FALSE(sequencer_->OnFrame(3, "abc")); sequencer_ 178 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(0, "abc")); sequencer_ 179 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(1u, sequencer_->frames()->size()); sequencer_ 180 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->num_bytes_consumed()); sequencer_ 183 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(0, "def")); sequencer_ 184 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(1u, sequencer_->frames()->size()); sequencer_ 190 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(0, "abc")); sequencer_ 191 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->frames()->size()); sequencer_ 192 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(3u, sequencer_->num_bytes_consumed()); sequencer_ 196 net/quic/quic_stream_sequencer_test.cc sequencer_->SetBlockedUntilFlush(); sequencer_ 198 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(0, "abc")); sequencer_ 199 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(1u, sequencer_->frames()->size()); sequencer_ 200 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->num_bytes_consumed()); sequencer_ 203 net/quic/quic_stream_sequencer_test.cc sequencer_->FlushBufferedFrames(); sequencer_ 204 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->frames()->size()); sequencer_ 205 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(3u, sequencer_->num_bytes_consumed()); sequencer_ 209 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFinFrame(3, "def")); sequencer_ 213 net/quic/quic_stream_sequencer_test.cc sequencer_->SetBlockedUntilFlush(); sequencer_ 215 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFinFrame(0, "abc")); sequencer_ 216 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(1u, sequencer_->frames()->size()); sequencer_ 217 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->num_bytes_consumed()); sequencer_ 221 net/quic/quic_stream_sequencer_test.cc sequencer_->FlushBufferedFrames(); sequencer_ 222 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->frames()->size()); sequencer_ 223 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(3u, sequencer_->num_bytes_consumed()); sequencer_ 229 net/quic/quic_stream_sequencer_test.cc EXPECT_FALSE(sequencer_->OnFrame(0, "")); sequencer_ 230 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->frames()->size()); sequencer_ 231 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->num_bytes_consumed()); sequencer_ 236 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFinFrame(0, "")); sequencer_ 237 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->frames()->size()); sequencer_ 238 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->num_bytes_consumed()); sequencer_ 244 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(0, "abc")); sequencer_ 245 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(1u, sequencer_->frames()->size()); sequencer_ 246 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(2u, sequencer_->num_bytes_consumed()); sequencer_ 247 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ("c", sequencer_->frames()->find(2)->second); sequencer_ 253 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(0, "abc")); sequencer_ 254 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(1u, sequencer_->frames()->size()); sequencer_ 255 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->num_bytes_consumed()); sequencer_ 256 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ("abc", sequencer_->frames()->find(0)->second); sequencer_ 260 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(3, "abc")); sequencer_ 261 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(1u, sequencer_->frames()->size()); sequencer_ 262 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->num_bytes_consumed()); sequencer_ 263 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ("abc", sequencer_->frames()->find(3)->second); sequencer_ 268 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(6, "ghi")); sequencer_ 269 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(1u, sequencer_->frames()->size()); sequencer_ 270 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->num_bytes_consumed()); sequencer_ 271 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(3u, sequencer_->num_bytes_buffered()); sequencer_ 273 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(3, "def")); sequencer_ 274 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(2u, sequencer_->frames()->size()); sequencer_ 275 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->num_bytes_consumed()); sequencer_ 276 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(6u, sequencer_->num_bytes_buffered()); sequencer_ 284 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(0, "abc")); sequencer_ 285 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(9u, sequencer_->num_bytes_consumed()); sequencer_ 286 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->num_bytes_buffered()); sequencer_ 288 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->frames()->size()); sequencer_ 292 net/quic/quic_stream_sequencer_test.cc sequencer_->SetMemoryLimit(9); sequencer_ 295 net/quic/quic_stream_sequencer_test.cc EXPECT_FALSE(sequencer_->OnFrame(9, "jkl")); sequencer_ 298 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(6, "ghi")); sequencer_ 299 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->num_bytes_consumed()); sequencer_ 300 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(3u, sequencer_->num_bytes_buffered()); sequencer_ 306 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(0, "abc")); sequencer_ 307 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(3u, sequencer_->num_bytes_consumed()); sequencer_ 308 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(3u, sequencer_->num_bytes_buffered()); sequencer_ 311 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(9, "jkl")); sequencer_ 312 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(3u, sequencer_->num_bytes_consumed()); sequencer_ 313 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(6u, sequencer_->num_bytes_buffered()); sequencer_ 319 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(3, "def")); sequencer_ 320 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(12u, sequencer_->num_bytes_consumed()); sequencer_ 321 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->frames()->size()); sequencer_ 322 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->num_bytes_buffered()); sequencer_ 326 net/quic/quic_stream_sequencer_test.cc sequencer_->SetMemoryLimit(9); sequencer_ 349 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(0, "abc")); sequencer_ 350 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(3, "def")); sequencer_ 351 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(9, "jkl")); sequencer_ 352 net/quic/quic_stream_sequencer_test.cc EXPECT_FALSE(sequencer_->OnFrame(12, "mno")); sequencer_ 353 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(6, "ghi")); sequencer_ 356 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(9u, sequencer_->num_bytes_buffered()); sequencer_ 359 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(3, sequencer_->Readv(iov, 2)); sequencer_ 361 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(6u, sequencer_->num_bytes_buffered()); sequencer_ 364 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(12, "mno")); sequencer_ 365 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(9u, sequencer_->num_bytes_buffered()); sequencer_ 369 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(9, sequencer_->Readv(iov, 2)); sequencer_ 371 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->num_bytes_buffered()); sequencer_ 373 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(15, "pqr")); sequencer_ 378 net/quic/quic_stream_sequencer_test.cc sequencer_->SetMemoryLimit(9); sequencer_ 385 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(0, "abc")); sequencer_ 386 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(3, "def")); sequencer_ 387 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(9, "jkl")); sequencer_ 388 net/quic/quic_stream_sequencer_test.cc EXPECT_FALSE(sequencer_->OnFrame(12, "mno")); sequencer_ 389 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(6, "ghi")); sequencer_ 392 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(9u, sequencer_->num_bytes_buffered()); sequencer_ 399 net/quic/quic_stream_sequencer_test.cc ASSERT_EQ(3, sequencer_->Readv(&read_iov, 1)); sequencer_ 400 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(6u, sequencer_->num_bytes_buffered()); sequencer_ 403 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(12, "mno")); sequencer_ 404 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(9u, sequencer_->num_bytes_buffered()); sequencer_ 410 net/quic/quic_stream_sequencer_test.cc ASSERT_EQ(9, sequencer_->Readv(&read_iov, 1)); sequencer_ 411 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(0u, sequencer_->num_bytes_buffered()); sequencer_ 413 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(15, "pqr")); sequencer_ 421 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFinFrame(0, "abc")); sequencer_ 423 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(3u, sequencer_->close_offset()); sequencer_ 427 net/quic/quic_stream_sequencer_test.cc sequencer_->OnFinFrame(6, ""); sequencer_ 428 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(6u, sequencer_->close_offset()); sequencer_ 434 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(3, "def")); sequencer_ 435 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(0, "abc")); sequencer_ 439 net/quic/quic_stream_sequencer_test.cc sequencer_->OnFinFrame(3, ""); sequencer_ 440 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(3u, sequencer_->close_offset()); sequencer_ 445 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(0, "abc")); sequencer_ 451 net/quic/quic_stream_sequencer_test.cc sequencer_->OnFinFrame(3, ""); sequencer_ 452 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(3u, sequencer_->close_offset()); sequencer_ 454 net/quic/quic_stream_sequencer_test.cc EXPECT_FALSE(sequencer_->IsClosed()); sequencer_ 457 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(0, "abc")); sequencer_ 460 net/quic/quic_stream_sequencer_test.cc int bytes_read = sequencer_->Readv(&iov, 1); sequencer_ 462 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->IsClosed()); sequencer_ 466 net/quic/quic_stream_sequencer_test.cc sequencer_->OnFinFrame(3, ""); sequencer_ 467 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(3u, sequencer_->close_offset()); sequencer_ 470 net/quic/quic_stream_sequencer_test.cc sequencer_->OnFinFrame(5, ""); sequencer_ 471 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(3u, sequencer_->close_offset()); sequencer_ 474 net/quic/quic_stream_sequencer_test.cc sequencer_->OnFinFrame(1, ""); sequencer_ 475 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(3u, sequencer_->close_offset()); sequencer_ 477 net/quic/quic_stream_sequencer_test.cc sequencer_->OnFinFrame(3, ""); sequencer_ 478 net/quic/quic_stream_sequencer_test.cc EXPECT_EQ(3u, sequencer_->close_offset()); sequencer_ 532 net/quic/quic_stream_sequencer_test.cc EXPECT_TRUE(sequencer_->OnFrame(list_[index].first, sequencer_ 542 net/quic/quic_stream_sequencer_test.cc sequencer_->SetMemoryLimit(26); sequencer_ 555 net/quic/quic_stream_sequencer_test.cc bool acked = sequencer_->OnFrame(list_[index].first, sequencer_ 109 net/quic/reliable_quic_stream.cc : sequencer_(this), sequencer_ 146 net/quic/reliable_quic_stream.cc return sequencer_.WillAcceptStreamFrame(frame); sequencer_ 160 net/quic/reliable_quic_stream.cc bool accepted = sequencer_.OnStreamFrame(frame); sequencer_ 170 net/quic/reliable_quic_stream.cc << ", we have consumed: " << sequencer_.num_bytes_consumed() sequencer_ 171 net/quic/reliable_quic_stream.cc << ", we have buffered: " << sequencer_.num_bytes_buffered() sequencer_ 191 net/quic/reliable_quic_stream.cc sequencer_.num_bytes_consumed(); sequencer_ 199 net/quic/reliable_quic_stream.cc << "Consumed bytes: " << sequencer_.num_bytes_consumed() sequencer_ 234 net/quic/reliable_quic_stream.cc DCHECK(sequencer_.IsClosed()); sequencer_ 490 net/quic/reliable_quic_stream.cc return sequencer_.num_bytes_consumed() + sequencer_.num_bytes_buffered(); sequencer_ 139 net/quic/reliable_quic_stream.h const QuicStreamSequencer* sequencer() const { return &sequencer_; } sequencer_ 140 net/quic/reliable_quic_stream.h QuicStreamSequencer* sequencer() { return &sequencer_; } sequencer_ 169 net/quic/reliable_quic_stream.h QuicStreamSequencer sequencer_;