Added compression filter to server creation

pull/2135/head
David Garcia Quintas 10 years ago
parent d16af0ea52
commit e25e92873d
  1. 6
      src/core/surface/server.c
  2. 6
      src/core/surface/server.h
  3. 5
      src/core/surface/server_create.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); */

@ -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 */

@ -32,9 +32,12 @@
*/
#include <grpc/grpc.h>
#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);
}

Loading…
Cancel
Save