| /external/jetty/src/java/org/eclipse/jetty/io/ |
| NetworkTrafficListener.java | 30 * <li>Incoming bytes, when the server receives bytes sent from a remote client</li>
53 * @param bytes the read-only buffer containing the incoming bytes
55 public void incoming(Socket socket, Buffer bytes); method in interface:NetworkTrafficListener
87 public void incoming(Socket socket, Buffer bytes) method in class:NetworkTrafficListener.Empty
|
| /art/compiler/optimizing/ |
| licm.cc | 72 HInstruction* incoming = input->InputAt(0); local
73 environment->SetRawEnvAt(i, incoming);
74 incoming->AddEnvUseAt(environment, i);
|
| instruction_builder.cc | 43 // We record incoming inputs of catch phis at throwing instructions and
101 HInstruction* incoming = local
103 if (incoming != nullptr) {
108 incoming->GetType());
[all...] |
| /external/dbus/test/ |
| loopback.c | 123 DBusMessage *outgoing, *incoming; local
143 incoming = g_queue_pop_head (&f->server_messages);
145 g_assert (!dbus_message_contains_unix_fds (incoming));
146 g_assert_cmpstr (dbus_message_get_destination (incoming), ==, NULL);
147 g_assert_cmpstr (dbus_message_get_error_name (incoming), ==, NULL);
148 g_assert_cmpstr (dbus_message_get_interface (incoming), ==,
150 g_assert_cmpstr (dbus_message_get_member (incoming), ==, "Greeting");
151 g_assert_cmpstr (dbus_message_get_sender (incoming), ==, NULL);
152 g_assert_cmpstr (dbus_message_get_signature (incoming), ==, "");
153 g_assert_cmpstr (dbus_message_get_path (incoming), ==, "/com/example/Hello")
[all...] |
| relay.c | 201 DBusMessage *incoming; local
216 incoming = g_queue_pop_head (&f->messages);
217 g_assert_cmpstr (dbus_message_get_member (incoming), ==, "First");
218 dbus_message_unref (incoming);
220 incoming = g_queue_pop_head (&f->messages);
221 g_assert_cmpstr (dbus_message_get_member (incoming), ==, "Second");
222 dbus_message_unref (incoming);
232 DBusMessage *incoming; local
259 while ((incoming = g_queue_pop_head (&f->messages)) != NULL)
262 dbus_message_unref (incoming);
[all...] |
| corrupt.c | 125 DBusMessage *outgoing, *incoming; local
145 incoming = g_queue_pop_head (&f->client_messages);
147 g_assert (!dbus_message_contains_unix_fds (incoming));
148 g_assert_cmpstr (dbus_message_get_destination (incoming), ==, NULL);
149 g_assert_cmpstr (dbus_message_get_error_name (incoming), ==, NULL);
150 g_assert_cmpstr (dbus_message_get_interface (incoming), ==,
152 g_assert_cmpstr (dbus_message_get_member (incoming), ==, "Greeting");
153 g_assert_cmpstr (dbus_message_get_sender (incoming), ==, NULL);
154 g_assert_cmpstr (dbus_message_get_signature (incoming), ==, "");
155 g_assert_cmpstr (dbus_message_get_path (incoming), ==, "/com/example/Hello")
209 DBusMessage *incoming; local
[all...] |
| /external/javassist/src/main/javassist/bytecode/stackmap/ |
| BasicBlock.java | 30 public int incoming; // the number of incoming branches. field in class:BasicBlock
38 incoming = 0;
77 .append(length).append(", in=").append(incoming)
202 m.block.incoming++;
340 bb.incoming++;
349 // the incoming flow from dead code is not counted
350 // bb.incoming++;
386 handler.incoming--;
392 handler.incoming++
[all...] |
| /external/llvm/lib/Transforms/Scalar/ |
| LoopDeletion.cpp | 95 Value *incoming = P->getIncomingValueForBlock(exitingBlocks[0]); local
97 // Make sure all exiting blocks produce the same incoming value for the exit
98 // block. If there are different incoming values for different exiting
102 if (incoming != P->getIncomingValueForBlock(exitingBlocks[i]))
106 if (Instruction *I = dyn_cast<Instruction>(incoming))
|
| /system/core/liblog/tests/ |
| libc_test.cpp | 66 int incoming = (eventData[0] & 0xFF) | local
71 if (incoming != 0) {
79 incoming = (eventData[4 + 1 + 0] & 0xFF) |
84 if (incoming == value) {
|
| /external/jetty/src/java/org/eclipse/jetty/io/nio/ |
| NetworkTrafficSelectChannelEndPoint.java | 100 listener.incoming(_socket, view);
|
| /external/mesa3d/src/mesa/drivers/dri/i965/ |
| brw_clip_util.c | 344 struct brw_reg incoming = get_element_ud(c->reg.R0, 2); local
348 brw_SHR(p, c->reg.planemask, incoming, brw_imm_ud(26));
356 brw_AND(p, tmp, incoming, brw_imm_ud(0x3f<<14));
|
| /external/llvm/examples/OCaml-Kaleidoscope/Chapter5/ |
| codegen.ml | 83 let incoming = [(then_val, new_then_bb); (else_val, new_else_bb)] in var
84 let phi = build_phi incoming "iftmp" builder in
|
| /external/llvm/examples/OCaml-Kaleidoscope/Chapter6/ |
| codegen.ml | 101 let incoming = [(then_val, new_then_bb); (else_val, new_else_bb)] in var
102 let phi = build_phi incoming "iftmp" builder in
|
| /external/llvm/examples/OCaml-Kaleidoscope/Chapter7/ |
| codegen.ml | 131 let incoming = [(then_val, new_then_bb); (else_val, new_else_bb)] in var
132 let phi = build_phi incoming "iftmp" builder in
|
| /external/webrtc/webrtc/base/ |
| httpserver.cc | 272 AsyncSocket* incoming = listener_->Accept(NULL); local
273 if (incoming) {
274 StreamInterface* stream = new SocketStream(incoming);
|
| /libcore/ojluni/src/main/java/sun/net/www/http/ |
| HttpCapture.java | 58 private boolean incoming = true; field in class:HttpCapture
123 if (incoming) {
125 incoming = false;
132 if (!incoming) {
134 incoming = true;
|
| /external/webrtc/webrtc/p2p/base/ |
| tcpport.cc | 13 * passive side just waits for an incoming connection.
120 std::list<Incoming>::iterator it;
139 // We can't accept TCP connections incoming on other ports
185 // recognize our incoming TCP connections. According to
256 Incoming incoming; local
257 incoming.addr = new_socket->GetRemoteAddress();
258 incoming.socket = new_socket;
259 incoming.socket->SignalReadPacket.connect(this, &TCPPort::OnReadPacket);
260 incoming.socket->SignalReadyToSend.connect(this, &TCPPort::OnReadyToSend)
[all...] |
| /packages/apps/Dialer/src/com/android/dialer/calllog/ |
| CallTypeIconsView.java | 113 return sResources.incoming;
158 // Drawable representing an incoming answered call.
159 public final Drawable incoming; field in class:CallTypeIconsView.Resources
164 // Drawable representing an incoming missed call.
191 incoming = r.getDrawable(R.drawable.ic_call_arrow);
192 incoming.setColorFilter(r.getColor(R.color.answered_call), PorterDuff.Mode.MULTIPLY);
|
| /external/mtpd/ |
| pptp.c | 132 } incoming, outgoing; variable in typeref:struct:packet
154 /* We are going to read a new message if incoming.expect is 0. */
155 if (!incoming.expect) {
156 incoming.length = 0;
157 incoming.expect = HEADER_SIZE;
163 length = incoming.expect - incoming.length;
164 if (incoming.length >= MAX_PACKET_LENGTH) {
168 if (incoming.expect > MAX_PACKET_LENGTH) {
169 length = MAX_PACKET_LENGTH - incoming.length
[all...] |
| l2tp.c | 120 } incoming, outgoing; variable in typeref:struct:packet
186 uint16_t *p = (uint16_t *)incoming.buffer;
188 incoming.length = recv(the_socket, incoming.buffer, MAX_PACKET_LENGTH, 0);
189 if (incoming.length == -1) {
198 if ((incoming.length != ACK_SIZE && incoming.length < MESSAGE_HEADER_SIZE)
200 ntohs(p[1]) != incoming.length || p[2] != local_tunnel) {
204 if (incoming.length == ACK_SIZE) {
205 incoming.message = ACK
[all...] |
| /ndk/build/core/ |
| definitions-graph.mk | 266 # For topological sort, we need to count the number of incoming edges
270 # Count the number of incoming edges for each node during topological
279 # zero the incoming edge counter for module $1
280 -ndk-mod-topo-zero-incoming = \
283 # increment the incoming edge counter for module $1
284 -ndk-mod-topo-increment-incoming = \
287 # decrement the incoming edge counter for module $1
288 -ndk-mod-topo-decrement-incoming = \
291 # return non-empty if the module $1's incoming edge counter is > 0
292 -ndk-mod-topo-has-incoming = $(_ndk_mod_topo_incoming.$1
[all...] |
| /external/v8/src/compiler/ |
| register-allocator-verifier.cc | 306 : incoming(nullptr),
310 MapValue* incoming; // value from first predecessor block. member in struct:v8::internal::compiler::__anon24213::OperandMap::MapValue
429 for (; v != nullptr; v = v->incoming) {
466 for (v = v->incoming; v != nullptr; v = v->incoming) {
531 // First ensure that incoming contains only keys in all predecessors.
552 // An incoming map contains no defines.
592 succ_val.second->incoming = nullptr;
607 auto incoming = outgoing_maps_[predecessor_index]; local
609 to_init->map() = incoming->map()
611 auto incoming = it.second; local
[all...] |
| /system/bt/hci/src/ |
| hci_layer.c | 549 packet_receive_data_t *incoming = &incoming_packets[PACKET_TYPE_TO_INBOUND_INDEX(type)]; local
553 switch (incoming->state) {
556 incoming->bytes_remaining = preamble_sizes[PACKET_TYPE_TO_INDEX(type)];
557 memset(incoming->preamble, 0, PREAMBLE_BUFFER_SIZE);
558 incoming->index = 0;
559 incoming->state = PREAMBLE;
562 incoming->preamble[incoming->index] = byte;
563 incoming->index++;
564 incoming->bytes_remaining--
[all...] |
| /external/libpcap/ |
| pcap-usb-linux.c | 483 int incoming=0; local
545 incoming = 1;
548 incoming = !incoming;
551 if (incoming)
|
| /packages/services/Telecomm/tests/src/com/android/server/telecom/tests/ |
| BasicCallTests.java | 121 * Tests the {@link TelecomManager#acceptRingingCall()} API. Tests simple case of an incoming
147 * Tests the {@link TelecomManager#acceptRingingCall()} API. Tests simple case of an incoming
202 * Tests the {@link TelecomManager#acceptRingingCall()} API. Tests simple case of an incoming
463 IdPair incoming = startAndMakeActiveIncomingCall("650-555-2323", local
468 mInCallServiceFixtureX.mInCallAdapter.disconnectCall(incoming.mCallId);
477 IdPair incoming = startAndMakeActiveIncomingCall("650-555-2323", local
489 mInCallServiceFixtureX.mInCallAdapter.disconnectCall(incoming.mCallId);
[all...] |
