This is an automated email from the ASF dual-hosted git repository. xiangweiwei pushed a commit to branch memoryleakmaster in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit f0be33780a6b420826f53bc6c0aa3f1273b209aa Author: Alima777 <[email protected]> AuthorDate: Mon Nov 8 17:40:44 2021 +0800 rename session id --- .../iotdb/db/query/control/SessionTimeoutManager.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/query/control/SessionTimeoutManager.java b/server/src/main/java/org/apache/iotdb/db/query/control/SessionTimeoutManager.java index abd557e..6741c05 100644 --- a/server/src/main/java/org/apache/iotdb/db/query/control/SessionTimeoutManager.java +++ b/server/src/main/java/org/apache/iotdb/db/query/control/SessionTimeoutManager.java @@ -58,32 +58,32 @@ public class SessionTimeoutManager { TimeUnit.MILLISECONDS); } - public void register(long id) { + public void register(long sessionId) { if (SESSION_TIMEOUT == 0) { return; } - sessionIdToLastActiveTime.put(id, System.currentTimeMillis()); + sessionIdToLastActiveTime.put(sessionId, System.currentTimeMillis()); } - public boolean unregister(long id) { + public boolean unregister(long sessionId) { if (SESSION_TIMEOUT == 0) { - return SessionManager.getInstance().releaseSessionResource(id); + return SessionManager.getInstance().releaseSessionResource(sessionId); } - if (SessionManager.getInstance().releaseSessionResource(id)) { - return sessionIdToLastActiveTime.remove(id) != null; + if (SessionManager.getInstance().releaseSessionResource(sessionId)) { + return sessionIdToLastActiveTime.remove(sessionId) != null; } return false; } - public void refresh(long id) { + public void refresh(long sessionId) { if (SESSION_TIMEOUT == 0) { return; } - sessionIdToLastActiveTime.computeIfPresent(id, (k, v) -> System.currentTimeMillis()); + sessionIdToLastActiveTime.computeIfPresent(sessionId, (k, v) -> System.currentTimeMillis()); } private void cleanup() {
