mirror of
https://github.com/honeymoose/OpenSearch.git
synced 2025-02-09 06:25:07 +00:00
[TEST] use util method to propperly shudtown threadpools
This commit is contained in:
parent
30fd70f07b
commit
1b8d8da648
@ -70,7 +70,7 @@ public class NettyTransportMultiPortTests extends ElasticsearchTestCase {
|
|||||||
assertPortIsBound(ports[1]);
|
assertPortIsBound(ports[1]);
|
||||||
assertPortIsBound(ports[2]);
|
assertPortIsBound(ports[2]);
|
||||||
} finally {
|
} finally {
|
||||||
threadPool.shutdownNow();
|
terminate(threadPool);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -89,7 +89,7 @@ public class NettyTransportMultiPortTests extends ElasticsearchTestCase {
|
|||||||
assertPortIsBound(ports[0]);
|
assertPortIsBound(ports[0]);
|
||||||
assertPortIsBound(ports[1]);
|
assertPortIsBound(ports[1]);
|
||||||
} finally {
|
} finally {
|
||||||
threadPool.shutdownNow();
|
terminate(threadPool);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -107,7 +107,7 @@ public class NettyTransportMultiPortTests extends ElasticsearchTestCase {
|
|||||||
try (NettyTransport ignored = startNettyTransport(settings, threadPool)) {
|
try (NettyTransport ignored = startNettyTransport(settings, threadPool)) {
|
||||||
assertPortIsBound(ports[0]);
|
assertPortIsBound(ports[0]);
|
||||||
} finally {
|
} finally {
|
||||||
threadPool.shutdownNow();
|
terminate(threadPool);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -128,7 +128,7 @@ public class NettyTransportMultiPortTests extends ElasticsearchTestCase {
|
|||||||
assertConnectionRefused(ports[1]);
|
assertConnectionRefused(ports[1]);
|
||||||
assertPortIsBound(ports[2]);
|
assertPortIsBound(ports[2]);
|
||||||
} finally {
|
} finally {
|
||||||
threadPool.shutdownNow();
|
terminate(threadPool);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -151,7 +151,7 @@ public class NettyTransportMultiPortTests extends ElasticsearchTestCase {
|
|||||||
assertPortIsBound(firstNonLoopbackAddress.getHostAddress(), ports[1]);
|
assertPortIsBound(firstNonLoopbackAddress.getHostAddress(), ports[1]);
|
||||||
assertConnectionRefused(ports[1]);
|
assertConnectionRefused(ports[1]);
|
||||||
} finally {
|
} finally {
|
||||||
threadPool.shutdownNow();
|
terminate(threadPool);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user