public String testFetchChildResource()

in loadtesting-utilities/src/main/java/org/apache/airavata/datalake/loadtesting/handlers/LoadTestHandler.java [175:239]
54 lines of code
5 McCabe index (conditional complexity)

    public String testFetchChildResource(@RequestParam("username") String username,
                                         @RequestParam("tenantId") String tenantId,
                                         @RequestParam("totalIterations") int iterations,
                                         @RequestParam("reportChunkSize") int reportChunkSize,
                                         @RequestParam("filePath") String filePath,
                                         @RequestParam("entityId") String resourceId,
                                         @RequestParam("depth") int depth,
                                         @RequestParam("type") String type) {


        ManagedChannel channel = ManagedChannelBuilder.forAddress(serviceHost, servicePort).usePlaintext().build();
        ResourceServiceGrpc.ResourceServiceBlockingStub resourceClient = ResourceServiceGrpc.newBlockingStub(channel);

        ChildResourceFetchRequest request = ChildResourceFetchRequest
                .newBuilder()
                .setType(type)
                .setDepth(depth)
                .setResourceId(resourceId)
                .setAuthToken(DRMSServiceAuthToken.newBuilder()
                        .setAuthenticatedUser(AuthenticatedUser.newBuilder()
                                .setTenantId(tenantId)
                                .setUsername(username)
                                .build()))
                .build();

        int successRequests = 0;
        int failureRequests = 0;
        long sum = 0;

        Map<String, String> latencyMap = new HashMap<>();

        int chunkSize = 1;

        for (int i = 0; i < iterations; i++) {
            try {
                long beginLatency = System.currentTimeMillis();
                ChildResourceFetchResponse response = resourceClient.fetchChildResources(request);
                long endLatency = System.currentTimeMillis();

                long diff = endLatency - beginLatency;
                latencyMap.put(String.valueOf(i), String.valueOf(diff));
                sum += diff;
                if (!response.getResourcesList().isEmpty()) {
                    successRequests++;
                }
            } catch (Exception ex) {
                failureRequests++;
            }

            if (chunkSize % reportChunkSize == 0) {
                long avgSuccessRate = (successRequests / chunkSize) * 100;
                long avgFailureRare = (failureRequests / chunkSize) * 100;

                writeToAFile(latencyMap, avgSuccessRate, avgFailureRare, filePath, "testFetchChildResource");
                latencyMap.clear();
                successRequests = 0;
                failureRequests = 0;
                chunkSize = 1;
            } else {
                chunkSize++;
            }
        }
        return "load test completed";

    }