Performance of PathTriesTree during high volume subscribe to same node in tree

[simon622]

java.lang.Thread.State: RUNNABLE
at java.util.HashMap$HashIterator.nextNode([email protected]/HashMap.java:1601)
at java.util.HashMap$KeyIterator.next([email protected]/HashMap.java:1620)
at java.util.Collections$UnmodifiableCollection$1.next([email protected]/Collections.java:1054)
at java.util.AbstractCollection.addAll([email protected]/AbstractCollection.java:335)
at org.slj.mqtt.sn.utils.tree.PathTriesTree.searchTreeForMembers(PathTriesTree.java:234)
at org.slj.mqtt.sn.utils.tree.PathTriesTree.searchMembers(PathTriesTree.java:157)
at org.slj.mqtt.sn.utils.tree.PathTriesTree.hasMembers(PathTriesTree.java:161)

[simon622]

mqtt-sn-udp-transport-ingress-1229202732-1" #25 daemon prio=2 os_prio=31 cpu=34923.49ms elapsed=211.67s tid=0x000000014a030e00 nid=0x5707 runnable [0x0000000291266000]
java.lang.Thread.State: RUNNABLE
at java.util.HashMap$HashIterator.nextNode([email protected]/HashMap.java:1601)
at java.util.HashMap$KeyIterator.next([email protected]/HashMap.java:1620)
at java.util.Collections$UnmodifiableCollection$1.next([email protected]/Collections.java:1054)
at java.util.AbstractCollection.addAll([email protected]/AbstractCollection.java:335)
at org.slj.mqtt.sn.utils.tree.PathTriesTree.searchTreeForMembers(PathTriesTree.java:234)
at org.slj.mqtt.sn.utils.tree.PathTriesTree.searchMembers(PathTriesTree.java:157)
at org.slj.mqtt.sn.utils.tree.PathTriesTree.hasMembers(PathTriesTree.java:161)
at org.slj.mqtt.sn.impl.ram.MqttsnInMemorySubscriptionRegistry.hasSubscription(MqttsnInMemorySubscriptionRegistry.java:108)
at org.slj.mqtt.sn.gateway.impl.gateway.type.MqttsnAggregatingGateway.subscribe(MqttsnAggregatingGateway.java:318)
at org.slj.mqtt.sn.gateway.impl.gateway.MqttsnGatewaySessionService.subscribe(MqttsnGatewaySessionService.java:257)
- locked <0x00000007fe873320> (a org.slj.mqtt.sn.model.ClientIdentifierContext)
at org.slj.mqtt.sn.gateway.impl.gateway.MqttsnGatewayMessageHandler.handleSubscribe(MqttsnGatewayMessageHandler.java:321)
at org.slj.mqtt.sn.impl.AbstractMqttsnMessageHandler.handle(AbstractMqttsnMessageHandler.java:218)
at org.slj.mqtt.sn.impl.AbstractMqttsnMessageHandler.receiveMessage(AbstractMqttsnMessageHandler.java:129)
at org.slj.mqtt.sn.impl.AbstractMqttsnTransport.receiveFromTransportInternal(AbstractMqttsnTransport.java:120)
at org.slj.mqtt.sn.impl.AbstractTransport.lambda$receiveFromTransport$1(AbstractTransport.java:120)
at org.slj.mqtt.sn.impl.AbstractTransport$$Lambda$187/0x0000000800d99668.run(Unknown Source)
at java.util.concurrent.Executors$RunnableAdapter.call([email protected]/Executors.java:539)
at java.util.concurrent.FutureTask.run([email protected]/FutureTask.java:264)
at java.util.concurrent.ThreadPoolExecutor.runWorker([email protected]/ThreadPoolExecutor.java:1136)
at java.util.concurrent.ThreadPoolExecutor$Worker.run([email protected]/ThreadPoolExecutor.java:635)
at java.lang.Thread.run([email protected]/Thread.java:833)

[simon622]

Fixed, abstracted to the MqttTree project which also includes performance work