Skip to content

Commit

Permalink
Run on GENERIC thread pool
Browse files Browse the repository at this point in the history
  • Loading branch information
Andrey Ershov committed May 23, 2019
1 parent 80edff1 commit c2e24f2
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -108,9 +108,9 @@ private void getMultipleReposSnapshotInfo(List<RepositoryMetaData> repos, String
boolean verbose, ActionListener<GetSnapshotsResponse> listener) {
List<Future<List<SnapshotInfo>>> futures = new ArrayList<>(repos.size());

// run concurrently for all repos on SNAPSHOT thread pool
// run concurrently for all repos on GENERIC thread pool
for (final RepositoryMetaData repo : repos) {
futures.add(threadPool.executor(ThreadPool.Names.SNAPSHOT).submit(
futures.add(threadPool.executor(ThreadPool.Names.GENERIC).submit(
() -> getSingleRepoSnapshotInfo(repo.name(), snapshots, ignoreUnavailable, verbose)));
}
assert repos.size() == futures.size();
Expand Down

0 comments on commit c2e24f2

Please sign in to comment.