|
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