diff options
author | 2016-04-05 16:05:46 -0700 | |
---|---|---|
committer | 2016-04-05 16:05:46 -0700 | |
commit | d1697d99d775bddd4f81fb1239eb415eeccc317f (patch) | |
tree | 6760c01fbdfa39a51194cdf064320e83adce1d4e /src/core/ext/census | |
parent | 978161549032df14c24b6409554d1af6f28b45cd (diff) |
Getting dependencies fixed up
Diffstat (limited to 'src/core/ext/census')
-rw-r--r-- | src/core/ext/census/grpc_plugin.c | 13 |
1 files changed, 12 insertions, 1 deletions
diff --git a/src/core/ext/census/grpc_plugin.c b/src/core/ext/census/grpc_plugin.c index 0f15ecb2c2..90721293d3 100644 --- a/src/core/ext/census/grpc_plugin.c +++ b/src/core/ext/census/grpc_plugin.c @@ -39,11 +39,22 @@ #include "src/core/lib/channel/channel_stack_builder.h" #include "src/core/lib/surface/channel_init.h" +static bool is_census_enabled(const grpc_channel_args *a) { + size_t i; + if (a == NULL) return 0; + for (i = 0; i < a->num_args; i++) { + if (0 == strcmp(a->args[i].key, GRPC_ARG_ENABLE_CENSUS)) { + return a->args[i].value.integer != 0 && census_enabled(); + } + } + return census_enabled(); +} + static bool maybe_add_census_filter(grpc_channel_stack_builder *builder, void *arg_must_be_null) { const grpc_channel_args *args = grpc_channel_stack_builder_get_channel_arguments(builder); - if (grpc_channel_args_is_census_enabled(args)) { + if (is_census_enabled(args)) { return grpc_channel_stack_builder_prepend_filter( builder, &grpc_client_census_filter, NULL, NULL); } |