File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
topic/src/main/java/tech/ydb/topic/write/impl Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -102,7 +102,7 @@ private IncomingMessage(EnqueuedMessage message) {
102102
103103 public CompletableFuture <Void > tryToEnqueue (EnqueuedMessage message , boolean instant ) {
104104 incomingQueueLock .lock ();
105-
105+
106106 try {
107107 if (currentInFlightCount >= settings .getMaxSendBufferMessagesCount ()) {
108108 if (instant ) {
@@ -193,7 +193,7 @@ private void moveEncodedMessagesToSendingQueue() {
193193 boolean haveNewMessagesToSend = false ;
194194 // Working with encodingMessages under incomingQueueLock to prevent deadlocks while working with free method
195195 incomingQueueLock .lock ();
196-
196+
197197 try {
198198 // Taking all encoded messages to sending queue
199199 while (true ) {
@@ -274,7 +274,7 @@ protected CompletableFuture<Void> flushImpl() {
274274 return CompletableFuture .completedFuture (null );
275275 }
276276 incomingQueueLock .lock ();
277-
277+
278278 try {
279279 return this .lastAcceptedMessageFuture .isDone ()
280280 ? CompletableFuture .completedFuture (null )
@@ -286,7 +286,7 @@ protected CompletableFuture<Void> flushImpl() {
286286
287287 private void free (int messageCount , long sizeBytes ) {
288288 incomingQueueLock .lock ();
289-
289+
290290 try {
291291 currentInFlightCount -= messageCount ;
292292 availableSizeBytes += sizeBytes ;
You can’t perform that action at this time.
0 commit comments