| /external/chromium_org/media/cast/net/rtp/ |
| framer_unittest.cc | 18 framer_(&testing_clock_, &mock_rtp_payload_feedback_, 0, true, 0) {
30 Framer framer_; member in class:media::cast::FramerTest
40 EXPECT_FALSE(framer_.GetEncodedFrame(&frame, &next_frame, &multiple));
51 complete = framer_.InsertPacket(
54 EXPECT_FALSE(framer_.GetEncodedFrame(&frame, &next_frame, &multiple));
58 complete = framer_.InsertPacket(
61 EXPECT_TRUE(framer_.GetEncodedFrame(&frame, &next_frame, &multiple));
67 framer_.ReleaseFrame(frame.frame_id);
79 complete = framer_.InsertPacket(
82 EXPECT_TRUE(framer_.GetEncodedFrame(&frame, &next_frame, &multiple))
[all...] |
| cast_message_builder.cc | 22 framer_(framer),
55 int complete_frame_count = framer_->NumberOfCompleteFrames();
99 if (last_update_time_.is_null() && framer_->Empty())
124 if (!framer_->Empty()) {
152 if (framer_->Empty())
155 uint32 newest_frame_id = framer_->NewestFrameId();
173 if (framer_->FrameExists(next_expected_frame_id)) {
175 framer_->GetMissingPackets(
|
| cast_message_builder_unittest.cc | 86 : framer_(&testing_clock_,
93 &framer_,
121 if (framer_.InsertPacket(&payload, 1, rtp_header_, &duplicate)) {
130 &framer_,
137 Framer framer_; member in class:media::cast::CastMessageBuilderTest
206 framer_.RemoveOldFrames(5); // Simulate 5 being pulled for rendering.
293 framer_.Reset();
335 framer_.RemoveOldFrames(3); // Simulate 3 being pulled for rendering.
367 framer_.RemoveOldFrames(3); // Simulate 3 being pulled for rendering.
424 framer_.RemoveOldFrames(frame_id)
[all...] |
| cast_message_builder.h | 48 const Framer* const framer_; member in class:media::cast::CastMessageBuilder
|
| /external/chromium_org/extensions/browser/api/cast_channel/ |
| cast_framer_unittest.cc | 31 framer_.reset(new MessageFramer(buffer_.get()));
42 scoped_ptr<MessageFramer> framer_; member in class:extensions::core_api::cast_channel::CastFramerTest
52 EXPECT_EQ(4u, framer_->BytesRequested());
53 EXPECT_EQ(NULL, framer_->Ingest(1, &message_length, &error).get());
55 EXPECT_EQ(3u, framer_->BytesRequested());
59 EXPECT_EQ(NULL, framer_->Ingest(3, &message_length, &error).get());
63 framer_->BytesRequested());
67 message = framer_->Ingest(framer_->BytesRequested(), &message_length, &error);
71 EXPECT_EQ(4u, framer_->BytesRequested())
[all...] |
| cast_transport.cc | 43 framer_.reset(new MessageFramer(read_buffer_));
376 size_t num_bytes_to_read = framer_->BytesRequested();
398 current_message_ = framer_->Ingest(result, &message_size, &error_state_);
|
| cast_transport.h | 179 scoped_ptr<MessageFramer> framer_; member in class:extensions::core_api::cast_channel::CastTransport
|
| cast_socket.cc | 100 framer_.reset(new MessageFramer(read_buffer_));
719 size_t num_bytes_to_read = framer_->BytesRequested();
743 current_message_ = framer_->Ingest(result, &message_size, &error_state_);
|
| /external/chromium_org/net/quic/ |
| quic_headers_stream_test.cc | 87 framer_(SPDY3) {
91 framer_.set_visitor(&visitor_);
148 framer_.ProcessInput(saved_data_.data(), saved_data_.length());
149 EXPECT_FALSE(framer_.HasError()) << framer_.error_code();
158 framer_.ParseHeaderBlockInBuffer(saved_header_data_.data(),
183 SpdyFramer framer_; member in class:net::test::__anon14094::QuicHeadersStreamTest
225 frame.reset(framer_.SerializeSynStream(syn_stream));
231 frame.reset(framer_.SerializeSynReply(syn_reply));
249 scoped_ptr<SpdySerializedFrame> frame(framer_.SerializeFrame(data))
[all...] |
| quic_framer_test.cc | 364 framer_(QuicSupportedVersions(), start_, true) {
366 framer_.set_version(version_);
367 framer_.SetDecrypter(decrypter_, ENCRYPTION_NONE);
368 framer_.SetEncrypter(ENCRYPTION_NONE, encrypter_);
369 framer_.set_visitor(&visitor_);
370 framer_.set_received_entropy_calculator(&entropy_calculator_);
449 EXPECT_FALSE(framer_.ProcessPacket(encrypted)) << "len: " << len;
450 EXPECT_EQ(expected_error, framer_.detailed_error()) << "len: " << len;
451 EXPECT_EQ(error_code, framer_.error()) << "len: " << len;
488 QuicFramerPeer::SetLastSequenceNumber(&framer_, last_sequence_number)
505 QuicFramer framer_; member in class:net::test::QuicFramerTest
[all...] |
| quic_packet_creator.cc | 72 framer_(framer),
84 framer_->set_fec_builder(this);
346 framer_->GetMaxPlaintextSize(max_packet_length_);
380 framer_->GetMaxPlaintextSize(max_packet_length_);
390 framer_->BuildDataPacket(header, queued_frames_, packet_size_);
417 SerializedPacket serialized = framer_->BuildFecPacket(header, fec_data);
435 DCHECK(framer_->is_server());
442 framer_->BuildVersionNegotiationPacket(header, supported_versions);
479 size_t frame_len = framer_->GetSerializedFrameLength(
|
| quic_dispatcher.cc | 191 framer_(supported_versions, /*unused*/ QuicTime::Zero(), true),
193 framer_.set_visitor(framer_visitor_.get());
216 framer_.ProcessPacket(packet);
249 !framer_.IsSupportedVersion(header.versions.front())) {
400 framer_.set_version(time_wait_list_manager_->GetQuicVersionFromConnectionId(
|
| quic_connection_test.cc | 276 framer_(SupportedVersions(version_)),
302 framer_.framer()->SetDecrypter(new TaggingDecrypter, ENCRYPTION_NONE);
304 EXPECT_TRUE(framer_.ProcessPacket(packet));
326 const QuicPacketHeader& header() { return framer_.header(); }
328 size_t frame_count() const { return framer_.num_frames(); }
331 return framer_.ack_frames();
335 return framer_.feedback_frames();
339 return framer_.stop_waiting_frames();
343 return framer_.connection_close_frames();
347 return framer_.stream_frames()
397 SimpleQuicFramer framer_; member in class:net::test::__anon14080::TestPacketWriter
1001 QuicFramer framer_; member in class:net::test::__anon14080::QuicConnectionTest
[all...] |
| quic_connection.cc | 191 : framer_(supported_versions, helper->GetClock()->ApproximateNow(),
218 packet_generator_(connection_id_, &framer_, random_generator_, this),
250 framer_.set_visitor(this);
251 framer_.set_received_entropy_calculator(&received_packet_manager_);
279 const QuicVersionVector& supported_versions = framer_.supported_versions();
284 framer_.set_version(version);
343 if (!framer_.IsSupportedVersion(received_version)) {
351 if (!framer_.IsSupportedVersion(received_version)) {
374 framer_.set_version(received_version);
[all...] |
| quic_dispatcher.h | 165 QuicFramer* framer() { return &framer_; }
245 QuicFramer framer_; member in class:net::QuicDispatcher
|
| /external/chromium_org/net/quic/test_tools/ |
| simple_quic_framer.h | 57 framer_.SetSupportedVersions(versions);
61 QuicFramer framer_; member in class:net::test::SimpleQuicFramer
|
| simple_quic_framer.cc | 191 : framer_(QuicSupportedVersions(), QuicTime::Zero(), true) {
195 : framer_(supported_versions, QuicTime::Zero(), true) {
202 scoped_ptr<QuicEncryptedPacket> encrypted(framer_.EncryptPacket(
209 framer_.set_visitor(visitor_.get());
210 return framer_.ProcessPacket(packet);
236 return &framer_;
|
| quic_connection_peer.cc | 141 QuicFramerPeer::SetIsServer(&connection->framer_, is_server);
159 QuicFramerPeer::SwapCrypters(framer, &connection->framer_);
170 return &connection->framer_;
242 connection->framer_.SetSupportedVersions(versions);
|
| /external/chromium_org/media/cast/receiver/ |
| frame_receiver.cc | 38 framer_(cast_environment->Clock(),
128 framer_.InsertPacket(payload_data, payload_size, rtp_header, &duplicate);
190 // Attempt to peek at the next completed frame from the |framer_|.
197 if (!framer_.GetEncodedFrame(encoded_frame.get(),
210 framer_.ReleaseFrame(encoded_frame->frame_id);
214 // If |framer_| has a frame ready that is out of sequence, examine the
241 framer_.AckFrame(encoded_frame->frame_id);
250 framer_.ReleaseFrame(encoded_frame->frame_id);
258 framer_.ReleaseFrame(encoded_frame->frame_id);
304 framer_.TimeToSendNextCastMessage(&send_time)
[all...] |
| frame_receiver.h | 82 // Processes ready-to-consume packets from |framer_|, decrypting each packet's
155 Framer framer_; member in class:media::cast::FrameReceiver
|
| /external/chromium_org/net/tools/quic/ |
| quic_dispatcher.cc | 196 framer_(supported_versions, /*unused*/ QuicTime::Zero(), true),
198 framer_.set_visitor(framer_visitor_.get());
221 framer_.ProcessPacket(packet);
254 !framer_.IsSupportedVersion(header.versions.front())) {
412 framer_.set_version(time_wait_list_manager_->GetQuicVersionFromConnectionId(
|
| quic_time_wait_list_manager_test.cc | 94 framer_(QuicSupportedVersions(), QuicTime::Zero(), true),
154 BuildUnsizedDataPacket(&framer_, header, frames).packet);
156 QuicEncryptedPacket* encrypted = framer_.EncryptPacket(ENCRYPTION_NONE,
167 QuicFramer framer_; member in class:net::tools::test::__anon14399::QuicTimeWaitListManagerTest
|
| quic_dispatcher.h | 173 QuicFramer* framer() { return &framer_; }
255 QuicFramer framer_; member in class:net::tools::QuicDispatcher
|
| /external/chromium_org/net/spdy/ |
| spdy_framer.cc | 2897 SpdyFramer* framer_; member in class:net::__anon14215::FrameSerializationVisitor
[all...] |
| spdy_framer_test.cc | 243 : framer_(version),
321 size_t parsed_length = framer_.ParseHeaderBlockInBuffer(
344 if (framer_.protocol_version() > SPDY3) {
356 if (framer_.protocol_version() > SPDY3) {
386 DCHECK_LT(SPDY3, framer_.protocol_version());
391 if (framer_.protocol_version() <= SPDY3) { return; }
476 framer_.set_enable_compression(use_compression_);
477 framer_.set_visitor(this);
481 framer_.error_code() == SpdyFramer::SPDY_NO_ERROR) {
488 size_t bytes_processed = framer_.ProcessInput(input_ptr, bytes_read)
521 SpdyFramer framer_; member in class:net::test::TestSpdyVisitor
[all...] |
