| /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 | 43 virtual ::grpc::Status CreateSession(::grpc::ClientContext* context,
46 virtual ::grpc::Status ExtendSession(::grpc::ClientContext* context,
50 ::grpc::ClientContext* context, const PartialRunSetupRequest& request,
52 virtual ::grpc::Status RunStep(::grpc::ClientContext* context,
55 virtual ::grpc::Status CloseSession(::grpc::ClientContext* context,
58 virtual ::grpc::Status ListDevices(::grpc::ClientContext* context,
61 virtual ::grpc::Status Reset(::grpc::ClientContext* context,
64 virtual ::grpc::Status MakeCallable(::grpc::ClientContext* context,
67 virtual ::grpc::Status RunCallable(::grpc::ClientContext* context,
71 ::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/tensorflow/tensorflow/contrib/bigtable/kernels/test_kernels/ |
| D | bigtable_test_client.h | 35 grpc::ClientContext* context,
40 grpc::ClientContext* context,
45 grpc::ClientContext* context,
52 grpc::ClientContext* context,
58 ReadRows(grpc::ClientContext* context,
63 grpc::ClientContext* context,
68 MutateRows(grpc::ClientContext* context,
73 AsyncMutateRow(grpc::ClientContext* context,
80 ::grpc::ClientContext* context,
86 AsyncMutateRows(::grpc::ClientContext* context,
[all …]
|
| D | bigtable_test_client.cc | 313 grpc::ClientContext* context, in MutateRow()
325 grpc::ClientContext* context, in CheckAndMutateRow()
332 grpc::ClientContext* context, in ReadModifyWriteRow()
341 grpc::ClientContext* context, in AsyncReadModifyWriteRow()
352 grpc::ClientContext* context, in ReadRows()
360 grpc::ClientContext* context, in SampleRowKeys()
367 grpc::ClientContext* context, in MutateRows()
383 grpc::ClientContext* context, in AsyncMutateRow()
394 ::grpc::ClientContext* context, in AsyncSampleRowKeys()
405 ::grpc::ClientContext* context, in AsyncMutateRows()
[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/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_service.h | 46 virtual ::grpc::Status CreateContext(::grpc::ClientContext* context,
49 virtual ::grpc::Status Enqueue(::grpc::ClientContext* context,
52 virtual ::grpc::Status WaitQueueDone(::grpc::ClientContext* context,
55 virtual ::grpc::Status KeepAlive(::grpc::ClientContext* context,
58 virtual ::grpc::Status CloseContext(::grpc::ClientContext* context,
62 ::grpc::ClientContext* context, const RegisterFunctionRequest& request,
64 virtual ::grpc::Status SendTensor(::grpc::ClientContext* context,
71 ::grpc::Status CreateContext(::grpc::ClientContext* context,
74 ::grpc::Status Enqueue(::grpc::ClientContext* context,
77 ::grpc::Status WaitQueueDone(::grpc::ClientContext* context,
[all …]
|
| D | grpc_eager_service.cc | 71 ::grpc::ClientContext* context, const CreateContextRequest& request, in CreateContext()
77 ::grpc::Status EagerService::Stub::Enqueue(::grpc::ClientContext* context, in Enqueue()
85 ::grpc::ClientContext* context, const WaitQueueDoneRequest& request, in WaitQueueDone()
91 ::grpc::Status EagerService::Stub::KeepAlive(::grpc::ClientContext* context, in KeepAlive()
99 ::grpc::ClientContext* context, const CloseContextRequest& request, in CloseContext()
106 ::grpc::ClientContext* context, const RegisterFunctionRequest& request, in RegisterFunction()
112 ::grpc::Status EagerService::Stub::SendTensor(::grpc::ClientContext* context, in SendTensor()
|
| /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&);
|
| D | client_unary_call.h | 31 class ClientContext; variable
39 ClientContext* context, const InputMessage& request, in BlockingUnaryCall()
50 ClientContext* context, const InputMessage& request, in BlockingUnaryCallImpl()
|
| /external/grpc-grpc/test/cpp/end2end/ |
| 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 …]
|
| 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 …]
|
| /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 …]
|
| D | reconnect_interop_client.cc | 43 using grpc::ClientContext;
63 ClientContext start_context; in main()
88 ClientContext retry_context; in main()
96 ClientContext stop_context; in main()
|
| /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/doc/ |
| D | binary-logging.md | 21 LogRequestHeaders(ClientContext context);
27 LogResponseHeaders(ClientContext context);
33 LogStatus(ClientContext context, grpc_status_code code, string details);
39 LogUserData(ClientContext context);
44 LogRequestMessage(ClientContext context, uint32_t length, T message);
48 LogResponseMessage(ClientContext context, uint32_t length, T message);
|
| D | unit_testing.md | 23 …virtual ::grpc::Status Echo(::grpc::ClientContext* context, const ::grpc::testing::EchoRequest& re…
25 …:testing::EchoRequest, ::grpc::testing::EchoResponse>> BidiStream(::grpc::ClientContext* context) {
30 …ng::EchoRequest, ::grpc::testing::EchoResponse>* BidiStreamRaw(::grpc::ClientContext* context) = 0;
46 …MOCK_METHOD3(Echo, ::grpc::Status(::grpc::ClientContext* context, const ::grpc::testing::EchoReque…
47 …ce< ::grpc::testing::EchoRequest, ::grpc::testing::EchoResponse>*(::grpc::ClientContext* context));
92 ClientContext context;
104 ClientContext context;
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | client_async.cc | 71 BenchmarkService::Stub*, grpc::ClientContext*, const RequestType&, in ClientRpcContextUnaryImpl() argument
119 grpc::ClientContext context_;
130 BenchmarkService::Stub*, grpc::ClientContext*, const RequestType&,
322 PrepareReq(BenchmarkService::Stub* stub, grpc::ClientContext* ctx, in PrepareReq()
343 BenchmarkService::Stub*, grpc::ClientContext*, CompletionQueue*)> in ClientRpcContextStreamingPingPongImpl() argument
434 grpc::ClientContext context_;
455 BenchmarkService::Stub*, grpc::ClientContext*, CompletionQueue*)>
504 PrepareReq(BenchmarkService::Stub* stub, grpc::ClientContext* ctx, in PrepareReq()
527 BenchmarkService::Stub*, grpc::ClientContext*, ResponseType*, in ClientRpcContextStreamingFromClientImpl() argument
589 grpc::ClientContext context_;
[all …]
|
| /external/apache-http/src/org/apache/http/impl/client/ |
| D | DefaultUserTokenHandler.java | 41 import org.apache.http.client.protocol.ClientContext;
59 ClientContext.TARGET_AUTH_STATE); in getUserToken()
64 ClientContext.PROXY_AUTH_STATE); in getUserToken()
|
| /external/apache-http/src/org/apache/http/client/protocol/ |
| D | RequestAddCookies.java | 94 ClientContext.COOKIE_STORE); in process()
102 ClientContext.COOKIESPEC_REGISTRY); in process()
193 context.setAttribute(ClientContext.COOKIE_SPEC, cookieSpec); in process()
194 context.setAttribute(ClientContext.COOKIE_ORIGIN, cookieOrigin); in process()
|