Madan Jampani
Committed by Ray Milkey

Gave threadpools more appropriate names.

Change-Id: Ib7ce71a3028363b1465fbd5775f84e2befaf80c1
......@@ -89,9 +89,7 @@ public class GossipApplicationStore extends ApplicationArchive
INSTALLED, ACTIVATED, DEACTIVATED
}
private final ScheduledExecutorService executor =
Executors.newSingleThreadScheduledExecutor(groupedThreads("onos/app", "store"));
private ScheduledExecutorService executor;
private ExecutorService messageHandlingExecutor;
private EventuallyConsistentMap<ApplicationId, Application> apps;
......@@ -113,6 +111,8 @@ public class GossipApplicationStore extends ApplicationArchive
.register(KryoNamespaces.API)
.register(InternalState.class);
executor = Executors.newSingleThreadScheduledExecutor(groupedThreads("onos/app", "store"));
messageHandlingExecutor = Executors.newSingleThreadExecutor(
groupedThreads("onos/store/app", "message-handler"));
......@@ -154,6 +154,7 @@ public class GossipApplicationStore extends ApplicationArchive
public void deactivate() {
clusterCommunicator.removeSubscriber(APP_BITS_REQUEST);
messageHandlingExecutor.shutdown();
executor.shutdown();
apps.destroy();
states.destroy();
permissions.destroy();
......
......@@ -178,7 +178,7 @@ public class DistributedFlowRuleStore
messageHandlingExecutor = Executors.newFixedThreadPool(
MESSAGE_HANDLER_THREAD_POOL_SIZE,
groupedThreads("onos/flow", "message-handlers"));
groupedThreads("onos/store/flow", "message-handlers"));
clusterCommunicator.addSubscriber(APPLY_BATCH_FLOWS, new OnStoreBatch(local), messageHandlingExecutor);
......
......@@ -89,7 +89,7 @@ public class DistributedPacketStore
public void activate() {
messageHandlingExecutor = Executors.newFixedThreadPool(
MESSAGE_HANDLER_THREAD_POOL_SIZE,
groupedThreads("onos/flow", "message-handlers"));
groupedThreads("onos/store/packet", "message-handlers"));
communicationService.addSubscriber(
PACKET_OUT_SUBJECT, new InternalClusterMessageHandler(), messageHandlingExecutor);
......