@@ -965,8 +965,7 @@ public void invalidateRepositories(Collection<? extends RepositoryInfo> repos, C
965
965
return ;
966
966
}
967
967
968
- Map <String , Repository > newrepos =
969
- Collections .synchronizedMap (new HashMap <>(repos .size ()));
968
+ Map <String , Repository > repositoryMap = Collections .synchronizedMap (new HashMap <>(repos .size ()));
970
969
Statistics elapsed = new Statistics ();
971
970
972
971
LOGGER .log (Level .FINE , "invalidating {0} repositories" , repos .size ());
@@ -991,21 +990,21 @@ public void invalidateRepositories(Collection<? extends RepositoryInfo> repos, C
991
990
return thread ;
992
991
});
993
992
994
- for (RepositoryInfo rinfo : repos ) {
993
+ for (RepositoryInfo repositoryInfo : repos ) {
995
994
executor .submit (() -> {
996
995
try {
997
- Repository r = RepositoryFactory .getRepository (rinfo , cmdType );
996
+ Repository r = RepositoryFactory .getRepository (repositoryInfo , cmdType );
998
997
if (r == null ) {
999
998
LOGGER .log (Level .WARNING ,
1000
- "Failed to instantiate internal repository data for {0} in {1}" ,
1001
- new Object []{rinfo .getType (), rinfo .getDirectoryName ()});
999
+ "Failed to instantiate internal repository data for {0} in '' {1}'' " ,
1000
+ new Object []{repositoryInfo .getType (), repositoryInfo .getDirectoryName ()});
1002
1001
} else {
1003
- newrepos .put (r .getDirectoryName (), r );
1002
+ repositoryMap .put (r .getDirectoryName (), r );
1004
1003
}
1005
1004
} catch (Exception ex ) {
1006
1005
// We want to catch any exception since we are in thread.
1007
- LOGGER .log (Level .WARNING , "Could not create " + rinfo .getType ()
1008
- + " for '" + rinfo .getDirectoryName (), ex );
1006
+ LOGGER .log (Level .WARNING , "Could not create " + repositoryInfo .getType ()
1007
+ + " repository object for '" + repositoryInfo .getDirectoryName () + "'" , ex );
1009
1008
} finally {
1010
1009
latch .countDown ();
1011
1010
}
@@ -1021,9 +1020,11 @@ public void invalidateRepositories(Collection<? extends RepositoryInfo> repos, C
1021
1020
executor .shutdown ();
1022
1021
1023
1022
clear ();
1024
- newrepos .forEach ((_key , repo ) -> putRepository (repo ));
1023
+ repositoryMap .forEach ((key , repo ) -> putRepository (repo ));
1025
1024
1026
- elapsed .report (LOGGER , String .format ("Done invalidating %d repositories" , newrepos .size ()),
1025
+ elapsed .report (LOGGER , String .format ("Done invalidating repositories (%d valid, %d working)" ,
1026
+ repositoryMap .size (), repositoryMap .values ().stream ().
1027
+ filter (RepositoryInfo ::isWorking ).collect (Collectors .toSet ()).size ()),
1027
1028
"history.repositories.invalidate" );
1028
1029
}
1029
1030
0 commit comments