| /external/pigweed/pw_rpc/raw/ |
| D | method.cc | 26 RawUnaryResponder responder(context.ClaimLocked()); in AsynchronousUnaryInvoker()
35 RawServerWriter server_writer(context.ClaimLocked()); in ServerStreamingInvoker()
44 RawServerReader reader(context.ClaimLocked()); in ClientStreamingInvoker()
52 RawServerReaderWriter reader_writer(context.ClaimLocked()); in BidirectionalStreamingInvoker()
|
| D | client_test.cc | 50 Call call(static_cast<internal::Endpoint&>(context.client()).ClaimLocked(), in StartCall()
|
| /external/pigweed/pw_rpc/public/pw_rpc/internal/ |
| D | call_context.h | 54 const LockedCallContext& ClaimLocked() const
57 LockedCallContext& ClaimLocked() PW_EXCLUSIVE_LOCKS_REQUIRED(rpc_lock());
94 inline const LockedCallContext& CallContext::ClaimLocked() const { in ClaimLocked() function
98 inline LockedCallContext& CallContext::ClaimLocked() { in ClaimLocked() function
|
| D | endpoint.h | 84 LockedEndpoint& ClaimLocked() PW_EXCLUSIVE_LOCKS_REQUIRED(rpc_lock());
265 inline LockedEndpoint& Endpoint::ClaimLocked() { in ClaimLocked() function
|
| D | client_call.h | 84 CallType call(client.ClaimLocked(), channel_id, service_id, method_id); in Start()
157 CallType call(client.ClaimLocked(), channel_id, service_id, method_id); in Start()
|
| D | test_method.h | 75 FakeServerCall fake_call(context.ClaimLocked(), kType); in InvokeForTest()
|
| D | test_method_context.h | 160 return T(call_context().ClaimLocked()); in GetResponder()
|
| /external/pigweed/pw_rpc/nanopb/ |
| D | method.cc | 39 NanopbServerCall responder(context.ClaimLocked(), MethodType::kUnary); in CallSynchronousUnary()
55 NanopbServerCall server_writer(context.ClaimLocked(), type); in CallUnaryRequest()
|
| /external/pigweed/pw_rpc/ |
| D | call_test.cc | 88 FakeServerWriter writer_temp(context_.get().ClaimLocked()); in ServerWriterTest()
128 FakeServerWriter writer(context_.get().ClaimLocked()); in TEST_F()
204 FakeServerReader reader_temp(context_.get().ClaimLocked()); in ServerReaderTest()
254 FakeServerReaderWriter reader_writer_temp(context_.get().ClaimLocked()); in ServerReaderWriterTest()
329 FakeServerReaderWriter destination(context_.get(123).ClaimLocked()); in TEST_F()
|
| D | server_test.cc | 411 context.ClaimLocked()); in BidiMethod()
468 .ClaimLocked()); in TEST_F()
589 internal::test::FakeServerReaderWriter(context.ClaimLocked()); in TEST_F()
660 internal::test::FakeServerWriter responder_temp(context.ClaimLocked()); in ServerStreamingMethod()
|
| D | call.cc | 55 : Call(context.server().ClaimLocked(), in Call()
|
| /external/pigweed/pw_rpc/pwpb/public/pw_rpc/pwpb/internal/ |
| D | method.h | 254 internal::PwpbServerCall responder(context.ClaimLocked(), in CallSynchronousUnary()
273 internal::PwpbServerCall server_writer(context.ClaimLocked(), method_type); in CallUnaryRequest()
342 context.ClaimLocked(), MethodType::kClientStreaming); in ClientStreamingInvoker()
354 context.ClaimLocked(), MethodType::kBidirectionalStreaming); in BidirectionalStreamingInvoker()
|
| /external/pigweed/pw_rpc/public/pw_rpc/ |
| D | server.h | 165 .ClaimLocked()); in OpenCall()
191 using Endpoint::ClaimLocked;
|
| D | client.h | 54 using Endpoint::ClaimLocked;
|
| /external/pigweed/pw_rpc/nanopb/public/pw_rpc/nanopb/ |
| D | client_reader_writer.h | 44 client.ClaimLocked(), channel_id, service_id, method_id, serde); in Start()
134 client.ClaimLocked(), channel_id, service_id, method_id, serde); in Start()
|
| /external/pigweed/pw_rpc/pwpb/public/pw_rpc/pwpb/ |
| D | client_reader_writer.h | 49 client.ClaimLocked(), channel_id, service_id, method_id, serde); in Start()
165 client.ClaimLocked(), channel_id, service_id, method_id, serde); in Start()
|
| /external/pigweed/pw_rpc/nanopb/public/pw_rpc/nanopb/internal/ |
| D | method.h | 387 BaseNanopbServerReader<Request> reader(context.ClaimLocked(),
400 context.ClaimLocked(), MethodType::kBidirectionalStreaming);
|