apache/cloudstack
1
0
Fork 0
mirror of https://github.com/apache/cloudstack.git synced 2025-10-26 08:42:29 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix

Browse Source 
Signed-off-by: Abhishek Kumar <abhishek.mrt22@gmail.com>
This commit is contained in:
Abhishek Kumar 2024-09-30 18:09:34 +05:30
parent d9269842d0
commit f7f9249be5
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
utils/src/main/java/com/cloud/utils/nio/NioConnection.java
View File

@ -97,7 +97,7 @@ public abstract class NioConnection implements Callable<Boolean> {
workerQueue = new LinkedBlockingQueue<>(5 * workers);
_executor = new ThreadPoolExecutor(workers, 5 * workers, 1, TimeUnit.DAYS,
workerQueue, new NamedThreadFactory(name + "-Handler"), new ThreadPoolExecutor.AbortPolicy());
sslHandshakeQueue = new SynchronousQueue<>();
sslHandshakeQueue = new LinkedBlockingQueue<>(2 * sslHandshakeMaxWorkers);
_sslHandshakeExecutor = new ThreadPoolExecutor(sslHandshakeMinWorkers, sslHandshakeMaxWorkers, 30,
TimeUnit.MINUTES, sslHandshakeQueue, new NamedThreadFactory(name + "-Handler"),
new ThreadPoolExecutor.AbortPolicy());

2
utils/src/test/java/com/cloud/utils/testcase/NioTest.java
View File

@ -98,7 +98,7 @@ public class NioTest {
testBytes = new byte[1000000];
randomGenerator.nextBytes(testBytes);
server = new NioServer("NioTestServer", 0, 1, 1, 1, new NioTestServer(), null, null);
server = new NioServer("NioTestServer", 0, 10, 1, 1, new NioTestServer(), null, null);
try {
server.start();
} catch (final NioConnectionException e) {