|
30 | 30 | import static oracle.weblogic.kubernetes.TestConstants.MII_BASIC_IMAGE_NAME;
|
31 | 31 | import static oracle.weblogic.kubernetes.TestConstants.MII_BASIC_IMAGE_TAG;
|
32 | 32 | import static oracle.weblogic.kubernetes.TestConstants.MII_BASIC_WDT_MODEL_FILE;
|
| 33 | +import static oracle.weblogic.kubernetes.TestConstants.OCNE; |
33 | 34 | import static oracle.weblogic.kubernetes.TestConstants.TRAEFIK_INGRESS_HTTP_HOSTPORT;
|
34 | 35 | import static oracle.weblogic.kubernetes.TestConstants.WEBLOGIC_IMAGE_TO_USE_IN_SPEC;
|
35 | 36 | import static oracle.weblogic.kubernetes.actions.ActionConstants.ARCHIVE_DIR;
|
@@ -148,60 +149,63 @@ public static void initAll(@Namespaces(5) List<String> namespaces) {
|
148 | 149 | + "verify admin server is accessible via REST interface.")
|
149 | 150 | @ValueSource(strings = {"modelInImage", "domainInImage", "domainOnPV", "auxiliaryImageDomain"})
|
150 | 151 | void testScaleClustersAndAdminRESTAccess(String domainType) {
|
151 |
| - DomainResource domain = createDomainBasedOnDomainType(domainType); |
152 |
| - |
153 |
| - // get the domain properties |
154 |
| - String domainUid = domain.getSpec().getDomainUid(); |
155 |
| - String domainNamespace = domain.getMetadata().getNamespace(); |
156 |
| - |
157 |
| - String dynamicServerPodName = domainUid + "-managed-server1"; |
158 |
| - OffsetDateTime dynTs = getPodCreationTime(domainNamespace, dynamicServerPodName); |
159 |
| - final String managedServerPrefix = domainUid + "-managed-server"; |
160 |
| - int numberOfServers = 3; |
161 |
| - logger.info("Scaling cluster {0} of domain {1} in namespace {2} to {3} servers.", |
162 |
| - clusterName, domainUid, domainNamespace, numberOfServers); |
163 |
| - assertDoesNotThrow(() -> scaleCluster(clusterName,domainNamespace, |
164 |
| - numberOfServers), "Could not scale up the cluster"); |
165 |
| - // check managed server pods are ready |
166 |
| - for (int i = 1; i <= numberOfServers; i++) { |
167 |
| - logger.info("Wait for managed server pod {0} to be ready in namespace {1}", |
168 |
| - managedServerPrefix + i, domainNamespace); |
169 |
| - checkPodReadyAndServiceExists(managedServerPrefix + i, domainUid, domainNamespace); |
170 |
| - } |
| 152 | + // workaround OWLS-122679 |
| 153 | + if (!(OCNE && domainType.equals("domainInImage"))) { |
| 154 | + DomainResource domain = createDomainBasedOnDomainType(domainType); |
| 155 | + |
| 156 | + // get the domain properties |
| 157 | + String domainUid = domain.getSpec().getDomainUid(); |
| 158 | + String domainNamespace = domain.getMetadata().getNamespace(); |
| 159 | + |
| 160 | + String dynamicServerPodName = domainUid + "-managed-server1"; |
| 161 | + OffsetDateTime dynTs = getPodCreationTime(domainNamespace, dynamicServerPodName); |
| 162 | + final String managedServerPrefix = domainUid + "-managed-server"; |
| 163 | + int numberOfServers = 3; |
| 164 | + logger.info("Scaling cluster {0} of domain {1} in namespace {2} to {3} servers.", |
| 165 | + clusterName, domainUid, domainNamespace, numberOfServers); |
| 166 | + assertDoesNotThrow(() -> scaleCluster(clusterName, domainNamespace, |
| 167 | + numberOfServers), "Could not scale up the cluster"); |
| 168 | + // check managed server pods are ready |
| 169 | + for (int i = 1; i <= numberOfServers; i++) { |
| 170 | + logger.info("Wait for managed server pod {0} to be ready in namespace {1}", |
| 171 | + managedServerPrefix + i, domainNamespace); |
| 172 | + checkPodReadyAndServiceExists(managedServerPrefix + i, domainUid, domainNamespace); |
| 173 | + } |
171 | 174 |
|
172 |
| - Callable<Boolean> isDynRestarted = |
173 |
| - assertDoesNotThrow(() -> isPodRestarted(dynamicServerPodName, domainNamespace, dynTs)); |
174 |
| - assertFalse(assertDoesNotThrow(isDynRestarted::call), |
175 |
| - "Dynamic managed server pod must not be restated"); |
176 |
| - |
177 |
| - // then scale cluster back to 1 server |
178 |
| - logger.info("Scaling back cluster {0} of domain {1} in namespace {2} from {3} servers to {4} servers.", |
179 |
| - clusterName, domainUid, domainNamespace,numberOfServers,replicaCount); |
180 |
| - assertDoesNotThrow(() -> scaleCluster(clusterName, domainNamespace, |
181 |
| - replicaCount), "Could not scale down the cluster"); |
182 |
| - |
183 |
| - for (int i = numberOfServers; i > replicaCount; i--) { |
184 |
| - logger.info("Wait for managed server pod {0} to be deleted in namespace {1}", |
185 |
| - managedServerPrefix + i, domainNamespace); |
186 |
| - checkPodDeleted(managedServerPrefix + i, domainUid, domainNamespace); |
187 |
| - } |
| 175 | + Callable<Boolean> isDynRestarted = |
| 176 | + assertDoesNotThrow(() -> isPodRestarted(dynamicServerPodName, domainNamespace, dynTs)); |
| 177 | + assertFalse(assertDoesNotThrow(isDynRestarted::call), |
| 178 | + "Dynamic managed server pod must not be restated"); |
| 179 | + |
| 180 | + // then scale cluster back to 1 server |
| 181 | + logger.info("Scaling back cluster {0} of domain {1} in namespace {2} from {3} servers to {4} servers.", |
| 182 | + clusterName, domainUid, domainNamespace, numberOfServers, replicaCount); |
| 183 | + assertDoesNotThrow(() -> scaleCluster(clusterName, domainNamespace, |
| 184 | + replicaCount), "Could not scale down the cluster"); |
| 185 | + |
| 186 | + for (int i = numberOfServers; i > replicaCount; i--) { |
| 187 | + logger.info("Wait for managed server pod {0} to be deleted in namespace {1}", |
| 188 | + managedServerPrefix + i, domainNamespace); |
| 189 | + checkPodDeleted(managedServerPrefix + i, domainUid, domainNamespace); |
| 190 | + } |
188 | 191 |
|
189 |
| - logger.info("Validating WebLogic admin server access by REST"); |
190 |
| - if (!TestConstants.WLSIMG_BUILDER.equals(TestConstants.WLSIMG_BUILDER_DEFAULT)) { |
191 |
| - hostHeader = createIngressHostRouting(domainNamespace, domainUid, adminServerName, 7001); |
192 |
| - assertDoesNotThrow(() |
193 |
| - -> verifyAdminServerRESTAccess("localhost", TRAEFIK_INGRESS_HTTP_HOSTPORT, false, hostHeader)); |
194 |
| - } else { |
195 |
| - String adminServerPodName = domainUid + "-" + ADMIN_SERVER_NAME_BASE; |
196 |
| - try { |
197 |
| - verifyAdminServerRESTAccessInAdminPod(adminServerPodName, "7001", |
198 |
| - domainNamespace, ADMIN_USERNAME_DEFAULT, ADMIN_PASSWORD_DEFAULT); |
199 |
| - } catch (IOException ex) { |
200 |
| - logger.severe(ex.getMessage()); |
| 192 | + logger.info("Validating WebLogic admin server access by REST"); |
| 193 | + if (!TestConstants.WLSIMG_BUILDER.equals(TestConstants.WLSIMG_BUILDER_DEFAULT)) { |
| 194 | + hostHeader = createIngressHostRouting(domainNamespace, domainUid, adminServerName, 7001); |
| 195 | + assertDoesNotThrow(() |
| 196 | + -> verifyAdminServerRESTAccess("localhost", TRAEFIK_INGRESS_HTTP_HOSTPORT, false, hostHeader)); |
| 197 | + } else { |
| 198 | + String adminServerPodName = domainUid + "-" + ADMIN_SERVER_NAME_BASE; |
| 199 | + try { |
| 200 | + verifyAdminServerRESTAccessInAdminPod(adminServerPodName, "7001", |
| 201 | + domainNamespace, ADMIN_USERNAME_DEFAULT, ADMIN_PASSWORD_DEFAULT); |
| 202 | + } catch (IOException ex) { |
| 203 | + logger.severe(ex.getMessage()); |
| 204 | + } |
201 | 205 | }
|
| 206 | + // shutdown domain and verify the domain is shutdown |
| 207 | + shutdownDomainAndVerify(domainNamespace, domainUid, replicaCount); |
202 | 208 | }
|
203 |
| - // shutdown domain and verify the domain is shutdown |
204 |
| - shutdownDomainAndVerify(domainNamespace, domainUid, replicaCount); |
205 | 209 | }
|
206 | 210 |
|
207 | 211 | /**
|
|
0 commit comments