From 1172da7883d57738a02cb766fd4e70c1e438c1f7 Mon Sep 17 00:00:00 2001 From: Madan Jampani Date: Wed, 17 Feb 2016 18:40:36 -0800 Subject: [PATCH] Set max number of copycat transport server threads to 4 Change-Id: I20c662fdfcabd86b547c7b699b5f97ce3d912a41 --- .../store/primitives/impl/CopycatTransportServer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/CopycatTransportServer.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/CopycatTransportServer.java index 2f24d6b4f3..d4f851fd13 100644 --- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/CopycatTransportServer.java +++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/CopycatTransportServer.java @@ -64,7 +64,7 @@ public class CopycatTransportServer implements Server { this.messagingService = checkNotNull(messagingService); this.protocolMessageSubject = String.format("onos-copycat-server-%s", partitionId); this.newConnectionMessageSubject = String.format("onos-copycat-server-connection-%s", partitionId); - this.executorService = Executors.newScheduledThreadPool(Runtime.getRuntime().availableProcessors(), + this.executorService = Executors.newScheduledThreadPool(Math.min(4, Runtime.getRuntime().availableProcessors()), new CatalystThreadFactory("copycat-server-p" + partitionId + "-%d")); }