Lines Matching refs:frames
75 void AppendTo(ScopedVector<WebSocketFrame>* frames,
84 frames->push_back(frame.release());
87 void AppendTo(ScopedVector<WebSocketFrame>* frames,
93 frames->push_back(frame.release());
117 ADD_FAILURE() << "There are missing frames to be input.";
121 ADD_FAILURE() << "There are extra written frames.";
127 virtual Result Predict(const ScopedVector<WebSocketFrame>& frames,
133 ADD_FAILURE() << "Control frames should not be recorded.";
152 ADD_FAILURE() << "Control frames should not be recorded.";
172 ADD_FAILURE() << "There are missing frames to be written.";
181 void AddFramesToBeInput(const ScopedVector<WebSocketFrame>& frames) {
182 for (size_t i = 0; i < frames.size(); ++i)
183 AddFrameToBeInput(frames[i]);
185 void VerifySentFrames(const ScopedVector<WebSocketFrame>& frames) {
186 for (size_t i = 0; i < frames.size(); ++i)
187 VerifySentFrame(frames[i]);
198 // Data frames which will be recorded by |RecordInputFrames|.
202 // Data frames recorded by |RecordWrittenFrames|.
294 int Call(ScopedVector<WebSocketFrame>* frames,
296 DCHECK(frames->empty());
297 frames_passed_ = frames;
299 frames->swap(frames_to_output_);
325 int Call(ScopedVector<WebSocketFrame>* frames,
327 frames_.insert(frames_.end(), frames->begin(), frames->end());
328 frames->weak_clear();
336 ScopedVector<WebSocketFrame>* frames() { return &frames_; }
346 ScopedVector<WebSocketFrame> frames;
350 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
353 EXPECT_EQ(ERR_FAILED, deflate_stream_->ReadFrames(&frames, callback));
363 ScopedVector<WebSocketFrame> frames;
367 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
371 ASSERT_EQ(OK, deflate_stream_->ReadFrames(&frames, callback));
372 ASSERT_EQ(1u, frames.size());
373 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[0]->header.opcode);
374 EXPECT_TRUE(frames[0]->header.final);
375 EXPECT_FALSE(frames[0]->header.reserved1);
376 EXPECT_EQ("hello", ToString(frames[0]));
381 ScopedVector<WebSocketFrame> frames;
388 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
393 ASSERT_EQ(ERR_IO_PENDING, deflate_stream_->ReadFrames(&frames, callback));
394 ASSERT_EQ(0u, frames.size());
403 ASSERT_EQ(1u, frames.size());
404 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[0]->header.opcode);
405 EXPECT_TRUE(frames[0]->header.final);
406 EXPECT_FALSE(frames[0]->header.reserved1);
407 EXPECT_EQ("hello", ToString(frames[0]));
412 ScopedVector<WebSocketFrame> frames;
419 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
424 ASSERT_EQ(ERR_IO_PENDING, deflate_stream_->ReadFrames(&frames, callback));
425 ASSERT_EQ(0u, frames.size());
434 ASSERT_EQ(0u, frames.size());
445 ScopedVector<WebSocketFrame> frames;
448 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
451 ASSERT_EQ(OK, deflate_stream_->ReadFrames(&frames, callback));
452 ASSERT_EQ(1u, frames.size());
453 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[0]->header.opcode);
454 EXPECT_TRUE(frames[0]->header.final);
455 EXPECT_FALSE(frames[0]->header.reserved1);
456 EXPECT_EQ("Hello", ToString(frames[0]));
464 ScopedVector<WebSocketFrame> frames;
467 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
472 ASSERT_EQ(ERR_IO_PENDING, deflate_stream_->ReadFrames(&frames, callback));
482 ASSERT_EQ(1u, frames.size());
483 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[0]->header.opcode);
484 EXPECT_TRUE(frames[0]->header.final);
485 EXPECT_FALSE(frames[0]->header.reserved1);
486 EXPECT_EQ("Hello", ToString(frames[0]));
502 ScopedVector<WebSocketFrame> frames;
506 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
512 ASSERT_EQ(ERR_IO_PENDING, deflate_stream_->ReadFrames(&frames, callback));
513 ASSERT_EQ(0u, frames.size());
523 ASSERT_EQ(1u, frames.size());
524 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[0]->header.opcode);
525 EXPECT_TRUE(frames[0]->header.final);
526 EXPECT_FALSE(frames[0]->header.reserved1);
527 EXPECT_EQ("Hello", ToString(frames[0]));
539 ScopedVector<WebSocketFrame> frames;
543 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
547 deflate_stream_->ReadFrames(&frames, callback));
548 ASSERT_EQ(0u, frames.size());
565 ScopedVector<WebSocketFrame> frames;
569 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
572 ASSERT_EQ(OK, deflate_stream_->ReadFrames(&frames, callback));
573 ASSERT_EQ(1u, frames.size());
574 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[0]->header.opcode);
575 EXPECT_TRUE(frames[0]->header.final);
576 EXPECT_FALSE(frames[0]->header.reserved1);
577 EXPECT_EQ("Hello", ToString(frames[0]));
590 ScopedVector<WebSocketFrame> frames;
594 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
597 ASSERT_EQ(OK, deflate_stream_->ReadFrames(&frames, callback));
598 ASSERT_EQ(2u, frames.size());
599 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[0]->header.opcode);
600 EXPECT_FALSE(frames[0]->header.final);
601 EXPECT_FALSE(frames[0]->header.reserved1);
602 EXPECT_EQ("", ToString(frames[0]));
604 frames[1]->header.opcode);
605 EXPECT_TRUE(frames[1]->header.final);
606 EXPECT_FALSE(frames[1]->header.reserved1);
607 EXPECT_EQ("", ToString(frames[1]));
621 ScopedVector<WebSocketFrame> frames;
625 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
628 ASSERT_EQ(OK, deflate_stream_->ReadFrames(&frames, callback));
629 ASSERT_EQ(1u, frames.size());
630 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[0]->header.opcode);
631 EXPECT_TRUE(frames[0]->header.final);
632 EXPECT_FALSE(frames[0]->header.reserved1);
633 EXPECT_EQ("", ToString(frames[0]));
649 ScopedVector<WebSocketFrame> frames;
653 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
656 ASSERT_EQ(OK, deflate_stream_->ReadFrames(&frames, callback));
657 ASSERT_EQ(1u, frames.size());
658 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[0]->header.opcode);
659 EXPECT_TRUE(frames[0]->header.final);
660 EXPECT_FALSE(frames[0]->header.reserved1);
661 EXPECT_EQ("Hello", ToString(frames[0]));
676 ScopedVector<WebSocketFrame> frames;
680 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
683 ASSERT_EQ(OK, deflate_stream_->ReadFrames(&frames, callback));
684 ASSERT_EQ(2u, frames.size());
685 EXPECT_EQ(WebSocketFrameHeader::kOpCodePing, frames[0]->header.opcode);
686 EXPECT_TRUE(frames[0]->header.final);
687 EXPECT_FALSE(frames[0]->header.reserved1);
688 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[1]->header.opcode);
689 EXPECT_TRUE(frames[1]->header.final);
690 EXPECT_FALSE(frames[1]->header.reserved1);
691 EXPECT_EQ("Hello", ToString(frames[1]));
710 ScopedVector<WebSocketFrame> frames;
713 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
717 ASSERT_EQ(OK, deflate_stream_->ReadFrames(&frames, callback));
718 ASSERT_EQ(3u, frames.size());
719 EXPECT_EQ(WebSocketFrameHeader::kOpCodeBinary, frames[0]->header.opcode);
720 EXPECT_FALSE(frames[0]->header.final);
721 EXPECT_FALSE(frames[0]->header.reserved1);
722 EXPECT_EQ(kChunkSize, static_cast<size_t>(frames[0]->header.payload_length));
724 frames[1]->header.opcode);
725 EXPECT_FALSE(frames[1]->header.final);
726 EXPECT_FALSE(frames[1]->header.reserved1);
727 EXPECT_EQ(kChunkSize, static_cast<size_t>(frames[1]->header.payload_length));
729 frames[2]->header.opcode);
730 EXPECT_TRUE(frames[2]->header.final);
731 EXPECT_FALSE(frames[2]->header.reserved1);
732 EXPECT_EQ(kChunkSize, static_cast<size_t>(frames[2]->header.payload_length));
734 ToString(frames[0]) + ToString(frames[1]) + ToString(frames[2]));
756 ScopedVector<WebSocketFrame> frames;
759 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
763 ASSERT_EQ(OK, deflate_stream_->ReadFrames(&frames, callback));
764 ASSERT_EQ(2u, frames.size());
765 EXPECT_EQ(WebSocketFrameHeader::kOpCodeBinary, frames[0]->header.opcode);
766 EXPECT_FALSE(frames[0]->header.final);
767 EXPECT_FALSE(frames[0]->header.reserved1);
768 EXPECT_EQ(kChunkSize, static_cast<size_t>(frames[0]->header.payload_length));
771 frames[1]->header.opcode);
772 EXPECT_TRUE(frames[1]->header.final);
773 EXPECT_FALSE(frames[1]->header.reserved1);
774 EXPECT_EQ(0u, static_cast<size_t>(frames[1]->header.payload_length));
775 EXPECT_EQ(original_data, ToString(frames[0]) + ToString(frames[1]));
793 ScopedVector<WebSocketFrame> frames;
797 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
801 deflate_stream_->ReadFrames(&frames, callback));
817 ScopedVector<WebSocketFrame> frames;
821 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
825 deflate_stream_->ReadFrames(&frames, callback));
841 ScopedVector<WebSocketFrame> frames;
845 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
848 ASSERT_EQ(OK, deflate_stream_->ReadFrames(&frames, callback));
849 ASSERT_EQ(2u, frames.size());
850 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[0]->header.opcode);
851 EXPECT_TRUE(frames[0]->header.final);
852 EXPECT_FALSE(frames[0]->header.reserved1);
853 EXPECT_EQ("compressed1", ToString(frames[0]));
854 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[1]->header.opcode);
855 EXPECT_TRUE(frames[1]->header.final);
856 EXPECT_FALSE(frames[1]->header.reserved1);
857 EXPECT_EQ("compressed2", ToString(frames[1]));
872 ScopedVector<WebSocketFrame> frames;
876 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
879 ASSERT_EQ(OK, deflate_stream_->ReadFrames(&frames, callback));
880 ASSERT_EQ(2u, frames.size());
881 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[0]->header.opcode);
882 EXPECT_TRUE(frames[0]->header.final);
883 EXPECT_FALSE(frames[0]->header.reserved1);
884 EXPECT_EQ("uncompressed1", ToString(frames[0]));
885 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[1]->header.opcode);
886 EXPECT_TRUE(frames[1]->header.final);
887 EXPECT_FALSE(frames[1]->header.reserved1);
888 EXPECT_EQ("uncompressed2", ToString(frames[1]));
905 ScopedVector<WebSocketFrame> frames;
909 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
912 ASSERT_EQ(OK, deflate_stream_->ReadFrames(&frames, callback));
913 ASSERT_EQ(2u, frames.size());
914 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[0]->header.opcode);
915 EXPECT_TRUE(frames[0]->header.final);
916 EXPECT_FALSE(frames[0]->header.reserved1);
917 EXPECT_EQ("compressed", ToString(frames[0]));
918 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[1]->header.opcode);
919 EXPECT_TRUE(frames[1]->header.final);
920 EXPECT_FALSE(frames[1]->header.reserved1);
921 EXPECT_EQ("uncompressed", ToString(frames[1]));
938 ScopedVector<WebSocketFrame> frames;
942 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
945 ASSERT_EQ(OK, deflate_stream_->ReadFrames(&frames, callback));
946 ASSERT_EQ(2u, frames.size());
947 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[0]->header.opcode);
948 EXPECT_TRUE(frames[0]->header.final);
949 EXPECT_FALSE(frames[0]->header.reserved1);
950 EXPECT_EQ("uncompressed", ToString(frames[0]));
951 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[1]->header.opcode);
952 EXPECT_TRUE(frames[1]->header.final);
953 EXPECT_FALSE(frames[1]->header.reserved1);
954 EXPECT_EQ("compressed", ToString(frames[1]));
965 ScopedVector<WebSocketFrame> frames;
969 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
972 EXPECT_CALL(*mock_stream_, ReadFrames(&frames, _))
978 ASSERT_EQ(ERR_IO_PENDING, deflate_stream_->ReadFrames(&frames, callback));
989 ASSERT_EQ(1u, frames.size());
990 EXPECT_EQ(WebSocketFrameHeader::kOpCodeText, frames[0]->header.opcode);
991 EXPECT_EQ("", ToString(frames[0]));
995 ScopedVector<WebSocketFrame> frames;
999 EXPECT_CALL(*mock_stream_, WriteFrames(&frames, _)).Times(0);
1001 EXPECT_EQ(OK, deflate_stream_->WriteFrames(&frames, callback));
1005 ScopedVector<WebSocketFrame> frames;
1009 EXPECT_CALL(*mock_stream_, WriteFrames(&frames, _))
1013 AppendTo(&frames, WebSocketFrameHeader::kOpCodeText, kFinal, "hello");
1014 predictor_->AddFramesToBeInput(frames);
1015 EXPECT_EQ(ERR_FAILED, deflate_stream_->WriteFrames(&frames, callback));
1020 ScopedVector<WebSocketFrame> frames;
1023 AppendTo(&frames, WebSocketFrameHeader::kOpCodeText, kFinal, "Hello");
1024 predictor_->AddFramesToBeInput(frames);
1030 ASSERT_EQ(OK, deflate_stream_->WriteFrames(&frames, callback));
1031 const ScopedVector<WebSocketFrame>& frames_passed = *stub.frames();
1045 ScopedVector<WebSocketFrame> frames;
1048 EXPECT_CALL(*mock_stream_, WriteFrames(&frames, _))
1053 AppendTo(&frames, WebSocketFrameHeader::kOpCodeText, kFinal, "Hello");
1054 predictor_->AddFramesToBeInput(frames);
1055 ASSERT_EQ(ERR_IO_PENDING, deflate_stream_->WriteFrames(&frames, callback));
1060 const ScopedVector<WebSocketFrame>& frames_passed = *stub.frames();
1070 ScopedVector<WebSocketFrame> frames;
1071 AppendTo(&frames, WebSocketFrameHeader::kOpCodeText, kNoFlag, "Hel");
1072 AppendTo(&frames, WebSocketFrameHeader::kOpCodePing, kFinal);
1073 AppendTo(&frames, WebSocketFrameHeader::kOpCodeContinuation, kFinal, "lo");
1074 predictor_->AddFramesToBeInput(frames);
1080 EXPECT_CALL(*mock_stream_, WriteFrames(&frames, _))
1083 ASSERT_EQ(OK, deflate_stream_->WriteFrames(&frames, callback));
1084 const ScopedVector<WebSocketFrame>& frames_passed = *stub.frames();
1097 ScopedVector<WebSocketFrame> frames;
1098 AppendTo(&frames, WebSocketFrameHeader::kOpCodeText, kFinal);
1099 predictor_->AddFramesToBeInput(frames);
1105 EXPECT_CALL(*mock_stream_, WriteFrames(&frames, _))
1108 ASSERT_EQ(OK, deflate_stream_->WriteFrames(&frames, callback));
1109 const ScopedVector<WebSocketFrame>& frames_passed = *stub.frames();
1118 ScopedVector<WebSocketFrame> frames;
1119 AppendTo(&frames, WebSocketFrameHeader::kOpCodeText, kNoFlag, "AAAA");
1120 AppendTo(&frames, WebSocketFrameHeader::kOpCodeContinuation, kFinal, "AAA");
1121 predictor_->AddFramesToBeInput(frames);
1129 EXPECT_CALL(*mock_stream_, WriteFrames(&frames, _))
1132 ASSERT_EQ(OK, deflate_stream_->WriteFrames(&frames, callback));
1133 const ScopedVector<WebSocketFrame>& frames_passed = *stub.frames();
1163 ScopedVector<WebSocketFrame> frames;
1169 AppendTo(&frames, WebSocketFrameHeader::kOpCodeBinary, flag, data);
1170 predictor_->AddFramesToBeInput(frames);
1171 ASSERT_EQ(OK, deflate_stream_->WriteFrames(&frames, callback));
1173 stub.frames()->begin(),
1174 stub.frames()->end());
1175 stub.frames()->weak_clear();
1202 ScopedVector<WebSocketFrame> frames;
1203 AppendTo(&frames, WebSocketFrameHeader::kOpCodeText, kFinal, "Hello");
1204 AppendTo(&frames, WebSocketFrameHeader::kOpCodeText, kFinal, "Hello");
1205 predictor_->AddFramesToBeInput(frames);
1211 EXPECT_CALL(*mock_stream_, WriteFrames(&frames, _))
1214 ASSERT_EQ(OK, deflate_stream_->WriteFrames(&frames, callback));
1215 const ScopedVector<WebSocketFrame>& frames_passed = *stub.frames();
1230 ScopedVector<WebSocketFrame> frames;
1231 AppendTo(&frames, WebSocketFrameHeader::kOpCodeText, kFinal, "Hello");
1232 AppendTo(&frames, WebSocketFrameHeader::kOpCodeText, kFinal, "Hello");
1233 predictor_->AddFramesToBeInput(frames);
1239 EXPECT_CALL(*mock_stream_, WriteFrames(&frames, _))
1242 ASSERT_EQ(OK, deflate_stream_->WriteFrames(&frames, callback));
1243 const ScopedVector<WebSocketFrame>& frames_passed = *stub.frames();
1261 ScopedVector<WebSocketFrame> frames;
1262 AppendTo(&frames, WebSocketFrameHeader::kOpCodeText, kNoFlag, "He");
1263 AppendTo(&frames, WebSocketFrameHeader::kOpCodeContinuation, kFinal, "llo");
1264 AppendTo(&frames, WebSocketFrameHeader::kOpCodeText, kNoFlag, "AAAAAAAAAA");
1265 AppendTo(&frames, WebSocketFrameHeader::kOpCodeContinuation, kFinal, "AA");
1266 AppendTo(&frames, WebSocketFrameHeader::kOpCodeText, kNoFlag, "XX");
1267 AppendTo(&frames, WebSocketFrameHeader::kOpCodeContinuation, kFinal, "YY");
1268 predictor_->AddFramesToBeInput(frames);
1275 EXPECT_CALL(*mock_stream_, WriteFrames(&frames, _))
1278 ASSERT_EQ(OK, deflate_stream_->WriteFrames(&frames, callback));
1279 const ScopedVector<WebSocketFrame>& frames_passed = *stub.frames();
1321 const ScopedVector<WebSocketFrame>& frames_passed = *stub.frames();
1340 const ScopedVector<WebSocketFrame>& frames_passed = *stub.frames();