/external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ThreadGroupReference/ |
H A D | ParentTest.java | 59 CommandPacket packet; 66 packet = new CommandPacket( 69 packet.setNextValueAsThreadID(threadID); 71 ReplyPacket reply = debuggeeWrapper.vmMirror.performCommand(packet); 76 packet = new CommandPacket( 79 packet.setNextValueAsThreadID(groupID); 81 reply = debuggeeWrapper.vmMirror.performCommand(packet); 153 CommandPacket packet = new CommandPacket( 156 packet.setNextValueAsThreadGroupID(groupID); 157 ReplyPacket reply = debuggeeWrapper.vmMirror.performCommand(packet); [all...] |
/external/chromium_org/third_party/webrtc/modules/audio_coding/neteq/ |
H A D | comfort_noise.cc | 28 int ComfortNoise::UpdateParameters(Packet* packet) { argument 29 assert(packet); // Existence is verified by caller. 32 packet->header.payloadType); 34 delete [] packet->payload; 35 delete packet; 38 decoder_database_->SetActiveCngDecoder(packet->header.payloadType); 41 packet->payload, 42 packet->payload_length); 43 delete [] packet->payload; 44 delete packet; [all...] |
/external/chromium_org/components/devtools_bridge/android/java/src/org/chromium/components/devtools_bridge/ |
H A D | SocketTunnelBase.java | 29 * CLIENT_OPEN packet to the server with newly assigned connection id. On receiving this packet 48 // Structure of control packet: 53 // Structure of data packet: 167 ByteBuffer packet = ByteBuffer.allocateDirect(CONTROL_PACKET_SIZE); 168 packet.put((byte) CONTROL_CONNECTION_ID); 169 packet.put(opCode); 170 packet.put((byte) connectionId); 171 return packet; 175 ByteBuffer packet 181 sendToDataChannel(ByteBuffer packet) argument 199 decodePacket(ByteBuffer packet) argument [all...] |
/external/chromium_org/third_party/opus/src/tests/ |
H A D | test_opus_api.c | 89 unsigned char packet[1276]; local 188 VG_UNDEF(packet,sizeof(packet)); 189 packet[0]=63<<2;packet[1]=packet[2]=0; 190 if(opus_decode(dec, packet, 3, sbuf, 960, 0)!=960)test_failed(); 196 packet[0]=1; 197 if(opus_decode(dec, packet, 1, sbuf, 960, 0)!=960)test_failed(); 247 VG_UNDEF(packet,sizeo 348 unsigned char packet[1276]; local 712 unsigned char packet[1276]; local 1072 unsigned char packet[1276]; local 1441 unsigned char *packet; local [all...] |
/external/libopus/tests/ |
H A D | test_opus_api.c | 89 unsigned char packet[1276]; local 188 VG_UNDEF(packet,sizeof(packet)); 189 packet[0]=63<<2;packet[1]=packet[2]=0; 190 if(opus_decode(dec, packet, 3, sbuf, 960, 0)!=960)test_failed(); 196 packet[0]=1; 197 if(opus_decode(dec, packet, 1, sbuf, 960, 0)!=960)test_failed(); 247 VG_UNDEF(packet,sizeo 348 unsigned char packet[1276]; local 712 unsigned char packet[1276]; local 1072 unsigned char packet[1276]; local 1441 unsigned char *packet; local [all...] |
/external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/VirtualMachine/ |
H A D | TopLevelThreadGroupsTest.java | 50 * <BR> - there are no extra data in the reply packet; 58 CommandPacket packet = new CommandPacket( 61 ReplyPacket reply = debuggeeWrapper.vmMirror.performCommand(packet); 82 CommandPacket packet = new CommandPacket( 85 packet.setNextValueAsThreadGroupID(rootID); 86 ReplyPacket replyParent = debuggeeWrapper.vmMirror.performCommand(packet); 93 packet = new CommandPacket( 96 packet.setNextValueAsThreadGroupID(rootID); 97 ReplyPacket replyChilds = debuggeeWrapper.vmMirror.performCommand(packet); 107 packet [all...] |
/external/smack/src/org/jivesoftware/smackx/ |
H A D | LastActivityManager.java | 28 import org.jivesoftware.smack.packet.IQ;
29 import org.jivesoftware.smack.packet.Message;
30 import org.jivesoftware.smack.packet.Packet;
31 import org.jivesoftware.smack.packet.Presence;
32 import org.jivesoftware.smackx.packet.DiscoverInfo;
33 import org.jivesoftware.smackx.packet.LastActivity;
53 * the LastActivity packet to them, as in the following code:
69 * To get the uptime of a host, you simple send the LastActivity packet to it,
108 public void processPacket(Packet packet) {
109 Presence presence = (Presence) packet;
[all...] |
/external/chromium_org/remoting/host/ |
H A D | audio_capturer_linux.cc | 69 scoped_ptr<AudioPacket> packet(new AudioPacket()); 70 packet->add_data(data->data()); 71 packet->set_encoding(AudioPacket::ENCODING_RAW); 72 packet->set_sampling_rate(AudioPipeReader::kSamplingRate); 73 packet->set_bytes_per_sample(AudioPipeReader::kBytesPerSample); 74 packet->set_channels(AudioPipeReader::kChannels); 75 callback_.Run(packet.Pass());
|
/external/chromium_org/third_party/WebKit/PerformanceTests/SunSpider/tests/v8-v4/ |
H A D | v8-richards.js | 78 * These two constants specify how many times a packet is queued and 231 * Add the specified packet to the end of the worklist used by the task 232 * associated with the packet and make the task runnable if it is currently 234 * @param {Packet} packet the packet to add 236 Scheduler.prototype.queue = function (packet) { 237 var t = this.blocks[packet.id]; 240 packet.link = null; 241 packet.id = this.currentId; 242 return t.checkPriorityAdd(this.currentTcb, packet); [all...] |
/external/chromium_org/third_party/WebKit/PerformanceTests/SunSpider/tests/v8-v5/ |
H A D | v8-richards.js | 78 * These two constants specify how many times a packet is queued and 231 * Add the specified packet to the end of the worklist used by the task 232 * associated with the packet and make the task runnable if it is currently 234 * @param {Packet} packet the packet to add 236 Scheduler.prototype.queue = function (packet) { 237 var t = this.blocks[packet.id]; 240 packet.link = null; 241 packet.id = this.currentId; 242 return t.checkPriorityAdd(this.currentTcb, packet); [all...] |
/external/chromium_org/third_party/WebKit/PerformanceTests/SunSpider/tests/v8-v6/ |
H A D | v8-richards.js | 78 * These two constants specify how many times a packet is queued and 231 * Add the specified packet to the end of the worklist used by the task 232 * associated with the packet and make the task runnable if it is currently 234 * @param {Packet} packet the packet to add 236 Scheduler.prototype.queue = function (packet) { 237 var t = this.blocks[packet.id]; 240 packet.link = null; 241 packet.id = this.currentId; 242 return t.checkPriorityAdd(this.currentTcb, packet); [all...] |
/external/chromium_org/v8/benchmarks/ |
H A D | richards.js | 83 * These two constants specify how many times a packet is queued and 236 * Add the specified packet to the end of the worklist used by the task 237 * associated with the packet and make the task runnable if it is currently 239 * @param {Packet} packet the packet to add 241 Scheduler.prototype.queue = function (packet) { 242 var t = this.blocks[packet.id]; 245 packet.link = null; 246 packet.id = this.currentId; 247 return t.checkPriorityAdd(this.currentTcb, packet); [all...] |
/external/smack/src/org/jivesoftware/smackx/bytestreams/ibb/ |
H A D | InitiationListener.java | 24 import org.jivesoftware.smack.packet.IQ;
25 import org.jivesoftware.smack.packet.Packet;
27 import org.jivesoftware.smackx.bytestreams.ibb.packet.Open;
46 /* packet filter for all In-Band Bytestream requests */
63 public void processPacket(final Packet packet) {
argument 67 processRequest(packet);
72 private void processRequest(Packet packet) {
argument 73 Open ibbRequest = (Open) packet;
85 // build bytestream request from packet
112 * Returns the packet filte [all...] |
/external/smack/src/org/jivesoftware/smackx/bytestreams/socks5/ |
H A D | InitiationListener.java | 24 import org.jivesoftware.smack.packet.IQ;
25 import org.jivesoftware.smack.packet.Packet;
27 import org.jivesoftware.smackx.bytestreams.socks5.packet.Bytestream;
42 /* packet filter for all SOCKS5 Bytestream requests */
59 public void processPacket(final Packet packet) {
argument 63 processRequest(packet);
68 private void processRequest(Packet packet) {
argument 69 Bytestream byteStreamRequest = (Bytestream) packet;
76 // build bytestream request from packet
104 * Returns the packet filte [all...] |
/external/smack/src/org/jivesoftware/smackx/forward/ |
H A D | Forwarded.java | 19 import org.jivesoftware.smack.packet.Packet; 20 import org.jivesoftware.smack.packet.PacketExtension; 23 import org.jivesoftware.smackx.packet.DelayInfo; 29 * the packet extension and a {@link PacketExtensionProvider} to parse 30 * forwarded messages from a packet. The extension 48 * Creates a new Forwarded packet extension. 50 * @param delay an optional {@link DelayInfo} timestamp of the packet. 51 * @param fwdPacket the packet that is forwarded (required). 83 * get the packet forwarded by this stanza. 92 * get the timestamp of the forwarded packet [all...] |
/external/chromium_org/net/quic/ |
H A D | quic_fec_group_test.cc | 47 for (size_t packet = 0; packet < num_packets; ++packet) { 49 if (packet == 0) { 50 // Initialize to the first packet. 55 uint8 byte = i > strlen(kData[packet]) ? 0x00 : kData[packet][i]; 62 // If we're out of order, send the FEC packet in the position of the 63 // lost packet. Otherwise send all (non-missing) packets, then FEC. 65 // Update the FEC state for each non-lost packet [all...] |
/external/chromium_org/third_party/webrtc/modules/rtp_rtcp/source/ |
H A D | rtp_format_h264_unittest.cc | 53 const uint8_t* packet, 59 EXPECT_EQ(kFuIndicator, packet[0]) << "FUA index: " << fua_index; 68 EXPECT_EQ(fu_header, packet[1]) << "FUA index: " << fua_index; 74 ::testing::ElementsAreArray(&packet[2], expected_sizes[fua_index])) 95 scoped_ptr<uint8_t[]> packet(new uint8_t[max_payload_size]); 100 ASSERT_TRUE(packetizer->NextPacket(packet.get(), &length, &last)); 101 VerifyFua(i, frame.get(), offset, packet.get(), length, expected_sizes); 106 EXPECT_FALSE(packetizer->NextPacket(packet.get(), &length, &last)); 126 const uint8_t* packet, 140 ::testing::ElementsAreArray(&packet[expected_payload_offse 50 VerifyFua(size_t fua_index, const uint8_t* expected_payload, int offset, const uint8_t* packet, size_t length, const std::vector<size_t>& expected_sizes) argument 198 uint8_t packet[kMaxPayloadSize] = {0}; local 235 uint8_t packet[kMaxPayloadSize] = {0}; local 270 uint8_t packet[kMaxPayloadSize] = {0}; local 322 uint8_t packet[kMaxPayloadSize] = {0}; local 409 uint8_t packet[2] = {0x05, 0xFF}; // F=0, NRI=0, Type=5. local 422 uint8_t packet[16] = {kStapA, // F=0, NRI=0, Type=24. local 438 uint8_t packet[16] = {kStapA, // F=0, NRI=0, Type=24. local [all...] |
/external/chromium_org/third_party/libsrtp/srtp/srtp/ |
H A D | ekt.c | 210 uint8_t *packet; local 220 packet = base_tag + base_tag_len; 222 /* copy encrypted master key into packet */ 224 memcpy(packet, ekt->encrypted_master_key, emk_len); 226 octet_string_hex_string(packet, emk_len)); 227 packet += emk_len; 229 /* copy ROC into packet */ 231 *((uint32_t *)packet) = be32_to_cpu(roc); 233 octet_string_hex_string(packet, sizeof(roc))); 234 packet [all...] |
/external/flac/libFLAC/ |
H A D | ogg_encoder_aspect.c | 94 * packet. The packet is prefixed with 95 * + the one-byte packet type 0x7F 99 * - The first packet is flushed to the first page. 100 * - Each subsequent metadata block goes into its own packet. 101 * - Each metadata packet is flushed to page (this is not required, 104 * - Each subsequent FLAC audio frame goes into its own packet. 120 * Treat fLaC magic packet specially. We will note when we see it, then 121 * wait until we get the STREAMINFO and prepend it in that packet 124 ogg_packet packet; local [all...] |
/external/srtp/srtp/ |
H A D | ekt.c | 207 uint8_t *packet; local 217 packet = (uint8_t*)base_tag + base_tag_len; 219 /* copy encrypted master key into packet */ 221 memcpy(packet, ekt->encrypted_master_key, emk_len); 223 octet_string_hex_string(packet, emk_len)); 224 packet += emk_len; 226 /* copy ROC into packet */ 228 *((uint32_t *)packet) = be32_to_cpu(roc); 230 octet_string_hex_string(packet, sizeof(roc))); 231 packet [all...] |
/external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ThreadReference/ |
H A D | StopTest.java | 74 CommandPacket packet = new CommandPacket( 77 packet.setNextValueAsReferenceTypeID(classID); 78 packet.setNextValueAsInt(1); 79 packet.setNextValueAsFieldID(fieldID); 80 ReplyPacket reply = debuggeeWrapper.vmMirror.performCommand(packet); 92 packet = new CommandPacket( 95 packet.setNextValueAsThreadID(threadID); 96 packet.setNextValueAsObjectID(fieldValue.getLongValue()); 98 reply = debuggeeWrapper.vmMirror.performCommand(packet);
|
/external/chromium_org/media/cast/net/rtp/ |
H A D | frame_buffer.cc | 28 // Is this the first packet in the frame? 43 // Insert every packet only once. 52 // Insert the packet. 97 int packet = 0; local 99 i != packets_.end() && packet <= maximum; 102 while (packet < end) { 103 missing_packets->insert(packet); 104 packet++; 106 packet++; 108 while (packet < [all...] |
/external/lldb/examples/python/ |
H A D | gdbremote.py | 4 # This module will enable GDB remote packet logging when the 190 description='''The command enables GDB remote packet logging with timestamps. The packets will be logged to <LOGFILEPATH> if supplied, or a temporary file will be used. Logging stops when stop_gdb_log is called and the packet times will 210 result.PutCString ("GDB packet logging enable with log file '%s'\nUse the 'stop_gdb_log' command to stop logging and show packet statistics." % g_log_file) 226 description='''The command stops a previously enabled GDB remote packet logging command. Packet logging must have been previously enabled with a call to start_gdb_log.''' 252 result.PutCString ("GDB packet logging disabled. Logged packets are in '%s'" % g_log_file) 257 print 'error: the GDB packet log file "%s" does not exist' % g_log_file 296 packet = Packet(hex_str) 298 uval = packet [all...] |
/external/chromium_org/media/cast/test/ |
H A D | loopback_transport.cc | 26 virtual void Send(scoped_ptr<Packet> packet) OVERRIDE { 27 packet_receiver_.Run(packet.Pass()); 47 bool LoopBackTransport::SendPacket(PacketRef packet, argument 50 scoped_ptr<Packet> packet_copy(new Packet(packet->data)); 52 bytes_sent_ += packet->data.size();
|
/external/chromium_org/remoting/client/plugin/ |
H A D | media_source_video_renderer.cc | 173 scoped_ptr<VideoPacket> packet, 177 // Don't need to do anything if the packet is empty. Host sends empty video 179 if (!packet->data().size()) 184 stats_.video_bandwidth()->Record(packet->data().size()); 185 if (packet->has_capture_time_ms()) 186 stats_.video_capture_ms()->Record(packet->capture_time_ms()); 187 if (packet->has_encode_time_ms()) 188 stats_.video_encode_ms()->Record(packet->encode_time_ms()); 189 if (packet->has_client_sequence_number() && 190 packet 172 ProcessVideoPacket( scoped_ptr<VideoPacket> packet, const base::Closure& done) argument [all...] |