diff options
author | 2016-04-07 09:55:49 -0700 | |
---|---|---|
committer | 2016-04-07 09:55:49 -0700 | |
commit | 361be66c3d1b99e253cf00f8a1d466e87887a0b6 (patch) | |
tree | 9ff7d1b53b21d77fe5110d4dee9eecab0514bfdb /src/core/ext/census | |
parent | 42a3916c92858069d58fb91de7a799b7d84053fb (diff) | |
parent | 03915e5de633e900f283675846f709115735a863 (diff) |
Merge pull request #6092 from ctiller/strong-includes
Check dependencies between filegroups
Diffstat (limited to 'src/core/ext/census')
-rw-r--r-- | src/core/ext/census/grpc_plugin.c | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/src/core/ext/census/grpc_plugin.c b/src/core/ext/census/grpc_plugin.c index c6039a3f64..e43ceafd0c 100644 --- a/src/core/ext/census/grpc_plugin.c +++ b/src/core/ext/census/grpc_plugin.c @@ -32,6 +32,7 @@ */ #include <limits.h> +#include <string.h> #include <grpc/census.h> @@ -39,11 +40,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) { 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, (const grpc_channel_filter *)arg, NULL, NULL); } |