| /external/webrtc/webrtc/modules/audio_coding/neteq/ |
| packet_buffer.cc | 12 // an STL list. The list is kept sorted at all times so that the next packet to
26 // Operator() returns true when |packet| goes before |new_packet|.
29 explicit NewTimestampIsLarger(const Packet* new_packet)
32 bool operator()(Packet* packet) {
33 return (*new_packet_ >= *packet);
37 const Packet* new_packet_;
57 int PacketBuffer::InsertPacket(Packet* packet) {
58 if (!packet || !packet->payload)
113 Packet* packet = packet_list->front(); local
190 Packet* packet = buffer_.front(); local
253 Packet* packet = (*it); local
[all...] |
| payload_splitter.cc | 20 // The method loops through a list of packets {A, B, C, ...}. Each packet is
23 // When the first packet in |packet_list| has been processed, the orignal packet
32 Packet* red_packet = (*it);
52 Packet* new_packet = new Packet;
89 // The block lengths in the RED headers do not match the overall packet
91 // payloads from this packet.
113 // Delete old packet payload.
116 // Remove |it| from the packet list. This operation effectively moves th
129 Packet* packet = (*it); \/\/ Just to make the notation more intuitive. local
224 Packet* packet = (*it); \/\/ Just to make the notation more intuitive. local
[all...] |
| /external/webrtc/webrtc/modules/audio_coding/test/ |
| RTPFile.cc | 89 RTPPacket *packet = new RTPPacket(payloadType, timeStamp, seqNo, payloadData, local
92 _rtpQueue.push(packet);
99 RTPPacket *packet = _rtpQueue.front(); local
103 rtpInfo->header.payloadType = packet->payloadType;
104 rtpInfo->header.sequenceNumber = packet->seqNo;
106 rtpInfo->header.timestamp = packet->timeStamp;
107 if (packet->payloadSize > 0 && payloadSize >= packet->payloadSize) {
108 memcpy(payloadData, packet->payloadData, packet->payloadSize)
[all...] |
| /external/webrtc/webrtc/modules/remote_bitrate_estimator/ |
| send_time_history_unittest.cc | 131 PacketInfo packet = received_packets[i]; local
132 EXPECT_TRUE(history_.GetInfo(&packet, false));
133 PacketInfo sent_packet = sent_packets[packet.sequence_number];
134 sent_packet.arrival_time_ms = packet.arrival_time_ms;
135 EXPECT_EQ(sent_packet, packet);
136 EXPECT_TRUE(history_.GetInfo(&packet, true));
138 for (PacketInfo packet : sent_packets)
139 EXPECT_FALSE(history_.GetInfo(&packet, false));
|
| /external/webrtc/webrtc/modules/rtp_rtcp/source/ |
| rtp_format_vp8_unittest.cc | 128 // size fits exactly in the maximum packet size.
276 // Frag start only true for first packet in equal size mode.
302 // EqualSize mode => First packet full; other not.
305 // Frag start only true for first packet in equal size mode.
335 // Expect one single packet of payload_size() + 4 bytes header.
337 const int kExpectedPart[1] = {0}; // Packet starts with partition 0.
364 // Expect one single packet of payload_size() + 3 bytes header.
366 const int kExpectedPart[1] = {0}; // Packet starts with partition 0.
394 // Expect one single packet of payload_size() + 3 bytes header.
396 const int kExpectedPart[1] = {0}; // Packet starts with partition 0
429 uint8_t packet[4] = {0}; local
448 uint8_t packet[10] = {0}; local
482 uint8_t packet[13] = {0}; local
500 uint8_t packet[10] = {0}; local
519 uint8_t packet[10] = {0}; local
537 uint8_t packet[10] = {0}; local
556 uint8_t packet[4] = {0}; local
569 uint8_t packet[20] = {0}; local
[all...] |
| /external/webrtc/webrtc/modules/video_coding/ |
| session_info_unittest.cc | 15 #include "webrtc/modules/video_coding/packet.h"
171 // Insert empty packet which will be the new high sequence number.
313 // Insert an older packet with a first packet set.
373 // Insert out of bound regular packets, and then the first and last packet.
382 // Insert an older packet with a first packet set.
428 VCMPacket* packet = local
431 static_cast<size_t>(session_.InsertPacket(*packet, frame_buffer_,
433 delete packet;
478 VCMPacket* packet = local
540 VCMPacket* packet = local
602 VCMPacket* packet = local
664 VCMPacket* packet = local
726 VCMPacket* packet = local
812 VCMPacket* packet = local
[all...] |
| /external/webrtc/webrtc/test/ |
| fake_network_pipe.cc | 63 // The packet data.
67 // The time the packet was sent out on the network.
69 // The time the packet should arrive at the reciver.
111 // Too many packet on the link, drop this one.
130 NetworkPacket* packet = new NetworkPacket(data, data_length, time_now, local
132 capacity_link_.push(packet);
161 // Time to get this packet.
162 NetworkPacket* packet = capacity_link_.front(); local
167 delete packet;
172 // earlier than the last packet in the queue
191 NetworkPacket* packet = delay_link_.front(); local
202 NetworkPacket* packet = packets_to_deliver.front(); local
[all...] |
| /external/webrtc/webrtc/voice_engine/test/auto_test/fakes/ |
| conference_transport.cc | 112 StorePacket(Packet::Rtp, data, len);
117 StorePacket(Packet::Rtcp, data, len);
131 void ConferenceTransport::StorePacket(Packet::Type type,
136 packet_queue_.push_back(Packet(type, data, len, rtc::Time()));
142 // a packet is first sent to the reflector, and then forwarded to the receiver
145 void ConferenceTransport::SendPacket(const Packet& packet) {
148 switch (packet.type_) {
149 case Packet::Rtp: {
151 rtp_header_parser_->Parse(packet.data_, packet.len_, &rtp_header)
199 Packet packet; local
[all...] |
| /system/bt/hci/src/ |
| hci_packet_factory.c | 49 BT_HDR *packet = make_command(HCI_HOST_BUFFER_SIZE, parameter_size, &stream); local
55 return packet;
73 BT_HDR *packet = make_command(HCI_READ_LOCAL_EXT_FEATURES, parameter_size, &stream); local
76 return packet;
82 BT_HDR *packet = make_command(HCI_WRITE_SIMPLE_PAIRING_MODE, parameter_size, &stream); local
85 return packet;
91 BT_HDR *packet = make_command(HCI_WRITE_SECURE_CONNS_SUPPORT, parameter_size, &stream); local
94 return packet;
100 BT_HDR *packet = make_command(HCI_SET_EVENT_MASK, parameter_size, &stream); local
103 return packet;
109 BT_HDR *packet = make_command(HCI_WRITE_LE_HOST_SUPPORT, parameter_size, &stream); local
147 BT_HDR *packet = make_command(HCI_BLE_SET_EVENT_MASK, parameter_size, &stream); local
160 BT_HDR *packet = make_packet(HCI_COMMAND_PREAMBLE_SIZE + parameter_size); local
[all...] |
| /system/bt/hci/test/ |
| hci_layer_test.cpp | 88 // TODO move this to a common packet testing helper
96 BT_HDR *packet = (BT_HDR *)osi_malloc(size + sizeof(BT_HDR)); local
97 packet->len = size;
98 packet->offset = 0;
99 packet->layer_specific = 0;
104 packet->event = event;
106 uint8_t *packet_data = packet->data;
125 return packet;
616 BT_HDR *packet = manufacture_packet(MSG_STACK_TO_HC_HCI_ACL, small_sample_data);
617 hci->transmit_downward(MSG_STACK_TO_HC_HCI_ACL, packet);
[all...] |
| packet_fragmenter_test.cpp | 73 BT_HDR *packet = (BT_HDR *)osi_malloc(size + sizeof(BT_HDR)); local
74 packet->len = size;
75 packet->offset = 0;
76 packet->event = event;
77 packet->layer_specific = 0;
78 uint8_t *packet_data = packet->data;
86 return packet;
89 static void expect_packet_fragmented(uint16_t event, int max_acl_data_size, BT_HDR *packet, const char *expected_data, bool send_complete) {
90 uint8_t *data = packet->data + packet->offset
142 BT_HDR *packet = (BT_HDR *)osi_malloc(length_to_send + 4 + sizeof(BT_HDR)); local
164 BT_HDR *packet = (BT_HDR *)osi_malloc(data_length + sizeof(BT_HDR)); local
[all...] |
| /system/connectivity/shill/ |
| active_link_monitor.cc | 239 ArpPacket packet; local
241 if (!arp_client_->ReceivePacket(&packet, &sender)) {
245 if (!packet.IsReply()) {
246 SLOG(connection_.get(), 4) << "This is not a reply packet. Ignoring.";
251 packet.remote_ip_address().address())) {
256 if (!local_mac_address_.Equals(packet.remote_mac_address())) {
262 packet.local_ip_address().address())) {
289 if (!gateway_mac_address_.Equals(packet.local_mac_address())) {
290 const ByteString& new_mac_address = packet.local_mac_address();
|
| arp_client_unittest.cc | 78 void SetupValidPacket(ArpPacket* packet);
116 void ArpClientTest::SetupValidPacket(ArpPacket* packet) {
119 packet->set_local_ip_address(local_ip);
122 packet->set_remote_ip_address(remote_ip);
124 packet->set_local_mac_address(local_mac);
126 packet->set_remote_mac_address(remote_mac);
170 HasSubstr("Could not attach packet filter"))).Times(1);
236 HasSubstr("Failed to parse ARP packet"))).Times(1);
239 ArpPacket packet; local
240 SetupValidPacket(&packet);
260 ArpPacket packet; local
[all...] |
| /system/core/liblog/tests/ |
| liblog_benchmark.cpp | 203 struct packet { struct
208 char buf[sizeof(struct packet) + 8] __aligned(8);
210 struct packet *buffer = (struct packet*)(((uintptr_t)buf + 7) & ~7);
279 struct packet { struct
284 char buf[sizeof(struct packet) + 8] __aligned(8);
286 struct packet *buffer = (struct packet*)((((uintptr_t)buf + 7) & ~7) + 1);
355 struct packet { struct
360 char buf[sizeof(struct packet) + 8 + LOGGER_ENTRY_MAX_PAYLOAD] __aligned(8)
428 struct packet { struct
[all...] |
| /external/nist-sip/java/gov/nist/javax/sip/stack/ |
| UDPMessageChannel.java | 163 * Constructor - takes a datagram packet and a stack structure Extracts the
164 * address of the other from the datagram packet and stashes away the
196 * @param packet
197 * is the incoming datagram packet.
200 UDPMessageProcessor messageProcessor, DatagramPacket packet) {
202 this.incomingPacket = packet;
255 DatagramPacket packet; local
286 packet = (DatagramPacket) ((UDPMessageProcessor) messageProcessor).messageQueue
290 this.incomingPacket = packet;
292 packet = this.incomingPacket
[all...] |
| /device/moto/shamu/camera/QCamera2/HAL/ |
| QCameraMem.cpp | 1113 struct encoder_media_buffer_type * packet = local
1159 struct encoder_media_buffer_type * packet = local
1184 struct encoder_media_buffer_type * packet = local
[all...] |
| /external/android-clat/ |
| clatd.c | 71 * Binds the packet socket and attaches the receive filter to it.
82 logmsg(ANDROID_LOG_FATAL, "binding packet socket: %s", strerror(errno));
91 // doesn't match, jump ahead to statement that returns 0 (ignore packet). Repeat for the other
92 // three words of the IPv6 address, and if they all match, return PACKETLEN (accept packet).
110 logmsg(ANDROID_LOG_FATAL, "attach packet filter failed: %s", strerror(errno));
196 * opens a packet socket to receive IPv6 packets and a raw socket to send them
224 * picks the clat IPv6 address and configures packet translation to use it.
267 // Update our packet socket filter to reflect the new 464xlat IP address.
327 * reads a packet from the tunnel fd and translates it
328 * read_fd - file descriptor to read original packet fro
334 uint8_t buf[PACKETLEN], *packet; local
[all...] |
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ObjectReference/ |
| InvokeMethodDefault002Test.java | 56 CommandPacket packet = new CommandPacket( local
59 packet.setNextValueAsByte(JDWPConstants.EventKind.METHOD_ENTRY);
60 packet.setNextValueAsByte(JDWPConstants.SuspendPolicy.ALL);
61 packet.setNextValueAsInt(1); // number of modifiers
62 packet.setNextValueAsByte(EventMod.ModKind.ClassOnly); // class-only modifier.
63 packet.setNextValueAsReferenceTypeID(debuggeeTypeID);
64 ReplyPacket reply = debuggeeWrapper.vmMirror.performCommand(packet);
129 packet = new CommandPacket(
132 packet.setNextValueAsObjectID(receiverObjectID);
133 packet.setNextValueAsThreadID(targetThreadID)
[all...] |
| InvokeMethodDefaultTest.java | 55 CommandPacket packet = new CommandPacket( local
58 packet.setNextValueAsByte(JDWPConstants.EventKind.METHOD_ENTRY);
59 packet.setNextValueAsByte(JDWPConstants.SuspendPolicy.ALL);
60 packet.setNextValueAsInt(1);
61 packet.setNextValueAsByte(EventMod.ModKind.ClassOnly); // class-only modifier.
62 packet.setNextValueAsReferenceTypeID(debuggeeTypeID);
63 ReplyPacket reply = debuggeeWrapper.vmMirror.performCommand(packet);
129 packet = new CommandPacket(
132 packet.setNextValueAsObjectID(receiverObjectID);
133 packet.setNextValueAsThreadID(targetThreadID)
[all...] |
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/StackFrame/ |
| JDWPStackFrameTestCase.java | 91 CommandPacket packet = new CommandPacket( local
94 packet.setNextValueAsThreadID(threadID);
96 ReplyPacket reply = debuggeeWrapper.vmMirror.performCommand(packet);
104 CommandPacket packet = new CommandPacket( local
107 packet.setNextValueAsThreadID(threadID);
108 packet.setNextValueAsInt(startFrame);
109 packet.setNextValueAsInt(length);
111 ReplyPacket reply = debuggeeWrapper.vmMirror.performCommand(packet);
125 CommandPacket packet = new CommandPacket( local
128 packet.setNextValueAsClassID(classID)
151 CommandPacket packet = new CommandPacket( local
169 CommandPacket packet = new CommandPacket( local
182 CommandPacket packet = new CommandPacket( local
192 CommandPacket packet = new CommandPacket( local
[all...] |
| /external/deqp/external/vulkancts/modules/vulkan/pipeline/ |
| vktPipelineReferenceRenderer.hpp | 68 rr::VertexPacket* const packet = packets[packetNdx]; member in class:vkt::pipeline::ColorVertexShader::rr
70 readVertexAttrib(position, inputs[0], packet->instanceNdx, packet->vertexNdx);
71 readVertexAttrib(color, inputs[1], packet->instanceNdx, packet->vertexNdx);
73 packet->outputs[0] = position;
74 packet->outputs[1] = color;
75 packet->position = position;
103 rr::VertexPacket* const packet = packets[packetNdx]; member in class:vkt::pipeline::TexCoordVertexShader::rr
105 readVertexAttrib(position, inputs[0], packet->instanceNdx, packet->vertexNdx)
145 const rr::FragmentPacket& packet = packets[packetNdx]; local
243 const rr::FragmentPacket& packet = packets[packetNdx]; local
[all...] |
| /external/deqp/modules/egl/ |
| teglColorClearCase.cpp | 369 ClearPacket& packet = packets[threadNdx][packetNdx]; local
372 packet.wait = semaphores[packetNdx*numThreads + threadNdx];
373 packet.signal = semaphores[packetNdx*numThreads + threadNdx + 1];
375 for (int clearNdx = 0; clearNdx < DE_LENGTH_OF_ARRAY(packet.clears); clearNdx++)
379 packet.clears[clearNdx] = ClearOp(0, 0, width, height, RGBA::black());
381 packet.clears[clearNdx] = computeRandomClear(rnd, width, height);
420 const ClearPacket& packet = packets[threadNdx][packetNdx]; local
421 for (int clearNdx = 0; clearNdx < DE_LENGTH_OF_ARRAY(packet.clears); clearNdx++)
424 packet.clears[clearNdx].x, packet.clears[clearNdx].y, 0
[all...] |
| /external/deqp/modules/gles31/functional/ |
| es31fFboTestUtil.cpp | 207 rr::VertexPacket& packet = *packets[packetNdx]; local
209 packet.position = rr::readVertexAttribFloat(inputs[0], packet.instanceNdx, packet.vertexNdx);
210 packet.outputs[0] = rr::readVertexAttribFloat(inputs[1], packet.instanceNdx, packet.vertexNdx);
370 rr::VertexPacket& packet = *packets[packetNdx]; local
371 const tcu::Vec2 a_coord = rr::readVertexAttribFloat(inputs[1], packet.instanceNdx, packet.vertexNdx).xy()
[all...] |
| /external/dnsmasq/contrib/wrt/ |
| dhcp_lease_time.c | 76 return NULL; /* malformed packet */
83 return NULL; /* malformed packet */
86 return NULL; /* malformed packet */
137 struct dhcp_packet packet; local
138 unsigned char *p = packet.options;
157 memset(&packet, 0, sizeof(packet));
159 packet.hlen = 0;
160 packet.htype = 0;
162 packet.op = BOOTREQUEST
[all...] |
| dhcp_release.c | 252 struct dhcp_packet packet; local
253 unsigned char *p = packet.options;
275 /* This voodoo fakes up a packet coming from the correct interface, which really matters for
288 memset(&packet, 0, sizeof(packet));
290 packet.hlen = parse_hex(argv[3], packet.chaddr, DHCP_CHADDR_MAX, &mac_type);
292 packet.htype = ARPHRD_ETHER;
294 packet.htype = mac_type;
296 packet.op = BOOTREQUEST
[all...] |
