| /external/pigweed/pw_rpc/java/main/dev/pigweed/pw_rpc/ |
| D | StreamObserverCall.java | 40 private final RpcManager rpcs; field in StreamObserverCall
54 private StreamObserverFutureCall(RpcManager rpcs, PendingRpc rpc) { in StreamObserverFutureCall()
117 UnaryResponseFuture(RpcManager rpcs, PendingRpc rpc, @Nullable RequestT request) { in UnaryResponseFuture()
148 RpcManager rpcs, PendingRpc rpc, Consumer<ResponseT> onNext, @Nullable RequestT request) { in StreamResponseFuture()
167 StreamObserverCall<RequestT, ResponseT> start(RpcManager rpcs, in start()
178 StreamObserverCall<RequestT, ResponseT> open(RpcManager rpcs, in open()
187 private StreamObserverCall(RpcManager rpcs, PendingRpc rpc, StreamObserver<ResponseT> observer) { in StreamObserverCall()
|
| D | MethodClient.java | 30 private final RpcManager rpcs; field in MethodClient
33 MethodClient(RpcManager rpcs, PendingRpc rpc, StreamObserver<MessageLite> defaultObserver) { in MethodClient()
44 protected final RpcManager rpcs() { in rpcs() method in MethodClient
|
| D | Client.java | 42 private final RpcManager rpcs; field in Client
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/load_reporter/ |
| D | load_reporter.h | 175 uint64_t rpcs; member
|
| D | load_reporter.cc | 270 uint64_t rpcs = 0; in GenerateLoadBalancingFeedback() local
368 void LoadReporter::AppendNewFeedbackRecord(uint64_t rpcs, uint64_t errors) { in AppendNewFeedbackRecord()
|
| /external/grpc-grpc/src/cpp/server/load_reporter/ |
| D | load_reporter.h | 173 uint64_t rpcs; member
|
| D | load_reporter.cc | 268 uint64_t rpcs = 0; in GenerateLoadBalancingFeedback() local
366 void LoadReporter::AppendNewFeedbackRecord(uint64_t rpcs, uint64_t errors) { in AppendNewFeedbackRecord()
|
| /external/pigweed/pw_rpc/ts/ |
| D | method.ts | 48 readonly rpcs: PendingCalls; property in MethodStub
|
| D | call.ts | 57 private rpcs: PendingCalls; property in Call
|
| D | client.ts | 116 readonly rpcs: PendingCalls; property in Client
|
| /external/pigweed/pw_system/py/pw_system/ |
| D | device.py | 78 def rpcs(self) -> Any: member in Device
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientTransportTest.java | 245 final List<Rpc> rpcs = new ArrayList<>(transports.size()); in creatingMultipleTlsTransportsShouldSucceed() local
382 Rpc[] rpcs = new Rpc[] { new Rpc(transport), new Rpc(transport), new Rpc(transport) }; in bufferedStreamsShouldBeClosedWhenConnectionTerminates() local
|
| /external/pigweed/pw_hdlc/py/pw_hdlc/ |
| D | rpc.py | 179 def rpcs(self, channel_id: int = None) -> Any: member in HdlcRpcClient
|