Lines Matching defs:frames_
170 ScopedVector<WebSocketFrame> frames_;
243 // it to |frames_|.
258 frames_.push_back(frame.release());
274 int result = stream_->ReadFrames(&frames_, cb_.callback());
276 ASSERT_EQ(1U, frames_.size());
277 EXPECT_EQ(GG_UINT64_C(6), frames_[0]->header.payload_length);
278 EXPECT_TRUE(frames_[0]->header.final);
283 int result = stream_->ReadFrames(&frames_, cb_.callback());
286 ASSERT_EQ(1U, frames_.size());
287 EXPECT_EQ(GG_UINT64_C(6), frames_[0]->header.payload_length);
296 int result = stream_->ReadFrames(&frames_, cb_.callback());
298 ASSERT_EQ(1U, frames_.size());
299 EXPECT_EQ(GG_UINT64_C(6), frames_[0]->header.payload_length);
306 int result = stream_->ReadFrames(&frames_, cb_.callback());
309 ASSERT_EQ(1U, frames_.size());
310 EXPECT_EQ(GG_UINT64_C(6), frames_[0]->header.payload_length);
319 int result = stream_->ReadFrames(&frames_, cb_.callback());
322 ASSERT_EQ(1U, frames_.size());
323 EXPECT_EQ(GG_UINT64_C(6), frames_[0]->header.payload_length);
333 EXPECT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
340 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
341 ASSERT_EQ(1U, frames_.size());
342 EXPECT_FALSE(frames_[0]->header.final);
344 static_cast<size_t>(frames_[0]->header.payload_length));
352 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
353 ASSERT_EQ(1U, frames_.size());
354 EXPECT_EQ(NULL, frames_[0]->data.get());
355 EXPECT_EQ(0U, frames_[0]->header.payload_length);
356 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames_[0]->header.opcode);
368 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
369 ASSERT_EQ(1U, frames_.size());
370 EXPECT_EQ(NULL, frames_[0]->data.get());
371 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames_[0]->header.opcode);
372 frames_.clear();
373 EXPECT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
375 ASSERT_EQ(1U, frames_.size());
377 frames_[0]->header.payload_length);
379 frames_[0]->header.opcode);
393 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[0].callback()));
395 ASSERT_EQ(1U, frames_.size());
397 frames_[0]->header.payload_length);
399 frames_.clear();
400 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[1].callback()));
402 ASSERT_EQ(1U, frames_.size());
403 EXPECT_EQ(kChunkSize, frames_[0]->header.payload_length);
417 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[0].callback()));
419 ASSERT_EQ(1U, frames_.size());
420 ASSERT_FALSE(frames_[0]->header.final);
422 frames_.clear();
423 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[1].callback()));
425 ASSERT_EQ(1U, frames_.size());
426 ASSERT_TRUE(frames_[0]->header.final);
443 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[0].callback()));
445 ASSERT_EQ(1U, frames_.size());
446 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames_[0]->header.opcode);
451 frames_.clear();
452 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[i].callback()));
454 ASSERT_EQ(1U, frames_.size());
456 frames_[0]->header.opcode);
464 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
465 ASSERT_EQ(3U, frames_.size());
466 EXPECT_TRUE(frames_[0]->header.final);
467 EXPECT_TRUE(frames_[1]->header.final);
468 EXPECT_TRUE(frames_[2]->header.final);
476 stream_->ReadFrames(&frames_, cb_.callback()));
482 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
494 stream_->ReadFrames(&frames_, cb_.callback()));
500 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
510 stream_->ReadFrames(&frames_, cb_.callback()));
516 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
531 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
532 EXPECT_EQ(1U, frames_.size());
533 frames_.clear();
535 stream_->ReadFrames(&frames_, cb_.callback()));
545 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
556 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
564 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
565 ASSERT_EQ(1U, frames_.size());
566 EXPECT_EQ(NULL, frames_[0]->data.get());
567 EXPECT_EQ(0U, frames_[0]->header.payload_length);
578 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
579 EXPECT_EQ(1U, frames_.size());
580 frames_.clear();
581 EXPECT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
595 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
596 EXPECT_EQ(1U, frames_.size());
597 frames_.clear();
598 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
600 ASSERT_EQ(1U, frames_.size());
601 EXPECT_EQ(WebSocketFrameHeader::kOpCodePong, frames_[0]->header.opcode);
609 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
610 ASSERT_EQ(1U, frames_.size());
611 EXPECT_EQ(NULL, frames_[0]->data.get());
612 EXPECT_EQ(0U, frames_[0]->header.payload_length);
625 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
626 ASSERT_EQ(1U, frames_.size());
627 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames_[0]->header.opcode);
628 frames_.clear();
629 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
630 ASSERT_EQ(1U, frames_.size());
631 EXPECT_TRUE(frames_[0]->header.final);
640 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
641 ASSERT_EQ(1U, frames_.size());
642 ASSERT_TRUE(frames_[0]->data.get());
643 EXPECT_EQ(GG_UINT64_C(6), frames_[0]->header.payload_length);
653 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
655 ASSERT_EQ(1U, frames_.size());
656 ASSERT_TRUE(frames_[0]->data.get());
657 EXPECT_EQ(GG_UINT64_C(6), frames_[0]->header.payload_length);
658 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames_[0]->header.opcode);
671 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
673 ASSERT_EQ(1U, frames_.size());
674 EXPECT_EQ(WebSocketFrameHeader::kOpCodeClose, frames_[0]->header.opcode);
675 EXPECT_EQ(kCloseFrameSize - 2, frames_[0]->header.payload_length);
678 memcmp(frames_[0]->data->data(), kCloseFrame + 2, kCloseFrameSize - 2));
691 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
692 ASSERT_EQ(1U, frames_.size());
693 EXPECT_EQ(WebSocketFrameHeader::kOpCodeClose, frames_[0]->header.opcode);
701 stream_->ReadFrames(&frames_, cb_.callback()));
707 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
719 stream_->ReadFrames(&frames_, cb_.callback()));
720 EXPECT_TRUE(frames_.empty());
731 stream_->ReadFrames(&frames_, cb_.callback()));
732 EXPECT_TRUE(frames_.empty());
748 stream_->ReadFrames(&frames_, cb_.callback()));
749 EXPECT_TRUE(frames_.empty());
763 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
767 EXPECT_TRUE(frames_.empty());
777 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
778 ASSERT_EQ(1U, frames_.size());
779 EXPECT_EQ(WebSocketFrameHeader::kOpCodeClose, frames_[0]->header.opcode);
789 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
791 ASSERT_EQ(1U, frames_.size());
792 EXPECT_EQ(WebSocketFrameHeader::kOpCodeClose, frames_[0]->header.opcode);
817 frames_.clear();
818 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_
820 ASSERT_EQ(1U, frames_.size());
827 EXPECT_EQ(expected_payload_size, frames_[0]->header.payload_length);
846 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[0].callback()));
848 ASSERT_EQ(1U, frames_.size());
849 EXPECT_TRUE(frames_[0]->header.reserved1);
851 frames_.clear();
852 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[1].callback()));
854 ASSERT_EQ(1U, frames_.size());
855 EXPECT_FALSE(frames_[0]->header.reserved1);
863 EXPECT_EQ(OK, stream_->WriteFrames(&frames_, cb_.callback()));
871 ASSERT_EQ(ERR_IO_PENDING, stream_->WriteFrames(&frames_, cb_.callback()));
884 ASSERT_EQ(ERR_IO_PENDING, stream_->WriteFrames(&frames_, cb_.callback()));
925 frames_.push_back(frame.release());
927 EXPECT_EQ(OK, stream_->WriteFrames(&frames_, cb_.callback()));
