| /external/mtpd/ |
| D | pptp.c | 137 } incoming, outgoing; variable
160 if (!incoming.expect) { in recv_packet()
161 incoming.length = 0; in recv_packet()
162 incoming.expect = HEADER_SIZE; in recv_packet()
168 length = incoming.expect - incoming.length; in recv_packet()
169 if (incoming.length >= MAX_PACKET_LENGTH) { in recv_packet()
173 if (incoming.expect > MAX_PACKET_LENGTH) { in recv_packet()
174 length = MAX_PACKET_LENGTH - incoming.length; in recv_packet()
176 length = recv(the_socket, &incoming.buffer[incoming.length], length, 0); in recv_packet()
190 incoming.length += length; in recv_packet()
[all …]
|
| D | l2tp.c | 125 } incoming, outgoing; variable
191 uint16_t *p = (uint16_t *)incoming.buffer; in recv_packet()
193 incoming.length = recv(the_socket, incoming.buffer, MAX_PACKET_LENGTH, 0); in recv_packet()
194 if (incoming.length == -1) { in recv_packet()
203 if ((incoming.length != ACK_SIZE && incoming.length < MESSAGE_HEADER_SIZE) in recv_packet()
205 ntohs(p[1]) != incoming.length || p[2] != local_tunnel) { in recv_packet()
209 if (incoming.length == ACK_SIZE) { in recv_packet()
210 incoming.message = ACK; in recv_packet()
212 incoming.message = ntohs(p[9]); in recv_packet()
219 if (incoming.message != ACK) { in recv_packet()
[all …]
|
| /external/grpc-grpc/test/core/bad_client/ |
| D | bad_client.cc | 136 grpc_slice_buffer incoming; in grpc_run_client_side_validator() local
137 grpc_slice_buffer_init(&incoming); in grpc_run_client_side_validator()
146 grpc_endpoint_read(sfd->client, &incoming, &read_done_closure); in grpc_run_client_side_validator()
157 if (arg->client_validator(&incoming, arg->client_validator_arg)) break; in grpc_run_client_side_validator()
162 grpc_slice_buffer_destroy_internal(&incoming); in grpc_run_client_side_validator()
253 bool client_connection_preface_validator(grpc_slice_buffer* incoming, in client_connection_preface_validator() argument
255 if (incoming->count < 1) { in client_connection_preface_validator()
258 grpc_slice slice = incoming->slices[0]; in client_connection_preface_validator()
280 bool rst_stream_client_validator(grpc_slice_buffer* incoming, void* arg) { in rst_stream_client_validator() argument
284 grpc_slice_buffer_trim_end(incoming, 13, &last_frame_buffer); in rst_stream_client_validator()
|
| D | 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);
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| D | frame_data.cc | 131 s->stats.incoming.framing_bytes++; in grpc_deframe_unprocessed_incoming_frames()
163 s->stats.incoming.framing_bytes++; in grpc_deframe_unprocessed_incoming_frames()
172 s->stats.incoming.framing_bytes++; in grpc_deframe_unprocessed_incoming_frames()
181 s->stats.incoming.framing_bytes++; in grpc_deframe_unprocessed_incoming_frames()
190 s->stats.incoming.framing_bytes++; in grpc_deframe_unprocessed_incoming_frames()
226 s->stats.incoming.data_bytes += remaining; in grpc_deframe_unprocessed_incoming_frames()
245 s->stats.incoming.data_bytes += remaining; in grpc_deframe_unprocessed_incoming_frames()
258 s->stats.incoming.data_bytes += p->frame_size; in grpc_deframe_unprocessed_incoming_frames()
|
| /external/grpc-grpc/test/core/security/ |
| D | secure_endpoint_test.cc | 175 grpc_slice_buffer incoming; in test_leftover() local
183 grpc_slice_buffer_init(&incoming); in test_leftover()
185 grpc_endpoint_read(f.client_ep, &incoming, &done_closure); in test_leftover()
189 GPR_ASSERT(incoming.count == 1); in test_leftover()
190 GPR_ASSERT(grpc_slice_eq(s, incoming.slices[0])); in test_leftover()
200 grpc_slice_buffer_destroy_internal(&incoming); in test_leftover()
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | tcp_posix_test.cc | 154 grpc_slice_buffer incoming; member
184 read_bytes = count_slices(state->incoming.slices, state->incoming.count, in read_cb()
194 grpc_endpoint_read(state->ep, &state->incoming, &state->read_cb); in read_cb()
229 grpc_slice_buffer_init(&state.incoming); in read_test()
232 grpc_endpoint_read(ep, &state.incoming, &state.read_cb); in read_test()
246 grpc_slice_buffer_destroy_internal(&state.incoming); in read_test()
280 grpc_slice_buffer_init(&state.incoming); in large_read_test()
283 grpc_endpoint_read(ep, &state.incoming, &state.read_cb); in large_read_test()
297 grpc_slice_buffer_destroy_internal(&state.incoming); in large_read_test()
519 grpc_slice_buffer_init(&state.incoming); in release_fd_test()
[all …]
|
| D | endpoint_tests.cc | 113 grpc_slice_buffer incoming; member
124 state->incoming.slices, state->incoming.count, &state->current_read_data); in read_and_write_test_read_handler()
132 grpc_endpoint_read(state->read_ep, &state->incoming, &state->done_read); in read_and_write_test_read_handler()
209 grpc_slice_buffer_init(&state.incoming); in read_and_write_test()
219 grpc_endpoint_read(state.read_ep, &state.incoming, &state.done_read); in read_and_write_test()
243 grpc_slice_buffer_destroy_internal(&state.incoming); in read_and_write_test()
|
| /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/grpc-grpc/src/core/lib/http/ |
| D | httpcli.cc | 55 grpc_slice_buffer incoming; member
102 grpc_slice_buffer_destroy_internal(&req->incoming); in finish()
124 grpc_endpoint_read(req->ep, &req->incoming, &req->on_read); in do_read()
131 for (i = 0; i < req->incoming.count; i++) { in on_read()
132 if (GRPC_SLICE_LENGTH(req->incoming.slices[i])) { in on_read()
135 &req->parser, req->incoming.slices[i], nullptr); in on_read()
249 grpc_slice_buffer_init(&req->incoming); in internal_request_begin()
|
| /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/swiftshader/third_party/llvm-7.0/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/python/cpython3/Lib/ |
| D | asynchat.py | 74 self.incoming = []
85 self.incoming.append(data)
88 d = b''.join(self.incoming)
89 del self.incoming[:]
267 del self.incoming[:]
|
| /external/python/cpython2/Lib/ |
| D | asynchat.py | 79 self.incoming = []
90 self.incoming.append(data)
93 d = ''.join(self.incoming)
94 del self.incoming[:]
258 del self.incoming[:]
|
| /external/swiftshader/third_party/LLVM/lib/Analysis/ |
| D | ProfileEstimatorPass.cpp | 181 double incoming = BBWeight; in recurseBasicBlock() local
193 incoming -= MinimalWeight[*ei]; in recurseBasicBlock()
197 incoming -= w; in recurseBasicBlock()
218 double fraction = floor(incoming/Edges.size()); in recurseBasicBlock()
224 incoming -= fraction; in recurseBasicBlock()
226 w = incoming; in recurseBasicBlock()
|
| /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,
|
| /external/swiftshader/third_party/llvm-7.0/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/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/iptables/extensions/ |
| D | libxt_devgroup.man | 1 Match device group of a packets incoming/outgoing interface.
4 Match device group of incoming device
|
| /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/swiftshader/third_party/llvm-7.0/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/swiftshader/third_party/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/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/libese/apps/boot/tests/ |
| D | ese_app_boot_tests.cpp | 58 std::vector<uint8_t> incoming(tx_total); in EseTransceive() local
59 ese_sg_to_buf(tx_sg, tx_nsg, 0, tx_total, incoming.data()); in EseTransceive()
60 EXPECT_EQ(0, memcmp(incoming.data(), invocation.expected_tx.data(), tx_total)); in EseTransceive()
|