/external/chromium_org/media/filters/ |
H A D | ffmpeg_h264_to_annex_b_bitstream_converter.cc | 22 bool FFmpegH264ToAnnexBBitstreamConverter::ConvertPacket(AVPacket* packet) { argument 25 if (packet == NULL || !packet->data) 44 packet->data, packet->size, avc_config.get()); 47 return false; // Invalid input packet. 49 // Allocate new packet for the output. 55 // the pointer of the old packet with a new one, we will initially copy the 56 // metadata from old packet to new bigger packet [all...] |
H A D | ffmpeg_h264_to_annex_b_bitstream_converter_unittest.cc | 272 void CreatePacket(AVPacket* packet, const uint8* data, uint32 data_size) { argument 273 // Create new packet sized of |data_size| from |data|. 274 EXPECT_EQ(av_new_packet(packet, data_size), 0); 275 memcpy(packet->data, data, data_size); 293 // packet and destroy the old one). 302 // Create new packet with 1000 excess bytes. 310 // packet and destroy the old one as we do NOT support in place transform). 326 // Create new packet to test actual conversion. 332 // packet and destroy the old one). This should fail due to missing extradata.
|
H A D | ffmpeg_video_decoder.cc | 260 // Create a packet for input data. 262 AVPacket packet; local 263 av_init_packet(&packet); 265 packet.data = NULL; 266 packet.size = 0; 268 packet.data = const_cast<uint8*>(buffer->data()); 269 packet.size = buffer->data_size(); 279 &packet); 286 // FFmpeg says some codecs might have multiple frames per packet. Previous 289 DCHECK_EQ(result, packet [all...] |
/external/chromium_org/media/midi/ |
H A D | midi_manager_mac.cc | 149 // Go through each packet and process separately. 151 // Each packet contains MIDI data for one or more messages (like note-on). 152 const MIDIPacket &packet = packet_list->packet[i]; local 153 double timestamp_seconds = MIDITimeStampToSeconds(packet.timeStamp); 157 packet.data, 158 packet.length,
|
H A D | usb_midi_input_stream.cc | 69 const uint8* packet, 71 // The first 4 bytes of the packet is accessible here. 72 uint8 code_index = packet[0] & 0x0f; 73 uint8 cable_number = packet[0] >> 4; 89 delegate_->OnReceivedData(it->second, &packet[1], packet_size, time); 67 ProcessOnePacket(UsbMidiDevice* device, int endpoint_number, const uint8* packet, base::TimeTicks time) argument
|
/external/chromium_org/native_client_sdk/src/libraries/nacl_io/socket/ |
H A D | fifo_packet.cc | 12 #include "nacl_io/socket/packet.h" 66 void FIFOPacket::WritePacket(Packet* packet) { argument 67 cur_bytes_ += packet->len(); 68 packets_.push_front(packet);
|
H A D | udp_event_emitter.cc | 17 Packet* packet = in_fifo_.ReadPacket(); local 20 return packet; 23 void UdpEventEmitter::WriteRXPacket_Locked(Packet* packet) { argument 24 in_fifo_.WritePacket(packet); 30 Packet* packet = out_fifo_.ReadPacket(); local 33 return packet; 36 void UdpEventEmitter::WriteTXPacket_Locked(Packet* packet) { argument 37 out_fifo_.WritePacket(packet);
|
H A D | udp_node.cc | 14 #include "nacl_io/socket/packet.h" 135 Packet* packet = new Packet(filesystem()->ppapi()); local 136 packet->Copy(data_, length_error, addr_); 138 emitter_->WriteRXPacket_Locked(packet); 256 Packet* packet = emitter_->ReadRXPacket_Locked(); local 260 if (packet) { 261 int capped_len = static_cast<int32_t>(std::min<int>(len, packet->len())); 262 memcpy(buf, packet->buffer(), capped_len); 264 if (packet->addr() != 0) { 265 filesystem_->ppapi()->AddRefResource(packet 297 Packet* packet = new Packet(filesystem_->ppapi()); local [all...] |
/external/chromium_org/net/dns/ |
H A D | dns_response.cc | 28 DnsRecordParser::DnsRecordParser(const void* packet, argument 31 : packet_(reinterpret_cast<const char*>(packet)), 72 // If seen the whole packet, then we must be in a loop.
|
H A D | mdns_client_unittest.cc | 408 void ExpectPacket(const uint8* packet, unsigned size); 409 void SimulatePacketReceive(const uint8* packet, unsigned size); 435 void MDnsTest::SimulatePacketReceive(const uint8* packet, unsigned size) { argument 436 socket_factory_.SimulateReceive(packet, size); 439 void MDnsTest::ExpectPacket(const uint8* packet, unsigned size) { argument 440 EXPECT_CALL(socket_factory_, OnSendTo(MakeString(packet, size))) 484 // Send the same packet twice to ensure no records are double-counted. 565 // First, send unsalvagable packet to ensure we can deal with it. 569 // Regression test: send a packet where the question cannot be read. 573 // Then send salvagable packet t [all...] |
H A D | mock_mdns_socket_factory.cc | 88 void MockMDnsSocketFactory::SimulateReceive(const uint8* packet, int size) { argument 93 memcpy(recv_buffer_->data(), packet, size); 110 const std::string& packet, const std::string& address, 112 OnSendTo(packet); 113 return packet.size(); 109 SendToInternal( const std::string& packet, const std::string& address, const CompletionCallback& callback) argument
|
/external/chromium_org/net/quic/crypto/ |
H A D | crypto_framer_test.cc | 59 unsigned char packet[] = { local 92 test::CompareCharArraysWithHexError("constructed packet", data->data(), 93 data->length(), AsChars(packet), 94 arraysize(packet)); 103 unsigned char packet[] = { local 130 test::CompareCharArraysWithHexError("constructed packet", data->data(), 131 data->length(), AsChars(packet), 132 arraysize(packet)); 140 unsigned char packet[] = { local 157 test::CompareCharArraysWithHexError("constructed packet", dat 180 unsigned char packet[] = { local 220 unsigned char packet[] = { local [all...] |
/external/chromium_org/net/quic/ |
H A D | quic_connection.cc | 86 // This alarm will be scheduled any time a data-bearing packet is sent out. 107 // a delay before sending packets and fires when the packet may be sent. 163 QuicConnection::QueuedPacket::QueuedPacket(SerializedPacket packet, argument 165 : serialized_packet(packet), 172 SerializedPacket packet, 176 : serialized_packet(packet), 265 delete it->serialized_packet.packet; 315 const QuicPublicResetPacket& packet) { 317 debug_visitor_->OnPublicResetPacket(packet); 326 DVLOG(1) << ENDPOINT << "Received packet wit 171 QueuedPacket( SerializedPacket packet, EncryptionLevel level, TransmissionType transmission_type, QuicPacketSequenceNumber original_sequence_number) argument 314 OnPublicResetPacket( const QuicPublicResetPacket& packet) argument 383 OnVersionNegotiationPacket( const QuicVersionNegotiationPacket& packet) argument 1095 ProcessUdpPacket(const IPEndPoint& self_address, const IPEndPoint& peer_address, const QuicEncryptedPacket& packet) argument 1330 WritePacket(QueuedPacket* packet) argument 1341 WritePacketInner(QueuedPacket* packet) argument 1484 ShouldDiscardPacket(const QueuedPacket& packet) argument 1541 SendOrQueuePacket(QueuedPacket packet) argument 1668 QueueUndecryptablePacket( const QuicEncryptedPacket& packet) argument 1681 QuicEncryptedPacket* packet = undecryptable_packets_.front(); local 2015 IsRetransmittable( const QueuedPacket& packet) argument 2027 IsConnectionClose( QueuedPacket packet) argument [all...] |
H A D | quic_connection.h | 126 // Called when a packet has been sent. 130 const QuicEncryptedPacket& packet, 133 // Called when the contents of a packet have been retransmitted as 134 // a new packet. 139 // Called when a packet has been received, but before it is 143 const QuicEncryptedPacket& packet) {} 145 // Called when a packet is received with a connection id that does not 150 // Called when an undecryptable packet has been received. 153 // Called when a duplicate packet has been received. 156 // Called when the protocol version on the received packet doens 127 OnPacketSent(QuicPacketSequenceNumber sequence_number, EncryptionLevel level, TransmissionType transmission_type, const QuicEncryptedPacket& packet, WriteResult result) argument 141 OnPacketReceived(const IPEndPoint& self_address, const IPEndPoint& peer_address, const QuicEncryptedPacket& packet) argument 196 OnPublicResetPacket(const QuicPublicResetPacket& packet) argument 199 OnVersionNegotiationPacket( const QuicVersionNegotiationPacket& packet) argument [all...] |
H A D | quic_connection_logger.cc | 32 // We have ranges-of-buckets in the cumulative histogram (covering 21 packet 217 const QuicVersionNegotiationPacket* packet, 222 for (QuicVersionVector::const_iterator it = packet->versions.begin(); 223 it != packet->versions.end(); ++it) { 478 const QuicEncryptedPacket& packet, 483 transmission_type, packet.length(), result)); 497 const QuicEncryptedPacket& packet) { 505 last_received_packet_size_ = packet.length(); 509 packet.length())); 541 // There is a gap between the largest packet previousl 216 NetLogQuicVersionNegotiationPacketCallback( const QuicVersionNegotiationPacket* packet, NetLog::LogLevel ) argument 474 OnPacketSent( QuicPacketSequenceNumber sequence_number, EncryptionLevel level, TransmissionType transmission_type, const QuicEncryptedPacket& packet, WriteResult result) argument 495 OnPacketReceived(const IPEndPoint& self_address, const IPEndPoint& peer_address, const QuicEncryptedPacket& packet) argument 667 OnPublicResetPacket( const QuicPublicResetPacket& packet) argument 674 OnVersionNegotiationPacket( const QuicVersionNegotiationPacket& packet) argument [all...] |
H A D | quic_connection_test.cc | 292 QuicEncryptedPacket packet(buffer, buf_len); 295 if (packet.length() >= sizeof(final_bytes_of_last_packet_)) { 297 memcpy(&final_bytes_of_last_packet_, packet.data() + packet.length() - 4, 304 EXPECT_TRUE(framer_.ProcessPacket(packet)); 312 last_packet_size_ = packet.length(); 373 // packet as a little-endian, uint32. This is intended to be used with a 375 // a given packet. 378 // Returns the final bytes of the second to last packet. 450 QuicPacket* packet, 448 SendPacket(EncryptionLevel level, QuicPacketSequenceNumber sequence_number, QuicPacket* packet, QuicPacketEntropyHash entropy_hash, HasRetransmittableData retransmittable) argument 763 ProcessFecPacket(QuicPacketSequenceNumber number, QuicPacketSequenceNumber min_protected_packet, bool expect_revival, bool entropy_flag, QuicPacket* packet) argument 876 QuicPacket* packet = local 897 QuicPacket* packet = local 920 QuicPacket* packet = local 2809 QuicPacket* packet = ConstructDataPacket(1, 0, !kEntropyFlag); local 2817 QuicPacket* packet = ConstructDataPacket(1, 0, !kEntropyFlag); local 3082 QuicPacket* packet = ConstructDataPacket(1, 0, !kEntropyFlag); local 3097 connection_.ProcessUdpPacket(IPEndPoint(), IPEndPoint(), *packet); local 3828 QuicPacket* packet = local [all...] |
H A D | quic_dispatcher.cc | 78 // payload of the packet. 80 const QuicPublicResetPacket& /*packet*/) OVERRIDE { 84 const QuicVersionNegotiationPacket& /*packet*/) OVERRIDE { 209 const QuicEncryptedPacket& packet) { 212 current_packet_ = &packet; 213 // ProcessPacket will cause the packet to be dispatched in 216 framer_.ProcessPacket(packet); 217 // TODO(rjshade): Return a status describing if/why a packet was dropped, 235 // Ensure the packet has a version negotiation bit set before creating a new 237 // have the flag set. Otherwise it may be a stray packet 207 ProcessPacket(const IPEndPoint& server_address, const IPEndPoint& client_address, const QuicEncryptedPacket& packet) argument [all...] |
H A D | quic_framer.cc | 281 // PADDING implies end of packet. 288 // Frame fits within packet. Note that acks may be truncated. 291 // Only truncate the first frame in a packet, so if subsequent ones go 300 // Truncate the frame so the packet will not exceed kMaxPacketSize. 428 QuicPacket* packet = QuicPacket::NewDataPacket( local 435 packet->FecProtectedData()); 439 header.public_header.sequence_number_length, packet, 475 const QuicPublicResetPacket& packet) { 476 DCHECK(packet.public_header.reset_flag); 480 reset.SetValue(kRNON, packet 474 BuildPublicResetPacket( const QuicPublicResetPacket& packet) argument 540 ProcessPacket(const QuicEncryptedPacket& packet) argument 598 ProcessDataPacket( const QuicPacketPublicHeader& public_header, const QuicEncryptedPacket& packet) argument 1012 ProcessPacketHeader( QuicPacketHeader* header, const QuicEncryptedPacket& packet) argument 1689 EncryptPacket( EncryptionLevel level, QuicPacketSequenceNumber packet_sequence_number, const QuicPacket& packet) argument 1727 DecryptPayload(const QuicPacketHeader& header, const QuicEncryptedPacket& packet) argument [all...] |
H A D | quic_framer_test.cc | 48 // offset and the last frame in a packet. 64 // Index into the private flags offset in the data packet header. 99 // Index into the message tag of the public reset packet. 219 const QuicPublicResetPacket& packet) OVERRIDE { 220 public_reset_packet_.reset(new QuicPublicResetPacket(packet)); 224 const QuicVersionNegotiationPacket& packet) OVERRIDE { 225 version_negotiation_packet_.reset(new QuicVersionNegotiationPacket(packet)); 386 QuicPacket* packet) { 388 LOG(ERROR) << "Encrypted incorrect packet sequence number. expected " 393 if (packet 385 CheckEncryption(QuicPacketSequenceNumber sequence_number, QuicPacket* packet) argument 444 CheckProcessingFails(unsigned char* packet, size_t len, string expected_error, QuicErrorCode error_code) argument 460 CheckStreamFrameBoundaries(unsigned char* packet, size_t stream_id_size, bool include_version) argument 617 char packet[] = { 0x00 }; local 624 unsigned char packet[kMaxPacketSize + 1] = { local 656 unsigned char packet[] = { local 710 unsigned char packet[] = { local 766 unsigned char packet[] = { local 822 unsigned char packet[] = { local 874 unsigned char packet[] = { local 933 unsigned char packet[] = { local 988 unsigned char packet[] = { local 1043 unsigned char packet[] = { local 1095 unsigned char packet[] = { local 1123 unsigned char packet[] = { local 1148 unsigned char packet[] = { local 1175 unsigned char packet[] = { local 1198 unsigned char packet[] = { local 1220 unsigned char packet[] = { local 1267 unsigned char packet[] = { local 1315 unsigned char packet[] = { local 1364 unsigned char packet[] = { local 1413 unsigned char packet[] = { local 1462 unsigned char packet[] = { local 1516 unsigned char packet[] = { local 1557 unsigned char packet[] = { local 1630 unsigned char packet[] = { local 1689 unsigned char packet[] = { local 1784 unsigned char packet[] = { local 1911 unsigned char packet[] = { local 2024 unsigned char packet[] = { local 2124 unsigned char packet[] = { local 2235 unsigned char packet[] = { local 2340 unsigned char packet[] = { local 2393 unsigned char packet[] = { local 2448 unsigned char packet[] = { local 2521 unsigned char packet[] = { local 2593 unsigned char packet[] = { local 2644 unsigned char packet[] = { local 2669 unsigned char packet[] = { local 2723 unsigned char packet[] = { local 2793 unsigned char packet[] = { local 2851 unsigned char packet[] = { local 2912 unsigned char packet[] = { local 2964 unsigned char packet[] = { local 3010 unsigned char packet[] = { local 3039 unsigned char packet[] = { local 3101 unsigned char packet[] = { local 3135 unsigned char packet[] = { local 3207 unsigned char packet[] = { local 3243 unsigned char packet[] = { local 3294 unsigned char packet[kMaxPacketSize] = { local 3341 unsigned char packet[kMaxPacketSize] = { local 3387 unsigned char packet[kMaxPacketSize] = { local 3433 unsigned char packet[kMaxPacketSize] = { local 3482 unsigned char packet[] = { local 3534 unsigned char packet[] = { local 3589 unsigned char packet[] = { local 3631 unsigned char packet[] = { local 3674 unsigned char packet[] = { local 3737 unsigned char packet[] = { local 3809 unsigned char packet[] = { local 3924 unsigned char packet[] = { local 4040 unsigned char packet[] = { local 4109 unsigned char packet[] = { local 4168 unsigned char packet[] = { local 4213 unsigned char packet[] = { local 4282 unsigned char packet[] = { local 4340 unsigned char packet[] = { local 4391 unsigned char packet[] = { local 4443 unsigned char packet[] = { local 4488 unsigned char packet[] = { local 4529 unsigned char packet[] = { local 4569 unsigned char packet[] = { local 4613 unsigned char packet[] = { local 4671 unsigned char packet[] = { local 4703 unsigned char packet[] = { local 4737 unsigned char packet[] = { local 4946 unsigned char packet[] = { local 4981 unsigned char packet[] = { local 5018 unsigned char packet[] = { local [all...] |
H A D | quic_http_stream_test.cc | 136 // Holds a packet to be written to the wire, and the IO mode that should 139 PacketToWrite(IoMode mode, QuicEncryptedPacket* packet) argument 141 packet(packet) { 144 QuicEncryptedPacket* packet; member in struct:net::test::QuicHttpStreamTest::PacketToWrite 165 delete writes_[i].packet; 169 // Adds a packet to the list of expected writes. 170 void AddWrite(scoped_ptr<QuicEncryptedPacket> packet) { argument 171 writes_.push_back(PacketToWrite(SYNCHRONOUS, packet.release())); 174 // Returns the packet t 183 ProcessPacket(scoped_ptr<QuicEncryptedPacket> packet) argument [all...] |
H A D | quic_network_transaction_unittest.cc | 72 void AddRead(scoped_ptr<QuicEncryptedPacket> packet) { argument 73 reads_.push_back(MockRead(SYNCHRONOUS, packet->data(), packet->length(), 75 packets_.push_back(packet.release()); 82 void AddWrite(scoped_ptr<QuicEncryptedPacket> packet) { argument 83 writes_.push_back(MockWrite(SYNCHRONOUS, packet->data(), packet->length(), 85 packets_.push_back(packet.release());
|
H A D | quic_packet_creator.cc | 122 // pending frames when FEC protection is turned on. If current packet can be 123 // converted to an FEC protected packet, do it. This will require the 125 // frame to be added to the packet. 155 // packet header size in all packets within a group. 163 // Update sequence number length only on packet and FEC group boundaries. 170 // the sequence number of the next packet. 177 // A packet that is already open might send kQuicVersionSize bytes less than the 178 // maximum packet size if we stop sending version before it is serialized. 192 // Since the packet creator will not change sequence number length mid FEC 224 // Assumes this is a stream with a single lone packet 318 SerializedPacket packet = SerializePacket(); local [all...] |
H A D | quic_packet_creator_test.cc | 81 void ProcessPacket(QuicPacket* packet) { argument 84 *packet)); 102 // Returns the number of bytes consumed by the header of packet, including 111 // Returns the number of bytes of overhead that will be added to a packet 119 // frame, assuming it is the last frame in the packet 146 // Run all packet creator tests with all supported versions of QUIC, and with 147 // and without version in the packet header. 173 ProcessPacket(serialized.packet); 174 delete serialized.packet; 178 // Enable FEC protection, and send FEC packet ever [all...] |
H A D | quic_packet_generator_test.cc | 45 MOCK_METHOD1(OnSerializedPacket, void(const SerializedPacket& packet)); 77 // Simple struct for describing the contents of a packet. 79 // that a packet contains the expected frames. 121 delete packet_.packet; 123 delete packet2_.packet; 125 delete packet3_.packet; 127 delete packet4_.packet; 129 delete packet5_.packet; 131 delete packet6_.packet; 133 delete packet7_.packet; 164 CheckPacketContains(const PacketContents& contents, const SerializedPacket& packet) argument 199 CheckPacketHasSingleStreamFrame(const SerializedPacket& packet) argument 208 CheckPacketIsFec(const SerializedPacket& packet, QuicPacketSequenceNumber fec_group) argument [all...] |
H A D | quic_protocol.cc | 691 QuicPacket* packet, 696 packet(packet), 688 SerializedPacket( QuicPacketSequenceNumber sequence_number, QuicSequenceNumberLength sequence_number_length, QuicPacket* packet, QuicPacketEntropyHash entropy_hash, RetransmittableFrames* retransmittable_frames) argument
|