This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 1824a86575 [Session] print ip and port for connection failure (#6650)
1824a86575 is described below
commit 1824a865753c95b399612746f2160eacd05d44fa
Author: Mrquan <[email protected]>
AuthorDate: Tue Jul 12 22:41:35 2022 +0800
[Session] print ip and port for connection failure (#6650)
---
.../apache/iotdb/session/SessionConnection.java | 84 +++++++++++++---------
1 file changed, 50 insertions(+), 34 deletions(-)
diff --git
a/session/src/main/java/org/apache/iotdb/session/SessionConnection.java
b/session/src/main/java/org/apache/iotdb/session/SessionConnection.java
index 63653dfbde..3c2ab44b72 100644
--- a/session/src/main/java/org/apache/iotdb/session/SessionConnection.java
+++ b/session/src/main/java/org/apache/iotdb/session/SessionConnection.java
@@ -69,12 +69,13 @@ import java.time.ZoneId;
import java.util.ArrayList;
import java.util.List;
import java.util.Random;
+import java.util.StringJoiner;
public class SessionConnection {
private static final Logger logger =
LoggerFactory.getLogger(SessionConnection.class);
public static final String MSG_RECONNECTION_FAIL =
- "Fail to reconnect to server. Please check server status";
+ "Fail to reconnect to server. Please check server status.";
private Session session;
private TTransport transport;
private IClientRPCService.Iface client;
@@ -207,7 +208,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
RpcUtils.verifySuccess(resp);
@@ -233,7 +234,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -250,7 +251,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -269,7 +270,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -288,7 +289,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -307,7 +308,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -349,7 +350,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
@@ -385,7 +386,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -410,7 +411,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
@@ -448,7 +449,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
@@ -480,7 +481,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -499,7 +500,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -519,7 +520,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -539,7 +540,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -558,7 +559,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -577,7 +578,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -596,7 +597,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -616,7 +617,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -633,7 +634,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -652,7 +653,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -671,7 +672,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -690,7 +691,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -709,7 +710,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -728,7 +729,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -747,7 +748,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -766,7 +767,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -820,7 +821,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -839,7 +840,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -858,7 +859,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -877,7 +878,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
@@ -899,7 +900,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -918,7 +919,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -937,7 +938,7 @@ public class SessionConnection {
throw new IoTDBConnectionException(tException);
}
} else {
- throw new IoTDBConnectionException(MSG_RECONNECTION_FAIL);
+ throw new IoTDBConnectionException(logForReconnectionFailure());
}
}
}
@@ -958,6 +959,21 @@ public class SessionConnection {
this.endPoint = endPoint;
}
+ // error log for connection failure
+ private String logForReconnectionFailure() {
+ if (endPointList == null) {
+ return MSG_RECONNECTION_FAIL;
+ }
+ StringJoiner urls = new StringJoiner(",");
+ for (TEndPoint endPoint : endPointList) {
+ StringJoiner url = new StringJoiner(":");
+ url.add(endPoint.getIp());
+ url.add(String.valueOf(endPoint.getPort()));
+ urls.add(url.toString());
+ }
+ return MSG_RECONNECTION_FAIL.concat(urls.toString());
+ }
+
@Override
public String toString() {
return "SessionConnection{" + " endPoint=" + endPoint + "}";
