You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by wu...@apache.org on 2020/12/03 07:16:45 UTC
[shardingsphere-elasticjob] branch master updated: snapshotService
log the actual port (#1756)
This is an automated email from the ASF dual-hosted git repository.
wuweijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere-elasticjob.git
The following commit(s) were added to refs/heads/master by this push:
new eb757b9 snapshotService log the actual port (#1756)
eb757b9 is described below
commit eb757b92f2fd57626cb5a0411e6cb4704cebb8a1
Author: kdYY <30...@users.noreply.github.com>
AuthorDate: Thu Dec 3 15:16:28 2020 +0800
snapshotService log the actual port (#1756)
* snapshotService log the actual port
* snapshotService log the actual port
---
.../elasticjob/lite/internal/snapshot/SnapshotService.java | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
diff --git a/elasticjob-lite/elasticjob-lite-core/src/main/java/org/apache/shardingsphere/elasticjob/lite/internal/snapshot/SnapshotService.java b/elasticjob-lite/elasticjob-lite-core/src/main/java/org/apache/shardingsphere/elasticjob/lite/internal/snapshot/SnapshotService.java
index f27cbc0..d2a1131 100644
--- a/elasticjob-lite/elasticjob-lite-core/src/main/java/org/apache/shardingsphere/elasticjob/lite/internal/snapshot/SnapshotService.java
+++ b/elasticjob-lite/elasticjob-lite-core/src/main/java/org/apache/shardingsphere/elasticjob/lite/internal/snapshot/SnapshotService.java
@@ -62,16 +62,16 @@ public final class SnapshotService {
*/
public void listen() {
try {
- log.info("ElasticJob: Snapshot service is running on port '{}'", port);
- openSocket(port);
+ log.info("ElasticJob: Snapshot service is running on port '{}'", openSocket(port));
} catch (final IOException ex) {
log.error("ElasticJob: Snapshot service listen failure, error is: ", ex);
}
}
- private void openSocket(final int port) throws IOException {
+ private int openSocket(final int port) throws IOException {
serverSocket = new ServerSocket(port);
- String threadName = String.format("elasticjob-snapshot-service-%d", port);
+ int localPort = serverSocket.getLocalPort();
+ String threadName = String.format("elasticjob-snapshot-service-%d", localPort);
new Thread(() -> {
while (!closed) {
try {
@@ -84,6 +84,7 @@ public final class SnapshotService {
}
}
}, threadName).start();
+ return localPort;
}
private boolean isIgnoredException() {