Home
last modified time | relevance | path

Searched refs:outgoing (Results 1 – 25 of 202) sorted by relevance

123456789

/third_party/boost/boost/graph/parallel/detail/
Dinplace_all_to_all.hpp29 const std::vector<std::vector<T> >& outgoing, in inplace_all_to_all()
45 send(pg, dest, 0, outgoing[dest].size()); in inplace_all_to_all()
46 if (!outgoing[dest].empty()) in inplace_all_to_all()
47 send(pg, dest, 1, &outgoing[dest].front(), outgoing[dest].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/boost/boost/mpi/collectives/
Dall_to_all.hpp57 std::vector<char, allocator<char> > outgoing; in all_to_all_impl() local
62 send_disps[dest] = outgoing.size(); in all_to_all_impl()
66 packed_oarchive oa(comm, outgoing); in all_to_all_impl()
72 send_sizes[dest] = outgoing.size() - send_disps[dest]; in all_to_all_impl()
89 if (outgoing.empty()) in all_to_all_impl()
90 outgoing.push_back(0); in all_to_all_impl()
94 (detail::c_data(outgoing), detail::c_data(send_sizes), in all_to_all_impl()
/third_party/boost/libs/graph_parallel/src/
Dmpi_process_group.cpp87 outgoing.resize(n); in impl()
107 outgoing[i].buffer.reserve(batch_message_size); in impl()
481 impl::outgoing_messages& outgoing = impl_->outgoing[dest]; in maybe_send_batch() local
482 if (outgoing.buffer.size() >= impl_->batch_buffer_size || in maybe_send_batch()
483 outgoing.headers.size() >= impl_->batch_header_number) { in maybe_send_batch()
487 batch.swap(outgoing); in maybe_send_batch()
492 batch.buffer.end(),std::back_inserter(outgoing.buffer)); in maybe_send_batch()
494 outgoing.headers.push_back(batch.headers.back()); in maybe_send_batch()
496 outgoing.headers.front().offset=0; in maybe_send_batch()
506 impl::outgoing_messages& outgoing = impl_->outgoing[dest]; in send_batch() local
[all …]
/third_party/typescript/tests/baselines/reference/
DcallHierarchyFunctionAmbiguity.5.callHierarchy.txt19outgoing:
34 │ │ ╰ outgoing: none
54 │ │ ╰ outgoing: none
DcallHierarchyFunction.callHierarchy.txt47outgoing:
64 │ │ ╰ outgoing: none
90 │ │ ╰ outgoing: none
DcallHierarchyExportEqualsFunction.callHierarchy.txt25outgoing:
42 │ │ ╰ outgoing: none
DcallHierarchyDecorator.callHierarchy.txt43outgoing:
60 │ │ ╰ outgoing: none
DcallHierarchyConstNamedArrowFunction.callHierarchy.txt43outgoing:
60 │ │ ╰ outgoing: none
DcallHierarchyConstNamedClassExpression.callHierarchy.txt47outgoing:
64 │ │ ╰ outgoing: none
DcallHierarchyExportDefaultClass.callHierarchy.txt47outgoing:
64 │ │ ╰ outgoing: none
DcallHierarchyExportDefaultFunction.callHierarchy.txt43outgoing:
60 │ │ ╰ outgoing: none
DcallHierarchyConstNamedFunctionExpression.callHierarchy.txt43outgoing:
60 │ │ ╰ outgoing: none
DcallHierarchyAccessor.callHierarchy.txt44outgoing:
61 │ │ ╰ outgoing: none
DcallHierarchyJsxElement.callHierarchy.txt43outgoing:
60 │ │ ╰ outgoing: none
DcallHierarchyClass.callHierarchy.txt43outgoing:
60 │ │ ╰ outgoing: none
/third_party/gstreamer/gstplugins_bad/gst/mpegtsdemux/
DTODO6 costly. Switch to pre-/re-allocating outgoing buffers in which we
44 pay extra attention to the outgoing NEWSEGMENT event and buffer
58 the outgoing buffer timestamps need to correspond to the incoming
64 => The outgoing buffers will be timestamped with their PTS values
111 => The outgoing buffers will be timestamped with their PTS values
120 compute the outgoing values.
122 => The outgoing values for the newsegment are calculated like for
126 => The outgoing buffer timestamps are timestamped with their PTS
/third_party/mesa3d/src/gallium/drivers/nouveau/codegen/
Dnv50_ir_bb.cpp106 for (Graph::EdgeIterator it = cfg.outgoing(); !it.end(); it.next()) { in clone()
313 while (!cfg.outgoing(true).end()) { in splitCommon()
314 Graph::Edge *e = cfg.outgoing(true).getEdge(); in splitCommon()
378 for (Graph::EdgeIterator ei = cfg.outgoing(); !ei.end(); ei.next()) in initiatesSimpleConditional()
380 eR = out[1]->outgoing().getType(); in initiatesSimpleConditional()
389 if (out[1]->outgoing().getNode() == out[0]) in initiatesSimpleConditional()
392 if (out[0]->outgoing().getNode() == out[1]->outgoing().getNode()) in initiatesSimpleConditional()
524 for (Graph::EdgeIterator ei = bb->cfg.outgoing(); !ei.end(); ei.next()) { in printCFGraph()
/third_party/boost/boost/graph/distributed/detail/
Dqueue.ipp156 outgoing_buffer_t& outgoing = outgoing_buffers->at(dest);
157 std::size_t size = outgoing.size();
160 send(process_group, dest, msg_multipush, outgoing);
163 buffer.push(outgoing[i]);
165 outgoing.clear();
/third_party/iptables/extensions/
Dlibxt_devgroup.man1 Match device group of a packets incoming/outgoing interface.
7 Match device group of outgoing device
Dlibebt_pkttype.t11 --pkttype-type outgoing;=;OK
12 --pkttype-type ! outgoing;=;OK
/third_party/grpc/test/core/iomgr/
Dendpoint_tests.cc114 grpc_slice_buffer outgoing; member
152 grpc_endpoint_write(state->write_ep, &state->outgoing, &state->done_write, in write_scheduler()
171 grpc_slice_buffer_reset_and_unref(&state->outgoing); in read_and_write_test_write_handler()
172 grpc_slice_buffer_addn(&state->outgoing, slices, nslices); in read_and_write_test_write_handler()
235 grpc_slice_buffer_init(&state.outgoing); in read_and_write_test()
269 grpc_slice_buffer_destroy_internal(&state.outgoing); in read_and_write_test()
/third_party/grpc/test/core/bad_client/
Dbad_client.cc108 grpc_slice_buffer outgoing; in grpc_run_client_side_validator() local
112 grpc_slice_buffer_init(&outgoing); in grpc_run_client_side_validator()
113 grpc_slice_buffer_add(&outgoing, slice); in grpc_run_client_side_validator()
118 grpc_endpoint_write(sfd->client, &outgoing, &done_write_closure, nullptr); in grpc_run_client_side_validator()
182 grpc_slice_buffer_destroy_internal(&outgoing); in grpc_run_client_side_validator()
/third_party/skia/third_party/externals/angle2/src/libANGLE/renderer/
Drenderer_utils.cpp236 gl::Rectangle *outgoing) in RotateRectangle() argument
243 outgoing->x = incoming.x; in RotateRectangle()
244 outgoing->y = flipY ? framebufferHeight - incoming.y - incoming.height : incoming.y; in RotateRectangle()
245 outgoing->width = incoming.width; in RotateRectangle()
246 outgoing->height = incoming.height; in RotateRectangle()
250 outgoing->x = incoming.y; in RotateRectangle()
251 outgoing->y = flipY ? incoming.x : framebufferWidth - incoming.x - incoming.width; in RotateRectangle()
252 outgoing->width = incoming.height; in RotateRectangle()
253 outgoing->height = incoming.width; in RotateRectangle()
257 outgoing->x = framebufferWidth - incoming.x - incoming.width; in RotateRectangle()
[all …]
/third_party/grpc/src/core/lib/http/
Dhttpcli.cc61 grpc_slice_buffer outgoing; member
107 grpc_slice_buffer_destroy_internal(&req->outgoing); in finish()
168 grpc_slice_buffer_add(&req->outgoing, req->request_text); in start_write()
169 grpc_endpoint_write(req->ep, &req->outgoing, &req->done_write, nullptr); in start_write()
254 grpc_slice_buffer_init(&req->outgoing); in internal_request_begin()
/third_party/libuv/test/
Dtest-tcp-close-accept.c57 uv_stream_t* outgoing; in connect_cb() local
77 outgoing = (uv_stream_t*) &tcp_outgoing[i]; in connect_cb()
78 ASSERT(0 == uv_write(&write_reqs[i], outgoing, &buf, 1, write_cb)); in connect_cb()

123456789