/external/chromium_org/media/cast/net/rtp/ |
D | framer_unittest.cc | 18 framer_(&testing_clock_, &mock_rtp_payload_feedback_, 0, true, 0) { in FramerTest() 30 Framer framer_; member in media::cast::FramerTest 40 EXPECT_FALSE(framer_.GetEncodedFrame(&frame, &next_frame, &multiple)); in TEST_F() 51 complete = framer_.InsertPacket( in TEST_F() 54 EXPECT_FALSE(framer_.GetEncodedFrame(&frame, &next_frame, &multiple)); in TEST_F() 58 complete = framer_.InsertPacket( in TEST_F() 61 EXPECT_TRUE(framer_.GetEncodedFrame(&frame, &next_frame, &multiple)); in TEST_F() 67 framer_.ReleaseFrame(frame.frame_id); in TEST_F() 79 complete = framer_.InsertPacket( in TEST_F() 82 EXPECT_TRUE(framer_.GetEncodedFrame(&frame, &next_frame, &multiple)); in TEST_F() [all …]
|
D | cast_message_builder.cc | 22 framer_(framer), in CastMessageBuilder() 55 int complete_frame_count = framer_->NumberOfCompleteFrames(); in UpdateAckMessage() 99 if (last_update_time_.is_null() && framer_->Empty()) in TimeToSendNextCastMessage() 124 if (!framer_->Empty()) { in UpdateCastMessageInternal() 152 if (framer_->Empty()) in BuildPacketList() 155 uint32 newest_frame_id = framer_->NewestFrameId(); in BuildPacketList() 173 if (framer_->FrameExists(next_expected_frame_id)) { in BuildPacketList() 175 framer_->GetMissingPackets( in BuildPacketList()
|
D | cast_message_builder_unittest.cc | 86 : framer_(&testing_clock_, in CastMessageBuilderTest() 93 &framer_, in CastMessageBuilderTest() 121 if (framer_.InsertPacket(&payload, 1, rtp_header_, &duplicate)) { in InsertPacket() 130 &framer_, in SetDecoderSlowerThanMaxFrameRate() 137 Framer framer_; member in media::cast::CastMessageBuilderTest 206 framer_.RemoveOldFrames(5); // Simulate 5 being pulled for rendering. in TEST_F() 293 framer_.Reset(); in TEST_F() 335 framer_.RemoveOldFrames(3); // Simulate 3 being pulled for rendering. in TEST_F() 367 framer_.RemoveOldFrames(3); // Simulate 3 being pulled for rendering. in TEST_F() 424 framer_.RemoveOldFrames(frame_id); in TEST_F()
|
D | cast_message_builder.h | 48 const Framer* const framer_; variable
|
/external/chromium_org/extensions/browser/api/cast_channel/ |
D | cast_framer_unittest.cc | 31 framer_.reset(new MessageFramer(buffer_.get())); in SetUp() 42 scoped_ptr<MessageFramer> framer_; member in extensions::core_api::cast_channel::CastFramerTest 52 EXPECT_EQ(4u, framer_->BytesRequested()); in TEST_F() 53 EXPECT_EQ(NULL, framer_->Ingest(1, &message_length, &error).get()); in TEST_F() 55 EXPECT_EQ(3u, framer_->BytesRequested()); in TEST_F() 59 EXPECT_EQ(NULL, framer_->Ingest(3, &message_length, &error).get()); in TEST_F() 63 framer_->BytesRequested()); in TEST_F() 67 message = framer_->Ingest(framer_->BytesRequested(), &message_length, &error); in TEST_F() 71 EXPECT_EQ(4u, framer_->BytesRequested()); in TEST_F() 95 EXPECT_EQ(4u, framer_->BytesRequested()); in TEST_F() [all …]
|
D | cast_transport.cc | 43 framer_.reset(new MessageFramer(read_buffer_)); in CastTransport() 376 size_t num_bytes_to_read = framer_->BytesRequested(); in DoRead() 398 current_message_ = framer_->Ingest(result, &message_size, &error_state_); in DoReadComplete()
|
D | cast_transport.h | 179 scoped_ptr<MessageFramer> framer_; variable
|
/external/chromium_org/net/quic/ |
D | quic_framer_test.cc | 364 framer_(QuicSupportedVersions(), start_, true) { in QuicFramerTest() 366 framer_.set_version(version_); in QuicFramerTest() 367 framer_.SetDecrypter(decrypter_, ENCRYPTION_NONE); in QuicFramerTest() 368 framer_.SetEncrypter(ENCRYPTION_NONE, encrypter_); in QuicFramerTest() 369 framer_.set_visitor(&visitor_); in QuicFramerTest() 370 framer_.set_received_entropy_calculator(&entropy_calculator_); in QuicFramerTest() 449 EXPECT_FALSE(framer_.ProcessPacket(encrypted)) << "len: " << len; in CheckProcessingFails() 450 EXPECT_EQ(expected_error, framer_.detailed_error()) << "len: " << len; in CheckProcessingFails() 451 EXPECT_EQ(error_code, framer_.error()) << "len: " << len; in CheckProcessingFails() 488 QuicFramerPeer::SetLastSequenceNumber(&framer_, last_sequence_number); in CheckCalculatePacketSequenceNumber() [all …]
|
D | quic_headers_stream_test.cc | 87 framer_(SPDY3) { in QuicHeadersStreamTest() 91 framer_.set_visitor(&visitor_); in QuicHeadersStreamTest() 148 framer_.ProcessInput(saved_data_.data(), saved_data_.length()); in WriteHeadersAndCheckData() 149 EXPECT_FALSE(framer_.HasError()) << framer_.error_code(); in WriteHeadersAndCheckData() 158 framer_.ParseHeaderBlockInBuffer(saved_header_data_.data(), in CheckHeaders() 183 SpdyFramer framer_; member in net::test::__anonc53cdcc40111::QuicHeadersStreamTest 225 frame.reset(framer_.SerializeSynStream(syn_stream)); in TEST_P() 231 frame.reset(framer_.SerializeSynReply(syn_reply)); in TEST_P() 249 scoped_ptr<SpdySerializedFrame> frame(framer_.SerializeFrame(data)); in TEST_P() 260 scoped_ptr<SpdySerializedFrame> frame(framer_.SerializeFrame(data)); in TEST_P() [all …]
|
D | quic_packet_creator.cc | 72 framer_(framer), in QuicPacketCreator() 84 framer_->set_fec_builder(this); in QuicPacketCreator() 346 framer_->GetMaxPlaintextSize(max_packet_length_); in BytesFree() 380 framer_->GetMaxPlaintextSize(max_packet_length_); in SerializePacket() 390 framer_->BuildDataPacket(header, queued_frames_, packet_size_); in SerializePacket() 417 SerializedPacket serialized = framer_->BuildFecPacket(header, fec_data); in SerializeFec() 435 DCHECK(framer_->is_server()); in SerializeVersionNegotiationPacket() 442 framer_->BuildVersionNegotiationPacket(header, supported_versions); in SerializeVersionNegotiationPacket() 479 size_t frame_len = framer_->GetSerializedFrameLength( in AddFrame()
|
D | quic_connection.cc | 191 : framer_(supported_versions, helper->GetClock()->ApproximateNow(), in QuicConnection() 218 packet_generator_(connection_id_, &framer_, random_generator_, this), in QuicConnection() 250 framer_.set_visitor(this); in QuicConnection() 251 framer_.set_received_entropy_calculator(&received_packet_manager_); in QuicConnection() 279 const QuicVersionVector& supported_versions = framer_.supported_versions(); in SelectMutualVersion() 284 framer_.set_version(version); in SelectMutualVersion() 343 if (!framer_.IsSupportedVersion(received_version)) { in OnProtocolVersionMismatch() 351 if (!framer_.IsSupportedVersion(received_version)) { in OnProtocolVersionMismatch() 374 framer_.set_version(received_version); in OnProtocolVersionMismatch() 989 << QuicVersionVectorToString(framer_.supported_versions()) << "}"; in SendVersionNegotiationPacket() [all …]
|
D | quic_dispatcher.cc | 191 framer_(supported_versions, /*unused*/ QuicTime::Zero(), true), in QuicDispatcher() 193 framer_.set_visitor(framer_visitor_.get()); in QuicDispatcher() 216 framer_.ProcessPacket(packet); in ProcessPacket() 249 !framer_.IsSupportedVersion(header.versions.front())) { in OnUnauthenticatedPublicHeader() 400 framer_.set_version(time_wait_list_manager_->GetQuicVersionFromConnectionId( in HandlePacketForTimeWait()
|
D | quic_connection_test.cc | 276 framer_(SupportedVersions(version_)), in TestPacketWriter() 302 framer_.framer()->SetDecrypter(new TaggingDecrypter, ENCRYPTION_NONE); in WritePacket() 304 EXPECT_TRUE(framer_.ProcessPacket(packet)); in WritePacket() 326 const QuicPacketHeader& header() { return framer_.header(); } in header() 328 size_t frame_count() const { return framer_.num_frames(); } in frame_count() 331 return framer_.ack_frames(); in ack_frames() 335 return framer_.feedback_frames(); in feedback_frames() 339 return framer_.stop_waiting_frames(); in stop_waiting_frames() 343 return framer_.connection_close_frames(); in connection_close_frames() 347 return framer_.stream_frames(); in stream_frames() [all …]
|
D | quic_dispatcher.h | 165 QuicFramer* framer() { return &framer_; } in framer() 245 QuicFramer framer_; variable
|
D | quic_connection.h | 335 QuicVersion version() const { return framer_.version(); } in version() 339 return framer_.supported_versions(); in supported_versions() 665 QuicFramer framer_; variable
|
/external/chromium_org/media/cast/receiver/ |
D | frame_receiver.cc | 38 framer_(cast_environment->Clock(), in FrameReceiver() 128 framer_.InsertPacket(payload_data, payload_size, rtp_header, &duplicate); in ProcessParsedPacket() 197 if (!framer_.GetEncodedFrame(encoded_frame.get(), in EmitAvailableEncodedFrames() 210 framer_.ReleaseFrame(encoded_frame->frame_id); in EmitAvailableEncodedFrames() 241 framer_.AckFrame(encoded_frame->frame_id); in EmitAvailableEncodedFrames() 250 framer_.ReleaseFrame(encoded_frame->frame_id); in EmitAvailableEncodedFrames() 258 framer_.ReleaseFrame(encoded_frame->frame_id); in EmitAvailableEncodedFrames() 304 framer_.TimeToSendNextCastMessage(&send_time); in ScheduleNextCastMessage() 319 framer_.SendCastMessage(); // Will only send a message if it is time. in SendNextCastMessage()
|
D | frame_receiver.h | 155 Framer framer_; variable
|
/external/chromium_org/net/quic/test_tools/ |
D | simple_quic_framer.cc | 191 : framer_(QuicSupportedVersions(), QuicTime::Zero(), true) { in SimpleQuicFramer() 195 : framer_(supported_versions, QuicTime::Zero(), true) { in SimpleQuicFramer() 202 scoped_ptr<QuicEncryptedPacket> encrypted(framer_.EncryptPacket( in ProcessPacket() 209 framer_.set_visitor(visitor_.get()); in ProcessPacket() 210 return framer_.ProcessPacket(packet); in ProcessPacket() 236 return &framer_; in framer()
|
D | quic_connection_peer.cc | 141 QuicFramerPeer::SetIsServer(&connection->framer_, is_server); in SetIsServer() 159 QuicFramerPeer::SwapCrypters(framer, &connection->framer_); in SwapCrypters() 170 return &connection->framer_; in GetFramer() 242 connection->framer_.SetSupportedVersions(versions); in SetSupportedVersions()
|
D | simple_quic_framer.h | 57 framer_.SetSupportedVersions(versions); in SetSupportedVersions() 61 QuicFramer framer_;
|
/external/chromium_org/net/tools/quic/ |
D | quic_dispatcher.cc | 196 framer_(supported_versions, /*unused*/ QuicTime::Zero(), true), in QuicDispatcher() 198 framer_.set_visitor(framer_visitor_.get()); in QuicDispatcher() 221 framer_.ProcessPacket(packet); in ProcessPacket() 254 !framer_.IsSupportedVersion(header.versions.front())) { in OnUnauthenticatedPublicHeader() 412 framer_.set_version(time_wait_list_manager_->GetQuicVersionFromConnectionId( in HandlePacketForTimeWait()
|
D | quic_dispatcher.h | 173 QuicFramer* framer() { return &framer_; } in framer() 255 QuicFramer framer_; variable
|
D | quic_time_wait_list_manager_test.cc | 94 framer_(QuicSupportedVersions(), QuicTime::Zero(), true), in QuicTimeWaitListManagerTest() 154 BuildUnsizedDataPacket(&framer_, header, frames).packet); in ConstructEncryptedPacket() 156 QuicEncryptedPacket* encrypted = framer_.EncryptPacket(ENCRYPTION_NONE, in ConstructEncryptedPacket() 167 QuicFramer framer_; member in net::tools::test::__anon53959c150111::QuicTimeWaitListManagerTest
|
/external/chromium_org/net/spdy/ |
D | spdy_framer_test.cc | 243 : framer_(version), in TestSpdyVisitor() 321 size_t parsed_length = framer_.ParseHeaderBlockInBuffer( in OnControlFrameHeaderData() 344 if (framer_.protocol_version() > SPDY3) { in OnSynStream() 356 if (framer_.protocol_version() > SPDY3) { in OnSynReply() 386 DCHECK_LT(SPDY3, framer_.protocol_version()); in OnSettingsAck() 391 if (framer_.protocol_version() <= SPDY3) { return; } in OnSettingsEnd() 476 framer_.set_enable_compression(use_compression_); in SimulateInFramer() 477 framer_.set_visitor(this); in SimulateInFramer() 481 framer_.error_code() == SpdyFramer::SPDY_NO_ERROR) { in SimulateInFramer() 488 size_t bytes_processed = framer_.ProcessInput(input_ptr, bytes_read); in SimulateInFramer() [all …]
|
D | spdy_framer.cc | 2845 explicit FrameSerializationVisitor(SpdyFramer* framer) : framer_(framer) {} in FrameSerializationVisitor() 2851 frame_.reset(framer_->SerializeData(data)); in VisitData() 2854 frame_.reset(framer_->SerializeSynStream(syn_stream)); in VisitSynStream() 2857 frame_.reset(framer_->SerializeSynReply(syn_reply)); in VisitSynReply() 2860 frame_.reset(framer_->SerializeRstStream(rst_stream)); in VisitRstStream() 2863 frame_.reset(framer_->SerializeSettings(settings)); in VisitSettings() 2866 frame_.reset(framer_->SerializePing(ping)); in VisitPing() 2869 frame_.reset(framer_->SerializeGoAway(goaway)); in VisitGoAway() 2872 frame_.reset(framer_->SerializeHeaders(headers)); in VisitHeaders() 2876 frame_.reset(framer_->SerializeWindowUpdate(window_update)); in VisitWindowUpdate() [all …]
|