| /third_party/grpc/src/python/grpcio_testing/grpc_testing/_server/ |
| D | _service.py | 21 def __init__(self, rpc, handler): argument
46 def _unary_response(argument, implementation, rpc, servicer_context): argument
55 def _stream_response(argument, implementation, rpc, servicer_context): argument
74 def unary_unary(implementation, rpc, request, servicer_context): argument
78 def unary_stream(implementation, rpc, request, servicer_context): argument
82 def stream_unary(implementation, rpc, handler, servicer_context): argument
87 def stream_stream(implementation, rpc, handler, servicer_context): argument
|
| D | _server.py | 33 def service(implementation, rpc, servicer_context): argument
41 def service(implementation, rpc, servicer_context): argument
49 def service(implementation, rpc, servicer_context): argument
57 def service(implementation, rpc, servicer_context): argument
|
| D | _servicer_context.py | 21 def __init__(self, rpc, time, deadline): argument
|
| /third_party/NuttX/fs/nfs/ |
| D | rpc_clnt.c | 163 static int rpcclnt_send(struct rpcclnt *rpc, int procid, int prog, in rpcclnt_send()
199 static int rpcclnt_receive(struct rpcclnt *rpc, struct sockaddr *aname, in rpcclnt_receive()
264 static int rpcclnt_receive(struct rpcclnt *rpc, struct sockaddr *aname, in rpcclnt_receive()
353 static int rpcclnt_reply(struct rpcclnt *rpc, int procid, int prog, in rpcclnt_reply()
446 static int rpcclnt_alivecheck(struct rpcclnt *rpc) in rpcclnt_alivecheck()
548 static int rpcclnt_reconnect(struct rpcclnt *rpc, struct sockaddr *saddr) in rpcclnt_reconnect()
646 int rpcclnt_connect(struct rpcclnt *rpc) in rpcclnt_connect()
844 void rpcclnt_disconnect(struct rpcclnt *rpc) in rpcclnt_disconnect()
861 int rpcclnt_umount(struct rpcclnt *rpc) in rpcclnt_umount()
963 int rpcclnt_request(struct rpcclnt *rpc, int procnum, int prog, in rpcclnt_request()
|
| D | nfs_adapter.c | 491 struct rpcclnt *rpc = NULL; in nfs_bind() local
|
| /third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/lib/ExecutionEngine/OrcError/ |
| D | RPCError.cpp | 27 namespace rpc { namespace
|
| /third_party/grpc/examples/cpp/helloworld/ |
| D | greeter_async_client.cc | 71 std::unique_ptr<ClientAsyncResponseReader<HelloReply> > rpc( in SayHello() local
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/gnn/ |
| D | graph_data_client.cc | 303 std::unique_ptr<grpc::ClientAsyncResponseReader<GnnMetaInfoResponsePb>> rpc( in GraphInfo() local
361 std::unique_ptr<grpc::ClientAsyncResponseReader<GnnGraphDataResponsePb>> rpc( in GetGraphData() local
519 std::unique_ptr<grpc::ClientAsyncResponseReader<GnnClientRegisterResponsePb>> rpc( in RegisterToServer() local
573 std::unique_ptr<grpc::ClientAsyncResponseReader<GnnClientUnRegisterResponsePb>> rpc( in UnRegisterToServer() local
|
| /third_party/grpc/src/ruby/lib/grpc/generic/ |
| D | service.rb | 92 def rpc(name, input, output) method
|
| /third_party/grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | XdsInteropClient.cs | 255 private static RpcType ParseRpc(string rpc) in ParseRpc()
|
| /third_party/grpc/test/cpp/end2end/ |
| D | client_callback_end2end_test.cc | 350 Client rpc(this, kMethodName, test_string, reuses, do_writes_done); in SendGenericEchoAsBidi() local
|
| /third_party/flatbuffers/src/ |
| D | idl_parser.cpp | 2630 auto &rpc = *new RPCCall(); in ParseService() local
|