| /external/rust/crates/grpcio-sys/grpc/src/cpp/client/ |
| D | client_context.cc | 39 : public ClientContext::GlobalCallbacks {
42 void DefaultConstructor(ClientContext* /*context*/) override {} in DefaultConstructor() argument
43 void Destructor(ClientContext* /*context*/) override {} in Destructor() argument
49 static ClientContext::GlobalCallbacks* g_client_callbacks =
52 ClientContext::ClientContext() in ClientContext() function in grpc::ClientContext
68 ClientContext::~ClientContext() { in ~ClientContext()
75 void ClientContext::set_credentials( in set_credentials()
91 std::unique_ptr<ClientContext> ClientContext::FromInternalServerContext( in FromInternalServerContext()
93 std::unique_ptr<ClientContext> ctx(new ClientContext); in FromInternalServerContext()
99 std::unique_ptr<ClientContext> ClientContext::FromServerContext( in FromServerContext()
[all …]
|
| /external/grpc-grpc/src/cpp/client/ |
| D | client_context.cc | 35 : public ClientContext::GlobalCallbacks {
38 void DefaultConstructor(ClientContext* context) override {} in DefaultConstructor()
39 void Destructor(ClientContext* context) override {} in Destructor()
44 static ClientContext::GlobalCallbacks* g_client_callbacks =
47 ClientContext::ClientContext() in ClientContext() function in grpc::ClientContext
62 ClientContext::~ClientContext() { in ~ClientContext()
69 std::unique_ptr<ClientContext> ClientContext::FromServerContext( in FromServerContext()
71 std::unique_ptr<ClientContext> ctx(new ClientContext); in FromServerContext()
77 void ClientContext::AddMetadata(const grpc::string& meta_key, in AddMetadata()
82 void ClientContext::set_call(grpc_call* call, in set_call()
[all …]
|
| D | generic_stub.cc | 29 ChannelInterface* channel, ClientContext* context, in CallInternal()
43 ClientContext* context, const grpc::string& method, CompletionQueue* cq, in Call()
50 ClientContext* context, const grpc::string& method, CompletionQueue* cq) { in PrepareCall()
56 ClientContext* context, const grpc::string& method, in PrepareUnaryCall()
66 ClientContext* context, const grpc::string& method, in UnaryCall()
|
| /external/tensorflow/tensorflow/compiler/xla/rpc/ |
| D | grpc_stub.cc | 24 const std::function<::grpc::Status(::grpc::ClientContext*)>& rpc_method) { in MakeRPC()
25 ::grpc::ClientContext context; in MakeRPC()
32 return MakeRPC([this, request, response](::grpc::ClientContext* context) { in TransferToClient()
39 return MakeRPC([this, request, response](::grpc::ClientContext* context) { in TransferToServer()
46 return MakeRPC([this, request, response](::grpc::ClientContext* context) { in TransferToInfeed()
53 return MakeRPC([this, request, response](::grpc::ClientContext* context) { in TransferFromOutfeed()
60 return MakeRPC([this, request, response](::grpc::ClientContext* context) { in ResetDevice()
67 return MakeRPC([this, request, response](::grpc::ClientContext* context) { in Compile()
74 return MakeRPC([this, request, response](::grpc::ClientContext* context) { in Execute()
82 return MakeRPC([this, request, response](::grpc::ClientContext* context) { in ExecuteGraphParallel()
[all …]
|
| /external/grpc-grpc/test/cpp/codegen/ |
| D | compiler_test_mock_golden | 16 …MOCK_METHOD3(MethodA1, ::grpc::Status(::grpc::ClientContext* context, const ::grpc::testing::Reque…
17 …ientAsyncResponseReaderInterface< ::grpc::testing::Response>*(::grpc::ClientContext* context, cons…
18 …ientAsyncResponseReaderInterface< ::grpc::testing::Response>*(::grpc::ClientContext* context, cons…
19 …aw, ::grpc::ClientWriterInterface< ::grpc::testing::Request>*(::grpc::ClientContext* context, ::gr…
20 …:grpc::ClientAsyncWriterInterface< ::grpc::testing::Request>*(::grpc::ClientContext* context, ::gr…
21 …:grpc::ClientAsyncWriterInterface< ::grpc::testing::Request>*(::grpc::ClientContext* context, ::gr…
22 …w, ::grpc::ClientReaderInterface< ::grpc::testing::Response>*(::grpc::ClientContext* context, cons…
23 …grpc::ClientAsyncReaderInterface< ::grpc::testing::Response>*(::grpc::ClientContext* context, cons…
24 …grpc::ClientAsyncReaderInterface< ::grpc::testing::Response>*(::grpc::ClientContext* context, cons…
25 …rInterface< ::grpc::testing::Request, ::grpc::testing::Response>*(::grpc::ClientContext* context));
[all …]
|
| D | compiler_test_golden | 65 …virtual ::grpc::Status MethodA1(::grpc::ClientContext* context, const ::grpc::testing::Request& re…
66 …nseReaderInterface< ::grpc::testing::Response>> AsyncMethodA1(::grpc::ClientContext* context, cons…
69 …erInterface< ::grpc::testing::Response>> PrepareAsyncMethodA1(::grpc::ClientContext* context, cons…
77 …c::ClientWriterInterface< ::grpc::testing::Request>> MethodA2(::grpc::ClientContext* context, ::gr…
80 …syncWriterInterface< ::grpc::testing::Request>> AsyncMethodA2(::grpc::ClientContext* context, ::gr…
83 …terInterface< ::grpc::testing::Request>> PrepareAsyncMethodA2(::grpc::ClientContext* context, ::gr…
88 …::ClientReaderInterface< ::grpc::testing::Response>> MethodA3(::grpc::ClientContext* context, cons…
91 …yncReaderInterface< ::grpc::testing::Response>> AsyncMethodA3(::grpc::ClientContext* context, cons…
94 …erInterface< ::grpc::testing::Response>> PrepareAsyncMethodA3(::grpc::ClientContext* context, cons…
99 …e< ::grpc::testing::Request, ::grpc::testing::Response>> MethodA4(::grpc::ClientContext* context) {
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_master_service_impl.h | 45 virtual ::grpc::Status CreateSession(::grpc::ClientContext* context,
48 virtual ::grpc::Status ExtendSession(::grpc::ClientContext* context,
52 ::grpc::ClientContext* context, const PartialRunSetupRequest& request,
54 virtual ::grpc::Status RunStep(::grpc::ClientContext* context,
57 virtual ::grpc::Status CloseSession(::grpc::ClientContext* context,
60 virtual ::grpc::Status ListDevices(::grpc::ClientContext* context,
63 virtual ::grpc::Status Reset(::grpc::ClientContext* context,
66 virtual ::grpc::Status MakeCallable(::grpc::ClientContext* context,
69 virtual ::grpc::Status RunCallable(::grpc::ClientContext* context,
73 ::grpc::ClientContext* context, const ReleaseCallableRequest& request,
[all …]
|
| D | grpc_master_service_impl.cc | 80 ::grpc::ClientContext* context, const CreateSessionRequest& request, in CreateSession()
87 ::grpc::ClientContext* context, const ExtendSessionRequest& request, in ExtendSession()
94 ::grpc::ClientContext* context, const PartialRunSetupRequest& request, in PartialRunSetup()
100 ::grpc::Status MasterService::Stub::RunStep(::grpc::ClientContext* context, in RunStep()
108 ::grpc::ClientContext* context, const CloseSessionRequest& request, in CloseSession()
115 ::grpc::ClientContext* context, const ListDevicesRequest& request, in ListDevices()
121 ::grpc::Status MasterService::Stub::Reset(::grpc::ClientContext* context, in Reset()
129 ::grpc::ClientContext* context, const MakeCallableRequest& request, in MakeCallable()
136 ::grpc::ClientContext* context, const RunCallableRequest& request, in RunCallable()
143 ::grpc::ClientContext* context, const ReleaseCallableRequest& request, in ReleaseCallable()
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/generic/ |
| D | generic_stub.h | 54 PrepareCall(ClientContext* context, const std::string& method, in PrepareCall()
64 ClientContext* context, const std::string& method, in PrepareUnaryCall()
81 ClientContext* context, const std::string& method, in Call()
89 void UnaryCall(ClientContext* context, const std::string& method, in UnaryCall()
100 void PrepareUnaryCall(ClientContext* context, const std::string& method, in PrepareUnaryCall()
110 ClientContext* context, const std::string& method, in PrepareBidiStreamingCall()
125 void UnaryCall(ClientContext* context, const std::string& method, in UnaryCall()
136 void PrepareUnaryCall(ClientContext* context, const std::string& method, in PrepareUnaryCall()
147 ClientContext* context, const std::string& method, in PrepareBidiStreamingCall()
164 void UnaryCallInternal(ClientContext* context, const std::string& method, in UnaryCallInternal()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/generic/ |
| D | generic_stub.h | 54 PrepareCall(ClientContext* context, const std::string& method, in PrepareCall()
64 ClientContext* context, const std::string& method, in PrepareUnaryCall()
81 ClientContext* context, const std::string& method, in Call()
89 void UnaryCall(ClientContext* context, const std::string& method, in UnaryCall()
100 void PrepareUnaryCall(ClientContext* context, const std::string& method, in PrepareUnaryCall()
110 ClientContext* context, const std::string& method, in PrepareBidiStreamingCall()
125 void UnaryCall(ClientContext* context, const std::string& method, in UnaryCall()
136 void PrepareUnaryCall(ClientContext* context, const std::string& method, in PrepareUnaryCall()
147 ClientContext* context, const std::string& method, in PrepareBidiStreamingCall()
164 void UnaryCallInternal(ClientContext* context, const std::string& method, in UnaryCallInternal()
[all …]
|
| /external/flatbuffers/tests/ |
| D | monster_test.grpc.fb.h | 38 …virtual ::grpc::Status Store(::grpc::ClientContext* context, const flatbuffers::grpc::Message<Mons…
39 …eaderInterface< flatbuffers::grpc::Message<Stat>>> AsyncStore(::grpc::ClientContext* context, cons… in AsyncStore()
42 …terface< flatbuffers::grpc::Message<Stat>>> PrepareAsyncStore(::grpc::ClientContext* context, cons… in PrepareAsyncStore()
45 …aderInterface< flatbuffers::grpc::Message<Monster>>> Retrieve(::grpc::ClientContext* context, cons… in Retrieve()
48 …nterface< flatbuffers::grpc::Message<Monster>>> AsyncRetrieve(::grpc::ClientContext* context, cons… in AsyncRetrieve()
51 …e< flatbuffers::grpc::Message<Monster>>> PrepareAsyncRetrieve(::grpc::ClientContext* context, cons… in PrepareAsyncRetrieve()
54 …terface< flatbuffers::grpc::Message<Monster>>> GetMaxHitPoint(::grpc::ClientContext* context, flat… in GetMaxHitPoint()
57 …ce< flatbuffers::grpc::Message<Monster>>> AsyncGetMaxHitPoint(::grpc::ClientContext* context, flat… in AsyncGetMaxHitPoint()
60 …tbuffers::grpc::Message<Monster>>> PrepareAsyncGetMaxHitPoint(::grpc::ClientContext* context, flat… in PrepareAsyncGetMaxHitPoint()
63 …e<Monster>, flatbuffers::grpc::Message<Stat>>> GetMinMaxHitPoints(::grpc::ClientContext* context) { in GetMinMaxHitPoints()
[all …]
|
| D | monster_test.grpc.fb.cc | 38 ::grpc::Status MonsterStorage::Stub::Store(::grpc::ClientContext* context, const flatbuffers::grpc:… in Store()
42 …rs::grpc::Message<Stat>>* MonsterStorage::Stub::AsyncStoreRaw(::grpc::ClientContext* context, cons… in AsyncStoreRaw()
46 …c::Message<Stat>>* MonsterStorage::Stub::PrepareAsyncStoreRaw(::grpc::ClientContext* context, cons… in PrepareAsyncStoreRaw()
50 …s::grpc::Message<Monster>>* MonsterStorage::Stub::RetrieveRaw(::grpc::ClientContext* context, cons… in RetrieveRaw()
54 …pc::Message<Monster>>* MonsterStorage::Stub::AsyncRetrieveRaw(::grpc::ClientContext* context, cons… in AsyncRetrieveRaw()
58 …sage<Monster>>* MonsterStorage::Stub::PrepareAsyncRetrieveRaw(::grpc::ClientContext* context, cons… in PrepareAsyncRetrieveRaw()
62 …c::Message<Monster>>* MonsterStorage::Stub::GetMaxHitPointRaw(::grpc::ClientContext* context, flat… in GetMaxHitPointRaw()
66 …ssage<Monster>>* MonsterStorage::Stub::AsyncGetMaxHitPointRaw(::grpc::ClientContext* context, flat… in AsyncGetMaxHitPointRaw()
70 …onster>>* MonsterStorage::Stub::PrepareAsyncGetMaxHitPointRaw(::grpc::ClientContext* context, flat… in PrepareAsyncGetMaxHitPointRaw()
74 …grpc::Message<Stat>>* MonsterStorage::Stub::GetMinMaxHitPointsRaw(::grpc::ClientContext* context) { in GetMinMaxHitPointsRaw()
[all …]
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | client_context.h | 63 class ClientContext; variable
164 class ClientContext {
166 ClientContext();
167 ~ClientContext();
179 static std::unique_ptr<ClientContext> FromServerContext(
353 virtual void DefaultConstructor(ClientContext* context) = 0;
354 virtual void Destructor(ClientContext* context) = 0;
371 ClientContext(const ClientContext&);
372 ClientContext& operator=(const ClientContext&);
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | channelz_service_test.cc | 67 std::unique_ptr<ClientContext> client_context = in Echo()
68 ClientContext::FromServerContext(*server_context); in Echo()
146 ClientContext context; in SendSuccessfulEcho()
160 ClientContext context; in SendFailedEcho()
171 ClientContext context; in GetChannelId()
210 ClientContext context; in TEST_F()
222 ClientContext context; in TEST_F()
235 ClientContext context; in TEST_F()
250 ClientContext context; in TEST_F()
273 ClientContext context; in TEST_F()
[all …]
|
| D | end2end_test.cc | 176 std::unique_ptr<ClientContext> client_context = in Echo()
177 ClientContext::FromServerContext(*server_context); in Echo()
347 ClientContext context; in SendRpc()
382 ClientContext context; in TestRequestStreamServerCancel()
455 ClientContext context; in TestResponseStreamServerCancel()
532 ClientContext context; in TestBidiStreamServerCancel()
602 ClientContext context; in TEST_P()
672 ClientContext context; in TEST_P()
736 ClientContext context; in TEST_P()
752 ClientContext context; in TEST_P()
[all …]
|
| /external/tensorflow/tensorflow/core/tpu/kernels/ |
| D | tpu_compilation_cache_grpc.h | 73 virtual ::grpc::Status GetTpuProgram(::grpc::ClientContext* context,
77 AsyncGetTpuProgram(::grpc::ClientContext* context, in AsyncGetTpuProgram()
85 PrepareAsyncGetTpuProgram(::grpc::ClientContext* context, in PrepareAsyncGetTpuProgram()
95 AsyncGetTpuProgramRaw(::grpc::ClientContext* context,
99 PrepareAsyncGetTpuProgramRaw(::grpc::ClientContext* context,
106 ::grpc::Status GetTpuProgram(::grpc::ClientContext* context,
110 AsyncGetTpuProgram(::grpc::ClientContext* context, in AsyncGetTpuProgram()
117 PrepareAsyncGetTpuProgram(::grpc::ClientContext* context, in PrepareAsyncGetTpuProgram()
127 ::grpc::ClientContext* context, const RequestType& request,
130 PrepareAsyncGetTpuProgramRaw(::grpc::ClientContext* context,
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | client_context.h | 192 class ClientContext {
194 ClientContext();
195 ~ClientContext();
207 static std::unique_ptr<ClientContext> FromServerContext(
210 static std::unique_ptr<ClientContext> FromCallbackServerContext(
404 virtual void DefaultConstructor(ClientContext* context) = 0;
405 virtual void Destructor(ClientContext* context) = 0;
422 ClientContext(const ClientContext&);
423 ClientContext& operator=(const ClientContext&);
491 static std::unique_ptr<ClientContext> FromInternalServerContext(
|
| D | async_unary_call.h | 93 const ::grpc::internal::RpcMethod& method, ::grpc::ClientContext* context, in Create()
113 std::function<void(ClientContext*, internal::Call*, in SetupRequest() argument
117 void(ClientContext*, internal::Call*, bool initial_metadata_read, in SetupRequest()
142 [](ClientContext* context, internal::Call* call, in SetupRequest()
157 *finish = [](ClientContext* context, internal::Call* call, in SetupRequest()
188 ::grpc::ClientContext* context, in StartCall()
203 const ::grpc::internal::RpcMethod& method, ::grpc::ClientContext* context, in Create()
266 ::grpc::ClientContext* const context_;
272 ::grpc::ClientContext* context) in ClientAsyncResponseReader()
281 std::function<void(ClientContext*, internal::Call*,
[all …]
|
| D | client_interceptor.h | 32 class ClientContext; variable
95 grpc::ClientContext* client_context() { return ctx_; } in client_context()
118 ClientRpcInfo(grpc::ClientContext* ctx, internal::RpcMethod::RpcType type, in ClientRpcInfo()
161 grpc::ClientContext* ctx_ = nullptr;
171 friend class grpc::ClientContext;
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | client_context.h | 192 class ClientContext {
194 ClientContext();
195 ~ClientContext();
207 static std::unique_ptr<ClientContext> FromServerContext(
210 static std::unique_ptr<ClientContext> FromCallbackServerContext(
404 virtual void DefaultConstructor(ClientContext* context) = 0;
405 virtual void Destructor(ClientContext* context) = 0;
422 ClientContext(const ClientContext&);
423 ClientContext& operator=(const ClientContext&);
491 static std::unique_ptr<ClientContext> FromInternalServerContext(
|
| D | async_unary_call.h | 93 const ::grpc::internal::RpcMethod& method, ::grpc::ClientContext* context, in Create()
113 std::function<void(ClientContext*, internal::Call*, in SetupRequest() argument
117 void(ClientContext*, internal::Call*, bool initial_metadata_read, in SetupRequest()
142 [](ClientContext* context, internal::Call* call, in SetupRequest()
157 *finish = [](ClientContext* context, internal::Call* call, in SetupRequest()
188 ::grpc::ClientContext* context, in StartCall()
203 const ::grpc::internal::RpcMethod& method, ::grpc::ClientContext* context, in Create()
266 ::grpc::ClientContext* const context_;
272 ::grpc::ClientContext* context) in ClientAsyncResponseReader()
281 std::function<void(ClientContext*, internal::Call*,
[all …]
|
| D | client_interceptor.h | 32 class ClientContext; variable
95 grpc::ClientContext* client_context() { return ctx_; } in client_context()
118 ClientRpcInfo(grpc::ClientContext* ctx, internal::RpcMethod::RpcType type, in ClientRpcInfo()
161 grpc::ClientContext* ctx_ = nullptr;
171 friend class grpc::ClientContext;
|
| /external/tensorflow/tensorflow/core/data/service/ |
| D | data_service.cc | 72 grpc::ClientContext client_ctx; in WorkerHeartbeat()
96 grpc::ClientContext client_ctx; in WorkerUpdate()
110 grpc::ClientContext client_ctx; in GetDatasetDef()
127 grpc::ClientContext client_ctx; in GetSplit()
147 grpc::ClientContext client_ctx; in RegisterDataset()
171 grpc::ClientContext client_ctx; in GetOrCreateJob()
188 grpc::ClientContext client_ctx; in ReleaseJobClient()
201 grpc::ClientContext ctx; in ClientHeartbeat()
214 grpc::ClientContext ctx; in GetWorkers()
243 grpc::ClientContext ctx; in EnsureInitialized()
[all …]
|
| /external/grpc-grpc/include/grpcpp/generic/ |
| D | generic_stub.h | 48 ClientContext* context, const grpc::string& method, CompletionQueue* cq);
55 ClientContext* context, const grpc::string& method,
65 ClientContext* context, const grpc::string& method, CompletionQueue* cq,
75 void UnaryCall(ClientContext* context, const grpc::string& method,
|
| /external/grpc-grpc/test/cpp/interop/ |
| D | interop_client.cc | 158 ClientContext context; in DoEmpty()
178 ClientContext context; in PerformLargeUnary()
238 ClientContext context; in DoOauth2AuthToken()
261 ClientContext context; in DoPerRpcCreds()
310 ClientContext probe_context; in DoClientCompressedUnary()
393 ClientContext context; in DoRequestStreaming()
424 ClientContext context; in DoResponseStreaming()
462 ClientContext probe_context; in DoClientCompressedStreaming()
489 ClientContext context; in DoClientCompressedStreaming()
528 ClientContext context; in DoServerCompressedStreaming()
[all …]
|