From e25e92873d1a63d2a377d4b4803337a8b50baa11 Mon Sep 17 00:00:00 2001 From: David Garcia Quintas Date: Tue, 23 Jun 2015 10:18:52 -0700 Subject: Added compression filter to server creation --- src/core/surface/server.c | 6 +++--- src/core/surface/server.h | 6 +++--- src/core/surface/server_create.c | 5 ++++- 3 files changed, 10 insertions(+), 7 deletions(-) diff --git a/src/core/surface/server.c b/src/core/surface/server.c index 825ef66804..80bbe42af4 100644 --- a/src/core/surface/server.c +++ b/src/core/surface/server.c @@ -658,9 +658,9 @@ void grpc_server_register_completion_queue(grpc_server *server, server->cqs[n] = cq; } -grpc_server *grpc_server_create_from_filters(grpc_channel_filter **filters, - size_t filter_count, - const grpc_channel_args *args) { +grpc_server *grpc_server_create_from_filters( + const grpc_channel_filter **filters, size_t filter_count, + const grpc_channel_args *args) { size_t i; /* TODO(census): restore this once we finalize census filter etc. int census_enabled = grpc_channel_args_is_census_enabled(args); */ diff --git a/src/core/surface/server.h b/src/core/surface/server.h index 91a1a2a7f6..ece7d1f00f 100644 --- a/src/core/surface/server.h +++ b/src/core/surface/server.h @@ -39,9 +39,9 @@ #include "src/core/transport/transport.h" /* Create a server */ -grpc_server *grpc_server_create_from_filters(grpc_channel_filter **filters, - size_t filter_count, - const grpc_channel_args *args); +grpc_server *grpc_server_create_from_filters( + const grpc_channel_filter **filters, size_t filter_count, + const grpc_channel_args *args); /* Add a listener to the server: when the server starts, it will call start, and when it shuts down, it will call destroy */ diff --git a/src/core/surface/server_create.c b/src/core/surface/server_create.c index b7390675ad..0433164053 100644 --- a/src/core/surface/server_create.c +++ b/src/core/surface/server_create.c @@ -32,9 +32,12 @@ */ #include + +#include "src/core/channel/compress_filter.h" #include "src/core/surface/completion_queue.h" #include "src/core/surface/server.h" grpc_server *grpc_server_create(const grpc_channel_args *args) { - return grpc_server_create_from_filters(NULL, 0, args); + const grpc_channel_filter *filters[] = {&grpc_compress_filter}; + return grpc_server_create_from_filters(filters, 0, args); } -- cgit v1.2.3