Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-4208 OpenWire chunk receive should not issue a flush

This commit is contained in:
Clebert Suconic 2023-03-15 15:07:43 -04:00 committed by clebertsuconic
parent 8b2be8ef3b
commit 80cc8030d3
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java
View File

@ -144,6 +144,8 @@ import java.lang.invoke.MethodHandles;
public class OpenWireConnection extends AbstractRemotingConnection implements SecurityAuth, TempQueueObserver {
private final Object lockSend = new Object();
// to be used on the packet size estimate processing for the ThresholdActor
private static final int MINIMAL_SIZE_ESTIAMTE = 1024;
@ -553,7 +555,7 @@ public class OpenWireConnection extends AbstractRemotingConnection implements Se
// We can't let any other packet to sneak in while chunkSend is happening.
// otherwise we may get wrong packts delivered
synchronized (transportConnection) {
synchronized (lockSend) {
if (maxChunkSize > 0 && bufferSize > maxChunkSize) {
chunkSend(bytes, bufferSize, maxChunkSize);
} else {
@ -582,7 +584,7 @@ public class OpenWireConnection extends AbstractRemotingConnection implements Se
}
final ActiveMQBuffer chunk = transportConnection.createTransportBuffer(chunkSize);
chunk.writeBytes(bytes.data, bytes.offset, chunkSize);
transportConnection.write(chunk, true, false);
transportConnection.write(chunk, false, false);
bytes.setOffset(bytes.getOffset() + chunkSize);
}
}