@Override public Void call() throws Exception { // Set up the injector injector = new MyInjector(); EncryptionFaultInjector.instance = injector; Future<Void> future = executor.submit(new CreateFileTask(fsWrapper, file)); injector.ready.await(); // Do the fault doFault(); // Allow create to proceed injector.wait.countDown(); future.get(); // Cleanup and postconditions doCleanup(); return null; }
@After public void teardown() { if (cluster != null) { cluster.shutdown(); } EncryptionFaultInjector.instance = new EncryptionFaultInjector(); }
@After public void teardown() { if (cluster != null) { cluster.shutdown(); cluster = null; } EncryptionFaultInjector.instance = new EncryptionFaultInjector(); }