We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fd324c4 commit 2f69214Copy full SHA for 2f69214
topic/src/main/java/tech/ydb/topic/write/impl/WriterImpl.java
@@ -191,8 +191,7 @@ private void encode(EnqueuedMessage message) {
191
192
private void moveEncodedMessagesToSendingQueue() {
193
boolean haveNewMessagesToSend = false;
194
- // Working with encodingMessages under synchronized incomingQueue to prevent deadlocks
195
- // while working with free method
+ // Working with encodingMessages under incomingQueueLock to prevent deadlocks while working with free method
196
incomingQueueLock.lock();
197
198
try {
0 commit comments