| /external/google-fruit/examples/server/ |
| server_context.h | 23 struct ServerContext {
|
| bar_handler.cpp | 27 const ServerContext& serverContext;
30 INJECT(BarHandlerImpl(const Request& request, const ServerContext& serverContext))
31 : request(request), serverContext(serverContext) {}
34 cout << "BarHandler handling request on server started at " << serverContext.startupTime
39 Component<Required<Request, ServerContext>, BarHandler> getBarHandlerComponent() {
|
| foo_handler.cpp | 27 const ServerContext& serverContext;
30 INJECT(FooHandlerImpl(const Request& request, const ServerContext& serverContext))
31 : request(request), serverContext(serverContext) {}
34 cout << "FooHandler handling request on server started at " << serverContext.startupTime
39 Component<Required<Request, ServerContext>, FooHandler> getFooHandlerComponent() {
|
| bar_handler.h | 32 fruit::Component<fruit::Required<Request, ServerContext>, BarHandler> getBarHandlerComponent();
|
| foo_handler.h | 32 fruit::Component<fruit::Required<Request, ServerContext>, FooHandler> getFooHandlerComponent();
|
| request_dispatcher.h | 32 fruit::Component<fruit::Required<Request, ServerContext>, RequestDispatcher> getRequestDispatcherComponent();
|
| server.h | 29 virtual void run(fruit::Component<fruit::Required<Request, ServerContext>, RequestDispatcher> (
|
| server.cpp | 39 void run(Component<Required<Request, ServerContext>, RequestDispatcher> (*getRequestDispatcherComponent)()) override {
40 ServerContext serverContext;
41 serverContext.startupTime = getTime();
44 getRequestDispatcherComponentWithContext, getRequestDispatcherComponent, &serverContext);
91 Component<Required<Request, ServerContext>, RequestDispatcher> (*getRequestDispatcherComponent)(),
92 ServerContext* serverContext) {
93 return createComponent().install(getRequestDispatcherComponent).bindInstance(*serverContext);
|
| /external/grpc-grpc/include/grpcpp/ |
| opencensus.h | 45 class ServerContext;
48 ::opencensus::trace::Span GetSpanFromServerContext(ServerContext* context);
|
| /external/tensorflow/tensorflow/compiler/xla/rpc/ |
| 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...] |
| grpc_service.cc | 35 ::grpc::Status GRPCService::Unregister(::grpc::ServerContext* context,
42 ::grpc::Status GRPCService::DeconstructTuple(::grpc::ServerContext* context,
50 ::grpc::Status GRPCService::GetDeviceHandles(::grpc::ServerContext* context,
58 ::grpc::Status GRPCService::Compile(::grpc::ServerContext* /*context*/,
65 ::grpc::Status GRPCService::Execute(::grpc::ServerContext* /*context*/,
73 ::grpc::ServerContext* /*context*/, const ExecuteGraphParallelRequest* arg,
80 ::grpc::Status GRPCService::WaitForExecution(::grpc::ServerContext* context,
88 ::grpc::Status GRPCService::TransferToClient(::grpc::ServerContext* context,
96 ::grpc::Status GRPCService::TransferToServer(::grpc::ServerContext* context,
104 ::grpc::Status GRPCService::TransferToInfeed(::grpc::ServerContext* context
[all...] |
| /external/grpc-grpc/src/cpp/server/channelz/ |
| 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,
|
| channelz_service.cc | 32 ServerContext* unused, const channelz::v1::GetTopChannelsRequest* request,
48 ServerContext* unused, const channelz::v1::GetServersRequest* request,
64 ServerContext* unused, const channelz::v1::GetChannelRequest* request,
80 ServerContext* unused, const channelz::v1::GetSubchannelRequest* request,
|
| /external/grpc-grpc/src/cpp/ext/ |
| 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/grpc-grpc/src/cpp/server/ |
| server_context.cc | 40 class ServerContext::CompletionOp final : public internal::CallOpSetInterface {
83 void ServerContext::CompletionOp::Unref() {
91 void ServerContext::CompletionOp::FillOps(grpc_call* call, grpc_op* ops,
100 bool ServerContext::CompletionOp::FinalizeResult(void** tag, bool* status) {
116 // ServerContext body
118 ServerContext::ServerContext()
129 ServerContext::ServerContext(gpr_timespec deadline, grpc_metadata_array* arr)
142 ServerContext::~ServerContext()
[all...] |
| /external/grpc-grpc/test/cpp/end2end/ |
| 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/examples/cpp/helloworld/ |
| greeter_server.cc | 33 using grpc::ServerContext;
41 Status SayHello(ServerContext* context, const HelloRequest* request,
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| server_context.h | 82 /// A ServerContext allows the person implementing a service handler to:
96 /// \warning ServerContext instances should \em not be reused across rpcs.
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)
[all...] |
| method_handler_impl.h | 55 RpcMethodHandler(std::function<Status(ServiceType*, ServerContext*,
91 std::function<Status(ServiceType*, ServerContext*, const RequestType*,
103 std::function<Status(ServiceType*, ServerContext*,
135 std::function<Status(ServiceType*, ServerContext*, ServerReader<RequestType>*,
146 std::function<Status(ServiceType*, ServerContext*, const RequestType*,
181 std::function<Status(ServiceType*, ServerContext*, const RequestType*,
198 std::function<Status(ServerContext*, Streamer*)> func)
230 std::function<Status(ServerContext*, Streamer*)> func_;
240 std::function<Status(ServiceType*, ServerContext*,
255 std::function<Status(ServerContext*,
[all...] |
| rpc_service_method.h | 35 class ServerContext;
43 HandlerParameter(Call* c, ServerContext* context, grpc_byte_buffer* req)
49 ServerContext* server_context;
|
| server_interface.h | 35 class ServerContext;
149 BaseAsyncRequest(ServerInterface* server, ServerContext* context,
159 ServerContext* const context_;
169 RegisteredAsyncRequest(ServerInterface* server, ServerContext* context,
183 ServerContext* context,
198 ServerContext* context,
244 ServerContext* const context_;
269 ServerContext* context,
281 ServerContext* context,
|
| /external/grpc-grpc/test/cpp/util/ |
| metrics_server.h | 73 grpc::Status GetAllGauges(ServerContext* context, const EmptyMessage* request,
76 grpc::Status GetGauge(ServerContext* context, const GaugeRequest* request,
|
| /external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| eager_service_impl.h | 105 class ServerContext : public core::RefCounted {
107 explicit ServerContext(std::unique_ptr<tensorflow::EagerContext> ctx,
114 ~ServerContext() {
194 // The returned ServerContext will need to be Unrefed.
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/include/grpcpp/ext/ |
| server_load_reporting.h | 46 void AddLoadReportingCost(grpc::ServerContext* ctx,
|
| /external/grpc-grpc/src/cpp/server/load_reporter/ |
| util.cc | 31 void AddLoadReportingCost(grpc::ServerContext* ctx,
|
