Home
last modified time | relevance | path

Searched full:outgoing (Results 1 – 25 of 1634) sorted by relevance

12345678910>>...66

/external/federated-compute/fcp/protocol/
Dgrpc_chunked_bidi_stream.h45 * @tparam Outgoing The type of the outgoing protocol buffer message.
48 template <typename Outgoing, typename Incoming>
57 grpc::internal::WriterInterface<Outgoing>* writer_interface,
60 grpc::internal::WriterInterface<Outgoing>* writer_interface,
69 ABSL_MUST_USE_RESULT absl::Status Send(Outgoing* message);
77 Outgoing* message);
78 ABSL_MUST_USE_RESULT absl::Status ChunkMessage(const Outgoing& message);
80 ABSL_MUST_USE_RESULT absl::Status TrySend(const Outgoing& message);
82 ABSL_MUST_USE_RESULT absl::Status SendRaw(const Outgoing& message,
91 grpc::internal::WriterInterface<Outgoing>* writer_interface_;
[all …]
/external/apache-commons-math/src/main/java/org/apache/commons/math3/geometry/spherical/twod/
DVertex.java35 /** Outgoing edge. */
36 private Edge outgoing; field in Vertex
47 this.outgoing = null; in Vertex()
105 /** Set outgoing edge.
107 * The circle supporting the outgoing edge is automatically bound
110 * @param outgoing outgoing edge
112 void setOutgoing(final Edge outgoing) { in setOutgoing() argument
113 this.outgoing = outgoing; in setOutgoing()
114 bindWith(outgoing.getCircle()); in setOutgoing()
117 /** Get outgoing edge.
[all …]
/external/cronet/tot/base/fuchsia/
Dstartup_context.h25 // wrappers for the various fields (e.g. the incoming & outgoing service
43 // Easy accessors for the incoming service directory, and outgoing directory.
47 sys::OutgoingDirectory* outgoing() const { in outgoing() function
48 return component_context_->outgoing().get(); in outgoing()
51 // Starts serving outgoing directory in the |component_context()|. Can be
52 // called at most once. All outgoing services should be published in
53 // |component_context()->outgoing()| before calling this function.
63 // Used to store outgoing directory until ServeOutgoingDirectory() is called.
Dscoped_service_binding_unittest.cc36 ComponentContextForProcess()->outgoing().get(), &test_service_); in TEST_F()
51 ComponentContextForProcess()->outgoing().get(), &test_service_, in TEST_F()
66 ComponentContextForProcess()->outgoing()->debug_dir(); in TEST_F()
83 // Verify that the service does not appear in the outgoing service directory. in TEST_F()
94 ComponentContextForProcess()->outgoing().get(), &test_service_, in TEST_F()
108 binding(ComponentContextForProcess()->outgoing().get(), &test_service_); in TEST_F()
129 binding(ComponentContextForProcess()->outgoing().get(), &test_service_); in TEST_F()
148 ComponentContextForProcess()->outgoing().get(), &test_service_); in TEST_F()
167 ComponentContextForProcess()->outgoing()->debug_dir(); in TEST_F()
183 // Verify that the service does not appear in the outgoing service directory. in TEST_F()
[all …]
Dscoped_natural_service_binding_unittest.cc36 ComponentContextForProcess()->outgoing().get(), &test_service_); in TEST_F()
52 ComponentContextForProcess()->outgoing().get(), &test_service_, in TEST_F()
66 ComponentContextForProcess()->outgoing()->debug_dir(); in TEST_F()
86 // Verify that the `TestInterface` service does not appear in the outgoing in TEST_F()
97 ComponentContextForProcess()->outgoing().get(), &test_service_); in TEST_F()
131 ComponentContextForProcess()->outgoing().get(), &test_service_); in TEST_F()
/external/cronet/stable/base/fuchsia/
Dstartup_context.h25 // wrappers for the various fields (e.g. the incoming & outgoing service
43 // Easy accessors for the incoming service directory, and outgoing directory.
47 sys::OutgoingDirectory* outgoing() const { in outgoing() function
48 return component_context_->outgoing().get(); in outgoing()
51 // Starts serving outgoing directory in the |component_context()|. Can be
52 // called at most once. All outgoing services should be published in
53 // |component_context()->outgoing()| before calling this function.
63 // Used to store outgoing directory until ServeOutgoingDirectory() is called.
Dscoped_service_binding_unittest.cc36 ComponentContextForProcess()->outgoing().get(), &test_service_); in TEST_F()
51 ComponentContextForProcess()->outgoing().get(), &test_service_, in TEST_F()
66 ComponentContextForProcess()->outgoing()->debug_dir(); in TEST_F()
83 // Verify that the service does not appear in the outgoing service directory. in TEST_F()
94 ComponentContextForProcess()->outgoing().get(), &test_service_, in TEST_F()
108 binding(ComponentContextForProcess()->outgoing().get(), &test_service_); in TEST_F()
129 binding(ComponentContextForProcess()->outgoing().get(), &test_service_); in TEST_F()
148 ComponentContextForProcess()->outgoing().get(), &test_service_); in TEST_F()
167 ComponentContextForProcess()->outgoing()->debug_dir(); in TEST_F()
183 // Verify that the service does not appear in the outgoing service directory. in TEST_F()
[all …]
Dscoped_natural_service_binding_unittest.cc36 ComponentContextForProcess()->outgoing().get(), &test_service_); in TEST_F()
52 ComponentContextForProcess()->outgoing().get(), &test_service_, in TEST_F()
66 ComponentContextForProcess()->outgoing()->debug_dir(); in TEST_F()
86 // Verify that the `TestInterface` service does not appear in the outgoing in TEST_F()
97 ComponentContextForProcess()->outgoing().get(), &test_service_); in TEST_F()
131 ComponentContextForProcess()->outgoing().get(), &test_service_); in TEST_F()
/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/nrs/
DHttpStreamsHandler.java49 private final Queue<Outgoing> outgoing = new LinkedList<>(); field in HttpStreamsHandler
117 * Invoked when an outgoing message is first received.
125 * Invoked when an outgoing message is fully sent.
265 Outgoing out = new Outgoing(outClass.cast(msg), promise); in write()
268 if (outgoing.isEmpty()) { in write()
269 outgoing.add(out); in write()
272 outgoing.add(out); in write()
285 protected void unbufferedWrite(final ChannelHandlerContext ctx, final Outgoing out) { in unbufferedWrite()
297 outgoing.remove(); in unbufferedWrite()
339 ChannelPromise promise = outgoing.peek().promise; in completeBody()
[all …]
/external/perfetto/src/trace_processor/perfetto_sql/intrinsics/functions/
Dgraph_scan.cc72 for (uint32_t outgoing : get_edges(id)) { in InitToOutputAndStepTable() local
74 RETURN_IF_ERROR(step.AddInteger(0, outgoing)); in InitToOutputAndStepTable()
133 for (uint32_t outgoing : get_edges(id)) { in SqliteToOutputAndStepTable() local
135 RETURN_IF_ERROR(step.AddInteger(0, outgoing)); in SqliteToOutputAndStepTable()
299 for (uint32_t outgoing : GetEdges(id)) { in PushDownAggregates() local
300 auto& dt = tables_per_depth[state[outgoing].depth]; in PushDownAggregates()
302 RETURN_IF_ERROR(dt.builder.AddInteger(0, outgoing)); in PushDownAggregates()
308 for (uint32_t outgoing : GetEdges(id)) { in PushDownAggregates() local
309 auto& dt = tables_per_depth[state[outgoing].depth]; in PushDownAggregates()
316 for (uint32_t outgoing : GetEdges(id)) { in PushDownAggregates() local
[all …]
/external/cronet/tot/net/third_party/quiche/src/quiche/quic/core/
Dlegacy_quic_stream_id_manager.h21 // questions: 1) can next outgoing stream ID be allocated (if yes, what is the
22 // next outgoing stream ID) and 2) can a new incoming stream be opened.
32 // Returns true if the next outgoing stream ID can be allocated.
45 // Returns the stream ID for a new outgoing stream, and increments the
104 // The maximum number of outgoing streams this connection can open.
110 // The ID to use for the next outgoing stream.
Dquic_stream_id_manager.h65 // Returns whether the next outgoing stream ID can be allocated or not.
72 // outgoing. If the stream is incoming, the number of streams that the peer
77 // Returns the next outgoing stream id. Applications must call
83 // Called on |max_open_streams| outgoing streams can be created because of 1)
135 // Get what should be the first incoming/outgoing stream ID that
159 // The ID to use for the next outgoing stream.
162 // The number of outgoing streams that have ever been opened, including those
Duber_quic_stream_id_manager.h32 // Called on |max_open_streams| outgoing streams can be created because of 1)
45 // Returns true if next outgoing bidirectional stream ID can be allocated.
48 // Returns true if next outgoing unidirectional stream ID can be allocated.
51 // Returns the next outgoing bidirectional stream id.
54 // Returns the next outgoing unidirectional stream id.
/external/cronet/stable/net/third_party/quiche/src/quiche/quic/core/
Dlegacy_quic_stream_id_manager.h21 // questions: 1) can next outgoing stream ID be allocated (if yes, what is the
22 // next outgoing stream ID) and 2) can a new incoming stream be opened.
32 // Returns true if the next outgoing stream ID can be allocated.
45 // Returns the stream ID for a new outgoing stream, and increments the
104 // The maximum number of outgoing streams this connection can open.
110 // The ID to use for the next outgoing stream.
Dquic_stream_id_manager.h65 // Returns whether the next outgoing stream ID can be allocated or not.
72 // outgoing. If the stream is incoming, the number of streams that the peer
77 // Returns the next outgoing stream id. Applications must call
83 // Called on |max_open_streams| outgoing streams can be created because of 1)
135 // Get what should be the first incoming/outgoing stream ID that
159 // The ID to use for the next outgoing stream.
162 // The number of outgoing streams that have ever been opened, including those
Duber_quic_stream_id_manager.h32 // Called on |max_open_streams| outgoing streams can be created because of 1)
45 // Returns true if next outgoing bidirectional stream ID can be allocated.
48 // Returns true if next outgoing unidirectional stream ID can be allocated.
51 // Returns the next outgoing bidirectional stream id.
54 // Returns the next outgoing unidirectional stream id.
/external/swiftshader/third_party/llvm-10.0/llvm/lib/CodeGen/
DCFIInstrInserter.cpp9 /// \file This pass verifies incoming and outgoing CFA information of basic
12 /// that outgoing information of predecessors matches incoming information of
99 /// Check if incoming CFA information of a basic block matches outgoing CFA
112 /// Go through each MBB in a function and check that outgoing offset and
115 /// outgoing offset and register of the MBB.
158 // Outgoing cfa offset set by the block. in calculateOutgoingCFAInfo()
160 // Outgoing cfa register set by the block. in calculateOutgoingCFAInfo()
218 // Update outgoing CFA info. in calculateOutgoingCFAInfo()
259 // If both outgoing offset and register of a previous block don't match in insertCFIInstrs()
267 // If outgoing offset of a previous block doesn't match incoming offset in insertCFIInstrs()
[all …]
/external/swiftshader/third_party/llvm-16.0/llvm/lib/Transforms/Utils/
DBasicBlockUtils.cpp1694 // After creating a control flow hub, the operands of PHINodes in an outgoing
1739 // out successors that are not in the set of outgoing blocks.
1742 // - Succ1 is non-null iff the sole/taken target is an outgoing block.
1744 // target is an outgoing block.
1747 const BBSetVector &Outgoing) { in redirectToHub() argument
1755 Succ0 = Outgoing.count(Succ0) ? Succ0 : nullptr; in redirectToHub()
1762 Succ1 = Outgoing.count(Succ1) ? Succ1 : nullptr; in redirectToHub()
1780 // control to the corresponding outgoing block or the next guard
1781 // block. The last guard block has two outgoing blocks as successors
1782 // since the condition for the final outgoing block is trivially
[all …]
/external/robolectric/shadows/framework/src/main/java/org/robolectric/shadows/
DShadowCallLogCalls.java17 * Gets the last outgoing call String set by {@link #setLastOutgoingCall(String)}.
20 * @return The last outgoing call set by {@link #setLastOutgoingCall(String)}
28 * Sets a last outgoing call that can later be retrieved by {@link #getLastOutgoingCall(Context)}.
30 * @param lastCall The last outgoing call String.
/external/swiftshader/third_party/llvm-16.0/llvm/lib/CodeGen/
DCFIInstrInserter.cpp9 /// \file This pass verifies incoming and outgoing CFA information of basic
12 /// that outgoing information of predecessors matches incoming information of
115 /// Check if incoming CFA information of a basic block matches outgoing CFA
129 /// Go through each MBB in a function and check that outgoing offset and
132 /// outgoing offset and register of the MBB.
176 // Outgoing cfa offset set by the block. in calculateOutgoingCFAInfo()
178 // Outgoing cfa register set by the block. in calculateOutgoingCFAInfo()
267 // Update outgoing CFA info. in calculateOutgoingCFAInfo()
271 // Update outgoing CSR info. in calculateOutgoingCFAInfo()
318 // If both outgoing offset and register of a previous block don't match in insertCFIInstrs()
[all …]
/external/autotest/server/site_tests/bluetooth_AdapterEPHealth/
Dbluetooth_AdapterEPHealth.py247 @test_wrapper('Outgoing: HID: Service in Allowlist', devices={'KEYBOARD':1})
249 """The test with service in allowlist for outgoing connection."""
255 @test_wrapper('Outgoing: Audio: Service in Allowlist',
258 """The test with service in allowlist for outgoing connection."""
265 @test_wrapper('Outgoing: HID: Service not in Allowlist',
268 """The test with service not in allowlist for outgoing connection."""
274 @test_wrapper('Outgoing: Audio: Service not in Allowlist',
277 """The test with service not in allowlist for outgoing connection."""
285 @test_wrapper('Outgoing: HID: Empty Allowlist',
288 """The test with an empty allowlist for outgoing connection."""
[all …]
/external/icu/icu4c/source/common/unicode/
Dresbund.h217 * @param status fills in the outgoing error code
232 * @param status fills in the outgoing error code
247 * @param status fills in the outgoing error code
261 * @param status fills in the outgoing error code
275 * @param status fills in the outgoing error code
329 * @param status fills in the outgoing error code
340 * @param status fills in the outgoing error code
352 * @param status fills in the outgoing error code
364 * @param status fills in the outgoing error code
376 * @param status fills in the outgoing error code
[all …]
/external/cronet/tot/third_party/icu/source/common/unicode/
Dresbund.h218 * @param status fills in the outgoing error code
233 * @param status fills in the outgoing error code
248 * @param status fills in the outgoing error code
262 * @param status fills in the outgoing error code
276 * @param status fills in the outgoing error code
336 * @param status fills in the outgoing error code
347 * @param status fills in the outgoing error code
359 * @param status fills in the outgoing error code
371 * @param status fills in the outgoing error code
383 * @param status fills in the outgoing error code
[all …]
/external/cronet/stable/third_party/icu/source/common/unicode/
Dresbund.h218 * @param status fills in the outgoing error code
233 * @param status fills in the outgoing error code
248 * @param status fills in the outgoing error code
262 * @param status fills in the outgoing error code
276 * @param status fills in the outgoing error code
336 * @param status fills in the outgoing error code
347 * @param status fills in the outgoing error code
359 * @param status fills in the outgoing error code
371 * @param status fills in the outgoing error code
383 * @param status fills in the outgoing error code
[all …]
/external/icu/libicu/cts_headers/unicode/
Dresbund.h217 * @param status fills in the outgoing error code
232 * @param status fills in the outgoing error code
247 * @param status fills in the outgoing error code
261 * @param status fills in the outgoing error code
275 * @param status fills in the outgoing error code
329 * @param status fills in the outgoing error code
340 * @param status fills in the outgoing error code
352 * @param status fills in the outgoing error code
364 * @param status fills in the outgoing error code
376 * @param status fills in the outgoing error code
[all …]

12345678910>>...66