Home
last modified time | relevance | path

Searched refs:framer_ (Results 1 – 25 of 30) sorted by relevance

12

/external/chromium_org/media/cast/net/rtp/
Dframer_unittest.cc18 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 …]
Dcast_message_builder.cc22 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()
Dcast_message_builder_unittest.cc86 : 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()
Dcast_message_builder.h48 const Framer* const framer_; variable
/external/chromium_org/extensions/browser/api/cast_channel/
Dcast_framer_unittest.cc31 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 …]
Dcast_transport.cc43 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()
Dcast_transport.h179 scoped_ptr<MessageFramer> framer_; variable
/external/chromium_org/net/quic/
Dquic_framer_test.cc364 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 …]
Dquic_headers_stream_test.cc87 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 …]
Dquic_packet_creator.cc72 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()
Dquic_connection.cc191 : 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 …]
Dquic_dispatcher.cc191 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()
Dquic_connection_test.cc276 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 …]
Dquic_dispatcher.h165 QuicFramer* framer() { return &framer_; } in framer()
245 QuicFramer framer_; variable
Dquic_connection.h335 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/
Dframe_receiver.cc38 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()
Dframe_receiver.h155 Framer framer_; variable
/external/chromium_org/net/quic/test_tools/
Dsimple_quic_framer.cc191 : 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()
Dquic_connection_peer.cc141 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()
Dsimple_quic_framer.h57 framer_.SetSupportedVersions(versions); in SetSupportedVersions()
61 QuicFramer framer_;
/external/chromium_org/net/tools/quic/
Dquic_dispatcher.cc196 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()
Dquic_dispatcher.h173 QuicFramer* framer() { return &framer_; } in framer()
255 QuicFramer framer_; variable
Dquic_time_wait_list_manager_test.cc94 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/
Dspdy_framer_test.cc243 : 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 …]
Dspdy_framer.cc2845 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 …]

12