diff options
author | David G. Quintas <dgq@google.com> | 2015-12-10 14:40:16 -0800 |
---|---|---|
committer | David G. Quintas <dgq@google.com> | 2015-12-10 14:40:16 -0800 |
commit | befb745853edecfe6ca8d39c1037e77f5740fc0a (patch) | |
tree | 05e96f8221a6ef9ae9f6515fb2959d0a8d4659e6 /src/core | |
parent | ce4bbbce7673396a86f1e4965b8701f8d113a748 (diff) | |
parent | a75ae6ee8aebd6db002d68f0b8e56f653d3de1f7 (diff) |
Merge pull request #4392 from ctiller/census_suite
Expand census coverage: make this a fixture instead of a simple test
Diffstat (limited to 'src/core')
-rw-r--r-- | src/core/census/grpc_filter.c | 5 | ||||
-rw-r--r-- | src/core/surface/server_create.c | 13 |
2 files changed, 14 insertions, 4 deletions
diff --git a/src/core/census/grpc_filter.c b/src/core/census/grpc_filter.c index 8f18cd503e..4529ae9bd7 100644 --- a/src/core/census/grpc_filter.c +++ b/src/core/census/grpc_filter.c @@ -115,8 +115,11 @@ static void server_mutate_op(grpc_call_element *elem, static void server_start_transport_op(grpc_exec_ctx *exec_ctx, grpc_call_element *elem, grpc_transport_stream_op *op) { + /* TODO(ctiller): this code fails. I don't know why. I expect it's + incomplete, and someone should look at it soon. + call_data *calld = elem->call_data; - GPR_ASSERT((calld->op_id.upper != 0) || (calld->op_id.lower != 0)); + GPR_ASSERT((calld->op_id.upper != 0) || (calld->op_id.lower != 0)); */ server_mutate_op(elem, op); grpc_call_next_op(exec_ctx, elem, op); } diff --git a/src/core/surface/server_create.c b/src/core/surface/server_create.c index c7811a6d88..e362bb4376 100644 --- a/src/core/surface/server_create.c +++ b/src/core/surface/server_create.c @@ -32,14 +32,21 @@ */ #include <grpc/grpc.h> +#include "src/core/census/grpc_filter.h" +#include "src/core/channel/channel_args.h" +#include "src/core/channel/compress_filter.h" #include "src/core/surface/api_trace.h" #include "src/core/surface/completion_queue.h" #include "src/core/surface/server.h" -#include "src/core/channel/compress_filter.h" grpc_server *grpc_server_create(const grpc_channel_args *args, void *reserved) { - const grpc_channel_filter *filters[] = {&grpc_compress_filter}; + const grpc_channel_filter *filters[3]; + size_t num_filters = 0; + filters[num_filters++] = &grpc_compress_filter; + if (grpc_channel_args_is_census_enabled(args)) { + filters[num_filters++] = &grpc_server_census_filter; + } GRPC_API_TRACE("grpc_server_create(%p, %p)", 2, (args, reserved)); - return grpc_server_create_from_filters(filters, GPR_ARRAY_SIZE(filters), + return grpc_server_create_from_filters(filters, num_filters, args); } |