Lines Matching full:cb
333 cb(name),
334 socket(name, cb, GetPacketObserver(name), options) {}
337 testing::NiceMock<MockDcSctpSocketCallbacks> cb; member
345 std::vector<uint8_t> packet_from_a = a.cb.ConsumeSentPacket(); in ExchangeMessages()
350 std::vector<uint8_t> packet_from_z = z.cb.ConsumeSentPacket(); in ExchangeMessages()
360 absl::optional<TimeoutID> timeout_id = s.cb.GetNextExpiredTimeout(); in RunTimers()
369 a.cb.AdvanceTime(duration); in AdvanceTime()
370 z.cb.AdvanceTime(duration); in AdvanceTime()
378 EXPECT_CALL(a.cb, OnConnected).Times(1); in ConnectSockets()
379 EXPECT_CALL(z.cb, OnConnected).Times(1); in ConnectSockets()
383 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in ConnectSockets()
384 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in ConnectSockets()
385 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in ConnectSockets()
386 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in ConnectSockets()
398 EXPECT_CALL(sut->cb, OnClosed).Times(1); in HandoverSocket()
407 EXPECT_CALL(handover_socket->cb, OnConnected).Times(1); in HandoverSocket()
416 absl::optional<DcSctpMessage> msg = z.cb.ConsumeReceivedMessage(); in GetReceivedMessagePpids()
458 absl::optional<DcSctpMessage> msg = z->cb.ConsumeReceivedMessage(); in MaybeHandoverSocketAndSendMessage()
479 EXPECT_CALL(a.cb, OnConnected).Times(1); in TEST()
480 EXPECT_CALL(z.cb, OnConnected).Times(1); in TEST()
481 EXPECT_CALL(a.cb, OnConnectionRestarted).Times(0); in TEST()
482 EXPECT_CALL(z.cb, OnConnectionRestarted).Times(0); in TEST()
486 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
488 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
490 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
492 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
502 EXPECT_CALL(a.cb, OnConnected).Times(1); in TEST()
503 EXPECT_CALL(z.cb, OnConnected).Times(1); in TEST()
504 EXPECT_CALL(a.cb, OnConnectionRestarted).Times(0); in TEST()
505 EXPECT_CALL(z.cb, OnConnectionRestarted).Times(0); in TEST()
519 EXPECT_CALL(a.cb, OnConnected).Times(0); in TEST()
520 EXPECT_CALL(z.cb, OnConnected).Times(1); in TEST()
524 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
526 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
528 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
530 z.cb.ConsumeSentPacket(); in TEST()
541 EXPECT_CALL(a.cb, OnClosed).Times(1); in TEST()
542 EXPECT_CALL(z.cb, OnClosed).Times(1); in TEST()
545 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
547 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
549 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
551 EXPECT_TRUE(a.cb.ConsumeSentPacket().empty()); in TEST()
552 EXPECT_TRUE(z.cb.ConsumeSentPacket().empty()); in TEST()
562 EXPECT_CALL(a.cb, OnConnected).Times(1); in TEST()
563 EXPECT_CALL(z.cb, OnConnected).Times(1); in TEST()
564 EXPECT_CALL(a.cb, OnConnectionRestarted).Times(0); in TEST()
565 EXPECT_CALL(z.cb, OnConnectionRestarted).Times(0); in TEST()
569 a.cb.ConsumeSentPacket(); in TEST()
574 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
577 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
580 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
595 EXPECT_CALL(a.cb, OnConnected).Times(1); in TEST()
596 EXPECT_CALL(z.cb, OnConnected).Times(1); in TEST()
597 EXPECT_CALL(a.cb, OnConnectionRestarted).Times(0); in TEST()
598 EXPECT_CALL(z.cb, OnConnectionRestarted).Times(0); in TEST()
602 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
604 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
606 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
608 z.cb.ConsumeSentPacket(); in TEST()
617 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
619 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
632 SctpPacket::Parse(a.cb.ConsumeSentPacket())); in TEST()
638 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
640 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
642 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
644 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
658 SctpPacket::Parse(a.cb.ConsumeSentPacket())); in TEST()
666 SctpPacket::Parse(a.cb.ConsumeSentPacket())); in TEST()
671 EXPECT_CALL(a.cb, OnAborted).Times(1); in TEST()
685 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
687 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
691 SctpPacket::Parse(a.cb.ConsumeSentPacket())); in TEST()
697 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
699 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
712 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
714 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
718 SctpPacket::Parse(a.cb.ConsumeSentPacket())); in TEST()
726 SctpPacket::Parse(a.cb.ConsumeSentPacket())); in TEST()
731 EXPECT_CALL(a.cb, OnAborted).Times(1); in TEST()
749 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
751 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
755 SctpPacket::Parse(a.cb.ConsumeSentPacket())); in TEST()
760 EXPECT_THAT(a.cb.ConsumeSentPacket(), IsEmpty()); in TEST()
768 EXPECT_THAT(a.cb.ConsumeSentPacket(), IsEmpty()); in TEST()
775 SctpPacket::Parse(a.cb.ConsumeSentPacket())); in TEST()
780 EXPECT_THAT(a.cb.ConsumeSentPacket(), IsEmpty()); in TEST()
786 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
788 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
794 EXPECT_THAT(z.cb.ConsumeReceivedMessage()->payload(), in TEST()
807 EXPECT_CALL(z->cb, OnClosed).Times(1); in TEST_P()
810 z->socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST_P()
812 a.socket.ReceivePacket(z->cb.ConsumeSentPacket()); in TEST_P()
814 z->socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST_P()
831 a.cb.ConsumeSentPacket(); in TEST()
840 SctpPacket::Parse(a.cb.ConsumeSentPacket())); in TEST()
842 EXPECT_TRUE(a.cb.ConsumeSentPacket().empty()); in TEST()
845 EXPECT_CALL(a.cb, OnAborted).Times(1); in TEST()
851 SctpPacket::Parse(a.cb.ConsumeSentPacket())); in TEST()
853 EXPECT_TRUE(a.cb.ConsumeSentPacket().empty()); in TEST()
865 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
867 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
869 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
871 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
876 absl::optional<DcSctpMessage> msg = z.cb.ConsumeReceivedMessage(); in TEST()
888 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
890 absl::optional<DcSctpMessage> msg = z.cb.ConsumeReceivedMessage(); in TEST()
903 a.cb.ConsumeSentPacket(); in TEST_P()
908 z->socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST_P()
910 absl::optional<DcSctpMessage> msg = z->cb.ConsumeReceivedMessage(); in TEST_P()
928 z->socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST_P()
930 a.cb.ConsumeSentPacket(); in TEST_P()
935 absl::optional<DcSctpMessage> msg = z->cb.ConsumeReceivedMessage(); in TEST_P()
960 SctpPacket::Parse(a.cb.ConsumeSentPacket())); in TEST_P()
978 EXPECT_THAT(a.cb.ConsumeSentPacket(), IsEmpty()); in TEST_P()
982 std::vector<uint8_t> hb_packet_raw = a.cb.ConsumeSentPacket(); in TEST_P()
996 a.socket.ReceivePacket(z->cb.ConsumeSentPacket()); in TEST_P()
1009 EXPECT_CALL(z->cb, OnClosed).Times(1); in TEST_P()
1010 EXPECT_THAT(a.cb.ConsumeSentPacket(), testing::IsEmpty()); in TEST_P()
1022 SctpPacket::Parse(a.cb.ConsumeSentPacket())); in TEST_P()
1035 EXPECT_THAT(a.cb.ConsumeSentPacket(), Not(IsEmpty())); in TEST_P()
1037 EXPECT_CALL(a.cb, OnAborted).Times(1); in TEST_P()
1051 EXPECT_THAT(a.cb.ConsumeSentPacket(), testing::IsEmpty()); in TEST_P()
1052 EXPECT_CALL(z->cb, OnClosed).Times(1); in TEST_P()
1062 a.cb.ConsumeSentPacket(); in TEST_P()
1073 std::vector<uint8_t> hb_packet_raw = a.cb.ConsumeSentPacket(); in TEST_P()
1086 EXPECT_CALL(a.cb, OnAborted).Times(0); in TEST_P()
1089 EXPECT_THAT(a.cb.ConsumeSentPacket(), IsEmpty()); in TEST_P()
1096 SctpPacket::Parse(a.cb.ConsumeSentPacket())); in TEST_P()
1108 z->socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST_P()
1110 absl::optional<DcSctpMessage> msg = z->cb.ConsumeReceivedMessage(); in TEST_P()
1115 a.socket.ReceivePacket(z->cb.ConsumeSentPacket()); in TEST_P()
1122 EXPECT_CALL(z->cb, OnIncomingStreamsReset).Times(1); in TEST_P()
1123 z->socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST_P()
1126 EXPECT_CALL(a.cb, OnStreamsResetPerformed).Times(1); in TEST_P()
1127 a.socket.ReceivePacket(z->cb.ConsumeSentPacket()); in TEST_P()
1144 auto packet1 = a.cb.ConsumeSentPacket(); in TEST_P()
1148 auto packet2 = a.cb.ConsumeSentPacket(); in TEST_P()
1153 a.socket.ReceivePacket(z->cb.ConsumeSentPacket()); in TEST_P()
1155 absl::optional<DcSctpMessage> msg1 = z->cb.ConsumeReceivedMessage(); in TEST_P()
1159 absl::optional<DcSctpMessage> msg2 = z->cb.ConsumeReceivedMessage(); in TEST_P()
1166 z->socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST_P()
1168 a.socket.ReceivePacket(z->cb.ConsumeSentPacket()); in TEST_P()
1174 auto packet3 = a.cb.ConsumeSentPacket(); in TEST_P()
1178 auto packet4 = a.cb.ConsumeSentPacket(); in TEST_P()
1183 a.socket.ReceivePacket(z->cb.ConsumeSentPacket()); in TEST_P()
1202 auto packet1 = a.cb.ConsumeSentPacket(); in TEST_P()
1207 auto packet2 = a.cb.ConsumeSentPacket(); in TEST_P()
1213 a.socket.ReceivePacket(z->cb.ConsumeSentPacket()); in TEST_P()
1218 auto packet3 = a.cb.ConsumeSentPacket(); in TEST_P()
1222 auto packet4 = a.cb.ConsumeSentPacket(); in TEST_P()
1226 a.socket.ReceivePacket(z->cb.ConsumeSentPacket()); in TEST_P()
1229 absl::optional<DcSctpMessage> msg1 = z->cb.ConsumeReceivedMessage(); in TEST_P()
1233 absl::optional<DcSctpMessage> msg2 = z->cb.ConsumeReceivedMessage(); in TEST_P()
1237 absl::optional<DcSctpMessage> msg3 = z->cb.ConsumeReceivedMessage(); in TEST_P()
1241 absl::optional<DcSctpMessage> msg4 = z->cb.ConsumeReceivedMessage(); in TEST_P()
1248 z->socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST_P()
1250 a.socket.ReceivePacket(z->cb.ConsumeSentPacket()); in TEST_P()
1257 auto packet5 = a.cb.ConsumeSentPacket(); in TEST_P()
1262 auto packet6 = a.cb.ConsumeSentPacket(); in TEST_P()
1268 a.socket.ReceivePacket(z->cb.ConsumeSentPacket()); in TEST_P()
1280 EXPECT_CALL(a.cb, OnConnectionRestarted).Times(1); in TEST_P()
1287 z->socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST_P()
1297 absl::optional<DcSctpMessage> msg = z2.cb.ConsumeReceivedMessage(); in TEST_P()
1318 z->socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST_P()
1320 a.cb.ConsumeSentPacket(); in TEST_P()
1322 z->socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST_P()
1325 a.socket.ReceivePacket(z->cb.ConsumeSentPacket()); in TEST_P()
1331 a.socket.ReceivePacket(z->cb.ConsumeSentPacket()); in TEST_P()
1343 z->socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST_P()
1346 a.socket.ReceivePacket(z->cb.ConsumeSentPacket()); in TEST_P()
1348 absl::optional<DcSctpMessage> msg1 = z->cb.ConsumeReceivedMessage(); in TEST_P()
1352 absl::optional<DcSctpMessage> msg2 = z->cb.ConsumeReceivedMessage(); in TEST_P()
1356 absl::optional<DcSctpMessage> msg3 = z->cb.ConsumeReceivedMessage(); in TEST_P()
1383 std::vector<uint8_t> packet = a.cb.ConsumeSentPacket(); in TEST_P()
1388 packet = a.cb.ConsumeSentPacket(); in TEST_P()
1392 packet = a.cb.ConsumeSentPacket(); in TEST_P()
1397 packet = a.cb.ConsumeSentPacket(); in TEST_P()
1402 packet = a.cb.ConsumeSentPacket(); in TEST_P()
1408 packet = a.cb.ConsumeSentPacket(); in TEST_P()
1413 packet = a.cb.ConsumeSentPacket(); in TEST_P()
1419 packet = a.cb.ConsumeSentPacket(); in TEST_P()
1431 absl::optional<DcSctpMessage> msg1 = z->cb.ConsumeReceivedMessage(); in TEST_P()
1435 ASSERT_FALSE(z->cb.ConsumeReceivedMessage().has_value()); in TEST_P()
1473 SctpPacket::Parse(a.cb.ConsumeSentPacket())); in TEST_P()
1499 EXPECT_CALL(a.cb, OnError(ErrorKind::kPeerReported, in TEST_P()
1514 EXPECT_CALL(z.cb, OnClosed).Times(0); in TEST()
1515 EXPECT_CALL(z.cb, OnAborted).Times(0); in TEST()
1518 std::vector<uint8_t> init_data = a.cb.ConsumeSentPacket(); in TEST()
1525 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
1526 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
1527 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
1544 EXPECT_THAT(z.cb.ConsumeSentPacket(), in TEST()
1559 z.cb.ConsumeSentPacket(), in TEST()
1572 z.cb.ConsumeSentPacket(), in TEST()
1585 z.cb.ConsumeSentPacket(), in TEST()
1600 z.cb.ConsumeSentPacket(), in TEST()
1603 EXPECT_CALL(z.cb, OnAborted(ErrorKind::kResourceExhaustion, _)); in TEST()
1604 EXPECT_CALL(z.cb, OnClosed).Times(0); in TEST()
1631 EXPECT_CALL(a.cb, TimeMillis).WillRepeatedly([&]() { in TEST_P()
1635 EXPECT_CALL(z->cb, TimeMillis).WillRepeatedly([&]() { in TEST_P()
1654 EXPECT_TRUE(z->cb.ConsumeReceivedMessage().has_value()); in TEST_P()
1657 EXPECT_FALSE(z->cb.ConsumeReceivedMessage().has_value()); in TEST_P()
1683 EXPECT_CALL(a.cb, TimeMillis).WillRepeatedly([&]() { in TEST_P()
1687 EXPECT_CALL(z->cb, TimeMillis).WillRepeatedly([&]() { in TEST_P()
1703 std::vector<uint8_t> packet_from_a = a.cb.ConsumeSentPacket(); in TEST_P()
1711 EXPECT_FALSE(z->cb.ConsumeReceivedMessage().has_value()); in TEST_P()
1717 ASSERT_HAS_VALUE_AND_ASSIGN(DcSctpMessage m1, z->cb.ConsumeReceivedMessage()); in TEST_P()
1722 EXPECT_FALSE(z->cb.ConsumeReceivedMessage().has_value()); in TEST_P()
1765 EXPECT_CALL(a.cb, OnBufferedAmountLow).Times(0); in TEST_P()
1769 EXPECT_CALL(a.cb, OnBufferedAmountLow(StreamID(1))); in TEST_P()
1775 EXPECT_CALL(a.cb, OnBufferedAmountLow).WillRepeatedly(testing::Return()); in TEST_P()
1789 EXPECT_CALL(a.cb, OnBufferedAmountLow).Times(0); in TEST_P()
1793 EXPECT_CALL(a.cb, OnBufferedAmountLow(StreamID(1))).Times(0); in TEST_P()
1816 EXPECT_CALL(a.cb, OnBufferedAmountLow).Times(0); in TEST_P()
1820 EXPECT_CALL(a.cb, OnBufferedAmountLow(StreamID(1))).Times(3); in TEST_P()
1821 EXPECT_CALL(a.cb, OnBufferedAmountLow(StreamID(2))).Times(2); in TEST_P()
1860 EXPECT_CALL(a.cb, OnBufferedAmountLow).Times(0); in TEST_P()
1864 EXPECT_CALL(a.cb, OnBufferedAmountLow).Times(0); in TEST_P()
1878 EXPECT_CALL(a.cb, OnBufferedAmountLow(StreamID(1))).Times(1); in TEST_P()
1892 EXPECT_CALL(a.cb, OnTotalBufferedAmountLow).Times(0); in TEST_P()
1911 EXPECT_CALL(a.cb, OnTotalBufferedAmountLow).Times(0); in TEST_P()
1922 EXPECT_CALL(a.cb, OnTotalBufferedAmountLow).Times(1); in TEST_P()
1972 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); // DATA in TEST()
1973 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); // SACK in TEST()
1977 EXPECT_TRUE(z.cb.ConsumeReceivedMessage().has_value()); in TEST()
1992 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); // DATA in TEST()
1993 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); // DATA in TEST()
1995 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); // SACK in TEST()
2000 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); // DATA in TEST()
2002 EXPECT_TRUE(z.cb.ConsumeReceivedMessage().has_value()); in TEST()
2014 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); // SACK in TEST()
2063 std::vector<uint8_t> packet = a.cb.ConsumeSentPacket(); in TEST_P()
2068 EXPECT_THAT(a.cb.ConsumeSentPacket(), IsEmpty()); in TEST_P()
2091 std::vector<uint8_t> packet_from_a = a.cb.ConsumeSentPacket(); in TEST_P()
2097 std::vector<uint8_t> packet_from_z = z->cb.ConsumeSentPacket(); in TEST_P()
2131 z->socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
2132 z->cb.ConsumeReceivedMessage(); in TEST()
2141 z->socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
2143 msg = z->cb.ConsumeReceivedMessage(); in TEST()
2151 z->socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
2153 msg = z->cb.ConsumeReceivedMessage(); in TEST()
2161 a.socket.ReceivePacket(z->cb.ConsumeSentPacket()); // ack in TEST()
2162 a.socket.ReceivePacket(z->cb.ConsumeSentPacket()); // data in TEST()
2164 msg = a.cb.ConsumeReceivedMessage(); in TEST()
2187 EXPECT_CALL(a.cb, OnConnected).Times(1); in TEST()
2188 EXPECT_CALL(z.cb, OnConnected).Times(1); in TEST()
2214 a.cb.ConsumeSentPacket(); in TEST_P()
2223 absl::optional<DcSctpMessage> msg = z->cb.ConsumeReceivedMessage(); in TEST_P()
2227 EXPECT_FALSE(z->cb.ConsumeReceivedMessage().has_value()); in TEST_P()
2238 std::vector<uint8_t> init_data = a.cb.ConsumeSentPacket(); in TEST()
2245 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
2246 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
2247 a.socket.ReceivePacket(z.cb.ConsumeSentPacket()); in TEST()
2286 EXPECT_CALL(z.cb, OnIncomingStreamsReset(ElementsAre(StreamID(1)))).Times(1); in TEST()
2287 EXPECT_CALL(z.cb, OnIncomingStreamsReset(ElementsAre(StreamID(2)))).Times(1); in TEST()
2288 EXPECT_CALL(a.cb, OnStreamsResetPerformed(ElementsAre(StreamID(1)))).Times(1); in TEST()
2289 EXPECT_CALL(a.cb, OnStreamsResetPerformed(ElementsAre(StreamID(2)))).Times(1); in TEST()
2310 EXPECT_CALL(z.cb, OnIncomingStreamsReset(ElementsAre(StreamID(1)))).Times(1); in TEST()
2311 EXPECT_CALL(z.cb, OnIncomingStreamsReset( in TEST()
2314 EXPECT_CALL(a.cb, OnStreamsResetPerformed(ElementsAre(StreamID(1)))).Times(1); in TEST()
2315 EXPECT_CALL(a.cb, OnStreamsResetPerformed( in TEST()
2341 EXPECT_CALL(z.cb, OnIncomingStreamsReset(ElementsAre(StreamID(1)))).Times(1); in TEST()
2342 EXPECT_CALL(z.cb, OnIncomingStreamsReset( in TEST()
2345 EXPECT_CALL(a.cb, OnStreamsResetPerformed(ElementsAre(StreamID(1)))).Times(1); in TEST()
2346 EXPECT_CALL(a.cb, OnStreamsResetPerformed( in TEST()
2362 absl::optional<DcSctpMessage> msg1 = z.cb.ConsumeReceivedMessage(); in TEST()
2365 absl::optional<DcSctpMessage> msg2 = z.cb.ConsumeReceivedMessage(); in TEST()
2368 absl::optional<DcSctpMessage> msg3 = z.cb.ConsumeReceivedMessage(); in TEST()
2375 std::vector<uint8_t> packet = a.cb.ConsumeSentPacket(); in TEST()
2394 absl::optional<DcSctpMessage> msg4 = z.cb.ConsumeReceivedMessage(); in TEST()
2397 absl::optional<DcSctpMessage> msg5 = z.cb.ConsumeReceivedMessage(); in TEST()
2400 absl::optional<DcSctpMessage> msg6 = z.cb.ConsumeReceivedMessage(); in TEST()
2462 EXPECT_CALL(z.cb, OnAborted).Times(1); in TEST()
2467 EXPECT_CALL(a.cb, OnConnected).Times(1); in TEST()
2468 EXPECT_CALL(z.cb, OnConnected).Times(1); in TEST()
2506 absl::optional<DcSctpMessage> msg = z.cb.ConsumeReceivedMessage(); in TEST()
2595 EXPECT_CALL(a.cb, OnLifecycleMessageDelivered(LifecycleId(41))); in TEST()
2596 EXPECT_CALL(a.cb, OnLifecycleEnd(LifecycleId(41))); in TEST()
2597 EXPECT_CALL(a.cb, OnLifecycleMessageDelivered(LifecycleId(42))); in TEST()
2598 EXPECT_CALL(a.cb, OnLifecycleEnd(LifecycleId(42))); in TEST()
2630 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
2632 a.cb.ConsumeSentPacket(); in TEST()
2634 EXPECT_CALL(a.cb, OnLifecycleMessageDelivered(LifecycleId(1))); in TEST()
2635 EXPECT_CALL(a.cb, OnLifecycleEnd(LifecycleId(1))); in TEST()
2636 EXPECT_CALL(a.cb, OnLifecycleMessageExpired(LifecycleId(2), in TEST()
2638 EXPECT_CALL(a.cb, OnLifecycleEnd(LifecycleId(2))); in TEST()
2639 EXPECT_CALL(a.cb, OnLifecycleMessageDelivered(LifecycleId(3))); in TEST()
2640 EXPECT_CALL(a.cb, OnLifecycleEnd(LifecycleId(3))); in TEST()
2673 z.socket.ReceivePacket(a.cb.ConsumeSentPacket()); in TEST()
2675 a.cb.ConsumeSentPacket(); in TEST()
2677 EXPECT_CALL(a.cb, OnLifecycleMessageExpired(LifecycleId(1), in TEST()
2679 EXPECT_CALL(a.cb, OnLifecycleEnd(LifecycleId(1))); in TEST()
2701 EXPECT_CALL(a.cb, OnLifecycleMessageExpired(LifecycleId(1), in TEST()
2703 EXPECT_CALL(a.cb, OnLifecycleEnd(LifecycleId(1))); in TEST()
2753 auto data1 = a.cb.ConsumeSentPacket(); in TEST()
2754 auto data2 = a.cb.ConsumeSentPacket(); in TEST()
2755 auto data3 = a.cb.ConsumeSentPacket(); in TEST()
2756 auto reconfig = a.cb.ConsumeSentPacket(); in TEST()
2770 absl::optional<DcSctpMessage> msg1 = z.cb.ConsumeReceivedMessage(); in TEST()
2776 absl::optional<DcSctpMessage> msg2 = z.cb.ConsumeReceivedMessage(); in TEST()
2782 EXPECT_CALL(a.cb, OnStreamsResetPerformed(ElementsAre(StreamID(1)))); in TEST()
2789 auto reconfig2 = a.cb.ConsumeSentPacket(); in TEST()
2791 EXPECT_CALL(z.cb, OnIncomingStreamsReset(ElementsAre(StreamID(1)))); in TEST()
2794 auto reconfig3 = z.cb.ConsumeSentPacket(); in TEST()
2811 absl::optional<DcSctpMessage> msg3 = z.cb.ConsumeReceivedMessage(); in TEST()
2835 EXPECT_CALL(a.cb, OnStreamsResetPerformed(ElementsAre(StreamID(1)))); in TEST()
2836 EXPECT_CALL(z.cb, OnIncomingStreamsReset(ElementsAre(StreamID(1)))); in TEST()
2839 absl::optional<DcSctpMessage> msg1 = z.cb.ConsumeReceivedMessage(); in TEST()
2845 absl::optional<DcSctpMessage> msg2 = z.cb.ConsumeReceivedMessage(); in TEST()