change.

Author: kannanjgithub

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

@@ -275,7 +275,8 @@ public void runInContext() {
     }
     if (effectiveDeadline != null) {
       stream.setDeadline(effectiveDeadline);
-    }
+    };
+    stream.setDeadline(Deadline.after(1, TimeUnit.SECONDS));
     stream.setCompressor(compressor);
     if (fullStreamDecompression) {
       stream.setFullStreamDecompression(fullStreamDecompression);

examples/build.gradle

@@ -45,7 +45,7 @@ dependencies {
 protobuf {
     protoc { artifact = "com.google.protobuf:protoc:${protocVersion}" }
     plugins {
-        grpc { artifact = "io.grpc:protoc-gen-grpc-java:${grpcVersion}" }
+        grpc { artifact = "io.grpc:protoc-gen-grpc-java:1.70.0" }
     }
     generateProtoTasks {
         all()*.plugins { grpc {} }

examples/src/main/java/io/grpc/examples/deadline/DeadlineClient.java

@@ -85,7 +85,7 @@ public static void main(String[] args) throws Exception {
       client.greet("deadline client", 1000);
 
       // A smaller deadline will result in us getting a DEADLINE_EXCEEDED error.
-      logger.info(
+      /*logger.info(
           "Calling server with an unrealistic (300ms) deadline, expecting a DEADLINE_EXCEEDED");
       client.greet("deadline client", 300);
 
@@ -102,7 +102,7 @@ public static void main(String[] args) throws Exception {
       // runs out of time waiting for the propagated call to finish.
       logger.info(
           "Calling server with propagation and a generous deadline, expecting a DEADLINE_EXCEEDED");
-      client.greet("deadline client [propagate]", 1000);
+      client.greet("deadline client [propagate]", 1000);*/
     } finally {
       channel.shutdownNow().awaitTermination(5, TimeUnit.SECONDS);
     }

examples/src/main/java/io/grpc/examples/deadline/DeadlineServer.java

@@ -19,7 +19,12 @@
 import io.grpc.Grpc;
 import io.grpc.InsecureChannelCredentials;
 import io.grpc.InsecureServerCredentials;
+import io.grpc.Metadata;
 import io.grpc.Server;
+import io.grpc.ServerCall;
+import io.grpc.ServerCall.Listener;
+import io.grpc.ServerCallHandler;
+import io.grpc.ServerInterceptor;
 import io.grpc.examples.helloworld.GreeterGrpc;
 import io.grpc.examples.helloworld.HelloReply;
 import io.grpc.examples.helloworld.HelloRequest;
@@ -38,6 +43,39 @@ private void start() throws IOException {
     int port = 50051;
     SlowGreeter slowGreeter = new SlowGreeter();
     server = Grpc.newServerBuilderForPort(port, InsecureServerCredentials.create())
+        .intercept(new ServerInterceptor() {
+          @Override
+          public <ReqT, RespT> Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> call,
+              Metadata headers, ServerCallHandler<ReqT, RespT> next) {
+            Listener<ReqT> fwkReqListener = next.startCall(call, headers);
+            return new Listener<ReqT>() {
+              @Override
+              public void onMessage(ReqT message) {
+                fwkReqListener.onMessage(message);
+              }
+
+              @Override
+              public void onHalfClose() {
+                fwkReqListener.onHalfClose();
+              }
+
+              @Override
+              public void onCancel() {
+                fwkReqListener.onCancel();
+              }
+
+              @Override
+              public void onComplete() {
+                fwkReqListener.onComplete();
+              }
+
+              @Override
+              public void onReady() {
+                fwkReqListener.onReady();
+              }
+            };
+          }
+        })
         .addService(slowGreeter)
         .build()
         .start();

examples/src/main/java/io/grpc/examples/helloworld/HelloWorldServer.java

@@ -18,7 +18,12 @@
 
 import io.grpc.Grpc;
 import io.grpc.InsecureServerCredentials;
+import io.grpc.Metadata;
 import io.grpc.Server;
+import io.grpc.ServerCall;
+import io.grpc.ServerCall.Listener;
+import io.grpc.ServerCallHandler;
+import io.grpc.ServerInterceptor;
 import io.grpc.stub.StreamObserver;
 import java.io.IOException;
 import java.util.concurrent.TimeUnit;
@@ -36,6 +41,39 @@ private void start() throws IOException {
     /* The port on which the server should run */
     int port = 50051;
     server = Grpc.newServerBuilderForPort(port, InsecureServerCredentials.create())
+        .intercept(new ServerInterceptor() {
+          @Override
+          public <ReqT, RespT> Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> call,
+              Metadata headers, ServerCallHandler<ReqT, RespT> next) {
+            Listener<ReqT> fwkReqListener = next.startCall(call, headers);
+            return new Listener<ReqT>() {
+              @Override
+              public void onMessage(ReqT message) {
+                fwkReqListener.onMessage(message);
+              }
+
+              @Override
+              public void onHalfClose() {
+                fwkReqListener.onHalfClose();
+              }
+
+              @Override
+              public void onCancel() {
+                fwkReqListener.onCancel();
+              }
+
+              @Override
+              public void onComplete() {
+                fwkReqListener.onComplete();
+              }
+
+              @Override
+              public void onReady() {
+                fwkReqListener.onReady();
+              }
+            };
+          }
+        })
         .addService(new GreeterImpl())
         .build()
         .start();
@@ -83,6 +121,11 @@ static class GreeterImpl extends GreeterGrpc.GreeterImplBase {
 
     @Override
     public void sayHello(HelloRequest req, StreamObserver<HelloReply> responseObserver) {
+      try {
+        Thread.sleep(10000);
+      } catch (InterruptedException e) {
+        throw new RuntimeException(e);
+      }
       HelloReply reply = HelloReply.newBuilder().setMessage("Hello " + req.getName()).build();
       responseObserver.onNext(reply);
       responseObserver.onCompleted();