| /external/qemu/ |
| D | shaper.c | 69 QueuedPacket packet; in queued_packet_create() local
70 size_t packet_size = sizeof(*packet); in queued_packet_create()
75 packet = qemu_malloc(packet_size); in queued_packet_create()
76 packet->next = NULL; in queued_packet_create()
77 packet->expiration = 0; in queued_packet_create()
78 packet->size = (size_t)size; in queued_packet_create()
79 packet->opaque = opaque; in queued_packet_create()
82 packet->data = (void*)(packet+1); in queued_packet_create()
83 memcpy( (char*)packet->data, (char*)data, packet->size ); in queued_packet_create()
85 packet->data = (void*)data; in queued_packet_create()
[all …]
|
| /external/ppp/pppd/plugins/rp-pppoe/ |
| D | common.c | 46 parsePacket(PPPoEPacket *packet, ParseFunc *func, void *extra) in parsePacket() argument
48 UINT16_t len = ntohs(packet->length); in parsePacket()
52 if (packet->ver != 1) { in parsePacket()
53 syslog(LOG_ERR, "Invalid PPPoE version (%d)", (int) packet->ver); in parsePacket()
56 if (packet->type != 1) { in parsePacket()
57 syslog(LOG_ERR, "Invalid PPPoE type (%d)", (int) packet->type); in parsePacket()
68 curTag = packet->payload; in parsePacket()
69 while(curTag - packet->payload < len) { in parsePacket()
78 if ((curTag - packet->payload) + tagLen + TAG_HDR_SIZE > len) { in parsePacket()
101 findTag(PPPoEPacket *packet, UINT16_t type, PPPoETag *tag) in findTag() argument
[all …]
|
| D | discovery.c | 81 packetIsForMe(PPPoEConnection *conn, PPPoEPacket *packet) in packetIsForMe() argument
86 if (memcmp(packet->ethHdr.h_dest, conn->myEth, ETH_ALEN)) return 0; in packetIsForMe()
91 parsePacket(packet, parseForHostUniq, &forMe); in packetIsForMe()
246 PPPoEPacket packet; in sendPADI() local
247 unsigned char *cursor = packet.payload; in sendPADI()
248 PPPoETag *svc = (PPPoETag *) (&packet.payload); in sendPADI()
256 CHECK_ROOM(cursor, packet.payload, plen); in sendPADI()
259 memset(packet.ethHdr.h_dest, 0xFF, ETH_ALEN); in sendPADI()
260 memcpy(packet.ethHdr.h_source, conn->myEth, ETH_ALEN); in sendPADI()
262 packet.ethHdr.h_proto = htons(Eth_PPPOE_Discovery); in sendPADI()
[all …]
|
| D | debug.c | 86 dumpPacket(FILE *fp, PPPoEPacket *packet, char const *dir) in dumpPacket() argument
88 int len = ntohs(packet->length); in dumpPacket()
97 UINT16_t type = etherType(packet); in dumpPacket()
113 switch(packet->code) { in dumpPacket()
123 (int) ntohs(packet->session), in dumpPacket()
130 (unsigned) packet->ethHdr.h_source[0], in dumpPacket()
131 (unsigned) packet->ethHdr.h_source[1], in dumpPacket()
132 (unsigned) packet->ethHdr.h_source[2], in dumpPacket()
133 (unsigned) packet->ethHdr.h_source[3], in dumpPacket()
134 (unsigned) packet->ethHdr.h_source[4], in dumpPacket()
[all …]
|
| /external/webkit/PerformanceTests/SunSpider/tests/v8-v5/ |
| D | v8-richards.js | 236 Scheduler.prototype.queue = function (packet) { argument
237 var t = this.blocks[packet.id];
240 packet.link = null;
241 packet.id = this.currentId;
242 return t.checkPriorityAdd(this.currentTcb, packet);
320 var packet;
322 packet = this.queue;
323 this.queue = packet.link;
330 packet = null;
332 return this.task.run(packet);
[all …]
|
| /external/webkit/PerformanceTests/SunSpider/tests/v8-v4/ |
| D | v8-richards.js | 236 Scheduler.prototype.queue = function (packet) { argument
237 var t = this.blocks[packet.id];
240 packet.link = null;
241 packet.id = this.currentId;
242 return t.checkPriorityAdd(this.currentTcb, packet);
320 var packet;
322 packet = this.queue;
323 this.queue = packet.link;
330 packet = null;
332 return this.task.run(packet);
[all …]
|
| /external/webkit/PerformanceTests/SunSpider/tests/v8-v6/ |
| D | v8-richards.js | 236 Scheduler.prototype.queue = function (packet) { argument
237 var t = this.blocks[packet.id];
240 packet.link = null;
241 packet.id = this.currentId;
242 return t.checkPriorityAdd(this.currentTcb, packet);
320 var packet;
322 packet = this.queue;
323 this.queue = packet.link;
330 packet = null;
332 return this.task.run(packet);
[all …]
|
| /external/v8/benchmarks/ |
| D | richards.js | 241 Scheduler.prototype.queue = function (packet) { argument
242 var t = this.blocks[packet.id];
245 packet.link = null;
246 packet.id = this.currentId;
247 return t.checkPriorityAdd(this.currentTcb, packet);
325 var packet;
327 packet = this.queue;
328 this.queue = packet.link;
335 packet = null;
337 return this.task.run(packet);
[all …]
|
| /external/speex/libspeex/ |
| D | jitter.c | 368 EXPORT void jitter_buffer_put(JitterBuffer *jitter, const JitterBufferPacket *packet) in jitter_buffer_put() argument
394 if (!jitter->reset_state && LT32(packet->timestamp, jitter->next_stop)) in jitter_buffer_put()
396 …update_timings(jitter, ((spx_int32_t)packet->timestamp) - ((spx_int32_t)jitter->next_stop) - jitte… in jitter_buffer_put()
410 …if (jitter->reset_state || GE32(packet->timestamp+packet->span+jitter->delay_step, jitter->pointer… in jitter_buffer_put()
444 jitter->packets[i].data = packet->data; in jitter_buffer_put()
446 jitter->packets[i].data=(char*)speex_alloc(packet->len); in jitter_buffer_put()
447 for (j=0;j<packet->len;j++) in jitter_buffer_put()
448 jitter->packets[i].data[j]=packet->data[j]; in jitter_buffer_put()
450 jitter->packets[i].timestamp=packet->timestamp; in jitter_buffer_put()
451 jitter->packets[i].span=packet->span; in jitter_buffer_put()
[all …]
|
| /external/llvm/test/CodeGen/Generic/ |
| D | 2003-05-30-BadPreselectPhi.ll | 5 ;; Function: struct task *handlerfn(struct packet *pkt)
12 %struct..packet = type { %struct..packet*, i32, i32, i32, [4 x i8] }
13 …uct..task = type { %struct..task*, i32, i32, %struct..packet*, i32, %struct..task* (%struct..packe…
17 define %struct..task* @handlerfn(%struct..packet* %pkt.2) {
19 %tmp.1 = icmp ne %struct..packet* %pkt.2, null ; <i1> [#uses=1]
27 … %tmp.12 = bitcast i32* %mem_tmp.0 to %struct..packet* ; <%struct..packet*> [#uses=1]
28 call void @append( %struct..packet* %pkt.2, %struct..packet* %tmp.12 )
32 declare void @append(%struct..packet*, %struct..packet*)
|
| /external/dnsmasq/contrib/wrt/ |
| D | dhcp_lease_time.c | 137 struct dhcp_packet packet; in main() local
138 unsigned char *p = packet.options; in main()
157 memset(&packet, 0, sizeof(packet)); in main()
159 packet.hlen = 0; in main()
160 packet.htype = 0; in main()
162 packet.op = BOOTREQUEST; in main()
163 packet.ciaddr = lease; in main()
164 packet.cookie = htonl(DHCP_COOKIE); in main()
176 if (sendto(fd, &packet, sizeof(packet), 0, in main()
185 rc = recv(fd, &packet, sizeof(packet), 0); in main()
[all …]
|
| /external/chromium/third_party/libjingle/source/talk/session/phone/ |
| D | rtpdump.cc | 93 talk_base::StreamResult RtpDumpReader::ReadPacket(RtpDumpPacket* packet) { in ReadPacket() argument
94 if (!packet) return talk_base::SR_ERROR; in ReadPacket()
117 packet->is_rtcp = (0 == data_len); in ReadPacket()
118 buf.ReadUInt32(&packet->elapsed_time); in ReadPacket()
119 packet->data.resize(dump_packet_len - sizeof(header)); in ReadPacket()
122 return stream_->ReadAll(&packet->data[0], packet->data.size(), NULL, NULL); in ReadPacket()
186 talk_base::StreamResult RtpDumpLoopReader::ReadPacket(RtpDumpPacket* packet) { in ReadPacket() argument
187 if (!packet) return talk_base::SR_ERROR; in ReadPacket()
189 talk_base::StreamResult res = RtpDumpReader::ReadPacket(packet); in ReadPacket()
193 UpdateStreamStatistics(*packet); in ReadPacket()
[all …]
|
| D | channel.cc | 43 talk_base::Buffer packet; member
68 static bool ValidPacket(bool rtcp, const talk_base::Buffer* packet) { in ValidPacket() argument
70 return (packet && in ValidPacket()
71 packet->length() >= (!rtcp ? kMinRtpPacketLen : kMinRtcpPacketLen) && in ValidPacket()
72 packet->length() <= kMaxRtpPacketLen); in ValidPacket()
75 static uint16 GetRtpSeqNum(const talk_base::Buffer* packet) { in GetRtpSeqNum() argument
76 return (packet->length() >= kMinRtpPacketLen) ? in GetRtpSeqNum()
77 talk_base::GetBE16(packet->data() + 2) : 0; in GetRtpSeqNum()
80 static uint32 GetRtpSsrc(const talk_base::Buffer* packet) { in GetRtpSsrc() argument
81 return (packet->length() >= kMinRtpPacketLen) ? in GetRtpSsrc()
[all …]
|
| D | filemediaengine.cc | 87 void OnPacketReceived(talk_base::Buffer* packet);
95 bool ReadNextPacket(RtpDumpPacket* packet);
152 void RtpSenderReceiver::OnPacketReceived(talk_base::Buffer* packet) { in OnPacketReceived() argument
154 rtp_dump_writer_->WriteRtpPacket(packet->data(), packet->length()); in OnPacketReceived()
180 bool RtpSenderReceiver::ReadNextPacket(RtpDumpPacket* packet) { in ReadNextPacket() argument
181 while (talk_base::SR_SUCCESS == rtp_dump_reader_->ReadPacket(packet)) { in ReadNextPacket()
183 if (!packet->GetRtpSsrc(&ssrc)) { in ReadNextPacket()
202 talk_base::Buffer packet(data, len, kMaxRtpPacketLen); in SendRtpPacket() local
203 return media_channel_->network_interface()->SendPacket(&packet); in SendRtpPacket()
225 void FileVoiceChannel::OnPacketReceived(talk_base::Buffer* packet) { in OnPacketReceived() argument
[all …]
|
| /external/flac/libFLAC/ |
| D | ogg_encoder_aspect.c | 124 ogg_packet packet; in FLAC__ogg_encoder_aspect_write_callback_wrapper() local
136 memset(&packet, 0, sizeof(packet)); in FLAC__ogg_encoder_aspect_write_callback_wrapper()
137 packet.granulepos = aspect->samples_written + samples; in FLAC__ogg_encoder_aspect_write_callback_wrapper()
172 packet.packet = (unsigned char *)synthetic_first_packet_body; in FLAC__ogg_encoder_aspect_write_callback_wrapper()
173 packet.bytes = sizeof(synthetic_first_packet_body); in FLAC__ogg_encoder_aspect_write_callback_wrapper()
175 packet.b_o_s = 1; in FLAC__ogg_encoder_aspect_write_callback_wrapper()
179 packet.packet = (unsigned char *)buffer; in FLAC__ogg_encoder_aspect_write_callback_wrapper()
180 packet.bytes = bytes; in FLAC__ogg_encoder_aspect_write_callback_wrapper()
188 packet.e_o_s = 1; in FLAC__ogg_encoder_aspect_write_callback_wrapper()
191 if(ogg_stream_packetin(&aspect->stream_state, &packet) != 0) in FLAC__ogg_encoder_aspect_write_callback_wrapper()
|
| /external/srtp/srtp/ |
| D | ekt.c | 207 uint8_t *packet; in ekt_write_data() local
217 packet = (uint8_t*)base_tag + base_tag_len; in ekt_write_data()
221 memcpy(packet, ekt->encrypted_master_key, emk_len); in ekt_write_data()
223 octet_string_hex_string(packet, emk_len)); in ekt_write_data()
224 packet += emk_len; in ekt_write_data()
228 *((uint32_t *)packet) = be32_to_cpu(roc); in ekt_write_data()
230 octet_string_hex_string(packet, sizeof(roc))); in ekt_write_data()
231 packet += sizeof(roc); in ekt_write_data()
235 *((uint16_t *)packet) = htons(isn); in ekt_write_data()
237 octet_string_hex_string(packet, sizeof(isn))); in ekt_write_data()
[all …]
|
| /external/dnsmasq/src/ |
| D | tftp.c | 23 static ssize_t tftp_err(int err, char *packet, char *mess, char *file);
24 static ssize_t tftp_err_oops(char *packet, char *file);
25 static ssize_t get_block(char *packet, struct tftp_transfer *transfer);
44 char *packet = daemon->packet; in tftp_request() local
77 iov.iov_base = packet; in tftp_request()
187 p = packet + 2; in tftp_request()
188 end = packet + len; in tftp_request()
190 if (ntohs(*((unsigned short *)packet)) != OP_RRQ || in tftp_request()
194 len = tftp_err(ERR_ILL, packet, _("unsupported request from %s"), inet_ntoa(peer.sin_addr)); in tftp_request()
268 if ((len = get_block(packet, transfer)) == -1) in tftp_request()
[all …]
|
| /external/quake/quake/src/QW/client/ |
| D | notes.txt | 8 packet sender
15 lock packet
18 unlock packet
20 packet receiver
21 wake up only on packet arrival
22 identify the packet source
24 save the packet off
32 // cause packet received messages to be issued
|
| /external/qemu/distrib/sdl-1.2.12/src/video/ps2gs/ |
| D | SDL_gsyuv.c | 86 struct ps2_packet *packet; in GS_CreateYUVOverlay() local
203 hwdata->plist.packet = (struct ps2_packet *)SDL_malloc( in GS_CreateYUVOverlay()
205 if ( ! hwdata->plist.packet ) { in GS_CreateYUVOverlay()
211 packet = hwdata->plist.packet; in GS_CreateYUVOverlay()
224 packet[pnum].ptr = &tags[0]; in GS_CreateYUVOverlay()
225 packet[pnum].len = 10 * sizeof(*tags); in GS_CreateYUVOverlay()
242 packet[pnum].ptr = &tags[10]; in GS_CreateYUVOverlay()
243 packet[pnum].len = 2 * sizeof(*tags); in GS_CreateYUVOverlay()
247 packet[pnum].ptr = (void *)base; in GS_CreateYUVOverlay()
248 packet[pnum].len = 16 * 16 * bpp; in GS_CreateYUVOverlay()
[all …]
|
| /external/jmonkeyengine/engine/src/networking/com/jme3/network/kernel/udp/ |
| D | UdpKernel.java | 185 protected void newData( DatagramPacket packet ) in newData() argument
192 Endpoint p = getEndpoint( packet.getSocketAddress(), true ); in newData()
195 byte[] data = new byte[packet.getLength()]; in newData()
196 System.arraycopy(packet.getData(), 0, data, 0, data.length); in newData()
202 protected void enqueueWrite( Endpoint endpoint, DatagramPacket packet ) in enqueueWrite() argument
204 writer.execute( new MessageWriter(endpoint, packet) ); in enqueueWrite()
210 private DatagramPacket packet; field in UdpKernel.MessageWriter
212 public MessageWriter( Endpoint endpoint, DatagramPacket packet ) in MessageWriter() argument
215 this.packet = packet; in MessageWriter()
227 thread.getSocket().send(packet); in run()
[all …]
|
| /external/dhcpcd/ |
| D | bpf.c | 166 struct bpf_hdr packet; in get_raw_packet() local
180 else if ((size_t)bytes < sizeof(packet)) in get_raw_packet()
186 memcpy(&packet, iface->buffer + iface->buffer_pos, in get_raw_packet()
187 sizeof(packet)); in get_raw_packet()
188 if (packet.bh_caplen != packet.bh_datalen) in get_raw_packet()
190 if (iface->buffer_pos + packet.bh_caplen + packet.bh_hdrlen > in get_raw_packet()
193 payload = iface->buffer + packet.bh_hdrlen + ETHER_HDR_LEN; in get_raw_packet()
194 bytes = packet.bh_caplen - ETHER_HDR_LEN; in get_raw_packet()
199 iface->buffer_pos += BPF_WORDALIGN(packet.bh_hdrlen + in get_raw_packet()
200 packet.bh_caplen); in get_raw_packet()
|
| D | net.c | 671 make_udp_packet(uint8_t **packet, const uint8_t *data, size_t length, in make_udp_packet() argument
713 *packet = (uint8_t *)udpp; in make_udp_packet()
720 struct udp_dhcp_packet packet; in get_udp_data() local
722 memcpy(&packet, udp, sizeof(packet)); in get_udp_data()
724 return ntohs(packet.ip.ip_len) - in get_udp_data()
725 sizeof(packet.ip) - in get_udp_data()
726 sizeof(packet.udp); in get_udp_data()
732 struct udp_dhcp_packet packet; in valid_udp_packet() local
735 if (data_len < sizeof(packet.ip)) { in valid_udp_packet()
741 memcpy(&packet, data, MIN(data_len, sizeof(packet))); in valid_udp_packet()
[all …]
|
| /external/qemu/android/ |
| D | sdk-controller-socket.c | 130 SDKCtlPacketHeader packet; member
191 SDKCtlPacketHeader packet; member
239 SDKCtlPacket* packet; member
525 SDKCtlPacket* const packet = _sdkctl_socket_alloc_recycler(sdkctl, total_size); in _sdkctl_packet_new() local
527 packet->sdkctl = sdkctl; in _sdkctl_packet_new()
528 packet->ref_count = 1; in _sdkctl_packet_new()
529 packet->header.size = size; in _sdkctl_packet_new()
530 packet->header.type = type; in _sdkctl_packet_new()
535 return packet; in _sdkctl_packet_new()
540 _sdkctl_packet_free(SDKCtlPacket* packet) in _sdkctl_packet_free() argument
[all …]
|
| /external/jmdns/src/javax/jmdns/impl/ |
| D | SocketListener.java | 38 DatagramPacket packet = new DatagramPacket(buf, buf.length); in run() local
40 packet.setLength(buf.length); in run()
41 this._jmDNSImpl.getSocket().receive(packet); in run()
46 if (this._jmDNSImpl.getLocalHost().shouldIgnorePacket(packet)) { in run()
50 DNSIncoming msg = new DNSIncoming(packet); in run()
55 if (packet.getPort() != DNSConstants.MDNS_PORT) { in run()
56 this._jmDNSImpl.handleQuery(msg, packet.getAddress(), packet.getPort()); in run()
|
| /external/nist-sip/java/gov/nist/javax/sip/stack/ |
| D | UDPMessageChannel.java | 200 UDPMessageProcessor messageProcessor, DatagramPacket packet) { in UDPMessageChannel() argument
202 this.incomingPacket = packet; in UDPMessageChannel()
255 DatagramPacket packet; in run() local
286 packet = (DatagramPacket) ((UDPMessageProcessor) messageProcessor).messageQueue in run()
290 this.incomingPacket = packet; in run()
292 packet = this.incomingPacket; in run()
297 processIncomingDataPacket(packet); in run()
316 private void processIncomingDataPacket(DatagramPacket packet) in processIncomingDataPacket() argument
318 this.peerAddress = packet.getAddress(); in processIncomingDataPacket()
319 int packetLength = packet.getLength(); in processIncomingDataPacket()
[all …]
|