| /external/grpc-grpc/test/cpp/end2end/ |
| D | test_service_impl.cc | 94 kServerTryCancelRequest, context->client_metadata(), DO_NOT_CANCEL); in Echo()
134 const std::multimap<grpc::string_ref, grpc::string_ref>& client_metadata = in Echo() local
135 context->client_metadata(); in Echo()
137 iter = client_metadata.begin(); in Echo()
138 iter != client_metadata.end(); ++iter) { in Echo()
182 kServerTryCancelRequest, context->client_metadata(), DO_NOT_CANCEL); in RequestStream()
232 kServerTryCancelRequest, context->client_metadata(), DO_NOT_CANCEL); in ResponseStream()
235 kServerUseCoalescingApi, context->client_metadata(), 0); in ResponseStream()
238 kServerResponseStreamsToSend, context->client_metadata(), in ResponseStream()
288 kServerTryCancelRequest, context->client_metadata(), DO_NOT_CANCEL); in BidiStream()
[all …]
|
| D | grpclb_end2end_test.cc | 138 context->client_metadata().find(g_kCallCredsMdKey); in Echo()
139 EXPECT_NE(call_credentials_entry, context->client_metadata().end()); in Echo()
140 if (call_credentials_entry != context->client_metadata().end()) { in Echo()
202 EXPECT_EQ(context->client_metadata().find(g_kCallCredsMdKey), in BalanceLoad()
203 context->client_metadata().end()); in BalanceLoad()
|
| D | server_early_return_test.cc | 102 auto metadata = context->client_metadata(); in GetIntValueFromMetadata()
|
| D | async_end2end_test.cc | 894 const auto& client_initial_metadata = srv_ctx.client_metadata(); in TEST_P()
1041 const auto& client_initial_metadata = srv_ctx.client_metadata(); in TEST_P()
|
| /external/grpc-grpc/test/cpp/interop/ |
| D | interop_server.cc | 73 const auto& client_metadata = context->client_metadata(); in MaybeEchoMetadata() local
74 GPR_ASSERT(client_metadata.count(kEchoInitialMetadataKey) <= 1); in MaybeEchoMetadata()
75 GPR_ASSERT(client_metadata.count(kEchoTrailingBinMetadataKey) <= 1); in MaybeEchoMetadata()
77 auto iter = client_metadata.find(kEchoInitialMetadataKey); in MaybeEchoMetadata()
78 if (iter != client_metadata.end()) { in MaybeEchoMetadata()
83 iter = client_metadata.find(kEchoTrailingBinMetadataKey); in MaybeEchoMetadata()
84 if (iter != client_metadata.end()) { in MaybeEchoMetadata()
91 iter = client_metadata.find(kEchoUserAgentKey); in MaybeEchoMetadata()
92 if (iter != client_metadata.end()) { in MaybeEchoMetadata()
93 iter = client_metadata.find("user-agent"); in MaybeEchoMetadata()
[all …]
|
| /external/grpc-grpc/test/cpp/util/ |
| D | cli_call_test.cc | 45 if (!context->client_metadata().empty()) { in Echo()
47 iter = context->client_metadata().begin(); in Echo()
48 iter != context->client_metadata().end(); ++iter) { in Echo()
107 std::multimap<grpc::string, grpc::string> client_metadata; in TEST_F() local
110 client_metadata.insert(std::pair<grpc::string, grpc::string>("key1", "val1")); in TEST_F()
112 client_metadata, &server_initial_metadata, in TEST_F()
|
| D | grpc_tool.cc | 122 std::multimap<grpc::string, grpc::string>* client_metadata) { in ParseMetadataFlag() argument
158 client_metadata->insert( in ParseMetadataFlag()
518 std::multimap<grpc::string, grpc::string> client_metadata; in CallMethod() local
519 ParseMetadataFlag(&client_metadata); in CallMethod()
520 PrintMetadata(client_metadata, "Sending client initial metadata:"); in CallMethod()
522 CliCall call(channel, formatted_method_name, client_metadata); in CallMethod()
619 std::multimap<grpc::string, grpc::string> client_metadata; in CallMethod() local
620 ParseMetadataFlag(&client_metadata); in CallMethod()
622 PrintMetadata(client_metadata, "Sending client initial metadata:"); in CallMethod()
648 CliCall call(channel, formatted_method_name, client_metadata); in CallMethod()
[all …]
|
| D | grpc_tool_test.cc | 134 if (!context->client_metadata().empty()) { in Echo()
136 iter = context->client_metadata().begin(); in Echo()
137 iter != context->client_metadata().end(); ++iter) { in Echo()
152 if (!context->client_metadata().empty()) { in RequestStream()
154 iter = context->client_metadata().begin(); in RequestStream()
155 iter != context->client_metadata().end(); ++iter) { in RequestStream()
170 if (!context->client_metadata().empty()) { in ResponseStream()
172 iter = context->client_metadata().begin(); in ResponseStream()
173 iter != context->client_metadata().end(); ++iter) { in ResponseStream()
194 if (!context->client_metadata().empty()) { in BidiStream()
[all …]
|
| /external/grpc-grpc/test/cpp/test/ |
| D | server_context_test_spouse_test.cc | 40 const auto& client_metadata = context.client_metadata(); in ClientMetadataContains() local
41 for (auto iter = client_metadata.begin(); iter != client_metadata.end(); in ClientMetadataContains()
|
| /external/grpc-grpc/test/cpp/cocoapods/test/ |
| D | server_context_test_spouse_test.mm | 43 const auto& client_metadata = context.client_metadata();
44 for (auto iter = client_metadata.begin(); iter != client_metadata.end(); ++iter) {
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_call.h | 237 const std::multimap<::grpc::string_ref, ::grpc::string_ref>& client_metadata() in client_metadata() function
239 return ctx_.client_metadata(); in client_metadata()
|
| D | grpc_master_service.cc | 185 auto* trace = TraceRpc("RunStep/Server", call->client_metadata()); in RunStepHandler()
258 auto* trace = TraceRpc("RunCallable/Server", call->client_metadata()); in RunCallableHandler()
|
| /external/grpc-grpc/src/ruby/spec/generic/ |
| D | server_interceptors_spec.rb | 30 let(:client_call_opts) { { metadata: client_metadata, return_op: true } }
52 receive(:request_response).with(request, metadata: client_metadata)
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| D | stream_compression_compressed_payload.cc | 99 grpc_status_code expected_error, grpc_metadata* client_metadata) { in request_for_disabled_algorithm() argument
158 if (client_metadata != nullptr) { in request_for_disabled_algorithm()
160 op->data.send_initial_metadata.metadata = client_metadata; in request_for_disabled_algorithm()
|
| D | compressed_payload.cc | 99 grpc_status_code expected_error, grpc_metadata* client_metadata) { in request_for_disabled_algorithm() argument
158 if (client_metadata != nullptr) { in request_for_disabled_algorithm()
160 op->data.send_initial_metadata.metadata = client_metadata; in request_for_disabled_algorithm()
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | server_context.h | 170 const std::multimap<grpc::string_ref, grpc::string_ref>& client_metadata() in client_metadata() function
|