Searched defs:packet (Results 51 - 75 of 509) sorted by path

1234567891011>>

/external/chromium_org/media/filters/
H A Dffmpeg_h264_to_annex_b_bitstream_converter.cc22 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 Dffmpeg_h264_to_annex_b_bitstream_converter_unittest.cc272 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 Dffmpeg_video_decoder.cc260 // 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 Dmidi_manager_mac.cc149 // 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 Dusb_midi_input_stream.cc69 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 Dfifo_packet.cc12 #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 Dudp_event_emitter.cc17 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 Dudp_node.cc14 #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 Ddns_response.cc28 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 Dmdns_client_unittest.cc408 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 Dmock_mdns_socket_factory.cc88 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 Dcrypto_framer_test.cc59 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 Dquic_connection.cc86 // 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 Dquic_connection.h126 // 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 Dquic_connection_logger.cc32 // 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 Dquic_connection_test.cc292 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 Dquic_dispatcher.cc78 // 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 Dquic_framer.cc281 // 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 Dquic_framer_test.cc48 // 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 Dquic_http_stream_test.cc136 // 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 Dquic_network_transaction_unittest.cc72 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 Dquic_packet_creator.cc122 // 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 Dquic_packet_creator_test.cc81 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 Dquic_packet_generator_test.cc45 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 Dquic_protocol.cc691 QuicPacket* packet,
696 packet(packet),
688 SerializedPacket( QuicPacketSequenceNumber sequence_number, QuicSequenceNumberLength sequence_number_length, QuicPacket* packet, QuicPacketEntropyHash entropy_hash, RetransmittableFrames* retransmittable_frames) argument

Completed in 450 milliseconds

1234567891011>>