Skip to content

Commit 2fd199c

Browse files
author
Ajay Kumar
committed
HDDS-1254. Fix failure in TestOzoneManagerHttpServer & TestStorageContainerManagerHttpServer. Contributed by Ajay Kumar.
1 parent c449cde commit 2fd199c

File tree

2 files changed

+12
-9
lines changed

2 files changed

+12
-9
lines changed

hadoop-hdds/server-scm/src/test/java/org/apache/hadoop/hdds/scm/TestStorageContainerManagerHttpServer.java

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -106,13 +106,15 @@ public TestStorageContainerManagerHttpServer(Policy policy) {
106106

107107
Assert.assertTrue(implies(policy.isHttpEnabled(),
108108
canAccess("http", server.getHttpAddress())));
109-
Assert.assertTrue(
110-
implies(!policy.isHttpEnabled(), server.getHttpAddress() == null));
109+
Assert.assertTrue(implies(policy.isHttpEnabled() &&
110+
!policy.isHttpsEnabled(),
111+
!canAccess("https", server.getHttpsAddress())));
111112

112113
Assert.assertTrue(implies(policy.isHttpsEnabled(),
113114
canAccess("https", server.getHttpsAddress())));
114-
Assert.assertTrue(
115-
implies(!policy.isHttpsEnabled(), server.getHttpsAddress() == null));
115+
Assert.assertTrue(implies(policy.isHttpsEnabled() &&
116+
!policy.isHttpEnabled(),
117+
!canAccess("http", server.getHttpAddress())));
116118

117119
} finally {
118120
if (server != null) {

hadoop-ozone/ozone-manager/src/test/java/org/apache/hadoop/ozone/om/TestOzoneManagerHttpServer.java

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -95,22 +95,23 @@ public TestOzoneManagerHttpServer(Policy policy) {
9595
@Test public void testHttpPolicy() throws Exception {
9696
conf.set(DFSConfigKeys.DFS_HTTP_POLICY_KEY, policy.name());
9797
conf.set(ScmConfigKeys.OZONE_SCM_HTTPS_ADDRESS_KEY, "localhost:0");
98-
9998
InetSocketAddress addr = InetSocketAddress.createUnresolved("localhost", 0);
99+
100100
OzoneManagerHttpServer server = null;
101101
try {
102102
server = new OzoneManagerHttpServer(conf, null);
103103
server.start();
104104

105105
Assert.assertTrue(implies(policy.isHttpEnabled(),
106106
canAccess("http", server.getHttpAddress())));
107-
Assert.assertTrue(
108-
implies(!policy.isHttpEnabled(), server.getHttpAddress() == null));
107+
Assert.assertTrue(implies(policy.isHttpEnabled() &&
108+
!policy.isHttpsEnabled(),
109+
!canAccess("https", server.getHttpsAddress())));
109110

110111
Assert.assertTrue(implies(policy.isHttpsEnabled(),
111112
canAccess("https", server.getHttpsAddress())));
112-
Assert.assertTrue(
113-
implies(!policy.isHttpsEnabled(), server.getHttpsAddress() == null));
113+
Assert.assertTrue(implies(policy.isHttpsEnabled(),
114+
!canAccess("http", server.getHttpsAddress())));
114115

115116
} finally {
116117
if (server != null) {

0 commit comments

Comments
 (0)