Repository navigation
memory leak #732
Description
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:
- Go to '...'
- Click on '....'
- Scroll down to '....'
- See error
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):
- OS: [e.g. iOS]
Additional context
Add any other context about the problem here.
Metadata
Metadata
Assignees
Labels
No labels
Activity
hujie6 commentedon Aug 18, 2022
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.