Log if GRPC server/channel exceeds shutdown timeout (#33)

Author: igor-vovk

README.md

@@ -151,8 +151,8 @@ Current status: 6/79 tests pass
 
 Known issues:
 
-* `fs2-grpc` server implementation doesn't support setting response headers (which is required by the tests)
-* `google.protobuf.Any` serialization doesn't follow Connect-RPC spec
+* `fs2-grpc` server implementation doesn't support setting response headers (which is required by the tests): [#31](https://github.com/igor-vovk/connect-rpc-scala/issues/31)
+* `google.protobuf.Any` serialization doesn't follow Connect-RPC spec: [#32](https://github.com/igor-vovk/connect-rpc-scala/issues/32)
 
 ## Future improvements
 

core/src/main/scala/org/ivovk/connect_rpc_scala/InProcessChannelBridge.scala

@@ -2,9 +2,9 @@ package org.ivovk.connect_rpc_scala
 
 import cats.Endo
 import cats.effect.{Resource, Sync}
-import cats.implicits.*
 import io.grpc.*
 import io.grpc.inprocess.{InProcessChannelBuilder, InProcessServerBuilder}
+import org.slf4j.{Logger, LoggerFactory}
 
 import java.util.concurrent.TimeUnit
 import scala.concurrent.duration.Duration
@@ -13,6 +13,8 @@ import scala.util.chaining.*
 
 object InProcessChannelBridge {
 
+  private val logger: Logger = LoggerFactory.getLogger(getClass)
+
   def create[F[_] : Sync](
     services: Seq[ServerServiceDefinition],
     serverBuilderConfigurator: Endo[ServerBuilder[?]] = identity,
@@ -40,8 +42,13 @@ object InProcessChannelBridge {
         .build()
         .start()
     }
-    val release = (s: Server) =>
-      Sync[F].delay(s.shutdown().awaitTermination(waitForShutdown.toMillis, TimeUnit.MILLISECONDS)).void
+    val release = (s: Server) => Sync[F].delay {
+      val res = s.shutdown().awaitTermination(waitForShutdown.toMillis, TimeUnit.MILLISECONDS)
+
+      if (!res) {
+        logger.warn(s"GRPC server did not shut down in $waitForShutdown")
+      }
+    }
 
     Resource.make(acquire)(release)
   }
@@ -57,8 +64,13 @@ object InProcessChannelBridge {
         .pipe(channelBuilderConfigurator)
         .build()
     }
-    val release = (c: ManagedChannel) =>
-      Sync[F].delay(c.shutdown().awaitTermination(waitForShutdown.toMillis, TimeUnit.MILLISECONDS)).void
+    val release = (c: ManagedChannel) => Sync[F].delay {
+      val res = c.shutdown().awaitTermination(waitForShutdown.toMillis, TimeUnit.MILLISECONDS)
+
+      if (!res) {
+        logger.warn(s"GRPC channel did not shut down in $waitForShutdown")
+      }
+    }
 
     Resource.make(acquire)(release)
   }