Merge github.com:grpc/grpc into slice_with_exec_ctx

8 years ago · 293ef1572b
parent 3ca6019d39 6f3ce09f9c
commit 293ef1572b
23 changed files with 75 additions and 53 deletions
--- a/5
+++ b/5
@ -423,6 +423,7 @@ grpc_cc_library(
        "src/core/lib/channel/handshaker.c",
        "src/core/lib/channel/http_client_filter.c",
        "src/core/lib/channel/http_server_filter.c",
+        "src/core/lib/channel/message_size_filter.c",
        "src/core/lib/compression/compression.c",
        "src/core/lib/compression/message_compress.c",
        "src/core/lib/debug/trace.c",
@ -537,6 +538,7 @@ grpc_cc_library(
        "src/core/lib/channel/handshaker.h",
        "src/core/lib/channel/http_client_filter.h",
        "src/core/lib/channel/http_server_filter.h",
+        "src/core/lib/channel/message_size_filter.h",
        "src/core/lib/compression/algorithm_metadata.h",
        "src/core/lib/compression/message_compress.h",
        "src/core/lib/debug/trace.h",
@ -648,6 +650,7 @@ grpc_cc_library(

 grpc_cc_library(
    name = "grpc_client_channel",
+    language = "c",
    srcs = [
        "src/core/ext/client_channel/channel_connectivity.c",
        "src/core/ext/client_channel/client_channel.c",
@ -660,7 +663,6 @@ grpc_cc_library(
        "src/core/ext/client_channel/lb_policy.c",
        "src/core/ext/client_channel/lb_policy_factory.c",
        "src/core/ext/client_channel/lb_policy_registry.c",
-        "src/core/ext/client_channel/message_size_filter.c",
        "src/core/ext/client_channel/parse_address.c",
        "src/core/ext/client_channel/resolver.c",
        "src/core/ext/client_channel/resolver_factory.c",
@ -678,7 +680,6 @@ grpc_cc_library(
        "src/core/ext/client_channel/lb_policy.h",
        "src/core/ext/client_channel/lb_policy_factory.h",
        "src/core/ext/client_channel/lb_policy_registry.h",
-        "src/core/ext/client_channel/message_size_filter.h",
        "src/core/ext/client_channel/parse_address.h",
        "src/core/ext/client_channel/resolver.h",
        "src/core/ext/client_channel/resolver_factory.h",
--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@ -294,6 +294,7 @@ add_library(grpc
  src/core/lib/channel/handshaker.c
  src/core/lib/channel/http_client_filter.c
  src/core/lib/channel/http_server_filter.c
+  src/core/lib/channel/message_size_filter.c
  src/core/lib/compression/compression.c
  src/core/lib/compression/message_compress.c
  src/core/lib/debug/trace.c
@ -459,7 +460,6 @@ add_library(grpc
  src/core/ext/client_channel/lb_policy.c
  src/core/ext/client_channel/lb_policy_factory.c
  src/core/ext/client_channel/lb_policy_registry.c
-  src/core/ext/client_channel/message_size_filter.c
  src/core/ext/client_channel/parse_address.c
  src/core/ext/client_channel/resolver.c
  src/core/ext/client_channel/resolver_factory.c
@ -576,6 +576,7 @@ add_library(grpc_cronet
  src/core/lib/channel/handshaker.c
  src/core/lib/channel/http_client_filter.c
  src/core/lib/channel/http_server_filter.c
+  src/core/lib/channel/message_size_filter.c
  src/core/lib/compression/compression.c
  src/core/lib/compression/message_compress.c
  src/core/lib/debug/trace.c
@ -715,7 +716,6 @@ add_library(grpc_cronet
  src/core/ext/client_channel/lb_policy.c
  src/core/ext/client_channel/lb_policy_factory.c
  src/core/ext/client_channel/lb_policy_registry.c
-  src/core/ext/client_channel/message_size_filter.c
  src/core/ext/client_channel/parse_address.c
  src/core/ext/client_channel/resolver.c
  src/core/ext/client_channel/resolver_factory.c
@ -829,6 +829,7 @@ add_library(grpc_unsecure
  src/core/lib/channel/handshaker.c
  src/core/lib/channel/http_client_filter.c
  src/core/lib/channel/http_server_filter.c
+  src/core/lib/channel/message_size_filter.c
  src/core/lib/compression/compression.c
  src/core/lib/compression/message_compress.c
  src/core/lib/debug/trace.c
@ -970,7 +971,6 @@ add_library(grpc_unsecure
  src/core/ext/client_channel/lb_policy.c
  src/core/ext/client_channel/lb_policy_factory.c
  src/core/ext/client_channel/lb_policy_registry.c
-  src/core/ext/client_channel/message_size_filter.c
  src/core/ext/client_channel/parse_address.c
  src/core/ext/client_channel/resolver.c
  src/core/ext/client_channel/resolver_factory.c
@ -1298,6 +1298,7 @@ add_library(grpc++_cronet
  src/core/lib/channel/handshaker.c
  src/core/lib/channel/http_client_filter.c
  src/core/lib/channel/http_server_filter.c
+  src/core/lib/channel/message_size_filter.c
  src/core/lib/compression/compression.c
  src/core/lib/compression/message_compress.c
  src/core/lib/debug/trace.c
@ -1412,7 +1413,6 @@ add_library(grpc++_cronet
  src/core/ext/client_channel/lb_policy.c
  src/core/ext/client_channel/lb_policy_factory.c
  src/core/ext/client_channel/lb_policy_registry.c
-  src/core/ext/client_channel/message_size_filter.c
  src/core/ext/client_channel/parse_address.c
  src/core/ext/client_channel/resolver.c
  src/core/ext/client_channel/resolver_factory.c
--- a/9
+++ b/9
@ -2633,6 +2633,7 @@ LIBGRPC_SRC = \
    src/core/lib/channel/handshaker.c \
    src/core/lib/channel/http_client_filter.c \
    src/core/lib/channel/http_server_filter.c \
+    src/core/lib/channel/message_size_filter.c \
    src/core/lib/compression/compression.c \
    src/core/lib/compression/message_compress.c \
    src/core/lib/debug/trace.c \
@ -2798,7 +2799,6 @@ LIBGRPC_SRC = \
    src/core/ext/client_channel/lb_policy.c \
    src/core/ext/client_channel/lb_policy_factory.c \
    src/core/ext/client_channel/lb_policy_registry.c \
-    src/core/ext/client_channel/message_size_filter.c \
    src/core/ext/client_channel/parse_address.c \
    src/core/ext/client_channel/resolver.c \
    src/core/ext/client_channel/resolver_factory.c \
@ -2933,6 +2933,7 @@ LIBGRPC_CRONET_SRC = \
    src/core/lib/channel/handshaker.c \
    src/core/lib/channel/http_client_filter.c \
    src/core/lib/channel/http_server_filter.c \
+    src/core/lib/channel/message_size_filter.c \
    src/core/lib/compression/compression.c \
    src/core/lib/compression/message_compress.c \
    src/core/lib/debug/trace.c \
@ -3072,7 +3073,6 @@ LIBGRPC_CRONET_SRC = \
    src/core/ext/client_channel/lb_policy.c \
    src/core/ext/client_channel/lb_policy_factory.c \
    src/core/ext/client_channel/lb_policy_registry.c \
-    src/core/ext/client_channel/message_size_filter.c \
    src/core/ext/client_channel/parse_address.c \
    src/core/ext/client_channel/resolver.c \
    src/core/ext/client_channel/resolver_factory.c \
@ -3223,6 +3223,7 @@ LIBGRPC_TEST_UTIL_SRC = \
    src/core/lib/channel/handshaker.c \
    src/core/lib/channel/http_client_filter.c \
    src/core/lib/channel/http_server_filter.c \
+    src/core/lib/channel/message_size_filter.c \
    src/core/lib/compression/compression.c \
    src/core/lib/compression/message_compress.c \
    src/core/lib/debug/trace.c \
@ -3440,6 +3441,7 @@ LIBGRPC_UNSECURE_SRC = \
    src/core/lib/channel/handshaker.c \
    src/core/lib/channel/http_client_filter.c \
    src/core/lib/channel/http_server_filter.c \
+    src/core/lib/channel/message_size_filter.c \
    src/core/lib/compression/compression.c \
    src/core/lib/compression/message_compress.c \
    src/core/lib/debug/trace.c \
@ -3581,7 +3583,6 @@ LIBGRPC_UNSECURE_SRC = \
    src/core/ext/client_channel/lb_policy.c \
    src/core/ext/client_channel/lb_policy_factory.c \
    src/core/ext/client_channel/lb_policy_registry.c \
-    src/core/ext/client_channel/message_size_filter.c \
    src/core/ext/client_channel/parse_address.c \
    src/core/ext/client_channel/resolver.c \
    src/core/ext/client_channel/resolver_factory.c \
@ -4021,6 +4022,7 @@ LIBGRPC++_CRONET_SRC = \
    src/core/lib/channel/handshaker.c \
    src/core/lib/channel/http_client_filter.c \
    src/core/lib/channel/http_server_filter.c \
+    src/core/lib/channel/message_size_filter.c \
    src/core/lib/compression/compression.c \
    src/core/lib/compression/message_compress.c \
    src/core/lib/debug/trace.c \
@ -4135,7 +4137,6 @@ LIBGRPC++_CRONET_SRC = \
    src/core/ext/client_channel/lb_policy.c \
    src/core/ext/client_channel/lb_policy_factory.c \
    src/core/ext/client_channel/lb_policy_registry.c \
-    src/core/ext/client_channel/message_size_filter.c \
    src/core/ext/client_channel/parse_address.c \
    src/core/ext/client_channel/resolver.c \
    src/core/ext/client_channel/resolver_factory.c \
--- a/binding.gyp
+++ b/binding.gyp
@ -574,6 +574,7 @@
        'src/core/lib/channel/handshaker.c',
        'src/core/lib/channel/http_client_filter.c',
        'src/core/lib/channel/http_server_filter.c',
+        'src/core/lib/channel/message_size_filter.c',
        'src/core/lib/compression/compression.c',
        'src/core/lib/compression/message_compress.c',
        'src/core/lib/debug/trace.c',
@ -739,7 +740,6 @@
        'src/core/ext/client_channel/lb_policy.c',
        'src/core/ext/client_channel/lb_policy_factory.c',
        'src/core/ext/client_channel/lb_policy_registry.c',
-        'src/core/ext/client_channel/message_size_filter.c',
        'src/core/ext/client_channel/parse_address.c',
        'src/core/ext/client_channel/resolver.c',
        'src/core/ext/client_channel/resolver_factory.c',
--- a/build.yaml
+++ b/build.yaml
@ -173,6 +173,7 @@ filegroups:
  - src/core/lib/channel/handshaker.h
  - src/core/lib/channel/http_client_filter.h
  - src/core/lib/channel/http_server_filter.h
+  - src/core/lib/channel/message_size_filter.h
  - src/core/lib/compression/algorithm_metadata.h
  - src/core/lib/compression/message_compress.h
  - src/core/lib/debug/trace.h
@ -270,6 +271,7 @@ filegroups:
  - src/core/lib/channel/handshaker.c
  - src/core/lib/channel/http_client_filter.c
  - src/core/lib/channel/http_server_filter.c
+  - src/core/lib/channel/message_size_filter.c
  - src/core/lib/compression/compression.c
  - src/core/lib/compression/message_compress.c
  - src/core/lib/debug/trace.c
@ -386,7 +388,6 @@ filegroups:
  - src/core/ext/client_channel/lb_policy.h
  - src/core/ext/client_channel/lb_policy_factory.h
  - src/core/ext/client_channel/lb_policy_registry.h
-  - src/core/ext/client_channel/message_size_filter.h
  - src/core/ext/client_channel/parse_address.h
  - src/core/ext/client_channel/resolver.h
  - src/core/ext/client_channel/resolver_factory.h
@ -406,7 +407,6 @@ filegroups:
  - src/core/ext/client_channel/lb_policy.c
  - src/core/ext/client_channel/lb_policy_factory.c
  - src/core/ext/client_channel/lb_policy_registry.c
-  - src/core/ext/client_channel/message_size_filter.c
  - src/core/ext/client_channel/parse_address.c
  - src/core/ext/client_channel/resolver.c
  - src/core/ext/client_channel/resolver_factory.c
--- a/config.m4
+++ b/config.m4
@ -90,6 +90,7 @@ if test "$PHP_GRPC" != "no"; then
    src/core/lib/channel/handshaker.c \
    src/core/lib/channel/http_client_filter.c \
    src/core/lib/channel/http_server_filter.c \
+    src/core/lib/channel/message_size_filter.c \
    src/core/lib/compression/compression.c \
    src/core/lib/compression/message_compress.c \
    src/core/lib/debug/trace.c \
@ -255,7 +256,6 @@ if test "$PHP_GRPC" != "no"; then
    src/core/ext/client_channel/lb_policy.c \
    src/core/ext/client_channel/lb_policy_factory.c \
    src/core/ext/client_channel/lb_policy_registry.c \
-    src/core/ext/client_channel/message_size_filter.c \
    src/core/ext/client_channel/parse_address.c \
    src/core/ext/client_channel/resolver.c \
    src/core/ext/client_channel/resolver_factory.c \
--- a/gRPC-Core.podspec
+++ b/gRPC-Core.podspec
@ -258,6 +258,7 @@ Pod::Spec.new do |s|
                      'src/core/lib/channel/handshaker.h',
                      'src/core/lib/channel/http_client_filter.h',
                      'src/core/lib/channel/http_server_filter.h',
+                      'src/core/lib/channel/message_size_filter.h',
                      'src/core/lib/compression/algorithm_metadata.h',
                      'src/core/lib/compression/message_compress.h',
                      'src/core/lib/debug/trace.h',
@ -399,7 +400,6 @@ Pod::Spec.new do |s|
                      'src/core/ext/client_channel/lb_policy.h',
                      'src/core/ext/client_channel/lb_policy_factory.h',
                      'src/core/ext/client_channel/lb_policy_registry.h',
-                      'src/core/ext/client_channel/message_size_filter.h',
                      'src/core/ext/client_channel/parse_address.h',
                      'src/core/ext/client_channel/resolver.h',
                      'src/core/ext/client_channel/resolver_factory.h',
@ -438,6 +438,7 @@ Pod::Spec.new do |s|
                      'src/core/lib/channel/handshaker.c',
                      'src/core/lib/channel/http_client_filter.c',
                      'src/core/lib/channel/http_server_filter.c',
+                      'src/core/lib/channel/message_size_filter.c',
                      'src/core/lib/compression/compression.c',
                      'src/core/lib/compression/message_compress.c',
                      'src/core/lib/debug/trace.c',
@ -603,7 +604,6 @@ Pod::Spec.new do |s|
                      'src/core/ext/client_channel/lb_policy.c',
                      'src/core/ext/client_channel/lb_policy_factory.c',
                      'src/core/ext/client_channel/lb_policy_registry.c',
-                      'src/core/ext/client_channel/message_size_filter.c',
                      'src/core/ext/client_channel/parse_address.c',
                      'src/core/ext/client_channel/resolver.c',
                      'src/core/ext/client_channel/resolver_factory.c',
@ -666,6 +666,7 @@ Pod::Spec.new do |s|
                              'src/core/lib/channel/handshaker.h',
                              'src/core/lib/channel/http_client_filter.h',
                              'src/core/lib/channel/http_server_filter.h',
+                              'src/core/lib/channel/message_size_filter.h',
                              'src/core/lib/compression/algorithm_metadata.h',
                              'src/core/lib/compression/message_compress.h',
                              'src/core/lib/debug/trace.h',
@ -807,7 +808,6 @@ Pod::Spec.new do |s|
                              'src/core/ext/client_channel/lb_policy.h',
                              'src/core/ext/client_channel/lb_policy_factory.h',
                              'src/core/ext/client_channel/lb_policy_registry.h',
-                              'src/core/ext/client_channel/message_size_filter.h',
                              'src/core/ext/client_channel/parse_address.h',
                              'src/core/ext/client_channel/resolver.h',
                              'src/core/ext/client_channel/resolver_factory.h',
--- a/grpc.gemspec
+++ b/grpc.gemspec
@ -175,6 +175,7 @@ Gem::Specification.new do |s|
  s.files += %w( src/core/lib/channel/handshaker.h )
  s.files += %w( src/core/lib/channel/http_client_filter.h )
  s.files += %w( src/core/lib/channel/http_server_filter.h )
+  s.files += %w( src/core/lib/channel/message_size_filter.h )
  s.files += %w( src/core/lib/compression/algorithm_metadata.h )
  s.files += %w( src/core/lib/compression/message_compress.h )
  s.files += %w( src/core/lib/debug/trace.h )
@ -316,7 +317,6 @@ Gem::Specification.new do |s|
  s.files += %w( src/core/ext/client_channel/lb_policy.h )
  s.files += %w( src/core/ext/client_channel/lb_policy_factory.h )
  s.files += %w( src/core/ext/client_channel/lb_policy_registry.h )
-  s.files += %w( src/core/ext/client_channel/message_size_filter.h )
  s.files += %w( src/core/ext/client_channel/parse_address.h )
  s.files += %w( src/core/ext/client_channel/resolver.h )
  s.files += %w( src/core/ext/client_channel/resolver_factory.h )
@ -355,6 +355,7 @@ Gem::Specification.new do |s|
  s.files += %w( src/core/lib/channel/handshaker.c )
  s.files += %w( src/core/lib/channel/http_client_filter.c )
  s.files += %w( src/core/lib/channel/http_server_filter.c )
+  s.files += %w( src/core/lib/channel/message_size_filter.c )
  s.files += %w( src/core/lib/compression/compression.c )
  s.files += %w( src/core/lib/compression/message_compress.c )
  s.files += %w( src/core/lib/debug/trace.c )
@ -520,7 +521,6 @@ Gem::Specification.new do |s|
  s.files += %w( src/core/ext/client_channel/lb_policy.c )
  s.files += %w( src/core/ext/client_channel/lb_policy_factory.c )
  s.files += %w( src/core/ext/client_channel/lb_policy_registry.c )
-  s.files += %w( src/core/ext/client_channel/message_size_filter.c )
  s.files += %w( src/core/ext/client_channel/parse_address.c )
  s.files += %w( src/core/ext/client_channel/resolver.c )
  s.files += %w( src/core/ext/client_channel/resolver_factory.c )
--- a/package.xml
+++ b/package.xml
@ -183,6 +183,7 @@
    <file baseinstalldir="/" name="src/core/lib/channel/handshaker.h" role="src" />
    <file baseinstalldir="/" name="src/core/lib/channel/http_client_filter.h" role="src" />
    <file baseinstalldir="/" name="src/core/lib/channel/http_server_filter.h" role="src" />
+    <file baseinstalldir="/" name="src/core/lib/channel/message_size_filter.h" role="src" />
    <file baseinstalldir="/" name="src/core/lib/compression/algorithm_metadata.h" role="src" />
    <file baseinstalldir="/" name="src/core/lib/compression/message_compress.h" role="src" />
    <file baseinstalldir="/" name="src/core/lib/debug/trace.h" role="src" />
@ -324,7 +325,6 @@
    <file baseinstalldir="/" name="src/core/ext/client_channel/lb_policy.h" role="src" />
    <file baseinstalldir="/" name="src/core/ext/client_channel/lb_policy_factory.h" role="src" />
    <file baseinstalldir="/" name="src/core/ext/client_channel/lb_policy_registry.h" role="src" />
-    <file baseinstalldir="/" name="src/core/ext/client_channel/message_size_filter.h" role="src" />
    <file baseinstalldir="/" name="src/core/ext/client_channel/parse_address.h" role="src" />
    <file baseinstalldir="/" name="src/core/ext/client_channel/resolver.h" role="src" />
    <file baseinstalldir="/" name="src/core/ext/client_channel/resolver_factory.h" role="src" />
@ -363,6 +363,7 @@
    <file baseinstalldir="/" name="src/core/lib/channel/handshaker.c" role="src" />
    <file baseinstalldir="/" name="src/core/lib/channel/http_client_filter.c" role="src" />
    <file baseinstalldir="/" name="src/core/lib/channel/http_server_filter.c" role="src" />
+    <file baseinstalldir="/" name="src/core/lib/channel/message_size_filter.c" role="src" />
    <file baseinstalldir="/" name="src/core/lib/compression/compression.c" role="src" />
    <file baseinstalldir="/" name="src/core/lib/compression/message_compress.c" role="src" />
    <file baseinstalldir="/" name="src/core/lib/debug/trace.c" role="src" />
@ -528,7 +529,6 @@
    <file baseinstalldir="/" name="src/core/ext/client_channel/lb_policy.c" role="src" />
    <file baseinstalldir="/" name="src/core/ext/client_channel/lb_policy_factory.c" role="src" />
    <file baseinstalldir="/" name="src/core/ext/client_channel/lb_policy_registry.c" role="src" />
-    <file baseinstalldir="/" name="src/core/ext/client_channel/message_size_filter.c" role="src" />
    <file baseinstalldir="/" name="src/core/ext/client_channel/parse_address.c" role="src" />
    <file baseinstalldir="/" name="src/core/ext/client_channel/resolver.c" role="src" />
    <file baseinstalldir="/" name="src/core/ext/client_channel/resolver_factory.c" role="src" />
--- a/src/core/ext/client_channel/message_size_filter.c
+++ b/src/core/ext/client_channel/message_size_filter.c
@ -29,7 +29,7 @@
 // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 //

-#include "src/core/ext/client_channel/message_size_filter.h"
+#include "src/core/lib/channel/message_size_filter.h"

 #include <limits.h>
 #include <string.h>
--- a/src/core/ext/client_channel/message_size_filter.h
+++ b/src/core/ext/client_channel/message_size_filter.h
@ -29,11 +29,11 @@
 // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 //

-#ifndef GRPC_CORE_EXT_CLIENT_CHANNEL_MESSAGE_SIZE_FILTER_H
-#define GRPC_CORE_EXT_CLIENT_CHANNEL_MESSAGE_SIZE_FILTER_H
+#ifndef GRPC_CORE_LIB_CHANNEL_MESSAGE_SIZE_FILTER_H
+#define GRPC_CORE_LIB_CHANNEL_MESSAGE_SIZE_FILTER_H

 #include "src/core/lib/channel/channel_stack.h"

 extern const grpc_channel_filter grpc_message_size_filter;

-#endif /* GRPC_CORE_EXT_CLIENT_CHANNEL_MESSAGE_SIZE_FILTER_H */
+#endif /* GRPC_CORE_LIB_CHANNEL_MESSAGE_SIZE_FILTER_H */
--- a/src/core/lib/surface/init.c
+++ b/src/core/lib/surface/init.c
@ -46,6 +46,7 @@
 #include "src/core/lib/channel/deadline_filter.h"
 #include "src/core/lib/channel/http_client_filter.h"
 #include "src/core/lib/channel/http_server_filter.h"
+#include "src/core/lib/channel/message_size_filter.h"
 #include "src/core/lib/debug/trace.h"
 #include "src/core/lib/http/parser.h"
 #include "src/core/lib/iomgr/combiner.h"
@ -109,6 +110,15 @@ static void register_builtin_channel_init() {
  grpc_channel_init_register_stage(
      GRPC_SERVER_CHANNEL, GRPC_CHANNEL_INIT_BUILTIN_PRIORITY, prepend_filter,
      (void *)&grpc_server_deadline_filter);
+  grpc_channel_init_register_stage(
+      GRPC_CLIENT_SUBCHANNEL, GRPC_CHANNEL_INIT_BUILTIN_PRIORITY,
+      prepend_filter, (void *)&grpc_message_size_filter);
+  grpc_channel_init_register_stage(
+      GRPC_CLIENT_DIRECT_CHANNEL, GRPC_CHANNEL_INIT_BUILTIN_PRIORITY,
+      prepend_filter, (void *)&grpc_message_size_filter);
+  grpc_channel_init_register_stage(
+      GRPC_SERVER_CHANNEL, GRPC_CHANNEL_INIT_BUILTIN_PRIORITY, prepend_filter,
+      (void *)&grpc_message_size_filter);
  grpc_channel_init_register_stage(
      GRPC_CLIENT_CHANNEL, GRPC_CHANNEL_INIT_BUILTIN_PRIORITY, prepend_filter,
      (void *)&grpc_compress_filter);
--- a/src/python/grpcio/grpc_core_dependencies.py
+++ b/src/python/grpcio/grpc_core_dependencies.py
@ -84,6 +84,7 @@ CORE_SOURCE_FILES = [
  'src/core/lib/channel/handshaker.c',
  'src/core/lib/channel/http_client_filter.c',
  'src/core/lib/channel/http_server_filter.c',
+  'src/core/lib/channel/message_size_filter.c',
  'src/core/lib/compression/compression.c',
  'src/core/lib/compression/message_compress.c',
  'src/core/lib/debug/trace.c',
@ -249,7 +250,6 @@ CORE_SOURCE_FILES = [
  'src/core/ext/client_channel/lb_policy.c',
  'src/core/ext/client_channel/lb_policy_factory.c',
  'src/core/ext/client_channel/lb_policy_registry.c',
-  'src/core/ext/client_channel/message_size_filter.c',
  'src/core/ext/client_channel/parse_address.c',
  'src/core/ext/client_channel/resolver.c',
  'src/core/ext/client_channel/resolver_factory.c',
--- a/test/core/end2end/fuzzers/BUILD
+++ b/test/core/end2end/fuzzers/BUILD
@ -32,7 +32,7 @@ load("//test/core/util:grpc_fuzzer.bzl", "grpc_fuzzer")
 grpc_fuzzer(
  name = "api_fuzzer",
  srcs = ["api_fuzzer.c"],
-  deps = ["//:gpr", "//:grpc", "//test/core/util:grpc_test_util"],
+  deps = ["//:gpr", "//:grpc", "//test/core/util:grpc_test_util", "//test/core/end2end:ssl_test_data"],
  corpus = "api_fuzzer_corpus",
  copts = ["-std=c99"],
 )
@ -52,4 +52,3 @@ grpc_fuzzer(
  corpus = "server_fuzzer_corpus",
  copts = ["-std=c99"],
 )
-
--- a/test/core/end2end/generate_tests.bzl
+++ b/test/core/end2end/generate_tests.bzl
@ -51,7 +51,6 @@ END2END_FIXTURES = {
    'h2_census': fixture_options(),
    'h2_load_reporting': fixture_options(),
    'h2_fakesec': fixture_options(),
-    'h2_fake_resolver': fixture_options(),
    'h2_fd': fixture_options(dns_resolver=False, fullstack=False,
                             platforms=['linux', 'mac', 'posix']),
    'h2_full': fixture_options(),
@ -87,6 +86,7 @@ def test_options(needs_fullstack=False, needs_dns=False, proxyable=True,
 END2END_TESTS = {
    'bad_hostname': test_options(),
    'binary_metadata': test_options(),
+    'resource_quota_server': test_options(proxyable=False),
    'call_creds': test_options(secure=True),
    'cancel_after_accept': test_options(),
    'cancel_after_client_done': test_options(),
@ -129,6 +129,8 @@ END2END_TESTS = {
    'simple_request': test_options(),
    'streaming_error_response': test_options(),
    'trailing_metadata': test_options(),
+    'authority_not_supported': test_options(),
+    'filter_latency': test_options(),
 }


@ -151,7 +153,7 @@ def compatible(fopt, topt):
 def grpc_end2end_tests():
  native.cc_library(
    name = 'end2end_tests',
-    srcs = ['end2end_tests.c'] + [
+    srcs = ['end2end_tests.c', 'end2end_test_utils.c'] + [
             'tests/%s.c' % t
             for t in sorted(END2END_TESTS.keys())],
    hdrs = [
--- a/tools/doxygen/Doxyfile.core.internal
+++ b/tools/doxygen/Doxyfile.core.internal
@ -799,6 +799,7 @@ src/core/lib/channel/deadline_filter.h \
 src/core/lib/channel/handshaker.h \
 src/core/lib/channel/http_client_filter.h \
 src/core/lib/channel/http_server_filter.h \
+src/core/lib/channel/message_size_filter.h \
 src/core/lib/compression/algorithm_metadata.h \
 src/core/lib/compression/message_compress.h \
 src/core/lib/debug/trace.h \
@ -940,7 +941,6 @@ src/core/ext/client_channel/initial_connect_string.h \
 src/core/ext/client_channel/lb_policy.h \
 src/core/ext/client_channel/lb_policy_factory.h \
 src/core/ext/client_channel/lb_policy_registry.h \
-src/core/ext/client_channel/message_size_filter.h \
 src/core/ext/client_channel/parse_address.h \
 src/core/ext/client_channel/resolver.h \
 src/core/ext/client_channel/resolver_factory.h \
@ -979,6 +979,7 @@ src/core/lib/channel/deadline_filter.c \
 src/core/lib/channel/handshaker.c \
 src/core/lib/channel/http_client_filter.c \
 src/core/lib/channel/http_server_filter.c \
+src/core/lib/channel/message_size_filter.c \
 src/core/lib/compression/compression.c \
 src/core/lib/compression/message_compress.c \
 src/core/lib/debug/trace.c \
@ -1144,7 +1145,6 @@ src/core/ext/client_channel/initial_connect_string.c \
 src/core/ext/client_channel/lb_policy.c \
 src/core/ext/client_channel/lb_policy_factory.c \
 src/core/ext/client_channel/lb_policy_registry.c \
-src/core/ext/client_channel/message_size_filter.c \
 src/core/ext/client_channel/parse_address.c \
 src/core/ext/client_channel/resolver.c \
 src/core/ext/client_channel/resolver_factory.c \
--- a/tools/run_tests/generated/sources_and_headers.json
+++ b/tools/run_tests/generated/sources_and_headers.json
@ -6683,6 +6683,7 @@
      "src/core/lib/channel/handshaker.h", 
      "src/core/lib/channel/http_client_filter.h", 
      "src/core/lib/channel/http_server_filter.h", 
+      "src/core/lib/channel/message_size_filter.h", 
      "src/core/lib/compression/algorithm_metadata.h", 
      "src/core/lib/compression/message_compress.h", 
      "src/core/lib/debug/trace.h", 
@ -6803,6 +6804,8 @@
      "src/core/lib/channel/http_client_filter.h", 
      "src/core/lib/channel/http_server_filter.c", 
      "src/core/lib/channel/http_server_filter.h", 
+      "src/core/lib/channel/message_size_filter.c", 
+      "src/core/lib/channel/message_size_filter.h", 
      "src/core/lib/compression/algorithm_metadata.h", 
      "src/core/lib/compression/compression.c", 
      "src/core/lib/compression/message_compress.c", 
@ -7010,7 +7013,6 @@
      "src/core/ext/client_channel/lb_policy.h", 
      "src/core/ext/client_channel/lb_policy_factory.h", 
      "src/core/ext/client_channel/lb_policy_registry.h", 
-      "src/core/ext/client_channel/message_size_filter.h", 
      "src/core/ext/client_channel/parse_address.h", 
      "src/core/ext/client_channel/resolver.h", 
      "src/core/ext/client_channel/resolver_factory.h", 
@ -7042,8 +7044,6 @@
      "src/core/ext/client_channel/lb_policy_factory.h", 
      "src/core/ext/client_channel/lb_policy_registry.c", 
      "src/core/ext/client_channel/lb_policy_registry.h", 
-      "src/core/ext/client_channel/message_size_filter.c", 
-      "src/core/ext/client_channel/message_size_filter.h", 
      "src/core/ext/client_channel/parse_address.c", 
      "src/core/ext/client_channel/parse_address.h", 
      "src/core/ext/client_channel/resolver.c", 
--- a/vsprojects/vcxproj/grpc/grpc.vcxproj
+++ b/vsprojects/vcxproj/grpc/grpc.vcxproj
@ -308,6 +308,7 @@
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\handshaker.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\http_client_filter.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\http_server_filter.h" />
+    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\message_size_filter.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\compression\algorithm_metadata.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\compression\message_compress.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\debug\trace.h" />
@ -449,7 +450,6 @@
    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\lb_policy.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\lb_policy_factory.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\lb_policy_registry.h" />
-    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\message_size_filter.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\parse_address.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\resolver.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\resolver_factory.h" />
@ -500,6 +500,8 @@
    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\lib\channel\http_server_filter.c">
    </ClCompile>
+    <ClCompile Include="$(SolutionDir)\..\src\core\lib\channel\message_size_filter.c">
+    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\lib\compression\compression.c">
    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\lib\compression\message_compress.c">
@ -830,8 +832,6 @@
    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\ext\client_channel\lb_policy_registry.c">
    </ClCompile>
-    <ClCompile Include="$(SolutionDir)\..\src\core\ext\client_channel\message_size_filter.c">
-    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\ext\client_channel\parse_address.c">
    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\ext\client_channel\resolver.c">
--- a/vsprojects/vcxproj/grpc/grpc.vcxproj.filters
+++ b/vsprojects/vcxproj/grpc/grpc.vcxproj.filters
@ -31,6 +31,9 @@
    <ClCompile Include="$(SolutionDir)\..\src\core\lib\channel\http_server_filter.c">
      <Filter>src\core\lib\channel</Filter>
    </ClCompile>
+    <ClCompile Include="$(SolutionDir)\..\src\core\lib\channel\message_size_filter.c">
+      <Filter>src\core\lib\channel</Filter>
+    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\lib\compression\compression.c">
      <Filter>src\core\lib\compression</Filter>
    </ClCompile>
@ -526,9 +529,6 @@
    <ClCompile Include="$(SolutionDir)\..\src\core\ext\client_channel\lb_policy_registry.c">
      <Filter>src\core\ext\client_channel</Filter>
    </ClCompile>
-    <ClCompile Include="$(SolutionDir)\..\src\core\ext\client_channel\message_size_filter.c">
-      <Filter>src\core\ext\client_channel</Filter>
-    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\ext\client_channel\parse_address.c">
      <Filter>src\core\ext\client_channel</Filter>
    </ClCompile>
@ -767,6 +767,9 @@
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\http_server_filter.h">
      <Filter>src\core\lib\channel</Filter>
    </ClInclude>
+    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\message_size_filter.h">
+      <Filter>src\core\lib\channel</Filter>
+    </ClInclude>
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\compression\algorithm_metadata.h">
      <Filter>src\core\lib\compression</Filter>
    </ClInclude>
@ -1190,9 +1193,6 @@
    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\lb_policy_registry.h">
      <Filter>src\core\ext\client_channel</Filter>
    </ClInclude>
-    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\message_size_filter.h">
-      <Filter>src\core\ext\client_channel</Filter>
-    </ClInclude>
    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\parse_address.h">
      <Filter>src\core\ext\client_channel</Filter>
    </ClInclude>
--- a/vsprojects/vcxproj/grpc_test_util/grpc_test_util.vcxproj
+++ b/vsprojects/vcxproj/grpc_test_util/grpc_test_util.vcxproj
@ -201,6 +201,7 @@
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\handshaker.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\http_client_filter.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\http_server_filter.h" />
+    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\message_size_filter.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\compression\algorithm_metadata.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\compression\message_compress.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\debug\trace.h" />
@ -348,6 +349,8 @@
    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\lib\channel\http_server_filter.c">
    </ClCompile>
+    <ClCompile Include="$(SolutionDir)\..\src\core\lib\channel\message_size_filter.c">
+    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\lib\compression\compression.c">
    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\lib\compression\message_compress.c">
--- a/vsprojects/vcxproj/grpc_test_util/grpc_test_util.vcxproj.filters
+++ b/vsprojects/vcxproj/grpc_test_util/grpc_test_util.vcxproj.filters
@ -88,6 +88,9 @@
    <ClCompile Include="$(SolutionDir)\..\src\core\lib\channel\http_server_filter.c">
      <Filter>src\core\lib\channel</Filter>
    </ClCompile>
+    <ClCompile Include="$(SolutionDir)\..\src\core\lib\channel\message_size_filter.c">
+      <Filter>src\core\lib\channel</Filter>
+    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\lib\compression\compression.c">
      <Filter>src\core\lib\compression</Filter>
    </ClCompile>
@ -554,6 +557,9 @@
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\http_server_filter.h">
      <Filter>src\core\lib\channel</Filter>
    </ClInclude>
+    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\message_size_filter.h">
+      <Filter>src\core\lib\channel</Filter>
+    </ClInclude>
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\compression\algorithm_metadata.h">
      <Filter>src\core\lib\compression</Filter>
    </ClInclude>
--- a/vsprojects/vcxproj/grpc_unsecure/grpc_unsecure.vcxproj
+++ b/vsprojects/vcxproj/grpc_unsecure/grpc_unsecure.vcxproj
@ -298,6 +298,7 @@
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\handshaker.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\http_client_filter.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\http_server_filter.h" />
+    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\message_size_filter.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\compression\algorithm_metadata.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\compression\message_compress.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\debug\trace.h" />
@ -416,7 +417,6 @@
    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\lb_policy.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\lb_policy_factory.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\lb_policy_registry.h" />
-    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\message_size_filter.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\parse_address.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\resolver.h" />
    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\resolver_factory.h" />
@ -468,6 +468,8 @@
    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\lib\channel\http_server_filter.c">
    </ClCompile>
+    <ClCompile Include="$(SolutionDir)\..\src\core\lib\channel\message_size_filter.c">
+    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\lib\compression\compression.c">
    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\lib\compression\message_compress.c">
@ -750,8 +752,6 @@
    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\ext\client_channel\lb_policy_registry.c">
    </ClCompile>
-    <ClCompile Include="$(SolutionDir)\..\src\core\ext\client_channel\message_size_filter.c">
-    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\ext\client_channel\parse_address.c">
    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\ext\client_channel\resolver.c">
--- a/vsprojects/vcxproj/grpc_unsecure/grpc_unsecure.vcxproj.filters
+++ b/vsprojects/vcxproj/grpc_unsecure/grpc_unsecure.vcxproj.filters
@ -34,6 +34,9 @@
    <ClCompile Include="$(SolutionDir)\..\src\core\lib\channel\http_server_filter.c">
      <Filter>src\core\lib\channel</Filter>
    </ClCompile>
+    <ClCompile Include="$(SolutionDir)\..\src\core\lib\channel\message_size_filter.c">
+      <Filter>src\core\lib\channel</Filter>
+    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\lib\compression\compression.c">
      <Filter>src\core\lib\compression</Filter>
    </ClCompile>
@ -457,9 +460,6 @@
    <ClCompile Include="$(SolutionDir)\..\src\core\ext\client_channel\lb_policy_registry.c">
      <Filter>src\core\ext\client_channel</Filter>
    </ClCompile>
-    <ClCompile Include="$(SolutionDir)\..\src\core\ext\client_channel\message_size_filter.c">
-      <Filter>src\core\ext\client_channel</Filter>
-    </ClCompile>
    <ClCompile Include="$(SolutionDir)\..\src\core\ext\client_channel\parse_address.c">
      <Filter>src\core\ext\client_channel</Filter>
    </ClCompile>
@ -680,6 +680,9 @@
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\http_server_filter.h">
      <Filter>src\core\lib\channel</Filter>
    </ClInclude>
+    <ClInclude Include="$(SolutionDir)\..\src\core\lib\channel\message_size_filter.h">
+      <Filter>src\core\lib\channel</Filter>
+    </ClInclude>
    <ClInclude Include="$(SolutionDir)\..\src\core\lib\compression\algorithm_metadata.h">
      <Filter>src\core\lib\compression</Filter>
    </ClInclude>
@ -1034,9 +1037,6 @@
    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\lb_policy_registry.h">
      <Filter>src\core\ext\client_channel</Filter>
    </ClInclude>
-    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\message_size_filter.h">
-      <Filter>src\core\ext\client_channel</Filter>
-    </ClInclude>
    <ClInclude Include="$(SolutionDir)\..\src\core\ext\client_channel\parse_address.h">
      <Filter>src\core\ext\client_channel</Filter>
    </ClInclude>