|
@@ -723,7 +723,7 @@ public class FSDirectory implements Closeable {
|
|
|
try {
|
|
|
int threads = (initThreads < 1) ? 1 : initThreads;
|
|
|
LOG.info("Initializing quota with " + threads + " thread(s)");
|
|
|
- long start = Time.now();
|
|
|
+ long start = Time.monotonicNow();
|
|
|
QuotaCounts counts = new QuotaCounts.Builder().build();
|
|
|
ForkJoinPool p = new ForkJoinPool(threads);
|
|
|
RecursiveAction task = new InitQuotaTask(getBlockStoragePolicySuite(),
|
|
@@ -731,7 +731,7 @@ public class FSDirectory implements Closeable {
|
|
|
p.execute(task);
|
|
|
task.join();
|
|
|
p.shutdown();
|
|
|
- LOG.info("Quota initialization completed in " + (Time.now() - start) +
|
|
|
+ LOG.info("Quota initialization completed in " + (Time.monotonicNow() - start) +
|
|
|
" milliseconds\n" + counts);
|
|
|
} finally {
|
|
|
writeUnlock();
|