| /third_party/node/lib/ |
| D | _http_common.js | 35 const incoming = require('_http_incoming'); constant
40 } = incoming;
97 const incoming = parser.incoming = new ParserIncomingMessage(socket);
98 incoming.httpVersionMajor = versionMajor;
99 incoming.httpVersionMinor = versionMinor;
100 incoming.httpVersion = `${versionMajor}.${versionMinor}`;
101 incoming.url = url;
102 incoming.upgrade = upgrade;
106 incoming[kRequestTimeout] = incoming.socket[kRequestTimeout];
107 incoming.socket[kRequestTimeout] = undefined;
[all …]
|
| /third_party/node/test/parallel/ |
| D | test-net-onread-static-buffer.js | 38 let incoming = new Uint8Array(0);
47 const newIncoming = new Uint8Array(incoming.length + nread);
48 newIncoming.set(incoming);
49 newIncoming.set(buf.slice(0, nread), incoming.length);
50 incoming = newIncoming;
55 assert.deepStrictEqual(incoming, new Uint8Array(message));
65 const incoming = [];
80 incoming.push(Buffer.from(buf.slice(0, nread)));
85 assert.deepStrictEqual(Buffer.concat(incoming), message);
96 let incoming = new Uint8Array(0);
[all …]
|
| D | test-tls-onread-static-buffer.js | 50 let incoming = new Uint8Array(0);
60 const newIncoming = new Uint8Array(incoming.length + nread);
61 newIncoming.set(incoming);
62 newIncoming.set(buf.slice(0, nread), incoming.length);
63 incoming = newIncoming;
68 assert.deepStrictEqual(incoming, new Uint8Array(smallMessage));
78 const incoming = [];
94 incoming.push(Buffer.from(buf.slice(0, nread)));
99 assert.deepStrictEqual(Buffer.concat(incoming), smallMessage);
110 let incoming = new Uint8Array(0);
[all …]
|
| /third_party/boost/libs/graph_parallel/src/ |
| D | mpi_process_group.cpp | 88 incoming.resize(n); in impl()
106 incoming[i].next_header.front() = incoming[i].headers.end(); in impl()
270 for (std::size_t i = 0; i < impl_->incoming.size(); ++i) { in mpi_process_group()
271 if (my_block_number() >= (int)impl_->incoming[i].next_header.size()) { in mpi_process_group()
272 impl_->incoming[i].next_header in mpi_process_group()
273 .push_back(impl_->incoming[i].headers.begin()); in mpi_process_group()
275 impl_->incoming[i].next_header[my_block_number()] = in mpi_process_group()
276 impl_->incoming[i].headers.begin(); in mpi_process_group()
316 for (std::size_t i = 0; i < impl_->incoming.size(); ++i) { in make_distributed_object()
317 if (my_block_number() >= (int)impl_->incoming[i].next_header.size()) { in make_distributed_object()
[all …]
|
| /third_party/boost/boost/graph/ |
| D | betweenness_centrality.hpp | 53 WeightMap weight, IncomingMap incoming, DistanceMap distance, in brandes_dijkstra_visitor()
57 , incoming(incoming) in brandes_dijkstra_visitor()
71 incoming[w].clear(); in edge_relaxed()
72 incoming[w].push_back(e); in edge_relaxed()
96 incoming[w].push_back(e); in edge_not_relaxed()
109 IncomingMap incoming; member
133 IncomingMap incoming, DistanceMap distance, in operator ()()
140 ov, weight_map, incoming, distance, path_count); in operator ()()
173 visitor_type(IncomingMap incoming, DistanceMap distance, in visitor_type()
176 : incoming(incoming) in visitor_type()
[all …]
|
| /third_party/libuv/test/ |
| D | test-pipe-sendmsg.c | 38 static uv_pipe_t incoming[4]; variable
88 ASSERT(incoming_count < ARRAY_SIZE(incoming)); in read_cb()
89 inc = &incoming[incoming_count++]; in read_cb()
94 if (incoming_count != ARRAY_SIZE(incoming)) in read_cb()
99 for (i = 0; i < ARRAY_SIZE(incoming); i++) in read_cb()
100 uv_close((uv_handle_t*) &incoming[i], close_cb); in read_cb()
111 int send_fds[ARRAY_SIZE(incoming)]; in TEST_IMPL()
157 ASSERT(ARRAY_SIZE(incoming) == incoming_count); in TEST_IMPL()
158 ASSERT(ARRAY_SIZE(incoming) + 1 == close_called); in TEST_IMPL()
|
| D | test-tcp-alloc-cb-fail.c | 31 static uv_tcp_t incoming; variable
59 uv_close((uv_handle_t*) &incoming, close_cb); in conn_read_cb()
80 ASSERT(0 == uv_tcp_init(tcp->loop, &incoming)); in connection_cb()
81 ASSERT(0 == uv_accept(tcp, (uv_stream_t*) &incoming)); in connection_cb()
82 ASSERT(0 == uv_read_start((uv_stream_t*) &incoming, in connection_cb()
|
| D | test-tcp-close-accept.c | 119 uv_tcp_t* incoming; in connection_cb() local
128 incoming = &tcp_incoming[got_connections++]; in connection_cb()
129 ASSERT(0 == uv_tcp_init(server->loop, incoming)); in connection_cb()
130 ASSERT(0 == uv_accept(server, (uv_stream_t*) incoming)); in connection_cb()
137 incoming = &tcp_incoming[i]; in connection_cb()
138 ASSERT(0 == uv_read_start((uv_stream_t*) incoming, alloc_cb, read_cb)); in connection_cb()
|
| D | test-tcp-try-write-error.c | 31 static uv_tcp_t incoming; variable
65 ASSERT(0 == uv_tcp_init(tcp->loop, &incoming)); in connection_cb()
66 ASSERT(0 == uv_accept(tcp, (uv_stream_t*) &incoming)); in connection_cb()
69 uv_close((uv_handle_t*) &incoming, incoming_close_cb); in connection_cb()
|
| D | test-tcp-try-write.c | 33 static uv_tcp_t incoming; variable
92 ASSERT(0 == uv_tcp_init(tcp->loop, &incoming)); in connection_cb()
93 ASSERT(0 == uv_accept(tcp, (uv_stream_t*) &incoming)); in connection_cb()
96 ASSERT(0 == uv_read_start((uv_stream_t*) &incoming, alloc_cb, read_cb)); in connection_cb()
|
| /third_party/boost/boost/graph/distributed/detail/ |
| D | mpi_process_group.ipp | 49 * Stores the incoming messages from a particular processor.
90 std::vector<incoming_messages> incoming;
308 impl::incoming_messages& incoming = impl_->incoming[source];
312 incoming.next_header[my_block_number()];
313 while (header != incoming.headers.end() && header->tag != tag) ++header;
316 if (header == incoming.headers.end()) return false;
320 boost::mpi::packed_iarchive ia(impl_->comm, incoming.buffer,
329 while (incoming.next_header[my_block_number()] != incoming.headers.end()
330 && incoming.next_header[my_block_number()]->tag == -1)
331 ++incoming.next_header[my_block_number()];
[all …]
|
| /third_party/boost/boost/mpi/collectives/ |
| D | reduce.hpp | 136 T incoming; in tree_reduce_impl() local
138 ia >> incoming; in tree_reduce_impl()
139 out_values[i] = op(out_values[i], incoming); in tree_reduce_impl()
181 T incoming; in tree_reduce_impl() local
183 ia >> incoming; in tree_reduce_impl()
184 out_values[i] = op(incoming, in_values[i]); in tree_reduce_impl()
196 T incoming; in tree_reduce_impl() local
198 ia >> incoming; in tree_reduce_impl()
199 out_values[i] = op(out_values[i], incoming); in tree_reduce_impl()
254 T incoming; in tree_reduce_impl() local
[all …]
|
| /third_party/boost/boost/graph/parallel/detail/ |
| D | inplace_all_to_all.hpp | 30 std::vector<std::vector<T> >& incoming) in inplace_all_to_all()
59 incoming[source].resize(size); in inplace_all_to_all()
61 receive(pg, source, 1, &incoming[source].front(), size); in inplace_all_to_all()
62 } else if (&incoming != &outgoing) { in inplace_all_to_all()
63 incoming[source] = outgoing[source]; in inplace_all_to_all()
|
| /third_party/typescript/tests/baselines/reference/ |
| D | callHierarchyContainerName.callHierarchy.txt | 14 ├ incoming:
34 │ │ ├ incoming:
54 │ │ │ │ ├ incoming:
74 │ │ │ │ │ │ ├ incoming:
94 │ │ │ │ │ │ │ │ ├ incoming:
118 │ │ │ │ │ │ │ │ │ │ ├ incoming:
134 │ │ │ │ │ │ │ │ │ │ │ │ ╰ incoming: none
|
| D | callHierarchyContainerNameServer.callHierarchy.txt | 14 ├ incoming:
34 │ │ ├ incoming:
54 │ │ │ │ ├ incoming:
74 │ │ │ │ │ │ ├ incoming:
94 │ │ │ │ │ │ │ │ ├ incoming:
118 │ │ │ │ │ │ │ │ │ │ ├ incoming:
134 │ │ │ │ │ │ │ │ │ │ │ │ ╰ incoming: none
|
| D | callHierarchyFunctionAmbiguity.3.callHierarchy.txt | 14 ├ incoming:
33 │ │ ╰ incoming: none
53 ├ incoming:
72 │ │ ╰ incoming: none
|
| D | callHierarchyFunctionAmbiguity.2.callHierarchy.txt | 14 ├ incoming:
33 │ │ ╰ incoming: none
53 ├ incoming:
72 │ │ ╰ incoming: none
|
| D | callHierarchyFunctionAmbiguity.1.callHierarchy.txt | 14 ├ incoming:
33 │ │ ╰ incoming: none
53 ├ incoming:
72 │ │ ╰ incoming: none
|
| D | callHierarchyFunctionAmbiguity.4.callHierarchy.txt | 14 ├ incoming:
33 │ │ ╰ incoming: none
53 ├ incoming:
72 │ │ ╰ incoming: none
|
| D | callHierarchyCrossFile.callHierarchy.txt | 14 ├ incoming:
33 │ │ ╰ incoming: none
57 │ │ ╰ incoming: none
|
| /third_party/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()
158 if (arg->client_validator(&incoming, arg->client_validator_arg)) break; in grpc_run_client_side_validator()
163 grpc_slice_buffer_destroy_internal(&incoming); in grpc_run_client_side_validator()
254 bool client_connection_preface_validator(grpc_slice_buffer* incoming, in client_connection_preface_validator() argument
256 if (incoming->count < 1) { in client_connection_preface_validator()
259 grpc_slice slice = incoming->slices[0]; in client_connection_preface_validator()
281 bool rst_stream_client_validator(grpc_slice_buffer* incoming, void* /*arg*/) { in rst_stream_client_validator() argument
285 grpc_slice_buffer_trim_end(incoming, 13, &last_frame_buffer); in rst_stream_client_validator()
|
| /third_party/boost/boost/graph/distributed/ |
| D | betweenness_centrality.hpp | 181 IncomingMap incoming,
218 IncomingMap incoming; member in boost::graph::parallel::detail::betweenness_centrality_delta_stepping_impl
266 IncomingMap incoming, in betweenness_centrality_delta_stepping_impl() argument
275 incoming(incoming), in betweenness_centrality_delta_stepping_impl()
433 IncomingType in = get(incoming, u); in run()
565 if (u != v) put(incoming, v, IncomingType(1, u)); in relax()
571 IncomingType in = get(incoming, v); in relax()
574 put(incoming, v, in); in relax()
615 IncomingMap incoming, in operator ()()
642 impl(g, distance, incoming, weight, path_count, in operator ()()
[all …]
|
| /third_party/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, /*urgent=*/false); 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()
|
| /third_party/boost/boost/polygon/detail/ |
| D | polygon_45_formation.hpp | 587 … Vertex45Count& counts, ActiveTail45** tails, Vertex45Count& incoming) { in processPoint_() argument
625 if(incoming[i] == 1) { in processPoint_()
629 if(incoming[j]) { in processPoint_()
630 if(incoming[j] == -1) { in processPoint_()
642 Vertex45 vertex(point, i -1, incoming[i]); in processPoint_()
648 incoming[i] = 0; in processPoint_()
649 incoming[j] = 0; in processPoint_()
668 if(incoming[j] != 0) { in processPoint_()
669 if(incoming[j] == 1) { in processPoint_()
679 …ements.push_back(std::pair<Vertex45, ActiveTail45*>(Vertex45(point, j -1, incoming[j]), tails[i])); in processPoint_()
[all …]
|
| /third_party/grpc/src/core/ext/transport/chttp2/transport/ |
| D | frame_data.cc | 121 s->stats.incoming.framing_bytes++; in grpc_deframe_unprocessed_incoming_frames()
153 s->stats.incoming.framing_bytes++; in grpc_deframe_unprocessed_incoming_frames()
162 s->stats.incoming.framing_bytes++; in grpc_deframe_unprocessed_incoming_frames()
171 s->stats.incoming.framing_bytes++; in grpc_deframe_unprocessed_incoming_frames()
180 s->stats.incoming.framing_bytes++; in grpc_deframe_unprocessed_incoming_frames()
218 s->stats.incoming.data_bytes += remaining; in grpc_deframe_unprocessed_incoming_frames()
237 s->stats.incoming.data_bytes += remaining; in grpc_deframe_unprocessed_incoming_frames()
250 s->stats.incoming.data_bytes += p->frame_size; in grpc_deframe_unprocessed_incoming_frames()
|