| /external/smack/src/org/jivesoftware/smackx/packet/ |
| StreamInitiation.java | 20 package org.jivesoftware.smackx.packet;
24 import org.jivesoftware.smack.packet.IQ;
25 import org.jivesoftware.smack.packet.PacketExtension;
134 * @see org.jivesoftware.smack.packet.IQ#getChildElementXML()
375 * The feature negotiation portion of the StreamInitiation packet.
|
| /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
122 const u_char *packet; local
127 packet = pcap_next(pcap, &hdr);
129 if (packet == NULL || hdr.caplen < sizeof(*ethhdr))
132 ethhdr = (struct l2_ethhdr *) packet;
|
| /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());
|
| /libcore/luni/src/main/java/java/net/ |
| PlainDatagramSocketImpl.java | 155 DatagramPacket packet = new DatagramPacket(EmptyArray.BYTE, 0); local
156 int result = peekData(packet);
158 sender.ipaddress = packet.getAddress().getAddress();
181 public void send(DatagramPacket packet) throws IOException {
182 int port = isNativeConnected ? 0 : packet.getPort();
183 InetAddress address = isNativeConnected ? null : packet.getAddress();
184 IoBridge.sendto(fd, packet.getData(), packet.getOffset(), packet.getLength(), 0, address,
245 * Set the received address and port in the packet. We do this when th
[all...] |
| /libcore/luni/src/test/java/libcore/java/net/ |
| OldAndroidDatagramTest.java | 48 DatagramPacket packet; field in class:OldAndroidDatagramTest.Reflector
58 packet.setLength(buffer.length);
59 socket.receive(packet);
60 String s = stringFromPacket(packet);
61 // System.out.println(s + " (from " + packet.getAddress() + ":" + packet.getPort() + ")");
69 stringToPacket(s.toUpperCase(), packet); local
71 packet.setAddress(InetAddress.getLocalHost());
72 packet.setPort(2345);
74 socket.send(packet);
130 DatagramPacket packet = new DatagramPacket(buffer, buffer.length); local
[all...] |
| /external/smack/src/org/jivesoftware/smackx/workgroup/agent/ |
| AgentSession.java | 31 import org.jivesoftware.smackx.workgroup.packet.*;
36 import org.jivesoftware.smack.packet.*;
40 import org.jivesoftware.smackx.packet.MUCUser;
116 public void processPacket(Packet packet) {
118 handlePacket(packet);
132 * packet listeners that were added by this agent session will be removed.
362 // Send information about max chats and current chats as a packet extension.
679 private void handlePacket(Packet packet) {
[all...] |
| /device/asus/flo/camera/QCamera2/stack/mm-camera-interface/src/ |
| mm_camera.c | 1543 cam_sock_packet_t packet; local
1577 cam_sock_packet_t packet; local
[all...] |
| mm_camera_stream.c | 1259 cam_sock_packet_t packet; local
1306 cam_sock_packet_t packet; local
[all...] |
| /device/lge/hammerhead/camera/QCamera2/stack/mm-camera-interface/src/ |
| mm_camera.c | 1544 cam_sock_packet_t packet; local
1578 cam_sock_packet_t packet; local
[all...] |
| mm_camera_stream.c | 1251 cam_sock_packet_t packet; local
1298 cam_sock_packet_t packet; local
[all...] |
| /device/lge/mako/camera/QCamera/stack/mm-camera-interface/src/ |
| mm_camera.c | 1716 cam_sock_packet_t packet; local
1733 cam_sock_packet_t packet; local
[all...] |
| mm_camera_channel.c | 1171 cam_sock_packet_t packet; local
[all...] |
| /device/moto/shamu/camera/QCamera/stack/mm-camera-interface/src/ |
| mm_camera_interface.c | 820 cam_sock_packet_t packet; local
821 memset(&packet, 0, sizeof(cam_sock_packet_t));
822 memcpy(&packet.payload.frame_fd_map, cmd, sizeof(mm_camera_frame_map_type));
823 if(packet.payload.frame_fd_map.is_hist) {
824 packet.msg_type = CAM_SOCK_MSG_TYPE_HIST_MAPPING;
826 packet.msg_type = CAM_SOCK_MSG_TYPE_FD_MAPPING;
828 rc = mm_camera_util_sendmsg(my_obj, &packet,
830 packet.payload.frame_fd_map.fd);
834 cam_sock_packet_t packet; local
835 memset(&packet, 0, sizeof(cam_sock_packet_t))
[all...] |
| /device/moto/shamu/camera/QCamera2/stack/mm-camera-interface/src/ |
| mm_camera.c | 1619 cam_sock_packet_t packet; local
1653 cam_sock_packet_t packet; local
[all...] |
| mm_camera_stream.c | 1283 cam_sock_packet_t packet; local
1330 cam_sock_packet_t packet; local
[all...] |
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/DebuggerOnDemand/ |
| LaunchedDebugger.java | 163 CommandPacket packet = new CommandPacket( local
166 packet.setNextValueAsThreadID(threadID);
167 packet.setNextValueAsInt(startFrame);
168 packet.setNextValueAsInt(length);
170 ReplyPacket reply = debuggeeWrapper.vmMirror.performCommand(packet);
187 CommandPacket packet = new CommandPacket( local
190 packet.setNextValueAsString(signature);
191 ReplyPacket reply = debuggeeWrapper.vmMirror.performCommand(packet);
228 CommandPacket packet = new CommandPacket( local
231 packet.setNextValueAsClassID(classID)
[all...] |
| /external/bluetooth/bluedroid/btif/src/ |
| btif_pan.c | 454 char packet[2000]; local
455 memcpy(packet, ð_hdr, sizeof(tETH_HDR));
458 ALOGE("btpan_tap_send eth packet size:%d is exceeded limit!", len);
461 memcpy(packet + sizeof(tETH_HDR), buf, len);
465 //dump_bin("packet to network", packet, len + sizeof(tETH_HDR));
466 int ret = write(tap_fd, packet, len + sizeof(tETH_HDR));
689 BTIF_TRACE_WARNING("%s unable to allocate buffer for packet.", __func__);
695 UINT8 *packet = (UINT8 *)buffer + sizeof(BT_HDR) + buffer->offset; local
697 // If we don't have an undelivered packet left over, pull one from the TAP driver
[all...] |
| /external/chromium_org/google_apis/gcm/engine/ |
| mcs_client.cc | 421 MCSPacketInternal packet = PopMessageForSend(); local
422 if (GetTTL(*packet->protobuf) > 0 &&
423 !HasTTLExpired(*packet->protobuf, clock_)) {
424 new_to_send.push_back(packet);
428 if (!packet->persistent_id.empty())
429 expired_ttl_ids.push_back(packet->persistent_id);
430 NotifyMessageSendStatus(*packet->protobuf, TTL_EXCEEDED);
473 MCSPacketInternal packet = PopMessageForSend();
474 if (HasTTLExpired(*packet->protobuf, clock_)) {
475 DCHECK(!packet->persistent_id.empty())
896 MCSPacketInternal packet = to_send_.front(); local
[all...] |
| /external/chromium_org/media/ffmpeg/ |
| ffmpeg_unittest.cc | 56 AVPacket* packet = packets_.front(); local
58 av_free_packet(packet);
59 delete packet;
62 void push(AVPacket* packet) {
63 av_dup_packet(packet);
64 packets_.push(packet);
185 scoped_ptr<AVPacket> packet(new AVPacket());
186 if (av_read_frame(av_format_context_, packet.get()) < 0) {
190 int stream_index = static_cast<int>(packet->stream_index);
194 ConvertFromTimeBase(av_audio_stream()->time_base, packet->pts
228 AVPacket packet; local
282 AVPacket packet; local
[all...] |
| /external/chromium_org/net/quic/ |
| quic_http_stream_test.cc | 116 // Holds a packet to be written to the wire, and the IO mode that should
119 PacketToWrite(IoMode mode, QuicEncryptedPacket* packet)
121 packet(packet) {
124 QuicEncryptedPacket* packet; member in struct:net::test::QuicHttpStreamTest::PacketToWrite
144 delete writes_[i].packet;
148 // Adds a packet to the list of expected writes.
149 void AddWrite(scoped_ptr<QuicEncryptedPacket> packet) {
150 writes_.push_back(PacketToWrite(SYNCHRONOUS, packet.release()));
153 // Returns the packet to be written at position |pos|
[all...] |
| quic_packet_creator.cc | 106 // pending frames when FEC protection is turned on. If current packet can be
107 // converted to an FEC protected packet, do it. This will require the
109 // frame to be added to the packet.
139 // packet header size in all packets within a group.
147 // Update sequence number length only on packet and FEC group boundaries.
154 // the sequence number of the next packet.
161 // A packet that is already open might send kQuicVersionSize bytes less than the
162 // maximum packet size if we stop sending version before it is serialized.
176 // Since the packet creator will not change sequence number length mid FEC
209 // Assumes this is a stream with a single lone packet
306 SerializedPacket packet = SerializePacket(); local
[all...] |
| /external/chromium_org/remoting/codec/ |
| codec_test.cc | 80 void ReceivedPacket(VideoPacket* packet) {
81 ASSERT_TRUE(decoder_->DecodePacket(*packet));
94 void ReceivedScopedPacket(scoped_ptr<VideoPacket> packet) {
95 ReceivedPacket(packet.get());
215 void DataAvailable(scoped_ptr<VideoPacket> packet) {
219 decoder_tester_->ReceivedPacket(packet.get());
256 scoped_ptr<VideoPacket> packet = encoder->Encode(*frame); local
257 tester->DataAvailable(packet.Pass());
306 scoped_ptr<VideoPacket> packet = encoder->Encode(*frame); local
307 encoder_tester->DataAvailable(packet.Pass())
366 scoped_ptr<VideoPacket> packet = encoder->Encode(*frame); local
[all...] |
| /external/chromium_org/remoting/protocol/ |
| channel_multiplexer.cc | 28 PendingPacket(scoped_ptr<MultiplexPacket> packet,
30 : packet(packet.Pass()),
38 bool is_empty() { return pos >= packet->data().size(); }
41 size = std::min(size, packet->data().size() - pos);
42 memcpy(buffer, packet->data().data() + pos, size);
48 scoped_ptr<MultiplexPacket> packet; member in class:remoting::protocol::__anon14498::PendingPacket
80 void OnIncomingPacket(scoped_ptr<MultiplexPacket> packet,
86 bool DoWrite(scoped_ptr<MultiplexPacket> packet,
221 scoped_ptr<MultiplexPacket> packet,
[all...] |
| /external/chromium_org/third_party/mesa/src/src/mesa/drivers/dri/r200/ |
| r200_sanity.c | 58 /* New (1.3) state mechanism. 3 commands (packet, scalar, vector) in
66 } packet[RADEON_MAX_STATE_PACKETS] = { variable in typeref:struct:__anon18107
[all...] |
