| /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/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,
|
| D | proto_server_reflection.cc | 48 ServerContext* context, in ServerReflectionInfo()
100 Status ProtoServerReflection::ListService(ServerContext* context, in ListService()
113 ServerContext* context, const grpc::string& filename, in GetFileByName()
130 ServerContext* context, const grpc::string& symbol, in GetFileContainingSymbol()
147 ServerContext* context, const ExtensionRequest* request, in GetFileContainingExtension()
171 ServerContext* context, const grpc::string& type, in GetAllExtensionNumbers()
|
| /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);
|
| D | service_type.h | 35 class ServerContext; variable
92 void RequestAsyncUnary(int index, ServerContext* context, Message* request, in RequestAsyncUnary()
104 int index, ServerContext* context, in RequestAsyncClientStreaming()
113 int index, ServerContext* context, Message* request, in RequestAsyncServerStreaming()
121 int index, ServerContext* context, in RequestAsyncBidiStreaming()
|
| /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/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_master_service_impl.h | 130 ::grpc::ServerContext* context, CreateSessionRequest* request, in RequestCreateSession()
138 ::grpc::ServerContext* context, ExtendSessionRequest* request, in RequestExtendSession()
146 ::grpc::ServerContext* context, PartialRunSetupRequest* request, in RequestPartialRunSetup()
154 ::grpc::ServerContext* context, RunStepRequest* request, in RequestRunStep()
162 ::grpc::ServerContext* context, CloseSessionRequest* request, in RequestCloseSession()
170 ::grpc::ServerContext* context, ListDevicesRequest* request, in RequestListDevices()
178 ::grpc::ServerContext* context, ResetRequest* request, in RequestReset()
186 ::grpc::ServerContext* context, MakeCallableRequest* request, in RequestMakeCallable()
194 ::grpc::ServerContext* context, RunCallableRequest* request, in RequestRunCallable()
202 ::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/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,
|
| D | channelz_service.cc | 32 ServerContext* unused, const channelz::v1::GetTopChannelsRequest* request, in GetTopChannels()
48 ServerContext* unused, const channelz::v1::GetServersRequest* request, in GetServers()
64 ServerContext* unused, const channelz::v1::GetChannelRequest* request, in GetChannel()
80 ServerContext* unused, const channelz::v1::GetSubchannelRequest* request, in GetSubchannel()
|
| /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/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| D | eager_service_impl.cc | 133 new ServerContext(std::move(ctx), request->keep_alive_secs(), env_)); in CreateContext()
152 ServerContext* server_context, in ExecuteOp()
204 ServerContext* context = nullptr; in Enqueue()
223 ServerContext* context = nullptr; in WaitQueueDone()
237 ServerContext* context = nullptr; in KeepAlive()
246 ServerContext* context = nullptr; in CloseContext()
268 ServerContext* context = nullptr; in RegisterFunction()
277 ServerContext* context = nullptr; in SendTensor()
305 uint64 context_id, ServerContext** server_context) { in GetServerContext()
|
| D | eager_service_impl.h | 105 class ServerContext : public core::RefCounted {
107 explicit ServerContext(std::unique_ptr<tensorflow::EagerContext> ctx, in ServerContext() function
114 ~ServerContext() { in ~ServerContext()
195 tensorflow::Status GetServerContext(uint64, ServerContext**);
198 Status ExecuteOp(const Operation& operation, ServerContext* server_context,
203 std::unordered_map<uint64, ServerContext*> contexts_ GUARDED_BY(contexts_mu_);
|
| /external/grpc-grpc/test/cpp/codegen/ |
| D | compiler_test_golden | 45 class ServerContext;
214 …virtual ::grpc::Status MethodA1(::grpc::ServerContext* context, const ::grpc::testing::Request* re…
220 …virtual ::grpc::Status MethodA2(::grpc::ServerContext* context, ::grpc::ServerReader< ::grpc::test…
223 …virtual ::grpc::Status MethodA3(::grpc::ServerContext* context, const ::grpc::testing::Request* re…
226 …virtual ::grpc::Status MethodA4(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::grpc…
241 …::grpc::Status MethodA1(::grpc::ServerContext* context, const ::grpc::testing::Request* request, :…
245 …void RequestMethodA1(::grpc::ServerContext* context, ::grpc::testing::Request* request, ::grpc::Se…
261 …::grpc::Status MethodA2(::grpc::ServerContext* context, ::grpc::ServerReader< ::grpc::testing::Req…
265 …void RequestMethodA2(::grpc::ServerContext* context, ::grpc::ServerAsyncReader< ::grpc::testing::R…
281 …::grpc::Status MethodA3(::grpc::ServerContext* context, const ::grpc::testing::Request* request, :…
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_service.h | 112 ::grpc::ServerContext* context, CreateContextRequest* request, in RequestCreateContext()
120 ::grpc::ServerContext* context, EnqueueRequest* request, in RequestEnqueue()
128 ::grpc::ServerContext* context, WaitQueueDoneRequest* request, in RequestWaitQueueDone()
136 ::grpc::ServerContext* context, KeepAliveRequest* request, in RequestKeepAlive()
144 ::grpc::ServerContext* context, CloseContextRequest* request, in RequestCloseContext()
152 ::grpc::ServerContext* context, RegisterFunctionRequest* request, in RequestRegisterFunction()
160 ::grpc::ServerContext* context, SendTensorRequest* request, in RequestSendTensor()
|
| /external/grpc-grpc/doc/ |
| D | binary-logging.md | 23 LogRequestHeaders(ServerContext context);
29 LogResponseHeaders(ServerContext context);
35 LogStatus(ServerContext context, grpc_status_code code, string details);
41 LogUserData(ServerContext context);
46 LogRequestMessage(ServerContext context, uint32_t length, T message);
50 LogResponseMessage(ServerContext context, uint32_t length, T message);
|
| /external/flatbuffers/tests/ |
| D | monster_test.grpc.fb.h | 24 class ServerContext; variable
147 …virtual ::grpc::Status Store(::grpc::ServerContext* context, const flatbuffers::grpc::Message<Mons…
148 …virtual ::grpc::Status Retrieve(::grpc::ServerContext* context, const flatbuffers::grpc::Message<S…
149 …virtual ::grpc::Status GetMaxHitPoint(::grpc::ServerContext* context, ::grpc::ServerReader< flatbu…
150 …virtual ::grpc::Status GetMinMaxHitPoints(::grpc::ServerContext* context, ::grpc::ServerReaderWrit…
164 …::grpc::Status Store(::grpc::ServerContext* context, const flatbuffers::grpc::Message<Monster>* re… in Store()
168 …void RequestStore(::grpc::ServerContext* context, flatbuffers::grpc::Message<Monster>* request, ::… in RequestStore()
184 …::grpc::Status Retrieve(::grpc::ServerContext* context, const flatbuffers::grpc::Message<Stat>* re… in Retrieve()
188 …void RequestRetrieve(::grpc::ServerContext* context, flatbuffers::grpc::Message<Stat>* request, ::… in RequestRetrieve()
204 …::grpc::Status GetMaxHitPoint(::grpc::ServerContext* context, ::grpc::ServerReader< flatbuffers::g… in GetMaxHitPoint()
[all …]
|
| /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()
|
| D | bar_handler.cpp | 27 const ServerContext& serverContext;
30 INJECT(BarHandlerImpl(const Request& request, const ServerContext& serverContext)) in INJECT()
39 Component<Required<Request, ServerContext>, BarHandler> getBarHandlerComponent() { in getBarHandlerComponent()
|
| D | server.cpp | 39 …void run(Component<Required<Request, ServerContext>, RequestDispatcher> (*getRequestDispatcherComp… in run() argument
40 ServerContext serverContext; in run()
91 … Component<Required<Request, ServerContext>, RequestDispatcher> (*getRequestDispatcherComponent)(), in getRequestDispatcherComponentWithContext() argument
92 ServerContext* serverContext) { in getRequestDispatcherComponentWithContext()
|
| /external/grpc-grpc/test/cpp/test/ |
| D | server_context_test_spouse_test.cc | 37 bool ClientMetadataContains(const ServerContext& context, in ClientMetadataContains()
51 ServerContext context; in TEST()
63 ServerContext context; in TEST()
77 ServerContext context; in TEST()
|