Skip to content

Commit

Permalink
Minor refactorinh
Browse files Browse the repository at this point in the history
  • Loading branch information
ektavarma10 committed Nov 29, 2023
1 parent 7a9f11b commit e0bc2b3
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ public class RangerAtlasAuthorizer implements AtlasAuthorizer {
add(AtlasPrivilege.ENTITY_UPDATE_CLASSIFICATION);
}};

private static final ExecutorService classification_access_threadpool = Executors.newFixedThreadPool(NUM_THREADS);
private static final ExecutorService classificationAccessThreadpool = Executors.newFixedThreadPool(NUM_THREADS);

@Override
public void init() {
Expand Down Expand Up @@ -676,7 +676,7 @@ private boolean isAccessAllowed(AtlasEntityAccessRequest request, RangerAtlasAud

RangerAccessRequestImpl rangerRequest = createRangerAccessRequest(request, classificationToAuthorize, rangerTagForEval);

completableFutures.add(CompletableFuture.supplyAsync(()->checkAccess(rangerRequest, auditHandler), classification_access_threadpool));
completableFutures.add(CompletableFuture.supplyAsync(()->checkAccess(rangerRequest, auditHandler), classificationAccessThreadpool));
}

// wait for all threads to complete their execution
Expand Down

0 comments on commit e0bc2b3

Please sign in to comment.