summaryrefslogtreecommitdiffstats
path: root/asdc-tests/src/main/java/org/openecomp/sdc/ci/tests/execute/resource/SimultaneousApiTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'asdc-tests/src/main/java/org/openecomp/sdc/ci/tests/execute/resource/SimultaneousApiTest.java')
-rw-r--r--asdc-tests/src/main/java/org/openecomp/sdc/ci/tests/execute/resource/SimultaneousApiTest.java124
1 files changed, 0 insertions, 124 deletions
diff --git a/asdc-tests/src/main/java/org/openecomp/sdc/ci/tests/execute/resource/SimultaneousApiTest.java b/asdc-tests/src/main/java/org/openecomp/sdc/ci/tests/execute/resource/SimultaneousApiTest.java
deleted file mode 100644
index 3002523ccb..0000000000
--- a/asdc-tests/src/main/java/org/openecomp/sdc/ci/tests/execute/resource/SimultaneousApiTest.java
+++ /dev/null
@@ -1,124 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * SDC
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.sdc.ci.tests.execute.resource;
-
-import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-
-import org.junit.Rule;
-import org.junit.rules.TestName;
-import org.openecomp.sdc.ci.tests.api.ComponentBaseTest;
-import org.openecomp.sdc.ci.tests.datatypes.ResourceReqDetails;
-import org.openecomp.sdc.ci.tests.datatypes.enums.UserRoleEnum;
-import org.openecomp.sdc.ci.tests.datatypes.http.RestResponse;
-import org.openecomp.sdc.ci.tests.utils.general.ElementFactory;
-import org.openecomp.sdc.ci.tests.utils.rest.ResourceRestUtils;
-import org.openecomp.sdc.ci.tests.utils.rest.ResponseParser;
-import org.testng.annotations.Test;
-
-public class SimultaneousApiTest extends ComponentBaseTest {
-
- protected static ResourceReqDetails resourceDetails = ElementFactory.getDefaultResource();
-
- @Rule
- public static TestName name = new TestName();
-
- static String httpCspUserId = "km2000";
- static String userFirstName = "Kot";
- static String userLastName = "Matroskin";
- static String email = "km2000@intl.sdc.com";
- static String role = ElementFactory.getDefaultUser(UserRoleEnum.ADMIN).getRole();
-
- public SimultaneousApiTest() {
- super(name, SimultaneousApiTest.class.getName());
-
- }
-
- public static class WorkerThread implements Runnable {
- CountDownLatch countDownLatch;
- int threadIndex;
-
- public WorkerThread(int threadIndex, CountDownLatch countDownLatch) {
- this.threadIndex = threadIndex;
- this.countDownLatch = countDownLatch;
- }
-
- @Override
- public void run() {
- System.out.println("**** Thread started " + threadIndex);
- try {
- RestResponse createResource = ResourceRestUtils.createResource(resourceDetails,
- ElementFactory.getDefaultUser(UserRoleEnum.DESIGNER));
- String id = ResponseParser.getUniqueIdFromResponse(createResource);
- // System.out.println("**** Thread " + threadIndex + " create
- // resource status " + createResource.getErrorCode() + " id = "
- // + id + " error " + createResource.getResponse());
- // assertEquals("**** create resource: " +
- // createResource.getErrorCode() + " thread " + threadIndex,
- // 201, status);
- } catch (Exception e) {
- // System.out.println("**** Thread " + threadIndex + " exception
- // " + e);
- }
- countDownLatch.countDown();
- // System.out.println("**** Thread finished " + threadIndex);
-
- }
-
- // public void run_() {
- // System.out.println("**** Thread started " + threadIndex);
- // try {
- // UserUtils userUtils = new UserUtils();
- // User userDetails = new User(userFirstName, userLastName,
- // httpCspUserId, email, role , 0L);
- // RestResponse response =
- // userUtils.createUserTowardsCatalogBe(userDetails,
- // userUtils.getUserDetailesAdmin());
- // System.out.println("**** Thread " + threadIndex + " create resource
- // status " + response.getErrorCode() + " response " +
- // response.getResponse());
- //// assertEquals("**** create resource: " +
- // createResource.getErrorCode() + " thread " + threadIndex, 201,
- // status);
- // } catch (Exception e) {
- // System.out.println("**** Thread " + threadIndex + " exception " + e);
- // }
- // countDownLatch.countDown();
- // System.out.println("**** Thread finished " + threadIndex);
- //
- // }
- }
-
- @Test
- public void create2Resources() throws InterruptedException {
- int threadCount = 5;
- CountDownLatch countDownLatch = new CountDownLatch(threadCount);
- ExecutorService executor = Executors.newFixedThreadPool(threadCount);
- for (int i = 0; i < threadCount; i++) {
- Runnable worker = new WorkerThread(i + 1, countDownLatch);
- executor.execute(worker);
- }
- countDownLatch.await();
- // System.out.println(" finished ");
-
- }
-}