| /art/test/482-checker-loop-back-edge-use/src/ |
| Main.java | 29 public static void loop1(boolean incoming) {
30 while (incoming) {}
44 public static void loop2(boolean incoming) {
50 while (incoming) {}
63 public static void loop3(boolean incoming) {
64 // 'incoming' only needs a use at the outer loop's back edge.
67 System.out.println(incoming);
76 public static void loop4(boolean incoming) {
77 // 'incoming' has no loop use, so should not have back edge uses.
78 System.out.println(incoming);
[all...] |
| /external/mtpd/ |
| pptp.c | 137 } incoming, outgoing; variable in typeref:struct:packet
159 /* We are going to read a new message if incoming.expect is 0. */
160 if (!incoming.expect) {
161 incoming.length = 0;
162 incoming.expect = HEADER_SIZE;
168 length = incoming.expect - incoming.length;
169 if (incoming.length >= MAX_PACKET_LENGTH) {
173 if (incoming.expect > MAX_PACKET_LENGTH) {
174 length = MAX_PACKET_LENGTH - incoming.length
[all...] |
| l2tp.c | 125 } incoming, outgoing; variable in typeref:struct:packet
191 uint16_t *p = (uint16_t *)incoming.buffer;
193 incoming.length = recv(the_socket, incoming.buffer, MAX_PACKET_LENGTH, 0);
194 if (incoming.length == -1) {
203 if ((incoming.length != ACK_SIZE && incoming.length < MESSAGE_HEADER_SIZE)
205 ntohs(p[1]) != incoming.length || p[2] != local_tunnel) {
209 if (incoming.length == ACK_SIZE) {
210 incoming.message = ACK
[all...] |
| /external/webrtc/webrtc/call/ |
| rtc_event_log.h | 64 // Logs the header of an incoming or outgoing RTP packet. packet_length
66 virtual void LogRtpHeader(bool incoming,
71 // Logs an incoming or outgoing RTCP packet.
72 virtual void LogRtcpPacket(bool incoming,
|
| rtc_event_log.cc | 50 void LogRtpHeader(bool incoming,
54 void LogRtcpPacket(bool incoming,
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);
|
| /external/grpc-grpc/test/core/bad_client/ |
| bad_client.h | 38 grpc_slice_buffer* incoming, void* arg);
79 bool client_connection_preface_validator(grpc_slice_buffer* incoming,
85 bool rst_stream_client_validator(grpc_slice_buffer* incoming, void* arg);
|
| bad_client.cc | 136 grpc_slice_buffer incoming; local
137 grpc_slice_buffer_init(&incoming);
146 grpc_endpoint_read(sfd->client, &incoming, &read_done_closure);
150 /* Perform a cq next just to provide a thread that can read incoming
157 if (arg->client_validator(&incoming, arg->client_validator_arg)) break;
162 grpc_slice_buffer_destroy_internal(&incoming);
253 bool client_connection_preface_validator(grpc_slice_buffer* incoming,
255 if (incoming->count < 1) {
258 grpc_slice slice = incoming->slices[0];
280 bool rst_stream_client_validator(grpc_slice_buffer* incoming, void* arg)
[all...] |
| /cts/tools/dasm/src/java_cup/ |
| lalr_item.java | 110 /** Propagate incoming lookaheads through this item to others need to
112 * @params incoming symbols to potentially be added to lookahead of this item.
114 public void propagate_lookaheads(terminal_set incoming) throws internal_error
119 if (!needs_propagation && (incoming == null || incoming.empty()))
122 /* if we have null incoming, treat as an empty set */
123 if (incoming != null)
125 /* add the incoming to the lookahead of this item */
126 change = lookahead().add(incoming);
|
| /external/curl/docs/cmdline-opts/ |
| trace.d | 6 Enables a full trace dump of all incoming and outgoing data, including
|
| trace-ascii.d | 6 Enables a full trace dump of all incoming and outgoing data, including
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| frame_data.cc | 131 s->stats.incoming.framing_bytes++;
163 s->stats.incoming.framing_bytes++;
172 s->stats.incoming.framing_bytes++;
181 s->stats.incoming.framing_bytes++;
190 s->stats.incoming.framing_bytes++;
226 s->stats.incoming.data_bytes += remaining;
245 s->stats.incoming.data_bytes += remaining;
258 s->stats.incoming.data_bytes += p->frame_size;
|
| /external/grpc-grpc/test/core/security/ |
| secure_endpoint_test.cc | 175 grpc_slice_buffer incoming; local
183 grpc_slice_buffer_init(&incoming);
185 grpc_endpoint_read(f.client_ep, &incoming, &done_closure);
189 GPR_ASSERT(incoming.count == 1);
190 GPR_ASSERT(grpc_slice_eq(s, incoming.slices[0]));
200 grpc_slice_buffer_destroy_internal(&incoming);
|
| /external/grpc-grpc/src/core/lib/http/ |
| httpcli.cc | 55 grpc_slice_buffer incoming; member in struct:__anon23101
102 grpc_slice_buffer_destroy_internal(&req->incoming);
124 grpc_endpoint_read(req->ep, &req->incoming, &req->on_read);
131 for (i = 0; i < req->incoming.count; i++) {
132 if (GRPC_SLICE_LENGTH(req->incoming.slices[i])) {
135 &req->parser, req->incoming.slices[i], nullptr);
249 grpc_slice_buffer_init(&req->incoming);
|
| /external/grpc-grpc/test/core/iomgr/ |
| endpoint_tests.cc | 113 grpc_slice_buffer incoming; member in struct:read_and_write_test_state
124 state->incoming.slices, state->incoming.count, &state->current_read_data);
132 grpc_endpoint_read(state->read_ep, &state->incoming, &state->done_read);
209 grpc_slice_buffer_init(&state.incoming);
219 grpc_endpoint_read(state.read_ep, &state.incoming, &state.done_read);
243 grpc_slice_buffer_destroy_internal(&state.incoming);
|
| tcp_posix_test.cc | 154 grpc_slice_buffer incoming; member in struct:read_socket_state
184 read_bytes = count_slices(state->incoming.slices, state->incoming.count,
194 grpc_endpoint_read(state->ep, &state->incoming, &state->read_cb);
229 grpc_slice_buffer_init(&state.incoming);
232 grpc_endpoint_read(ep, &state.incoming, &state.read_cb);
246 grpc_slice_buffer_destroy_internal(&state.incoming);
280 grpc_slice_buffer_init(&state.incoming);
283 grpc_endpoint_read(ep, &state.incoming, &state.read_cb);
297 grpc_slice_buffer_destroy_internal(&state.incoming);
[all...] |
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/ |
| asynchat.py | 74 self.incoming = []
85 self.incoming.append(data)
88 d = ''.join(self.incoming)
89 del self.incoming[:]
251 del self.incoming[:]
|
| /external/python/cpython2/Lib/ |
| asynchat.py | 79 self.incoming = []
90 self.incoming.append(data)
93 d = ''.join(self.incoming)
94 del self.incoming[:]
258 del self.incoming[:]
|
| /external/python/cpython3/Lib/ |
| asynchat.py | 74 self.incoming = []
85 self.incoming.append(data)
88 d = b''.join(self.incoming)
89 del self.incoming[:]
267 del self.incoming[:]
|
| /art/compiler/optimizing/ |
| licm.cc | 73 HInstruction* incoming = input->InputAt(0); local
74 environment->SetRawEnvAt(i, incoming);
75 incoming->AddEnvUseAt(environment, i);
|
| /developers/samples/android/notification/Bubbles/app/src/main/java/com/example/android/bubbles/ui/chat/ |
| MessageAdapter.kt | 39 val incoming: ColorStateList = ColorStateList.valueOf(ContextCompat.getColor(context, R.color.incoming))
83 ViewCompat.setBackgroundTintList(this, tint.incoming)
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Interceptors/ |
| ServerServiceDefinitionExtensions.cs | 32 /// intercepts incoming calls to the underlying service handler through the given interceptor.
35 /// <param name="interceptor">The interceptor to intercept the incoming invocations with.</param>
52 /// intercepts incoming calls to the underlying service handler through the given interceptors.
56 /// An array of interceptors to intercept the incoming invocations with.
|
| /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...] |
| /external/swiftshader/third_party/LLVM/lib/Analysis/ |
| ProfileEstimatorPass.cpp | 113 // weight of the incoming edges must be equal the block weight which must in
128 // To get the block weight, read all incoming edges.
178 // There is at least one incoming backedge that will bring us this flow later
181 double incoming = BBWeight; local
193 incoming -= MinimalWeight[*ei];
197 incoming -= w;
218 double fraction = floor(incoming/Edges.size());
224 incoming -= fraction;
226 w = incoming;
|
| /external/libese/apps/boot/tests/ |
| ese_app_boot_tests.cpp | 58 std::vector<uint8_t> incoming(tx_total);
59 ese_sg_to_buf(tx_sg, tx_nsg, 0, tx_total, incoming.data());
60 EXPECT_EQ(0, memcmp(incoming.data(), invocation.expected_tx.data(), tx_total));
|
| /external/llvm/lib/Transforms/Scalar/ |
| LoopDeletion.cpp | 50 Value *incoming = P->getIncomingValueForBlock(exitingBlocks[0]); local
52 // Make sure all exiting blocks produce the same incoming value for the exit
53 // block. If there are different incoming values for different exiting
58 return incoming == P->getIncomingValueForBlock(BB);
64 if (Instruction *I = dyn_cast<Instruction>(incoming))
|
