Endpoint port validation in GrpcTransport

fmsprog · fmsprog · commit 106084fdcdfa · 2025-10-10T11:26:59.000+03:00
diff --git a/core/src/main/java/tech/ydb/core/impl/YdbTransportImpl.java b/core/src/main/java/tech/ydb/core/impl/YdbTransportImpl.java
@@ -126,7 +126,7 @@ static EndpointRecord getDiscoveryEndpoint(GrpcTransportBuilder builder) {
                     + "endpoint " + builder.getEndpoint() + " and empty host " + builder.getHost());
         }
 
-        if (endpointURI.getPort() == -1) {
+        if (endpointURI.getPort() < 0) {
             throw new IllegalArgumentException("Can't create discovery rpc, port is not specified for "
                     + "endpoint " + builder.getEndpoint());
         }

Original file line number	Diff line number	Diff line change
`@@ -126,7 +126,7 @@ static EndpointRecord getDiscoveryEndpoint(GrpcTransportBuilder builder) {`
`126`	`126`	`+ "endpoint " + builder.getEndpoint() + " and empty host " + builder.getHost());`
`127`	`127`	`}`
`128`	`128`
`129`		`- if (endpointURI.getPort() == -1) {`
	`129`	`+ if (endpointURI.getPort() < 0) {`
`130`	`130`	`throw new IllegalArgumentException("Can't create discovery rpc, port is not specified for "`
`131`	`131`	`+ "endpoint " + builder.getEndpoint());`
`132`	`132`	`}`