| /external/skqp/experimental/Networking/ |
| SkSockets.cpp | 90 char packet[PACKET_SIZE]; local
95 memset(packet, 0, PACKET_SIZE);
105 int retval = read(i, packet + bytesReadInPacket,
113 continue; //incomplete packet or frame, keep tring
133 continue; //incomplete packet, keep trying
137 memcpy(&h.done, packet, sizeof(bool));
138 memcpy(&h.bytes, packet + sizeof(bool), sizeof(int));
139 memcpy(&h.type, packet + sizeof(bool) + sizeof(int), sizeof(DataType));
141 //SkDebugf("bad packet\n");
145 //SkDebugf("read packet(done:%d, bytes:%d) from fd:%d in %d tries\n"
177 char packet[PACKET_SIZE]; local
[all...] |
| /external/syslinux/gpxe/src/core/ |
| gdbstub.c | 49 /* Buffer for payload data when parsing a packet. Once the
50 * packet has been received, this buffer is used to hold
57 /* Packet parser states */
301 /* GDB packet parser */
313 stub->len = 0; /* retry new packet */
363 char packet [ SIZEOF_PAYLOAD + 4 ]; local
375 while ( !stub.exit_handler && ( len = stub.trans->recv ( packet, sizeof ( packet ) ) ) > 0 ) {
377 gdbstub_parse ( &stub, packet [ i ] );
|
| /external/syslinux/gpxe/src/include/ |
| nic.h | 43 unsigned char *packet; member in struct:nic
67 unsigned int size, const void *packet ) {
68 nic.nic_op->transmit ( &nic, dest, type, size, packet );
|
| /external/syslinux/gpxe/src/net/udp/ |
| slam.c | 65 * Int : Packet sequence number within the transfer (if this packet
68 * Raw : Packet data (if this packet contains data).
202 * Add a variable-length value to a SLAM packet
247 * Send SLAM NACK packet
270 /* Construct NACK. We always request only a single packet;
274 * RX checksumming, this would inevitably cause packet drops.
301 /* Transmit packet */
359 * Read and strip a variable-length value from a SLAM packet
486 unsigned long packet; local
[all...] |
| /external/webrtc/talk/media/base/ |
| testutils.cc | 75 bool RawRtpPacket::SameExceptSeqNumTimestampSsrc(const RawRtpPacket& packet,
81 ver_to_cc == packet.ver_to_cc &&
82 m_to_pt == packet.m_to_pt &&
84 0 == memcmp(payload, packet.payload, sizeof(payload));
110 bool RawRtcpPacket::EqualsTo(const RawRtcpPacket& packet) const {
111 return ver_to_count == packet.ver_to_count &&
112 type == packet.type &&
113 length == packet.length &&
114 0 == memcmp(payload, packet.payload, sizeof(payload));
176 RtpDumpPacket packet; local
[all...] |
| /external/webrtc/webrtc/modules/audio_coding/neteq/ |
| packet_buffer_unittest.cc | 18 #include "webrtc/modules/audio_coding/neteq/packet.h"
31 Packet* NextPacket(int payload_size_bytes);
52 Packet* PacketGenerator::NextPacket(int payload_size_bytes) {
53 Packet* packet = new Packet; local
54 packet->header.sequenceNumber = seq_no_;
55 packet->header.timestamp = ts_;
56 packet->header.payloadType = pt_;
57 packet->header.markerBit = false
93 Packet* packet = gen.NextPacket(payload_len); local
116 Packet* packet = gen.NextPacket(payload_len); local
137 Packet* packet = gen.NextPacket(payload_len); local
146 Packet* packet = gen.NextPacket(payload_len); local
166 Packet* packet = gen.NextPacket(payload_len); local
202 Packet* packet = gen.NextPacket(payload_len); local
206 Packet* packet = gen.NextPacket(payload_len); local
270 Packet* packet = gen.NextPacket(kPayloadLength); local
282 Packet* packet = buffer.GetNextPacket(&drop_count); local
302 Packet* packet = gen.NextPacket(payload_len); local
333 Packet* packet = gen.NextPacket(payload_len); local
358 Packet* packet = buffer.GetNextPacket(NULL); local
378 Packet* packet = NULL; local
506 Packet* packet = gen.NextPacket(payload_len); local
[all...] |
| payload_splitter_unittest.cc | 22 #include "webrtc/modules/audio_coding/neteq/packet.h"
35 // A possible Opus packet that contains FEC is the following.
71 // Creates a RED packet, with |num_payloads| payloads, with payload types given
75 Packet* CreateRedPayload(size_t num_payloads,
79 Packet* packet = new Packet; local
80 packet->header.payloadType = kRedPayloadType;
81 packet->header.timestamp = kBaseTimestamp;
82 packet->header.sequenceNumber = kSequenceNumber
125 Packet* packet = new Packet; local
171 Packet* packet = CreateRedPayload(2, payload_types, kTimestampOffset); local
198 Packet* packet = CreateRedPayload(1, payload_types, kTimestampOffset); local
238 Packet* packet = CreateRedPayload(3, payload_types, kTimestampOffset); local
305 Packet* packet = CreatePacket(i, 10, 0); local
325 Packet* packet = packet_list.front(); local
339 Packet* packet = CreateRedPayload(3, payload_types, kTimestampOffset); local
614 Packet* packet = CreatePacket(kPayloadType, payload_length_bytes, 0); local
639 Packet* packet = (*it); local
685 Packet* packet = CreatePacket(kPayloadType, kPayloadLengthBytes, 0); local
717 Packet* packet = CreatePacket(kPayloadType, kPayloadLengthBytes, 0); local
751 Packet* packet = CreatePacket(0, 10, 0xFF, true); local
806 Packet* packet = CreateRedPayload(2, payload_types, kTimestampOffset, true); local
[all...] |
| /external/webrtc/webrtc/modules/rtp_rtcp/source/ |
| producer_fec.cc | 37 ForwardErrorCorrection::Packet* pkt;
147 ForwardErrorCorrection::Packet* packet = new ForwardErrorCorrection::Packet; local
148 packet->length = payload_length + rtp_header_length;
149 memcpy(packet->data, data_buffer, packet->length);
150 media_packets_fec_.push_back(packet);
189 // Returns true if the media packet list for the FEC is at least
222 // Build FEC packet. The FEC packets in |fec_packets_| doesn'
[all...] |
| rtp_fec_unittest.cc | 29 typedef std::list<ForwardErrorCorrection::Packet*> PacketList;
34 T* packet = NULL; local
36 packet = my_list->front();
37 delete packet;
60 // Media packet "i" is lost if media_loss_mask_[i] = 1,
64 // FEC packet "i" is lost if fec_loss_mask_[i] = 1,
68 // Construct the media packet list, up to |num_media_packets| packets.
69 // Returns the next sequence number after the last media packet.
70 // (this will be the sequence of the first FEC packet)
74 // Construct the received packet list: a subset of the media and FEC packets
854 ForwardErrorCorrection::Packet* packet; local
[all...] |
| rtp_format_h264.cc | 80 LOG(LS_ERROR) << "StapA packet with incorrect NALU packet lengths.";
202 packets_.push(Packet(offset,
216 // Aggregate fragments into one packet (STAP-A).
224 packets_.push(Packet(fragment_offset,
241 // If we are going to try to aggregate more fragments into this packet
243 // NALU of this packet.
262 Packet packet = packets_.front(); local
264 if (packet.first_fragment && packet.last_fragment)
283 Packet packet = packets_.front(); local
308 Packet packet = packets_.front(); local
[all...] |
| rtp_format_h264_unittest.cc | 47 const uint8_t* packet,
53 EXPECT_EQ(kFuIndicator, packet[0]) << "FUA index: " << fua_index;
62 EXPECT_EQ(fu_header, packet[1]) << "FUA index: " << fua_index;
68 ::testing::ElementsAreArray(&packet[2], expected_sizes[fua_index]))
89 rtc::scoped_ptr<uint8_t[]> packet(new uint8_t[max_payload_size]);
94 ASSERT_TRUE(packetizer->NextPacket(packet.get(), &length, &last));
95 VerifyFua(i, frame.get(), offset, packet.get(), length, expected_sizes);
100 EXPECT_FALSE(packetizer->NextPacket(packet.get(), &length, &last));
120 const uint8_t* packet,
134 ::testing::ElementsAreArray(&packet[expected_payload_offset]
192 uint8_t packet[kMaxPayloadSize] = {0}; local
229 uint8_t packet[kMaxPayloadSize] = {0}; local
264 uint8_t packet[kMaxPayloadSize] = {0}; local
316 uint8_t packet[kMaxPayloadSize] = {0}; local
401 uint8_t packet[2] = {0x05, 0xFF}; \/\/ F=0, NRI=0, Type=5 (IDR). local
415 uint8_t packet[] = {kSps, 0x7A, 0x00, 0x1F, 0xBC, 0xD9, 0x40, 0x50, local
432 uint8_t packet[16] = {kStapA, \/\/ F=0, NRI=0, Type=24. local
450 uint8_t packet[] = {kStapA, \/\/ F=0, NRI=0, Type=24. local
470 uint8_t packet[16] = {kStapA, \/\/ F=0, NRI=0, Type=24. local
[all...] |
| rtp_format_vp9_unittest.cc | 75 void ParseAndCheckPacket(const uint8_t* packet,
81 ASSERT_TRUE(depacketizer->Parse(&parsed, packet, expected_length));
85 VerifyPayload(parsed, packet + expected_hdr_length, kExpectedPayloadLength);
149 void CheckPayload(const uint8_t* packet,
154 EXPECT_EQ(packet[i], payload_[payload_pos_++]);
187 // One packet:
289 // One packet:
356 // One packet:
377 // One packet:
414 // One packet
477 uint8_t packet[4] = {0}; local
486 uint8_t packet[10] = {0}; local
497 uint8_t packet[10] = {0}; local
514 uint8_t packet[13] = {0}; local
535 uint8_t packet[13] = {0}; local
556 uint8_t packet[13] = {0}; local
586 uint8_t packet[13] = {0}; local
596 uint8_t packet[13] = {0}; local
613 uint8_t packet[23] = {0}; local
637 uint8_t packet[2] = {0}; local
647 uint8_t packet[2] = {0}; local
659 uint8_t packet[20] = {0}; local
678 uint8_t packet[1] = {0}; local
685 uint8_t packet[kHeaderLength] = {0}; local
[all...] |
| rtp_payload_registry_unittest.cc | 256 // Generates an RTX packet for the given length and original sequence number.
262 uint8_t* packet = local
267 packet[0] = static_cast<uint8_t>(kRtpExpectedVersion << 6);
268 // Write a junk sequence number. It should be thrown away when the packet is
270 ByteWriter<uint16_t>::WriteBigEndian(packet + 2, 9999);
271 // Write a junk ssrc. It should also be thrown away when the packet is
273 ByteWriter<uint32_t>::WriteBigEndian(packet + 8, 9999);
277 ByteWriter<uint16_t>::WriteBigEndian(packet + header_length,
279 return packet;
299 rtc::scoped_ptr<const uint8_t[]> packet(GenerateRtxPacket
[all...] |
| /external/webrtc/webrtc/modules/video_coding/ |
| receiver_unittest.cc | 19 #include "webrtc/modules/video_coding/packet.h"
45 VCMPacket packet; local
46 bool packet_available = stream_generator_->GetPacket(&packet, index);
50 return receiver_.InsertPacket(packet, kWidth, kHeight);
54 VCMPacket packet; local
55 bool packet_available = stream_generator_->PopPacket(&packet, index);
59 return receiver_.InsertPacket(packet, kWidth, kHeight);
69 // Drop the second packet.
70 VCMPacket packet; local
71 stream_generator_->PopPacket(&packet, 0)
390 VCMPacket packet; local
[all...] |
| /external/webrtc/webrtc/p2p/base/ |
| relayserver_unittest.cc | 120 rtc::TestClient::Packet* packet = local
122 if (packet) {
123 rtc::ByteBuffer buf(packet->buf, packet->size);
126 delete packet;
132 rtc::TestClient::Packet* packet = local
134 if (packet) {
135 raw = std::string(packet->buf, packet->size)
[all...] |
| /external/webrtc/webrtc/video/ |
| replay.cc | 267 "length/packet interleaved.\n");
283 test::RtpPacket packet; local
284 if (!rtp_reader->NextPacket(&packet))
287 switch (call->Receiver()->DeliverPacket(webrtc::MediaType::ANY, packet.data,
288 packet.length, PacketTime())) {
294 parser->Parse(packet.data, packet.length, &header);
301 fprintf(stderr, "Packet error, corrupt packets or incorrect setup?\n");
304 if (last_time_ms != 0 && last_time_ms != packet.time_ms) {
305 SleepMs(packet.time_ms - last_time_ms)
[all...] |
| /external/wpa_supplicant_8/src/l2_packet/ |
| l2_packet_freebsd.c | 2 * WPA Supplicant - Layer2 packet handling with FreeBSD
80 const u_char *packet; local
85 packet = pcap_next(pcap, &hdr);
87 if (packet == NULL || hdr.caplen < sizeof(*ethhdr))
90 ethhdr = (struct l2_ethhdr *) packet;
|
| l2_packet_pcap.c | 2 * WPA Supplicant - Layer2 packet handling with libpcap/libdnet and WinPcap
123 const u_char *packet; local
128 packet = pcap_next(pcap, &hdr);
130 if (packet == NULL || hdr.caplen < sizeof(*ethhdr))
133 ethhdr = (struct l2_ethhdr *) packet;
|
| /frameworks/base/tools/preload2/src/com/android/preload/classdataretrieval/jdwp/ |
| JDWPClassDataRetriever.java | 83 CommandPacket packet = new CommandPacket( local
86 ReplyPacket reply = debuggeeWrapper.vmMirror.performCommand(packet);
93 CommandPacket packet = new CommandPacket( local
96 ReplyPacket reply = debuggeeWrapper.vmMirror.performCommand(packet);
152 CommandPacket packet = new CommandPacket( local
155 /* ReplyPacket reply = */ debuggeeWrapper.vmMirror.performCommand(packet);
161 CommandPacket packet = new CommandPacket( local
164 packet.setNextValueAsReferenceTypeID(typeID);
165 ReplyPacket reply = debuggeeWrapper.vmMirror.performCommand(packet);
182 CommandPacket packet = new CommandPacket local
[all...] |
| /hardware/interfaces/bluetooth/1.0/default/ |
| vendor_interface.cc | 56 HC_BT_HDR* packet = reinterpret_cast<HC_BT_HDR*>(new uint8_t[packet_size]); local
57 packet->offset = 0;
58 packet->len = data.size();
59 packet->layer_specific = 0;
60 packet->event = event;
63 memcpy(packet->data, data.data(), data.size());
64 return packet;
67 bool internal_command_event_match(const hidl_vec<uint8_t>& packet) {
68 uint8_t event_code = packet[0];
76 uint16_t opcode = packet[opcode_offset] | (packet[opcode_offset + 1] << 8)
[all...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/net/ |
| DatagramPacketTest.java | 38 assertEquals("Created incorrect packet", "Hello", new String(dp
58 assertEquals("Created incorrect packet", "Hello", new String(dp
138 DatagramPacket packet = new DatagramPacket(new byte[] { 1, 2, 3, 4, 5, local
140 socket.send(packet);
141 socket.receive(packet);
143 assertTrue("datagram received wrong port: " + packet.getPort(), packet
184 assertEquals("Failed to set packet length", 1, dp.getLength());
|
| /system/bt/profile/avrcp/ |
| connection_handler.cc | 376 device_map_[handle]->MessageReceived(label, Packet::Parse(pkt));
485 std::shared_ptr<::bluetooth::Packet> packet = VectorPacket::Make(); local
486 message->Serialize(packet);
491 (uint8_t)(::bluetooth::Packet::Specialize<Packet>(packet)->GetCType());
502 // the packet so none of these layer specific fields will be used.
512 pkt->len = packet->size();
514 for (auto it = packet->begin(); it != packet->end(); it++)
[all...] |
| /system/bt/stack/l2cap/ |
| l2cap_client.cc | 55 static void read_ready_cb(uint16_t local_channel_id, BT_HDR* packet);
59 static void fragment_packet(l2cap_client_t* client, buffer_t* packet);
175 bool l2cap_client_write(l2cap_client_t* client, buffer_t* packet) {
177 CHECK(packet != NULL);
182 fragment_packet(client, packet);
362 static void read_ready_cb(uint16_t local_channel_id, BT_HDR* packet) {
373 buffer_t* buffer = buffer_new(packet->len);
374 memcpy(buffer_ptr(buffer), packet->data + packet->offset, packet->len)
428 BT_HDR* packet = (BT_HDR*)list_front(client->outbound_fragments); local
[all...] |
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/DebuggerOnDemand/ |
| LaunchedDebugger.java | 168 CommandPacket packet = new CommandPacket( local
171 packet.setNextValueAsThreadID(threadID);
172 packet.setNextValueAsInt(startFrame);
173 packet.setNextValueAsInt(length);
175 ReplyPacket reply = debuggeeWrapper.vmMirror.performCommand(packet);
193 CommandPacket packet = new CommandPacket( local
196 packet.setNextValueAsString(signature);
197 ReplyPacket reply = debuggeeWrapper.vmMirror.performCommand(packet);
|
| /external/boringssl/src/ssl/ |
| d1_both.cc | 777 uint8_t *packet = (uint8_t *)OPENSSL_malloc(ssl->d1->mtu); local
778 if (packet == NULL) {
788 if (!seal_next_packet(ssl, packet, &packet_len, ssl->d1->mtu)) {
792 int bio_ret = BIO_write(ssl->wbio, packet, packet_len);
794 // Retry this packet the next time around.
811 OPENSSL_free(packet);
|
