mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-05-20 12:24:54 +00:00
del[signal]: remove unnecessary log
This commit is contained in:
@@ -13,9 +13,6 @@
|
||||
package com.zfoo.net.router;
|
||||
|
||||
import com.zfoo.net.router.attachment.SignalAttachment;
|
||||
import com.zfoo.protocol.util.JsonUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import java.util.Map;
|
||||
import java.util.concurrent.ConcurrentHashMap;
|
||||
@@ -29,8 +26,6 @@ import java.util.concurrent.atomic.AtomicReferenceArray;
|
||||
*/
|
||||
public class SignalBridge {
|
||||
|
||||
private static final Logger logger = LoggerFactory.getLogger(SignalBridge.class);
|
||||
|
||||
// equal with 32767
|
||||
private static final int SIGNAL_MASK = 0B00000000_00000000_01111111_11111111;
|
||||
|
||||
@@ -72,18 +67,16 @@ public class SignalBridge {
|
||||
return signalAttachmentMap.remove(signalId);
|
||||
}
|
||||
|
||||
public static void status() {
|
||||
var count = 0;
|
||||
public static int signalSize() {
|
||||
var size = 0;
|
||||
for (int i = 0; i < SIGNAL_MASK + 1; i++) {
|
||||
var value = signalAttachmentArray.get(i);
|
||||
if (value != null) {
|
||||
logger.info("signalPacketArray has attachment [index:{}][count:{}][value:{}]", i, ++count, JsonUtils.object2String(value));
|
||||
size++;
|
||||
}
|
||||
}
|
||||
|
||||
signalAttachmentMap.forEach((key, value) -> {
|
||||
logger.info("signalAttachmentMap has attachment [key:{}][value:{}]", key, JsonUtils.object2String(value));
|
||||
});
|
||||
size += signalAttachmentMap.size();
|
||||
return size;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -14,6 +14,7 @@ package com.zfoo.net.router;
|
||||
|
||||
import com.zfoo.event.manager.EventBus;
|
||||
import com.zfoo.net.router.attachment.SignalAttachment;
|
||||
import com.zfoo.protocol.util.StringUtils;
|
||||
import com.zfoo.scheduler.util.TimeUtils;
|
||||
import org.junit.Ignore;
|
||||
import org.junit.Test;
|
||||
@@ -36,7 +37,7 @@ public class SignalBridgeTest {
|
||||
for (int i = 0; i < 10; i++) {
|
||||
arrayTest();
|
||||
}
|
||||
SignalBridge.status();
|
||||
System.out.println(StringUtils.format("attachment size:[{}]", SignalBridge.signalSize()));
|
||||
System.out.println(SignalAttachment.ATOMIC_ID.get());
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user