aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorncteisen <ncteisen@gmail.com>2018-09-05 18:16:13 -0700
committerncteisen <ncteisen@gmail.com>2018-09-05 18:16:13 -0700
commit16f53ff583c23b3b2a260ba0935fd0c30b479acf (patch)
treefb94fe0c927a50a5608edac4d01d8dc7ac95eeff
parentc9e300d5b044351c6e09221b09ba49e53d211643 (diff)
downloadgrpc-grpc-16f53ff583c23b3b2a260ba0935fd0c30b479acf.tar.gz
Surface user agent by default
-rw-r--r--include/grpc/impl/codegen/grpc_types.h3
-rw-r--r--src/core/ext/filters/http/server/http_server_filter.cc2
-rw-r--r--test/core/end2end/tests/workaround_cronet_compression.cc9
-rw-r--r--test/cpp/end2end/end2end_test.cc13
4 files changed, 6 insertions, 21 deletions
diff --git a/include/grpc/impl/codegen/grpc_types.h b/include/grpc/impl/codegen/grpc_types.h
index 9097984a96..5f3b96f40b 100644
--- a/include/grpc/impl/codegen/grpc_types.h
+++ b/include/grpc/impl/codegen/grpc_types.h
@@ -342,7 +342,8 @@ typedef struct {
"grpc.disable_client_authority_filter"
/** If set to zero, disables use of http proxies. Enabled by default. */
#define GRPC_ARG_ENABLE_HTTP_PROXY "grpc.enable_http_proxy"
-/** If set to non zero, surfaces the user agent string to the server. */
+/** If set to non zero, surfaces the user agent string to the server. User
+ agent is surfaced by default. */
#define GRPC_ARG_SURFACE_USER_AGENT "grpc.surface_user_agent"
/** \} */
diff --git a/src/core/ext/filters/http/server/http_server_filter.cc b/src/core/ext/filters/http/server/http_server_filter.cc
index 53cd059aa8..1b3426b120 100644
--- a/src/core/ext/filters/http/server/http_server_filter.cc
+++ b/src/core/ext/filters/http/server/http_server_filter.cc
@@ -445,7 +445,7 @@ static grpc_error* hs_init_channel_elem(grpc_channel_element* elem,
chand->surface_user_agent = grpc_channel_arg_get_bool(
grpc_channel_args_find(args->channel_args,
const_cast<char*>(GRPC_ARG_SURFACE_USER_AGENT)),
- false);
+ true);
return GRPC_ERROR_NONE;
}
diff --git a/test/core/end2end/tests/workaround_cronet_compression.cc b/test/core/end2end/tests/workaround_cronet_compression.cc
index e1bce603fa..f44ddca3b1 100644
--- a/test/core/end2end/tests/workaround_cronet_compression.cc
+++ b/test/core/end2end/tests/workaround_cronet_compression.cc
@@ -149,15 +149,6 @@ static void request_with_payload_template(
arg.value.string = user_agent_override;
client_args = grpc_channel_args_copy_and_add(client_args_old, &arg, 1);
grpc_channel_args_destroy(client_args_old);
- // force grpc lib to pass the user agent back up to server.
- grpc_channel_args* server_args_old = server_args;
- grpc_arg server_arg;
- server_arg.key = const_cast<char*>(GRPC_ARG_SURFACE_USER_AGENT);
- server_arg.type = GRPC_ARG_INTEGER;
- server_arg.value.integer = 1;
- server_args =
- grpc_channel_args_copy_and_add(server_args_old, &server_arg, 1);
- grpc_channel_args_destroy(server_args_old);
}
f = begin_test(config, test_name, client_args, server_args);
diff --git a/test/cpp/end2end/end2end_test.cc b/test/cpp/end2end/end2end_test.cc
index e835f55738..fc07681535 100644
--- a/test/cpp/end2end/end2end_test.cc
+++ b/test/cpp/end2end/end2end_test.cc
@@ -244,17 +244,15 @@ class End2endTest : public ::testing::TestWithParam<TestScenario> {
BuildAndStartServer(processor);
}
- void RestartServer(const std::shared_ptr<AuthMetadataProcessor>& processor,
- bool surface_user_agent = false) {
+ void RestartServer(const std::shared_ptr<AuthMetadataProcessor>& processor) {
if (is_server_started_) {
server_->Shutdown();
- BuildAndStartServer(processor, surface_user_agent);
+ BuildAndStartServer(processor);
}
}
void BuildAndStartServer(
- const std::shared_ptr<AuthMetadataProcessor>& processor,
- bool surface_user_agent = false) {
+ const std::shared_ptr<AuthMetadataProcessor>& processor) {
ServerBuilder builder;
ConfigureServerBuilder(&builder);
auto server_creds = GetCredentialsProvider()->GetServerCredentials(
@@ -270,9 +268,6 @@ class End2endTest : public ::testing::TestWithParam<TestScenario> {
builder.SetSyncServerOption(ServerBuilder::SyncServerOption::NUM_CQS, 4);
builder.SetSyncServerOption(
ServerBuilder::SyncServerOption::CQ_TIMEOUT_MSEC, 10);
- if (surface_user_agent) {
- builder.AddChannelArgument(GRPC_ARG_SURFACE_USER_AGENT, 1);
- }
server_ = builder.BuildAndStart();
is_server_started_ = true;
@@ -669,8 +664,6 @@ TEST_P(End2endTest, SimpleRpcWithCustomUserAgentPrefix) {
}
user_agent_prefix_ = "custom_prefix";
ResetStub();
- RestartServer(std::shared_ptr<AuthMetadataProcessor>(), true);
- ResetChannel();
EchoRequest request;
EchoResponse response;
request.set_message("Hello hello hello hello");