[ignite-3] 07/12: .

[sd...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

sdanilov pushed a commit to branch ignite-16393
in repository https://gitbox.apache.org/repos/asf/ignite-3.git

commit b01363490e802e27e829ec96bb5b407d9a4c5469
Author: Semyon Danilov <sa...@yandex.ru>
AuthorDate: Thu Mar 3 18:20:40 2022 +0300

    .
---
 .../org/apache/ignite/network/DefaultMessagingService.java     | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/modules/network/src/main/java/org/apache/ignite/network/DefaultMessagingService.java b/modules/network/src/main/java/org/apache/ignite/network/DefaultMessagingService.java
index 54d9de6..8577233 100644
--- a/modules/network/src/main/java/org/apache/ignite/network/DefaultMessagingService.java
+++ b/modules/network/src/main/java/org/apache/ignite/network/DefaultMessagingService.java
@@ -191,7 +191,7 @@ public class DefaultMessagingService extends AbstractMessagingService {
 
     private CompletableFuture<Void> sendMessage0(NetworkMessage message, String recipientConsistentId, InetSocketAddress addr) {
         if (isInNetworkThread()) {
-            return CompletableFuture.supplyAsync(() -> sendMessage0(message, recipientConsistentId, addr), svc).thenCompose(Function.identity());
+            return CompletableFuture.supplyAsync(() -> sendMessage0(message, recipientConsistentId, addr), outSvc).thenCompose(Function.identity());
         }
 
         List<ClassDescriptorMessage> descriptors;
@@ -348,7 +348,8 @@ public class DefaultMessagingService extends AbstractMessagingService {
         }
     }
 
-    private final ExecutorService svc = Executors.newSingleThreadExecutor();
+    private final ExecutorService outSvc = Executors.newSingleThreadExecutor();
+    private final ExecutorService inSvc = Executors.newSingleThreadExecutor();
 
     /**
      * Handles an incoming messages.
@@ -358,7 +359,7 @@ public class DefaultMessagingService extends AbstractMessagingService {
      */
     private void onMessage(InNetworkObject obj) {
         if (isInNetworkThread()) {
-            svc.submit(() -> onMessage(obj));
+            inSvc.submit(() -> onMessage(obj));
             return;
         }
 
@@ -491,7 +492,8 @@ public class DefaultMessagingService extends AbstractMessagingService {
 
         requestsMap.clear();
 
-        svc.shutdown();
+        inSvc.shutdown();
+        outSvc.shutdown();
     }
 
     private UserObjectSerializationContext createUserObjectSerializationContext() {