bug fix: avoid wrong local port increment

emac · emac · commit 00149bae435d · 2015-09-10T16:32:08.000+08:00
diff --git a/src/main/java/com/m11n/jdbc/ssh/SshTunnel.java b/src/main/java/com/m11n/jdbc/ssh/SshTunnel.java
@@ -94,7 +94,7 @@ public void start() {
                 nextPort = localPort.incrementAndGet();
             }
 
-            assignedPort = session.setPortForwardingL(localPort.incrementAndGet(), forwardHost, remotePort);
+            assignedPort = session.setPortForwardingL(nextPort, forwardHost, remotePort);
 
             if(logger.isDebugEnabled()) {
                 logger.debug("Server version: {}", session.getServerVersion());

Original file line number	Diff line number	Diff line change
`@@ -94,7 +94,7 @@ public void start() {`
`94`	`94`	`nextPort = localPort.incrementAndGet();`
`95`	`95`	`}`
`96`	`96`
`97`		`- assignedPort = session.setPortForwardingL(localPort.incrementAndGet(), forwardHost, remotePort);`
	`97`	`+ assignedPort = session.setPortForwardingL(nextPort, forwardHost, remotePort);`
`98`	`98`
`99`	`99`	`if(logger.isDebugEnabled()) {`
`100`	`100`	`logger.debug("Server version: {}", session.getServerVersion());`