From d96c201aec31112e3c7771a6bced6e3eb6572265 Mon Sep 17 00:00:00 2001 From: heavyrain2012 Date: Tue, 28 Dec 2021 19:30:48 +0800 Subject: [PATCH] add log --- .../java/io/moquette/persistence/MemorySessionStore.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java b/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java index 67fb0cf0..fd649883 100755 --- a/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemorySessionStore.java @@ -727,6 +727,10 @@ public class MemorySessionStore implements ISessionsStore { public ErrorCode kickoffPCClient(String operator, String pcClientId) { Session session = sessions.get(pcClientId); if (session != null) { + if(!operator.equals(session.getUsername())) { + LOG.error("kickoffPCClient failure, user {} don't have client {}", operator, pcClientId); + return ErrorCode.ERROR_CODE_NOT_RIGHT; + } if (session.getPlatform() == ProtoConstants.Platform.Platform_LINUX || session.getPlatform() == ProtoConstants.Platform.Platform_Windows || session.getPlatform() == ProtoConstants.Platform.Platform_OSX @@ -737,8 +741,11 @@ public class MemorySessionStore implements ISessionsStore { sessions.remove(pcClientId); mServer.getProcessor().kickoffSession(session); } else { + LOG.error("session {} is not pc client:{}", pcClientId, session.getPlatform()); return ErrorCode.ERROR_CODE_NOT_RIGHT; } + } else { + LOG.error("Can't find the session for client <{}>", pcClientId); } return ErrorCode.ERROR_CODE_SUCCESS; }