| /third_party/boost/boost/graph/distributed/detail/ |
| D | mpi_process_group.ipp | 49 * Stores the incoming messages from a particular processor.
89 /// Incoming message information, indexed by source 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)
[all …]
|
| /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/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()
64 * Whenever an edge e = (v, w) is relaxed, the incoming edge list
71 incoming[w].clear(); in edge_relaxed()
72 incoming[w].push_back(e); in edge_relaxed()
79 * the incoming edges of w and add all of the shortest paths to v to
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 ()()
[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/libwebsockets/include/libwebsockets/ |
| D | lws-sha1-base64.h | 37 * \param d: incoming buffer
38 * \param n: length of incoming buffer
49 * \param in: incoming buffer
50 * \param in_len: length of incoming buffer
61 * \param in: incoming buffer
62 * \param in_len: length of incoming buffer
73 * \param in: incoming buffer
84 * \param in: incoming buffer
85 * \param in_len: length of incoming buffer
|
| /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()
178 // we had 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()
187 // There was no left value, so copy our incoming value. in tree_reduce_impl()
193 // value we had incoming. in tree_reduce_impl()
196 T incoming; in tree_reduce_impl() local
[all …]
|
| /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()
336 // Incoming edge count map is an implementation detail and should in run()
433 IncomingType in = get(incoming, u); in run()
446 // Set incoming edge counts in run()
564 // Update tentative distance information and incoming, path_count in relax()
565 if (u != v) put(incoming, v, IncomingType(1, u)); in relax()
570 // Add incoming edge if it's not already in the list in relax()
[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-close-accept.c | 63 * Time to finish the test: close both the check and pending incoming in connect_cb()
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()
160 * receive stale event of second incoming and invoke `connect_cb` with zero in TEST_IMPL()
|
| /third_party/node/deps/npm/node_modules/socks/docs/examples/typescript/ |
| D | bindExample.md | 5 … on a new TCP port for an incoming connection. It communicates the newly opened port back to the o…
7 This can be used for things such as FTP clients which require incoming TCP connections, etc.
46 // This event is fired when the SOCKS server has started listening on a new port for incoming conne…
52 … { // This is the remote ip and port of the SOCKS proxy that is now accepting incoming connections.
60 // This event is fired when the SOCKS server has accepted an incoming connection on the newly bound…
|
| /third_party/node/deps/npm/node_modules/socks/docs/examples/javascript/ |
| D | bindExample.md | 5 … on a new TCP port for an incoming connection. It communicates the newly opened port back to the o…
7 This can be used for things such as FTP clients which require incoming TCP connections, etc.
46 // This event is fired when the SOCKS server has started listening on a new port for incoming conne…
52 … { // This is the remote ip and port of the SOCKS proxy that is now accepting incoming connections.
60 // This event is fired when the SOCKS server has accepted an incoming connection on the newly bound…
|
| /third_party/openssl/doc/man3/ |
| D | BIO_s_accept.pod | 50 waits for an incoming connection.
60 incoming connection.
89 will be duplicated and prepended to the chain when an incoming
107 and subsequent calls to BIO_do_accept() will await an incoming
113 incoming connection before processing I/O calls. When an accept
120 an initial accept socket will await an incoming connection then
129 incoming connections. This can be done by waiting for a connection and
136 again which can be used to await further incoming connections.
142 however because the accept BIO will still accept additional incoming
147 called to await an incoming connection it is possible for
[all …]
|
| /third_party/glib/gio/ |
| D | gsocketservice.c | 32 * connection is made to the service the #GSocketService::incoming
41 * g_socket_service_new() and to connect to the #GSocketService::incoming
46 * will block additional incoming connections from being serviced.
55 * handle incoming clients.
261 * handling an incoming client request.
281 * handling an incoming client request.
325 class->incoming = g_socket_service_real_incoming; in g_socket_service_class_init()
328 * GSocketService::incoming: in g_socket_service_class_init()
334 * The ::incoming signal is emitted when a new incoming connection in g_socket_service_class_init()
347 g_signal_new (I_("incoming"), G_TYPE_FROM_CLASS (class), G_SIGNAL_RUN_LAST, in g_socket_service_class_init()
[all …]
|
| /third_party/boost/boost/geometry/algorithms/detail/ |
| D | get_left_turns.hpp | 102 // Collinear, check if one is incoming, incoming angles come first in operator ()()
103 if (p.incoming != q.incoming) in operator ()()
105 return int(p.incoming) < int(q.incoming); in operator ()()
169 if (it->incoming) in get_left_turns()
237 if (it->incoming) in block_turns()
273 // Only incoming, previous was only outgoing: block this one in block_turns()
281 // Only incoming, next also incoming, block this one in block_turns()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/wpa_supplicant/dbus/ |
| D | dbus_new_handlers.c | 47 * @message: Pointer to incoming dbus message this error refers to
63 * @message: Pointer to incoming dbus message this error refers to
78 * @message: Pointer to incoming dbus message this error refers to
93 * @message: Pointer to incoming dbus message this error refers to
116 * @message: Pointer to incoming dbus message this error refers to
341 * @message: Pointer to incoming dbus message
375 * @iter: Pointer to incoming dbus message iterator
468 * @iter: Pointer to incoming dbus message iterator
550 * @message: Pointer to incoming dbus message
665 * @message: Pointer to incoming dbus message
[all …]
|
| D | dbus_new_handlers_wps.c | 212 * @message: Pointer to incoming dbus message
328 * @message: Pointer to incoming dbus message
348 * @message: Pointer to incoming dbus message
370 * @iter: Pointer to incoming dbus message iter
406 * @iter: Pointer to incoming dbus message iter
428 * @iter: Pointer to incoming dbus message iter
463 * @iter: Pointer to incoming dbus message iter
483 * @iter: Pointer to incoming dbus message iter
519 * @iter: Pointer to incoming dbus message iter
539 * @iter: Pointer to incoming dbus message iter
[all …]
|
| /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()
151 /* Perform a cq next just to provide a thread that can read incoming 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
[all …]
|
| /third_party/boost/libs/asio/example/cpp03/http/server4/ |
| D | server.hpp | 45 /// The user-supplied handler for all incoming requests.
48 /// Acceptor used to listen for incoming connections.
54 /// Buffer for incoming data.
57 /// The incoming request.
63 /// The parser for the incoming request.
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/http/server4/ |
| D | server.hpp | 45 /// The user-supplied handler for all incoming requests.
48 /// Acceptor used to listen for incoming connections.
54 /// Buffer for incoming data.
57 /// The incoming request.
63 /// The parser for the incoming request.
|
| /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
|
| /third_party/boost/boost/polygon/detail/ |
| D | polygon_45_formation.hpp | 587 … Vertex45Count& counts, ActiveTail45** tails, Vertex45Count& incoming) { in processPoint_() argument
593 //std::cout << incoming[0] << " "; in processPoint_()
594 //std::cout << incoming[1] << " "; in processPoint_()
595 //std::cout << incoming[2] << " "; in processPoint_()
596 //std::cout << incoming[3] << "\n"; in processPoint_()
621 //find any pairs of incoming edges that need to create pair for leading solid in processPoint_()
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_()
[all …]
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/wpa_supplicant/dbus/ |
| D | dbus_new_handlers_wps.c | 212 * @message: Pointer to incoming dbus message
328 * @message: Pointer to incoming dbus message
348 * @message: Pointer to incoming dbus message
370 * @iter: Pointer to incoming dbus message iter
406 * @iter: Pointer to incoming dbus message iter
428 * @iter: Pointer to incoming dbus message iter
463 * @iter: Pointer to incoming dbus message iter
483 * @iter: Pointer to incoming dbus message iter
519 * @iter: Pointer to incoming dbus message iter
539 * @iter: Pointer to incoming dbus message iter
[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()
|