|
@@ -270,23 +270,20 @@ public final class RandomKeyGenerator implements Callable<Void> {
|
|
|
processor.shutdown();
|
|
|
processor.awaitTermination(Integer.MAX_VALUE, TimeUnit.MILLISECONDS);
|
|
|
completed = true;
|
|
|
- progressbar.shutdown();
|
|
|
|
|
|
- if (validateWrites) {
|
|
|
+ if (exception) {
|
|
|
+ progressbar.terminate();
|
|
|
+ } else {
|
|
|
+ progressbar.shutdown();
|
|
|
+ }
|
|
|
+
|
|
|
+ if (validator != null) {
|
|
|
validator.join();
|
|
|
}
|
|
|
ozoneClient.close();
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
- private void parseOptions(CommandLine cmdLine) {
|
|
|
- if (keySize < 1024) {
|
|
|
- throw new IllegalArgumentException(
|
|
|
- "keySize can not be less than 1024 bytes");
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
/**
|
|
|
* Adds ShutdownHook to print statistics.
|
|
|
*/
|