Repository navigation
memory leak #732
Description
Activity
case BODY:
ByteBuf mqttBuf = in.readBytes(header.getBodyLength());
MqttAdapterMessage adapterMsg = new MqttAdapterMessage(header.version, header.clientId);
out.add(adapterMsg);
out.add(mqttBuf);readBytes() will create a new ByteBuf, and we add it to the out list, it will be released by netty. however, when i start two thousand clients to pub and sub, mop has occasional memory leaks，and i do not know why.
Reacted by Qiang Zhao
Metadata
Metadata
Assignees
Labels
No labels
Describe the bug
when i test mqtt proxy with many connections, memory leak appeared.
it seems that bytebuf.release was not be called when decode msg
To Reproduce
Steps to reproduce the behavior:
Expected behavior
A clear and concise description of what you expected to happen.
Screenshots
If applicable, add screenshots to help explain your problem.
Desktop (please complete the following information):
Additional context
Add any other context about the problem here.