Added handle of exceptions on channel creating

Author: alex268

core/src/main/java/tech/ydb/core/impl/YdbDiscovery.java

@@ -140,26 +140,30 @@ private void tick() {
 
     private void runDiscovery() {
         lastUpdateTime = handler.instant();
-        final GrpcTransport transport = handler.createDiscoveryTransport();
         try {
-            logger.debug("execute list endpoints on {} with timeout {}", transport, discoveryTimeout);
-            DiscoveryProtos.ListEndpointsRequest request = DiscoveryProtos.ListEndpointsRequest.newBuilder()
-                    .setDatabase(discoveryDatabase)
-                    .build();
-
-            GrpcRequestSettings grpcSettings = GrpcRequestSettings.newBuilder()
-                    .withDeadline(discoveryTimeout)
-                    .build();
-
-            transport.unaryCall(DiscoveryServiceGrpc.getListEndpointsMethod(), grpcSettings, request)
-                    .whenComplete((res, ex) -> transport.close()) // close transport for any result
-                    .thenApply(OperationBinder.bindSync(
-                            DiscoveryProtos.ListEndpointsResponse::getOperation,
-                            DiscoveryProtos.ListEndpointsResult.class
-                    ))
-                    .whenComplete(this::handleDiscoveryResult);
+            final GrpcTransport transport = handler.createDiscoveryTransport();
+            try {
+                logger.debug("execute list endpoints on {} with timeout {}", transport, discoveryTimeout);
+                DiscoveryProtos.ListEndpointsRequest request = DiscoveryProtos.ListEndpointsRequest.newBuilder()
+                        .setDatabase(discoveryDatabase)
+                        .build();
+
+                GrpcRequestSettings grpcSettings = GrpcRequestSettings.newBuilder()
+                        .withDeadline(discoveryTimeout)
+                        .build();
+
+                transport.unaryCall(DiscoveryServiceGrpc.getListEndpointsMethod(), grpcSettings, request)
+                        .whenComplete((res, ex) -> transport.close()) // close transport for any result
+                        .thenApply(OperationBinder.bindSync(
+                                DiscoveryProtos.ListEndpointsResponse::getOperation,
+                                DiscoveryProtos.ListEndpointsResult.class
+                        ))
+                        .whenComplete(this::handleDiscoveryResult);
+            } catch (Throwable th) {
+                transport.close();
+                throw th;
+            }
         } catch (Throwable th) {
-            transport.close();
             handleDiscoveryResult(null, th);
         }
     }

core/src/main/java/tech/ydb/core/impl/pool/GrpcChannel.java

@@ -25,12 +25,17 @@ public class GrpcChannel {
     private final ReadyWatcher readyWatcher;
 
     public GrpcChannel(EndpointRecord endpoint, ManagedChannelFactory factory) {
-        logger.debug("Creating grpc channel with {}", endpoint);
-        this.endpoint = endpoint;
-        this.channel = factory.newManagedChannel(endpoint.getHost(), endpoint.getPort());
-        this.connectTimeoutMs = factory.getConnectTimeoutMs();
-        this.readyWatcher = new ReadyWatcher();
-        this.readyWatcher.checkState();
+        try {
+            logger.debug("Creating grpc channel with {}", endpoint);
+            this.endpoint = endpoint;
+            this.channel = factory.newManagedChannel(endpoint.getHost(), endpoint.getPort());
+            this.connectTimeoutMs = factory.getConnectTimeoutMs();
+            this.readyWatcher = new ReadyWatcher();
+            this.readyWatcher.checkState();
+        } catch (Throwable th) {
+            logger.error("cannot create channel", th);
+            throw new RuntimeException("cannot create channel", th);
+        }
     }
 
     public EndpointRecord getEndpoint() {