This is an automated email from the ASF dual-hosted git repository.
zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 10bbd2d6617 Refactor MySQLPacketCodecEngine to use do-while loop for
adding pending messages (#37224)
10bbd2d6617 is described below
commit 10bbd2d661747dc78be8e3b41f0875482db67dae
Author: Liang Zhang <[email protected]>
AuthorDate: Sun Nov 30 10:28:10 2025 +0800
Refactor MySQLPacketCodecEngine to use do-while loop for adding pending
messages (#37224)
---
.../database/protocol/mysql/codec/MySQLPacketCodecEngine.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git
a/database/protocol/dialect/mysql/src/main/java/org/apache/shardingsphere/database/protocol/mysql/codec/MySQLPacketCodecEngine.java
b/database/protocol/dialect/mysql/src/main/java/org/apache/shardingsphere/database/protocol/mysql/codec/MySQLPacketCodecEngine.java
index 08380a61ee3..2d229ca8b4a 100644
---
a/database/protocol/dialect/mysql/src/main/java/org/apache/shardingsphere/database/protocol/mysql/codec/MySQLPacketCodecEngine.java
+++
b/database/protocol/dialect/mysql/src/main/java/org/apache/shardingsphere/database/protocol/mysql/codec/MySQLPacketCodecEngine.java
@@ -74,10 +74,9 @@ public final class MySQLPacketCodecEngine implements
DatabasePacketCodecEngine {
CompositeByteBuf result =
context.alloc().compositeBuffer(SEQUENCE_LENGTH + pendingMessages.size() + 1);
result.addComponent(true, lastMessage.readSlice(SEQUENCE_LENGTH));
Iterator<ByteBuf> pendingMessagesIterator = pendingMessages.iterator();
- result.addComponent(true, pendingMessagesIterator.next());
- while (pendingMessagesIterator.hasNext()) {
+ do {
result.addComponent(true, pendingMessagesIterator.next());
- }
+ } while (pendingMessagesIterator.hasNext());
if (lastMessage.readableBytes() > 0) {
result.addComponent(true, lastMessage);
}