| /external/mtpd/ |
| D | pptp.c | 132 } incoming, outgoing; variable
155 if (!incoming.expect) { in recv_packet()
156 incoming.length = 0; in recv_packet()
157 incoming.expect = HEADER_SIZE; in recv_packet()
163 length = incoming.expect - incoming.length; in recv_packet()
164 if (incoming.length >= MAX_PACKET_LENGTH) { in recv_packet()
168 if (incoming.expect > MAX_PACKET_LENGTH) { in recv_packet()
169 length = MAX_PACKET_LENGTH - incoming.length; in recv_packet()
171 length = recv(the_socket, &incoming.buffer[incoming.length], length, 0); in recv_packet()
185 incoming.length += length; in recv_packet()
[all …]
|
| D | l2tp.c | 120 } incoming, outgoing; variable
186 uint16_t *p = (uint16_t *)incoming.buffer; in recv_packet()
188 incoming.length = recv(the_socket, incoming.buffer, MAX_PACKET_LENGTH, 0); in recv_packet()
189 if (incoming.length == -1) { in recv_packet()
198 if ((incoming.length != ACK_SIZE && incoming.length < MESSAGE_HEADER_SIZE) in recv_packet()
200 ntohs(p[1]) != incoming.length || p[2] != local_tunnel) { in recv_packet()
204 if (incoming.length == ACK_SIZE) { in recv_packet()
205 incoming.message = ACK; in recv_packet()
207 incoming.message = ntohs(p[9]); in recv_packet()
214 if (incoming.message != ACK) { in recv_packet()
[all …]
|
| /external/dbus/test/ |
| D | corrupt.c | 125 DBusMessage *outgoing, *incoming; in test_message() local
145 incoming = g_queue_pop_head (&f->client_messages); in test_message()
147 g_assert (!dbus_message_contains_unix_fds (incoming)); in test_message()
148 g_assert_cmpstr (dbus_message_get_destination (incoming), ==, NULL); in test_message()
149 g_assert_cmpstr (dbus_message_get_error_name (incoming), ==, NULL); in test_message()
150 g_assert_cmpstr (dbus_message_get_interface (incoming), ==, in test_message()
152 g_assert_cmpstr (dbus_message_get_member (incoming), ==, "Greeting"); in test_message()
153 g_assert_cmpstr (dbus_message_get_sender (incoming), ==, NULL); in test_message()
154 g_assert_cmpstr (dbus_message_get_signature (incoming), ==, ""); in test_message()
155 g_assert_cmpstr (dbus_message_get_path (incoming), ==, "/com/example/Hello"); in test_message()
[all …]
|
| D | loopback.c | 123 DBusMessage *outgoing, *incoming; in test_message() local
143 incoming = g_queue_pop_head (&f->server_messages); in test_message()
145 g_assert (!dbus_message_contains_unix_fds (incoming)); in test_message()
146 g_assert_cmpstr (dbus_message_get_destination (incoming), ==, NULL); in test_message()
147 g_assert_cmpstr (dbus_message_get_error_name (incoming), ==, NULL); in test_message()
148 g_assert_cmpstr (dbus_message_get_interface (incoming), ==, in test_message()
150 g_assert_cmpstr (dbus_message_get_member (incoming), ==, "Greeting"); in test_message()
151 g_assert_cmpstr (dbus_message_get_sender (incoming), ==, NULL); in test_message()
152 g_assert_cmpstr (dbus_message_get_signature (incoming), ==, ""); in test_message()
153 g_assert_cmpstr (dbus_message_get_path (incoming), ==, "/com/example/Hello"); in test_message()
[all …]
|
| D | relay.c | 201 DBusMessage *incoming; in test_relay() local
216 incoming = g_queue_pop_head (&f->messages); in test_relay()
217 g_assert_cmpstr (dbus_message_get_member (incoming), ==, "First"); in test_relay()
218 dbus_message_unref (incoming); in test_relay()
220 incoming = g_queue_pop_head (&f->messages); in test_relay()
221 g_assert_cmpstr (dbus_message_get_member (incoming), ==, "Second"); in test_relay()
222 dbus_message_unref (incoming); in test_relay()
232 DBusMessage *incoming; in test_limit() local
259 while ((incoming = g_queue_pop_head (&f->messages)) != NULL) in test_limit()
262 dbus_message_unref (incoming); in test_limit()
|
| /external/autotest/client/cros/cellular/wardmodem/ |
| D | at_channel.py | 219 incoming = ''.join(incoming_list)
220 if not incoming:
235 incoming = re.sub(';', '\rAT', incoming)
243 incoming = re.sub('\r|\n|;', '\r\r', incoming)
246 parts = re.split('\r', incoming)
|
| /external/webrtc/webrtc/p2p/base/ |
| D | tcpport.cc | 256 Incoming incoming; in OnNewConnection() local
257 incoming.addr = new_socket->GetRemoteAddress(); in OnNewConnection()
258 incoming.socket = new_socket; in OnNewConnection()
259 incoming.socket->SignalReadPacket.connect(this, &TCPPort::OnReadPacket); in OnNewConnection()
260 incoming.socket->SignalReadyToSend.connect(this, &TCPPort::OnReadyToSend); in OnNewConnection()
261 incoming.socket->SignalSentPacket.connect(this, &TCPPort::OnSentPacket); in OnNewConnection()
264 << incoming.addr.ToSensitiveString(); in OnNewConnection()
265 incoming_.push_back(incoming); in OnNewConnection()
|
| /external/chromium-trace/catapult/telemetry/telemetry/testing/fakes/ |
| D | __init__.py | 204 def platform(self, incoming): argument
206 assert isinstance(incoming, FakePlatform)
207 self._platform = incoming
215 def returned_system_info(self, incoming): argument
219 assert isinstance(incoming, FakeSystemInfo)
220 self._returned_system_info = incoming
228 def browser_type(self, incoming): argument
230 self._browser_type = incoming
|
| /external/bison/build-aux/ |
| D | gnupload | 327 $dbg ncftpput ftp-upload.gnu.org /incoming/alpha $files $base.directive.asc
332 $dbg ncftpput ftp-upload.gnu.org /incoming/ftp $files $base.directive.asc
338 $dbg ncftpput savannah.gnu.org /incoming/savannah/$destdir $files
344 $dbg ncftpput savannah.nongnu.org /incoming/savannah/$destdir $files
354 done | $dbg sftp -b - puszcza.gnu.org.ua:/incoming/$destdir_topdir
|
| /external/chromium-trace/catapult/telemetry/third_party/altgraph/doc/ |
| D | graph.rst | 40 Hides a *node* from the graph. The incoming and outgoing edges of
49 Restores a previously hidden *node*. The incoming and outgoing
83 and incoming edges for the node.
105 Return the list of incoming edges for *node*
109 Return the list of incoming and outgoing edges for *node*
117 Return the number of incoming edges for *node*.
121 Return the number of edges (incoming or outgoing) for *node*.
204 Return a list of all nodes connected by incoming edges.
208 Returns a list of nodes connected by an incoming or outgoing edge.
217 Return a list of nodes where the successors (based on incoming
[all …]
|
| /external/llvm/test/Transforms/SimplifyCFG/ |
| D | EqualPHIEdgeBlockMerge.ll | 22 ; It's ok to merge N and M because the incoming values for W are the
29 ; Test merging of blocks with phi nodes where at least one incoming value
47 ; R's incoming value with the incoming value of that predecessor since
48 ; R's incoming value is undef and both of those predecessors are simple
54 ; Test merging of blocks with phi nodes where at least one incoming value
77 ; V's incoming value with the incoming value of that predecessor since
78 ; V's incoming value is undef and both of those predecessors are simple
107 ; and thus 5 incoming values to the phi.
|
| /external/iptables/extensions/ |
| D | libxt_devgroup.man | 1 Match device group of a packets incoming/outgoing interface.
4 Match device group of incoming device
|
| /external/jetty/src/java/org/eclipse/jetty/io/ |
| D | NetworkTrafficListener.java | 55 public void incoming(Socket socket, Buffer bytes); in incoming() method
87 public void incoming(Socket socket, Buffer bytes) in incoming() method in NetworkTrafficListener.Empty
|
| /external/llvm/test/Transforms/SLPVectorizer/X86/ |
| D | crash_vectorizeTree.ll | 7 ; We used indices to get the incoming value of two phi nodes rather than
8 ; incoming block lookup.
9 ; This can give wrong results when the ordering of incoming
|
| /external/javassist/src/main/javassist/bytecode/stackmap/ |
| D | BasicBlock.java | 30 public int incoming; // the number of incoming branches. field in BasicBlock
38 incoming = 0; in BasicBlock()
77 .append(length).append(", in=").append(incoming)
202 m.block.incoming++;
340 bb.incoming++;
386 handler.incoming--;
392 handler.incoming++;
|
| /external/webrtc/webrtc/call/ |
| D | rtc_event_log.cc | 50 void LogRtpHeader(bool incoming, in LogRtpHeader() argument
54 void LogRtcpPacket(bool incoming, in LogRtcpPacket() argument
77 void LogRtpHeader(bool incoming,
81 void LogRtcpPacket(bool incoming,
330 void RtcEventLogImpl::LogRtpHeader(bool incoming,
354 rtp_event.mutable_rtp_packet()->set_incoming(incoming);
361 void RtcEventLogImpl::LogRtcpPacket(bool incoming,
369 rtcp_event.mutable_rtcp_packet()->set_incoming(incoming);
|
| D | rtc_event_log.h | 66 virtual void LogRtpHeader(bool incoming,
72 virtual void LogRtcpPacket(bool incoming,
|
| D | rtc_event_log.proto | 75 // required - True if the packet is incoming w.r.t. the user logging the data
76 optional bool incoming = 1; field
92 // required - True if the packet is incoming w.r.t. the user logging the data
93 optional bool incoming = 1; field
174 // RTX settings for incoming video payloads that may be received.
|
| /external/llvm/test/Transforms/Mem2Reg/ |
| D | 2003-04-24-MultipleIdenticalSuccessors.ll | 1 ; Mem2reg used to only add one incoming value to a PHI node, even if it had
2 ; multiple incoming edges from a block.
|
| /external/v8/src/compiler/ |
| D | register-allocator-verifier.cc | 306 : incoming(nullptr), in MapValue()
310 MapValue* incoming; // value from first predecessor block. member
429 for (; v != nullptr; v = v->incoming) { in Use()
466 for (v = v->incoming; v != nullptr; v = v->incoming) { in UsePhi()
592 succ_val.second->incoming = nullptr; in PropagateUsesBackwards()
607 auto incoming = outgoing_maps_[predecessor_index]; in InitializeFromFirstPredecessor() local
609 to_init->map() = incoming->map(); in InitializeFromFirstPredecessor()
611 auto incoming = it.second; in InitializeFromFirstPredecessor() local
613 it.second->incoming = incoming; in InitializeFromFirstPredecessor()
|
| /external/autotest/client/common_lib/ |
| D | pexpect.py | 1363 incoming = self.buffer
1364 freshlen = len(incoming)
1366 index = searcher.search(incoming, freshlen, searchwindowsize)
1368 self.buffer = incoming[searcher.end : ]
1369 self.before = incoming[ : searcher.start]
1370 self.after = incoming[searcher.start : searcher.end]
1381 incoming = incoming + c
1386 self.before = incoming
1398 self.buffer = incoming
1399 self.before = incoming
[all …]
|
| /external/llvm/lib/Transforms/Scalar/ |
| D | LoopDeletion.cpp | 95 Value *incoming = P->getIncomingValueForBlock(exitingBlocks[0]); in isLoopDead() local
102 if (incoming != P->getIncomingValueForBlock(exitingBlocks[i])) in isLoopDead()
106 if (Instruction *I = dyn_cast<Instruction>(incoming)) in isLoopDead()
|
| /external/webrtc/webrtc/base/ |
| D | httpserver.cc | 272 AsyncSocket* incoming = listener_->Accept(NULL); in OnReadEvent() local
273 if (incoming) { in OnReadEvent()
274 StreamInterface* stream = new SocketStream(incoming); in OnReadEvent()
|
| /external/jetty/src/java/org/eclipse/jetty/websocket/ |
| D | AbstractExtension.java | 75 …public void bind(WebSocket.FrameConnection connection, FrameHandler incoming, WebSocketGenerator o… in bind() argument
78 _inbound=incoming; in bind()
|
| /external/dbus/dbus/ |
| D | dbus-auth.c | 158 DBusString incoming; /**< Incoming data buffer */ member
359 if (!_dbus_string_init (&auth->incoming)) in _dbus_auth_new()
411 _dbus_string_free (&auth->incoming); in _dbus_auth_new()
2155 if (!_dbus_string_find (&auth->incoming, 0, "\r\n", &eol)) in process_command()
2171 if (!_dbus_string_copy_len (&auth->incoming, 0, eol, &line, 0)) in process_command()
2212 _dbus_string_delete (&auth->incoming, 0, eol); in process_command()
2215 _dbus_string_delete (&auth->incoming, 0, 2); in process_command()
2374 _dbus_string_free (&auth->incoming); in _dbus_auth_unref()
2443 if (_dbus_string_get_length (&auth->incoming) > MAX_BUFFER || in _dbus_auth_do_work()
2526 *buffer = &auth->incoming; in _dbus_auth_get_buffer()
[all …]
|