CR

Author: panchenko

core/src/main/java/io/grpc/internal/ServerCallImpl.java

@@ -330,17 +330,8 @@ private void messagesAvailableInternal(final MessageProducer producer) {
       InputStream message;
       try {
         while ((message = producer.next()) != null) {
-          ReqT parsedMessage;
           try {
-            parsedMessage = call.method.parseRequest(message);
-          } catch (StatusRuntimeException e) {
-            GrpcUtil.closeQuietly(message);
-            call.cancelled = true;
-            call.close(e.getStatus(), new Metadata());
-            return;
-          }
-          try {
-            listener.onMessage(parsedMessage);
+            listener.onMessage(call.method.parseRequest(message));
           } catch (Throwable t) {
             GrpcUtil.closeQuietly(message);
             throw t;

interop-testing/src/test/java/io/grpc/testing/integration/TransportCompressionTest.java

@@ -141,7 +141,7 @@ public void compresses() {
   private static final String DECOMPRESSED_MESSAGE_TOO_LONG_METHOD_NAME = "decompressedMessageTooLong";
 
   @Test
-//  @Ignore("WIP")
+  @Ignore("WIP")
   public void decompressedMessageTooLong() {
     assertEquals(DECOMPRESSED_MESSAGE_TOO_LONG_METHOD_NAME, currentTest.getMethodName());
     final SimpleRequest bigRequest = SimpleRequest.newBuilder()