in-progress changes.

Author: kannanjgithub

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

@@ -300,7 +300,6 @@ private void drainPendingCalls() {
       }
       for (Runnable runnable : toRun) {
         // Must not call transport while lock is held to prevent deadlocks.
-        // TODO(ejona): exception handling
         runnable.run();
       }
       toRun.clear();

stub/src/main/java/io/grpc/stub/ClientCalls.java

@@ -170,12 +170,12 @@ public static <ReqT, RespT> RespT blockingUnaryCall(
           // Now wait for onClose() to be called, so interceptors can clean up
         }
       }
-      executor.shutdown();
       return getUnchecked(responseFuture);
     } catch (RuntimeException | Error e) {
       // Something very bad happened. All bets are off; it may be dangerous to wait for onClose().
       throw cancelThrow(call, e);
     } finally {
+      executor.shutdown();
       if (interrupt) {
         Thread.currentThread().interrupt();
       }
@@ -822,7 +822,7 @@ public void waitAndDrain() throws InterruptedException {
         }
       }
       do {
-        runQuietly(runnable);
+        runnable.run();
       } while ((runnable = poll()) != null);
     }
 

stub/src/test/java/io/grpc/stub/ClientCallsTest.java

@@ -163,6 +163,35 @@ public void start(io.grpc.ClientCall.Listener<String> listener, Metadata headers
     }
   }
 
+  @Test
+  public void unaryBlockingCallFailed_outboundMessageSizeExceeded() throws Exception {
+    Integer req = 2;
+    final Integer resp = 3;
+
+    class BasicUnaryResponse implements UnaryMethod<Integer, Integer> {
+      Integer request;
+
+      @Override public void invoke(Integer request, StreamObserver<Integer> responseObserver) {
+        this.request = request;
+        responseObserver.onNext(resp);
+        responseObserver.onCompleted();
+      }
+    }
+    BasicUnaryResponse service = new BasicUnaryResponse();
+    server = InProcessServerBuilder.forName("simple-reply").directExecutor()
+        .addService(ServerServiceDefinition.builder("some")
+            .addMethod(UNARY_METHOD, ServerCalls.asyncUnaryCall(service))
+            .build())
+        .build().start();
+    channel = InProcessChannelBuilder.forName("simple-reply").directExecutor().build();
+    try {
+      ClientCalls.blockingUnaryCall(channel, UNARY_METHOD, CallOptions.DEFAULT.withMaxOutboundMessageSize(0), req);
+      fail("Should fail");
+    } catch (StatusRuntimeException e) {
+      System.out.println("err");
+    }
+  }
+
   @Test
   public void blockingUnaryCall2_success() throws Exception {
     Integer req = 2;