| /external/pigweed/pw_rpc/public/pw_rpc/ |
| D | server_context.h | 30 class ServerContext : private internal::ServerCall {
35 constexpr ServerContext() = delete;
37 constexpr ServerContext(const ServerContext&) = delete;
38 constexpr ServerContext& operator=(const ServerContext&) = delete;
40 constexpr ServerContext(ServerContext&&) = delete;
41 constexpr ServerContext& operator=(ServerContext&&) = delete;
48 inline ServerContext& ServerCall::context() { in context()
49 return static_cast<ServerContext&>(*this); in context()
|
| /external/grpc-grpc/src/cpp/server/ |
| D | server_context.cc | 40 class ServerContext::CompletionOp final : public internal::CallOpSetInterface {
83 void ServerContext::CompletionOp::Unref() { in Unref()
91 void ServerContext::CompletionOp::FillOps(grpc_call* call, grpc_op* ops, in FillOps()
100 bool ServerContext::CompletionOp::FinalizeResult(void** tag, bool* status) { in FinalizeResult()
118 ServerContext::ServerContext() in ServerContext() function in grpc::ServerContext
129 ServerContext::ServerContext(gpr_timespec deadline, grpc_metadata_array* arr) in ServerContext() function in grpc::ServerContext
142 ServerContext::~ServerContext() { in ~ServerContext()
151 void ServerContext::BeginCompletionOp(internal::Call* call) { in BeginCompletionOp()
160 internal::CompletionQueueTag* ServerContext::GetCompletionOpTag() { in GetCompletionOpTag()
164 void ServerContext::AddInitialMetadata(const grpc::string& key, in AddInitialMetadata()
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/rpc/ |
| D | grpc_service.h | 34 ::grpc::Status Unregister(::grpc::ServerContext* context,
38 ::grpc::Status DeconstructTuple(::grpc::ServerContext* context,
42 ::grpc::Status GetDeviceHandles(::grpc::ServerContext* context,
46 ::grpc::Status Compile(::grpc::ServerContext* context,
50 ::grpc::Status Execute(::grpc::ServerContext* context,
53 ::grpc::Status ExecuteGraphParallel(::grpc::ServerContext* context,
57 ::grpc::Status WaitForExecution(::grpc::ServerContext* context,
61 ::grpc::Status TransferToClient(::grpc::ServerContext* context,
65 ::grpc::Status TransferToServer(::grpc::ServerContext* context,
69 ::grpc::Status TransferToInfeed(::grpc::ServerContext* context,
[all …]
|
| D | grpc_service.cc | 35 ::grpc::Status GRPCService::Unregister(::grpc::ServerContext* context, in Unregister()
42 ::grpc::Status GRPCService::DeconstructTuple(::grpc::ServerContext* context, in DeconstructTuple()
50 ::grpc::Status GRPCService::GetDeviceHandles(::grpc::ServerContext* context, in GetDeviceHandles()
58 ::grpc::Status GRPCService::Compile(::grpc::ServerContext* /*context*/, in Compile() argument
65 ::grpc::Status GRPCService::Execute(::grpc::ServerContext* /*context*/, in Execute() argument
73 ::grpc::ServerContext* /*context*/, const ExecuteGraphParallelRequest* arg, in ExecuteGraphParallel() argument
80 ::grpc::Status GRPCService::WaitForExecution(::grpc::ServerContext* context, in WaitForExecution()
88 ::grpc::Status GRPCService::TransferToClient(::grpc::ServerContext* context, in TransferToClient()
96 ::grpc::Status GRPCService::TransferToServer(::grpc::ServerContext* context, in TransferToServer()
104 ::grpc::Status GRPCService::TransferToInfeed(::grpc::ServerContext* context, in TransferToInfeed()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/channelz/ |
| D | channelz_service.h | 33 ServerContext* unused, const channelz::v1::GetTopChannelsRequest* request,
36 Status GetServers(ServerContext* unused,
40 Status GetServer(ServerContext* unused,
45 ServerContext* unused,
49 Status GetChannel(ServerContext* unused,
53 Status GetSubchannel(ServerContext* unused,
57 Status GetSocket(ServerContext* unused,
|
| D | channelz_service.cc | 40 ServerContext* /*unused*/, in GetTopChannels() argument
57 ServerContext* /*unused*/, const channelz::v1::GetServersRequest* request, in GetServers() argument
72 Status ChannelzService::GetServer(ServerContext* /*unused*/, in GetServer() argument
89 ServerContext* /*unused*/, in GetServerSockets() argument
107 ServerContext* /*unused*/, const channelz::v1::GetChannelRequest* request, in GetChannel() argument
122 ServerContext* /*unused*/, in GetSubchannel() argument
138 Status ChannelzService::GetSocket(ServerContext* /*unused*/, in GetSocket() argument
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | method_handler.h | 101 std::function<::grpc::Status(ServiceType*, ::grpc::ServerContext*, in RpcMethodHandler() argument
113 static_cast<::grpc::ServerContext*>(param.server_context), in RunHandler()
132 std::function<::grpc::Status(ServiceType*, ::grpc::ServerContext*,
144 std::function<::grpc::Status(ServiceType*, ::grpc::ServerContext*, in ClientStreamingHandler() argument
152 param.call, static_cast<::grpc::ServerContext*>(param.server_context)); in RunHandler()
157 static_cast<::grpc::ServerContext*>(param.server_context), in RunHandler()
181 std::function<::grpc::Status(ServiceType*, ::grpc::ServerContext*,
192 ServiceType*, ::grpc::ServerContext*, in ServerStreamingHandler() argument
203 static_cast<::grpc::ServerContext*>(param.server_context)); in RunHandler()
206 static_cast<::grpc::ServerContext*>(param.server_context), in RunHandler()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | method_handler.h | 101 std::function<::grpc::Status(ServiceType*, ::grpc::ServerContext*, in RpcMethodHandler() argument
113 static_cast<::grpc::ServerContext*>(param.server_context), in RunHandler()
132 std::function<::grpc::Status(ServiceType*, ::grpc::ServerContext*,
144 std::function<::grpc::Status(ServiceType*, ::grpc::ServerContext*, in ClientStreamingHandler() argument
152 param.call, static_cast<::grpc::ServerContext*>(param.server_context)); in RunHandler()
157 static_cast<::grpc::ServerContext*>(param.server_context), in RunHandler()
181 std::function<::grpc::Status(ServiceType*, ::grpc::ServerContext*,
192 ServiceType*, ::grpc::ServerContext*, in ServerStreamingHandler() argument
203 static_cast<::grpc::ServerContext*>(param.server_context)); in RunHandler()
206 static_cast<::grpc::ServerContext*>(param.server_context), in RunHandler()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/ext/ |
| D | proto_server_reflection.h | 41 ServerContext* context,
47 Status ListService(ServerContext* context,
50 Status GetFileByName(ServerContext* context, const std::string& file_name,
54 ServerContext* context, const std::string& symbol,
58 ServerContext* context,
63 ServerContext* context, const std::string& type,
|
| /external/grpc-grpc/src/cpp/ext/ |
| D | proto_server_reflection.h | 41 ServerContext* context,
47 Status ListService(ServerContext* context,
50 Status GetFileByName(ServerContext* context, const grpc::string& file_name,
54 ServerContext* context, const grpc::string& symbol,
58 ServerContext* context,
63 ServerContext* context, const grpc::string& type,
|
| /external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| D | eager_service_impl.h | 115 class ServerContext : public core::RefCounted {
118 static ServerContext* CreateMasterContext(tensorflow::EagerContext* ctx, in CreateMasterContext()
120 return new ServerContext(ctx, -1, env, /* is_master= */ true); in CreateMasterContext()
123 explicit ServerContext(tensorflow::EagerContext* ctx,
133 ~ServerContext() override { in ~ServerContext()
169 tensorflow::Status GetServerContext(uint64, ServerContext**);
174 ServerContext* context, in ClientTensorHandleDeleteNode()
206 ServerContext* const context_;
224 std::unordered_map<uint64, ServerContext*> contexts_
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | test_service_impl.h | 52 Status Echo(ServerContext* context, const EchoRequest* request,
57 Status RequestStream(ServerContext* context,
61 Status ResponseStream(ServerContext* context, const EchoRequest* request,
65 ServerContext* context,
79 void ServerTryCancel(ServerContext* context);
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | server_interface.h | 35 class ServerContext; variable
149 BaseAsyncRequest(ServerInterface* server, ServerContext* context,
159 ServerContext* const context_;
169 RegisteredAsyncRequest(ServerInterface* server, ServerContext* context,
183 ServerContext* context, in NoPayloadAsyncRequest()
198 ServerContext* context, in PayloadAsyncRequest()
244 ServerContext* const context_;
269 ServerContext* context, in RequestAsyncCall()
281 ServerContext* context, in RequestAsyncCall()
|
| D | method_handler_impl.h | 55 RpcMethodHandler(std::function<Status(ServiceType*, ServerContext*, in RpcMethodHandler() argument
91 std::function<Status(ServiceType*, ServerContext*, const RequestType*,
103 std::function<Status(ServiceType*, ServerContext*, in ClientStreamingHandler() argument
135 std::function<Status(ServiceType*, ServerContext*, ServerReader<RequestType>*,
146 std::function<Status(ServiceType*, ServerContext*, const RequestType*, in ServerStreamingHandler() argument
181 std::function<Status(ServiceType*, ServerContext*, const RequestType*,
198 std::function<Status(ServerContext*, Streamer*)> func) in TemplatedBidiStreamingHandler() argument
230 std::function<Status(ServerContext*, Streamer*)> func_;
240 std::function<Status(ServiceType*, ServerContext*, in BidiStreamingHandler() argument
255 std::function<Status(ServerContext*, in StreamedUnaryHandler() argument
[all …]
|
| D | server_context.h | 97 class ServerContext {
99 ServerContext(); // for async calls
100 ~ServerContext();
273 ServerContext(const ServerContext&);
274 ServerContext& operator=(const ServerContext&);
282 ServerContext(gpr_timespec deadline, grpc_metadata_array* arr);
|
| /external/grpc-grpc/src/cpp/server/channelz/ |
| D | channelz_service.h | 33 ServerContext* unused, const channelz::v1::GetTopChannelsRequest* request,
36 Status GetServers(ServerContext* unused,
40 Status GetChannel(ServerContext* unused,
44 Status GetSubchannel(ServerContext* unused,
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_master_service_impl.h | 132 ::grpc::ServerContext* context, CreateSessionRequest* request, in RequestCreateSession()
140 ::grpc::ServerContext* context, ExtendSessionRequest* request, in RequestExtendSession()
148 ::grpc::ServerContext* context, PartialRunSetupRequest* request, in RequestPartialRunSetup()
156 ::grpc::ServerContext* context, RunStepRequest* request, in RequestRunStep()
164 ::grpc::ServerContext* context, CloseSessionRequest* request, in RequestCloseSession()
172 ::grpc::ServerContext* context, ListDevicesRequest* request, in RequestListDevices()
180 ::grpc::ServerContext* context, ResetRequest* request, in RequestReset()
188 ::grpc::ServerContext* context, MakeCallableRequest* request, in RequestMakeCallable()
196 ::grpc::ServerContext* context, RunCallableRequest* request, in RequestRunCallable()
204 ::grpc::ServerContext* context, ReleaseCallableRequest* request, in RequestReleaseCallable()
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | server_sync.cc | 39 Status UnaryCall(ServerContext* context, const SimpleRequest* request, in UnaryCall()
48 ServerContext* context, in StreamingCall()
63 Status StreamingFromClient(ServerContext* context, in StreamingFromClient()
72 Status StreamingFromServer(ServerContext* context, in StreamingFromServer()
83 ServerContext* context, in StreamingBothWays()
117 static Status ClientPull(ServerContext* context, R* stream, in ClientPull()
131 static Status ServerPush(ServerContext* context, W* stream, in ServerPush()
|
| /external/tensorflow/tensorflow/compiler/xla/pjrt/distributed/ |
| D | service.h | 67 ::grpc::Status Connect(::grpc::ServerContext* context,
71 ::grpc::Status Shutdown(::grpc::ServerContext* context,
75 ::grpc::Status Heartbeat(::grpc::ServerContext* context,
79 ::grpc::Status EnumerateDevices(::grpc::ServerContext* context,
83 ::grpc::Status KeyValueGet(::grpc::ServerContext* context,
87 ::grpc::Status KeyValueSet(::grpc::ServerContext* context,
|
| /external/pigweed/pw_rpc/nanopb/ |
| D | nanopb_method_test.cc | 38 Status Unary(ServerContext&, const FakePb&, FakePb&) { return Status(); } in Unary() argument
40 static Status StaticUnary(ServerContext&, const FakePb&, FakePb&) { in StaticUnary() argument
44 void ServerStreaming(ServerContext&, const FakePb&, ServerWriter<FakePb>&) {} in ServerStreaming() argument
46 static void StaticServerStreaming(ServerContext&, in StaticServerStreaming() argument
50 Status UnaryWrongArg(ServerContext&, FakePb&, FakePb&) { return Status(); } in UnaryWrongArg() argument
52 static void StaticUnaryVoidReturn(ServerContext&, const FakePb&, FakePb&) {} in StaticUnaryVoidReturn() argument
54 int ServerStreamingBadReturn(ServerContext&, in ServerStreamingBadReturn() argument
131 Status AddFive(ServerContext&, in AddFive() argument
139 Status DoNothing(ServerContext&, const pw_rpc_test_Empty&, pw_rpc_test_Empty&) { in DoNothing() argument
143 void StartStream(ServerContext&, in StartStream() argument
|
| D | method_lookup_test.cc | 25 StatusWithSize TestRpc(ServerContext&, ConstByteSpan, ByteSpan) { in TestRpc() argument
29 void TestStreamRpc(ServerContext&, in TestStreamRpc() argument
40 Status TestRpc(ServerContext&, in TestRpc() argument
46 void TestStreamRpc(ServerContext&, ConstByteSpan, RawServerWriter&) { in TestStreamRpc() argument
|
| /external/pigweed/pw_rpc/raw/ |
| D | raw_method_test.cc | 36 StatusWithSize Unary(ServerContext&, ConstByteSpan, ByteSpan) { in Unary() argument
40 static StatusWithSize StaticUnary(ServerContext&, ConstByteSpan, ByteSpan) { in StaticUnary() argument
44 void ServerStreaming(ServerContext&, ConstByteSpan, RawServerWriter&) {} in ServerStreaming() argument
46 static void StaticServerStreaming(ServerContext&, in StaticServerStreaming() argument
50 StatusWithSize UnaryWrongArg(ServerContext&, ConstByteSpan, ConstByteSpan) { in UnaryWrongArg() argument
54 static void StaticUnaryVoidReturn(ServerContext&, ConstByteSpan, ByteSpan) {} in StaticUnaryVoidReturn() argument
56 Status ServerStreamingBadReturn(ServerContext&, in ServerStreamingBadReturn() argument
112 StatusWithSize AddFive(ServerContext&, in AddFive() argument
126 void StartStream(ServerContext&, in StartStream() argument
|
| /external/pigweed/pw_trace_tokenized/public/pw_trace_tokenized/ |
| D | trace_rpc_service_nanopb.h | 22 pw::Status Enable(ServerContext&,
26 pw::Status IsEnabled(ServerContext&,
30 void GetTraceData(ServerContext&,
|
| /external/grpc-grpc/test/cpp/interop/ |
| D | interop_server.cc | 50 using grpc::ServerContext;
72 void MaybeEchoMetadata(ServerContext* context) { in MaybeEchoMetadata()
108 bool CheckExpectedCompression(const ServerContext& context, in CheckExpectedCompression()
141 Status EmptyCall(ServerContext* context, const grpc::testing::Empty* request, in EmptyCall()
148 Status CacheableUnaryCall(ServerContext* context, in CacheableUnaryCall()
158 Status UnaryCall(ServerContext* context, const SimpleRequest* request, in UnaryCall()
194 ServerContext* context, const StreamingOutputCallRequest* request, in StreamingOutputCall()
234 Status StreamingInputCall(ServerContext* context, in StreamingInputCall()
254 ServerContext* context, in FullDuplexCall()
290 ServerContext* context, in HalfDuplexCall()
|
| /external/google-fruit/examples/server/ |
| D | foo_handler.cpp | 27 const ServerContext& serverContext;
30 INJECT(FooHandlerImpl(const Request& request, const ServerContext& serverContext)) in INJECT()
39 Component<Required<Request, ServerContext>, FooHandler> getFooHandlerComponent() { in getFooHandlerComponent()
|