aurora-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ma...@apache.org
Subject [1/4] Moving @Override to a separate line to comply with IntelliJ editor.
Date Wed, 05 Feb 2014 02:10:28 GMT
Updated Branches:
  refs/heads/master 80106ee0e -> e7949b1ad


http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/storage/log/LogStorageTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/storage/log/LogStorageTest.java b/src/test/java/org/apache/aurora/scheduler/storage/log/LogStorageTest.java
index a651d16..f708ab3 100644
--- a/src/test/java/org/apache/aurora/scheduler/storage/log/LogStorageTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/storage/log/LogStorageTest.java
@@ -155,7 +155,8 @@ public class LogStorageTest extends EasyMockTest {
     // supplied initialization logic.
     final AtomicBoolean initialized = new AtomicBoolean(false);
     MutateWork.NoResult.Quiet initializationLogic = new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider provider) {
+      @Override
+      protected void execute(MutableStoreProvider provider) {
         // Creating a mock and expecting apply(storeProvider) does not work here for whatever
         // reason.
         initialized.set(true);
@@ -165,7 +166,8 @@ public class LogStorageTest extends EasyMockTest {
     final Capture<MutateWork.NoResult.Quiet> recoverAndInitializeWork = createCapture();
     storageUtil.storage.write(capture(recoverAndInitializeWork));
     expectLastCall().andAnswer(new IAnswer<Void>() {
-      @Override public Void answer() throws Throwable {
+      @Override
+      public Void answer() throws Throwable {
         recoverAndInitializeWork.getValue().apply(storageUtil.mutableStoreProvider);
         return null;
       }
@@ -186,7 +188,8 @@ public class LogStorageTest extends EasyMockTest {
     final Capture<MutateWork<Void, RuntimeException>> recoveryWork = createCapture();
     expect(storageUtil.storage.write(capture(recoveryWork))).andAnswer(
         new IAnswer<Void>() {
-          @Override public Void answer() {
+          @Override
+          public Void answer() {
             recoveryWork.getValue().apply(storageUtil.mutableStoreProvider);
             return null;
           }
@@ -197,7 +200,8 @@ public class LogStorageTest extends EasyMockTest {
     final Capture<MutateWork<Void, RuntimeException>> initializationWork = createCapture();
     expect(storageUtil.storage.write(capture(initializationWork))).andAnswer(
         new IAnswer<Void>() {
-          @Override public Void answer() {
+          @Override
+          public Void answer() {
             initializationWork.getValue().apply(storageUtil.mutableStoreProvider);
             return null;
           }
@@ -218,7 +222,8 @@ public class LogStorageTest extends EasyMockTest {
     final Capture<MutateWork<Void, RuntimeException>> snapshotWork = createCapture();
     expect(storageUtil.storage.write(capture(snapshotWork))).andAnswer(
         new IAnswer<Void>() {
-          @Override public Void answer() {
+          @Override
+          public Void answer() {
             snapshotWork.getValue().apply(storageUtil.mutableStoreProvider);
             return null;
           }
@@ -245,7 +250,8 @@ public class LogStorageTest extends EasyMockTest {
     MutationFixture() {
       // Prevent otherwise silent noop tests that forget to call run().
       addTearDown(new TearDown() {
-        @Override public void tearDown() {
+        @Override
+        public void tearDown() {
           assertTrue(runCalled.get());
         }
       });
@@ -269,7 +275,8 @@ public class LogStorageTest extends EasyMockTest {
       final Capture<MutateWork.NoResult.Quiet> recoverAndInitializeWork = createCapture();
       storageUtil.storage.write(capture(recoverAndInitializeWork));
       expectLastCall().andAnswer(new IAnswer<Void>() {
-        @Override public Void answer() throws Throwable {
+        @Override
+        public Void answer() throws Throwable {
           recoverAndInitializeWork.getValue().apply(storageUtil.mutableStoreProvider);
           return null;
         }
@@ -279,7 +286,8 @@ public class LogStorageTest extends EasyMockTest {
       final Capture<MutateWork<Void, RuntimeException>> recoveryWork = createCapture();
       expect(storageUtil.storage.write(capture(recoveryWork))).andAnswer(
           new IAnswer<Void>() {
-            @Override public Void answer() {
+            @Override
+            public Void answer() {
               recoveryWork.getValue().apply(storageUtil.mutableStoreProvider);
               return null;
             }
@@ -309,14 +317,16 @@ public class LogStorageTest extends EasyMockTest {
   public void testSaveFrameworkId() throws Exception {
     final String frameworkId = "bob";
     new MutationFixture() {
-      @Override protected void setupExpectations() throws CodingException {
+      @Override
+      protected void setupExpectations() throws CodingException {
         storageUtil.expectOperations();
         storageUtil.schedulerStore.saveFrameworkId(frameworkId);
         streamMatcher.expectTransaction(Op.saveFrameworkId(new SaveFrameworkId(frameworkId)))
             .andReturn(position);
       }
 
-      @Override protected void performMutations() {
+      @Override
+      protected void performMutations() {
         logStorage.saveFrameworkId(frameworkId);
       }
     }.run();
@@ -328,7 +338,8 @@ public class LogStorageTest extends EasyMockTest {
         IJobConfiguration.build(new JobConfiguration().setKey(new JobKey("owner", "env",
"jake")));
     final String managerId = "CRON";
     new MutationFixture() {
-      @Override protected void setupExpectations() throws Exception {
+      @Override
+      protected void setupExpectations() throws Exception {
         storageUtil.expectOperations();
         storageUtil.jobStore.saveAcceptedJob(managerId, jobConfig);
         streamMatcher.expectTransaction(
@@ -336,7 +347,8 @@ public class LogStorageTest extends EasyMockTest {
             .andReturn(position);
       }
 
-      @Override protected void performMutations() {
+      @Override
+      protected void performMutations() {
         logStorage.saveAcceptedJob(managerId, jobConfig);
       }
     }.run();
@@ -346,7 +358,8 @@ public class LogStorageTest extends EasyMockTest {
   public void testRemoveJob() throws Exception {
     final IJobKey jobKey = JobKeys.from("role", "env", "name");
     new MutationFixture() {
-      @Override protected void setupExpectations() throws Exception {
+      @Override
+      protected void setupExpectations() throws Exception {
         storageUtil.expectOperations();
         storageUtil.jobStore.removeJob(jobKey);
         streamMatcher.expectTransaction(
@@ -354,7 +367,8 @@ public class LogStorageTest extends EasyMockTest {
             .andReturn(position);
       }
 
-      @Override protected void performMutations() {
+      @Override
+      protected void performMutations() {
         logStorage.removeJob(jobKey);
       }
     }.run();
@@ -364,7 +378,8 @@ public class LogStorageTest extends EasyMockTest {
   public void testSaveTasks() throws Exception {
     final Set<IScheduledTask> tasks = ImmutableSet.of(task("a", ScheduleStatus.INIT));
     new MutationFixture() {
-      @Override protected void setupExpectations() throws Exception {
+      @Override
+      protected void setupExpectations() throws Exception {
         storageUtil.expectOperations();
         storageUtil.taskStore.saveTasks(tasks);
         streamMatcher.expectTransaction(
@@ -372,7 +387,8 @@ public class LogStorageTest extends EasyMockTest {
             .andReturn(position);
       }
 
-      @Override protected void performMutations() {
+      @Override
+      protected void performMutations() {
         logStorage.saveTasks(tasks);
       }
     }.run();
@@ -385,7 +401,8 @@ public class LogStorageTest extends EasyMockTest {
     final ImmutableSet<IScheduledTask> mutated =
         ImmutableSet.of(task("a", ScheduleStatus.STARTING));
     new MutationFixture() {
-      @Override protected void setupExpectations() throws Exception {
+      @Override
+      protected void setupExpectations() throws Exception {
         storageUtil.expectOperations();
         expect(storageUtil.taskStore.mutateTasks(query, mutation)).andReturn(mutated);
         streamMatcher.expectTransaction(
@@ -393,7 +410,8 @@ public class LogStorageTest extends EasyMockTest {
             .andReturn(null);
       }
 
-      @Override protected void performMutations() {
+      @Override
+      protected void performMutations() {
         assertEquals(mutated, logStorage.mutateTasks(query, mutation));
       }
     }.run();
@@ -406,7 +424,8 @@ public class LogStorageTest extends EasyMockTest {
     final ITaskConfig updatedConfig =
         task(taskId, ScheduleStatus.RUNNING).getAssignedTask().getTask();
     new MutationFixture() {
-      @Override protected void setupExpectations() throws Exception {
+      @Override
+      protected void setupExpectations() throws Exception {
         storageUtil.expectOperations();
         expect(storageUtil.taskStore.unsafeModifyInPlace(taskId2, updatedConfig)).andReturn(false);
         expect(storageUtil.taskStore.unsafeModifyInPlace(taskId, updatedConfig)).andReturn(true);
@@ -415,7 +434,8 @@ public class LogStorageTest extends EasyMockTest {
             .andReturn(position);
       }
 
-      @Override protected void performMutations() {
+      @Override
+      protected void performMutations() {
         logStorage.unsafeModifyInPlace(taskId2, updatedConfig);
         logStorage.unsafeModifyInPlace(taskId, updatedConfig);
       }
@@ -431,7 +451,8 @@ public class LogStorageTest extends EasyMockTest {
     final ImmutableSet<String> tasksToRemove = ImmutableSet.of("b");
 
     new MutationFixture() {
-      @Override protected void setupExpectations() throws Exception {
+      @Override
+      protected void setupExpectations() throws Exception {
         storageUtil.expectOperations();
         expect(storageUtil.taskStore.mutateTasks(query, mutation)).andReturn(mutated);
 
@@ -443,12 +464,15 @@ public class LogStorageTest extends EasyMockTest {
             .andReturn(position);
       }
 
-      @Override protected void performMutations() {
+      @Override
+      protected void performMutations() {
         logStorage.write(new MutateWork.NoResult.Quiet() {
-          @Override protected void execute(MutableStoreProvider provider) {
+          @Override
+          protected void execute(MutableStoreProvider provider) {
             assertEquals(mutated, provider.getUnsafeTaskStore().mutateTasks(query, mutation));
             logStorage.write(new MutateWork.NoResult.Quiet() {
-              @Override protected void execute(MutableStoreProvider innerProvider) {
+              @Override
+              protected void execute(MutableStoreProvider innerProvider) {
                 innerProvider.getUnsafeTaskStore().deleteTasks(tasksToRemove);
               }
             });
@@ -466,7 +490,8 @@ public class LogStorageTest extends EasyMockTest {
     final ImmutableSet<IScheduledTask> mutated = ImmutableSet.of(task("a", ScheduleStatus.PENDING));
 
     new MutationFixture() {
-      @Override protected void setupExpectations() throws Exception {
+      @Override
+      protected void setupExpectations() throws Exception {
         storageUtil.expectOperations();
         storageUtil.taskStore.saveTasks(saved);
 
@@ -479,9 +504,11 @@ public class LogStorageTest extends EasyMockTest {
             .andReturn(null);
       }
 
-      @Override protected void performMutations() {
+      @Override
+      protected void performMutations() {
         logStorage.write(new MutateWork.NoResult.Quiet() {
-          @Override protected void execute(MutableStoreProvider provider) {
+          @Override
+          protected void execute(MutableStoreProvider provider) {
             logStorage.saveTasks(saved);
             assertEquals(mutated, logStorage.mutateTasks(query, mutation));
           }
@@ -498,7 +525,8 @@ public class LogStorageTest extends EasyMockTest {
     final ImmutableSet<IScheduledTask> mutated = ImmutableSet.of(task("a", ScheduleStatus.PENDING));
 
     new MutationFixture() {
-      @Override protected void setupExpectations() throws Exception {
+      @Override
+      protected void setupExpectations() throws Exception {
         storageUtil.expectOperations();
         storageUtil.taskStore.saveTasks(saved);
 
@@ -515,9 +543,11 @@ public class LogStorageTest extends EasyMockTest {
             .andReturn(position);
       }
 
-      @Override protected void performMutations() {
+      @Override
+      protected void performMutations() {
         logStorage.write(new MutateWork.NoResult.Quiet() {
-          @Override protected void execute(MutableStoreProvider provider) {
+          @Override
+          protected void execute(MutableStoreProvider provider) {
             logStorage.saveTasks(saved);
             assertEquals(mutated, logStorage.mutateTasks(query, mutation));
           }
@@ -531,7 +561,8 @@ public class LogStorageTest extends EasyMockTest {
     final IScheduledTask task = task("a", ScheduleStatus.FINISHED);
     final Set<String> taskIds = Tasks.ids(task);
     new MutationFixture() {
-      @Override protected void setupExpectations() throws Exception {
+      @Override
+      protected void setupExpectations() throws Exception {
         storageUtil.expectOperations();
         expect(storageUtil.taskStore.fetchTasks(Query.unscoped())).andReturn(ImmutableSet.of(task));
         storageUtil.taskStore.deleteTasks(taskIds);
@@ -539,7 +570,8 @@ public class LogStorageTest extends EasyMockTest {
             .andReturn(position);
       }
 
-      @Override protected void performMutations() {
+      @Override
+      protected void performMutations() {
         logStorage.deleteAllTasks();
       }
     }.run();
@@ -549,14 +581,16 @@ public class LogStorageTest extends EasyMockTest {
   public void testRemoveTasksIds() throws Exception {
     final Set<String> taskIds = ImmutableSet.of("42");
     new MutationFixture() {
-      @Override protected void setupExpectations() throws Exception {
+      @Override
+      protected void setupExpectations() throws Exception {
         storageUtil.expectOperations();
         storageUtil.taskStore.deleteTasks(taskIds);
         streamMatcher.expectTransaction(Op.removeTasks(new RemoveTasks(taskIds)))
             .andReturn(position);
       }
 
-      @Override protected void performMutations() {
+      @Override
+      protected void performMutations() {
         logStorage.deleteTasks(taskIds);
       }
     }.run();
@@ -567,14 +601,16 @@ public class LogStorageTest extends EasyMockTest {
     final String role = "role";
     final IQuota quota = IQuota.build(new Quota(1.0, 128L, 1024L));
     new MutationFixture() {
-      @Override protected void setupExpectations() throws Exception {
+      @Override
+      protected void setupExpectations() throws Exception {
         storageUtil.expectOperations();
         storageUtil.quotaStore.saveQuota(role, quota);
         streamMatcher.expectTransaction(Op.saveQuota(new SaveQuota(role, quota.newBuilder())))
             .andReturn(position);
       }
 
-      @Override protected void performMutations() {
+      @Override
+      protected void performMutations() {
         logStorage.saveQuota(role, quota);
       }
     }.run();
@@ -584,13 +620,15 @@ public class LogStorageTest extends EasyMockTest {
   public void testRemoveQuota() throws Exception {
     final String role = "role";
     new MutationFixture() {
-      @Override protected void setupExpectations() throws Exception {
+      @Override
+      protected void setupExpectations() throws Exception {
         storageUtil.expectOperations();
         storageUtil.quotaStore.removeQuota(role);
         streamMatcher.expectTransaction(Op.removeQuota(new RemoveQuota(role))).andReturn(position);
       }
 
-      @Override protected void performMutations() {
+      @Override
+      protected void performMutations() {
         logStorage.removeQuota(role);
       }
     }.run();
@@ -604,14 +642,16 @@ public class LogStorageTest extends EasyMockTest {
         .setUser("testUser")
         .setTimestampMs(12345L));
     new MutationFixture() {
-      @Override protected void setupExpectations() throws Exception {
+      @Override
+      protected void setupExpectations() throws Exception {
         storageUtil.expectOperations();
         storageUtil.lockStore.saveLock(lock);
         streamMatcher.expectTransaction(Op.saveLock(new SaveLock(lock.newBuilder())))
             .andReturn(position);
       }
 
-      @Override protected void performMutations() {
+      @Override
+      protected void performMutations() {
         logStorage.saveLock(lock);
       }
     }.run();
@@ -622,14 +662,16 @@ public class LogStorageTest extends EasyMockTest {
     final ILockKey lockKey =
         ILockKey.build(LockKey.job(JobKeys.from("testRole", "testEnv", "testJob").newBuilder()));
     new MutationFixture() {
-      @Override protected void setupExpectations() throws Exception {
+      @Override
+      protected void setupExpectations() throws Exception {
         storageUtil.expectOperations();
         storageUtil.lockStore.removeLock(lockKey);
         streamMatcher.expectTransaction(Op.removeLock(new RemoveLock(lockKey.newBuilder())))
             .andReturn(position);
       }
 
-      @Override protected void performMutations() {
+      @Override
+      protected void performMutations() {
         logStorage.removeLock(lockKey);
       }
     }.run();
@@ -645,7 +687,8 @@ public class LogStorageTest extends EasyMockTest {
         .setAttributes(attributes));
 
     new MutationFixture() {
-      @Override protected void setupExpectations() throws Exception {
+      @Override
+      protected void setupExpectations() throws Exception {
         storageUtil.expectOperations();
         expect(storageUtil.attributeStore.getHostAttributes(host))
             .andReturn(Optional.<HostAttributes>absent());
@@ -664,7 +707,8 @@ public class LogStorageTest extends EasyMockTest {
         expect(storageUtil.attributeStore.getHostAttributes(host)).andReturn(hostAttributes);
       }
 
-      @Override protected void performMutations() {
+      @Override
+      protected void performMutations() {
         logStorage.saveHostAttributes(hostAttributes.get());
         assertEquals(hostAttributes, logStorage.getHostAttributes(host));
         logStorage.saveHostAttributes(hostAttributes.get());

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/storage/mem/MemStorageTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/storage/mem/MemStorageTest.java b/src/test/java/org/apache/aurora/scheduler/storage/mem/MemStorageTest.java
index 260d960..de5cdcf 100644
--- a/src/test/java/org/apache/aurora/scheduler/storage/mem/MemStorageTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/storage/mem/MemStorageTest.java
@@ -63,7 +63,8 @@ public class MemStorageTest extends TearDownTestCase {
     executor = Executors.newSingleThreadExecutor(
         new ThreadFactoryBuilder().setNameFormat("SlowRead-%d").setDaemon(true).build());
     addTearDown(new TearDown() {
-      @Override public void tearDown() {
+      @Override
+      public void tearDown() {
         new ExecutorServiceShutdown(executor, Amount.of(1L, Time.SECONDS)).execute();
       }
     });
@@ -78,9 +79,11 @@ public class MemStorageTest extends TearDownTestCase {
     final CountDownLatch slowReadFinished = new CountDownLatch(1);
 
     Future<String> future = executor.submit(new Callable<String>() {
-      @Override public String call() throws Exception {
+      @Override
+      public String call() throws Exception {
         return storage.consistentRead(new Work.Quiet<String>() {
-          @Override public String apply(StoreProvider storeProvider) {
+          @Override
+          public String apply(StoreProvider storeProvider) {
             slowReadStarted.countDown();
             try {
               slowReadFinished.await();
@@ -96,7 +99,8 @@ public class MemStorageTest extends TearDownTestCase {
     slowReadStarted.await();
 
     String fastResult = storage.consistentRead(new Work.Quiet<String>() {
-      @Override public String apply(StoreProvider storeProvider) {
+      @Override
+      public String apply(StoreProvider storeProvider) {
         return "fastResult";
       }
     });
@@ -129,7 +133,8 @@ public class MemStorageTest extends TearDownTestCase {
 
   private void expectTasks(final String... taskIds) {
     storage.consistentRead(new Work.Quiet<Void>() {
-      @Override public Void apply(StoreProvider storeProvider) {
+      @Override
+      public Void apply(StoreProvider storeProvider) {
         Query.Builder query = Query.unscoped();
         Set<String> ids = FluentIterable.from(storeProvider.getTaskStore().fetchTasks(query))
             .transform(Tasks.SCHEDULED_TO_ID)
@@ -143,7 +148,8 @@ public class MemStorageTest extends TearDownTestCase {
   @Test
   public void testOperations() {
     expectWriteFail(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) {
         storeProvider.getUnsafeTaskStore().saveTasks(ImmutableSet.of(makeTask("a"), makeTask("b")));
         throw new CustomException();
       }
@@ -151,14 +157,16 @@ public class MemStorageTest extends TearDownTestCase {
     expectTasks("a", "b");
 
     storage.write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) {
         storeProvider.getUnsafeTaskStore().saveTasks(ImmutableSet.of(makeTask("a"), makeTask("b")));
       }
     });
     expectTasks("a", "b");
 
     expectWriteFail(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) {
         storeProvider.getUnsafeTaskStore().deleteAllTasks();
         throw new CustomException();
       }
@@ -166,14 +174,16 @@ public class MemStorageTest extends TearDownTestCase {
     expectTasks();
 
     expectWriteFail(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) {
         storeProvider.getUnsafeTaskStore().saveTasks(ImmutableSet.of(makeTask("a")));
         throw new CustomException();
       }
     });
     expectTasks("a");
     storage.consistentRead(new Work.Quiet<Void>() {
-      @Override public Void apply(StoreProvider storeProvider) {
+      @Override
+      public Void apply(StoreProvider storeProvider) {
         assertEquals(
             makeTask("a"),
             Iterables.getOnlyElement(storeProvider.getTaskStore().fetchTasks(
@@ -184,10 +194,12 @@ public class MemStorageTest extends TearDownTestCase {
 
     // Nested transaction where inner transaction fails.
     expectWriteFail(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) {
         storeProvider.getUnsafeTaskStore().saveTasks(ImmutableSet.of(makeTask("c")));
         storage.write(new MutateWork.NoResult.Quiet() {
-          @Override protected void execute(MutableStoreProvider storeProvider) {
+          @Override
+          protected void execute(MutableStoreProvider storeProvider) {
             storeProvider.getUnsafeTaskStore().saveTasks(ImmutableSet.of(makeTask("d")));
             throw new CustomException();
           }
@@ -198,10 +210,12 @@ public class MemStorageTest extends TearDownTestCase {
 
     // Nested transaction where outer transaction fails.
     expectWriteFail(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) {
         storeProvider.getUnsafeTaskStore().saveTasks(ImmutableSet.of(makeTask("c")));
         storage.write(new MutateWork.NoResult.Quiet() {
-          @Override protected void execute(MutableStoreProvider storeProvider) {
+          @Override
+          protected void execute(MutableStoreProvider storeProvider) {
             storeProvider.getUnsafeTaskStore().saveTasks(ImmutableSet.of(makeTask("d")));
           }
         });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/storage/mem/MemTaskStoreTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/storage/mem/MemTaskStoreTest.java b/src/test/java/org/apache/aurora/scheduler/storage/mem/MemTaskStoreTest.java
index 0955338..884f589 100644
--- a/src/test/java/org/apache/aurora/scheduler/storage/mem/MemTaskStoreTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/storage/mem/MemTaskStoreTest.java
@@ -198,7 +198,8 @@ public class MemTaskStoreTest {
     assertQueryResults(joesJob, d);
 
     store.mutateTasks(jimsJob, new TaskMutation() {
-      @Override public IScheduledTask apply(IScheduledTask task) {
+      @Override
+      public IScheduledTask apply(IScheduledTask task) {
         return IScheduledTask.build(task.newBuilder().setStatus(RUNNING));
       }
     });
@@ -266,7 +267,8 @@ public class MemTaskStoreTest {
     final IScheduledTask b = setHost(a, Optional.of(host));
     Set<IScheduledTask> result = store.mutateTasks(Query.taskScoped(Tasks.id(a)),
         new Function<IScheduledTask, IScheduledTask>() {
-          @Override public IScheduledTask apply(IScheduledTask task) {
+          @Override
+          public IScheduledTask apply(IScheduledTask task) {
             assertEquals(a, task);
             return b;
           }
@@ -279,7 +281,8 @@ public class MemTaskStoreTest {
     final IScheduledTask c = setHost(b, Optional.of(host2));
     Set<IScheduledTask> result2 = store.mutateTasks(Query.taskScoped(Tasks.id(a)),
         new Function<IScheduledTask, IScheduledTask>() {
-          @Override public IScheduledTask apply(IScheduledTask task) {
+          @Override
+          public IScheduledTask apply(IScheduledTask task) {
             assertEquals(b, task);
             return c;
           }
@@ -303,7 +306,8 @@ public class MemTaskStoreTest {
     final IScheduledTask b = setHost(a, Optional.<String>absent());
     Set<IScheduledTask> result = store.mutateTasks(Query.taskScoped(Tasks.id(a)),
         new Function<IScheduledTask, IScheduledTask>() {
-          @Override public IScheduledTask apply(IScheduledTask task) {
+          @Override
+          public IScheduledTask apply(IScheduledTask task) {
             assertEquals(a, task);
             return b;
           }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/thrift/SchedulerThriftInterfaceTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/thrift/SchedulerThriftInterfaceTest.java
b/src/test/java/org/apache/aurora/scheduler/thrift/SchedulerThriftInterfaceTest.java
index 02b7a27..4cb84da 100644
--- a/src/test/java/org/apache/aurora/scheduler/thrift/SchedulerThriftInterfaceTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/thrift/SchedulerThriftInterfaceTest.java
@@ -159,7 +159,8 @@ public class SchedulerThriftInterfaceTest extends EasyMockTest {
 
     // Use guice and install AuthModule to apply AOP-style auth layer.
     Module testModule = new AbstractModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         bind(Clock.class).toInstance(new FakeClock());
         bind(Storage.class).toInstance(storageUtil.storage);
         bind(SchedulerCore.class).toInstance(scheduler);

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/thrift/ThriftIT.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/thrift/ThriftIT.java b/src/test/java/org/apache/aurora/scheduler/thrift/ThriftIT.java
index 644d6e8..2254574 100644
--- a/src/test/java/org/apache/aurora/scheduler/thrift/ThriftIT.java
+++ b/src/test/java/org/apache/aurora/scheduler/thrift/ThriftIT.java
@@ -70,7 +70,8 @@ public class ThriftIT extends EasyMockTest {
   private QuotaManager quotaManager;
 
   private final SessionValidator validator = new SessionValidator() {
-    @Override public SessionContext checkAuthenticated(
+    @Override
+    public SessionContext checkAuthenticated(
         SessionKey sessionKey,
         Set<String> targetRoles) throws AuthFailedException {
 
@@ -83,7 +84,8 @@ public class ThriftIT extends EasyMockTest {
       return context;
     }
 
-    @Override public String toString(SessionKey sessionKey) {
+    @Override
+    public String toString(SessionKey sessionKey) {
       return "test";
     }
   };
@@ -95,7 +97,8 @@ public class ThriftIT extends EasyMockTest {
       this.validator = validator;
     }
 
-    @Override public SessionContext checkAuthorized(
+    @Override
+    public SessionContext checkAuthorized(
         SessionKey sessionKey,
         Capability capability,
         AuditCheck check)
@@ -106,7 +109,8 @@ public class ThriftIT extends EasyMockTest {
           ImmutableSet.of(CAPABILITIES.get(capability)));
     }
 
-    @Override public SessionContext checkAuthenticated(
+    @Override
+    public SessionContext checkAuthenticated(
         SessionKey sessionKey,
         Set<String> targetRoles)
         throws AuthFailedException {
@@ -114,7 +118,8 @@ public class ThriftIT extends EasyMockTest {
       return validator.checkAuthenticated(sessionKey, targetRoles);
     }
 
-    @Override public String toString(SessionKey sessionKey) {
+    @Override
+    public String toString(SessionKey sessionKey) {
       return validator.toString(sessionKey);
     }
   }
@@ -137,7 +142,8 @@ public class ThriftIT extends EasyMockTest {
             return mock;
           }
 
-          @Override protected void configure() {
+          @Override
+          protected void configure() {
             bindMock(CronScheduler.class);
             bindMock(MaintenanceController.class);
             bindMock(Recovery.class);

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/thrift/aop/AopModuleTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/thrift/aop/AopModuleTest.java b/src/test/java/org/apache/aurora/scheduler/thrift/aop/AopModuleTest.java
index b510bf1..d93ac53 100644
--- a/src/test/java/org/apache/aurora/scheduler/thrift/aop/AopModuleTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/thrift/aop/AopModuleTest.java
@@ -56,7 +56,8 @@ public class AopModuleTest extends EasyMockTest {
   private Iface getIface(Map<String, Boolean> toggledMethods) {
     Injector injector = Guice.createInjector(
         new AbstractModule() {
-          @Override protected void configure() {
+          @Override
+          protected void configure() {
             bind(CapabilityValidator.class).toInstance(capabilityValidator);
             MockDecoratedThrift.bindForwardedMock(binder(), mockThrift);
           }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/thrift/aop/FeatureToggleInterceptorTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/thrift/aop/FeatureToggleInterceptorTest.java
b/src/test/java/org/apache/aurora/scheduler/thrift/aop/FeatureToggleInterceptorTest.java
index d184a52..7179d18 100644
--- a/src/test/java/org/apache/aurora/scheduler/thrift/aop/FeatureToggleInterceptorTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/thrift/aop/FeatureToggleInterceptorTest.java
@@ -48,7 +48,8 @@ public class FeatureToggleInterceptorTest extends EasyMockTest {
     realThrift = createMock(AuroraAdmin.Iface.class);
     predicate = createMock(new Clazz<Predicate<Method>>() { });
     Injector injector = Guice.createInjector(new AbstractModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         MockDecoratedThrift.bindForwardedMock(binder(), realThrift);
         bind(new TypeLiteral<Predicate<Method>>() { }).toInstance(predicate);
         AopModule.bindThriftDecorator(

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/thrift/aop/ThriftStatsExporterInterceptorTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/thrift/aop/ThriftStatsExporterInterceptorTest.java
b/src/test/java/org/apache/aurora/scheduler/thrift/aop/ThriftStatsExporterInterceptorTest.java
index 8860bda..6c46ff7 100644
--- a/src/test/java/org/apache/aurora/scheduler/thrift/aop/ThriftStatsExporterInterceptorTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/thrift/aop/ThriftStatsExporterInterceptorTest.java
@@ -50,7 +50,8 @@ public class ThriftStatsExporterInterceptorTest extends EasyMockTest {
     statsInterceptor = new ThriftStatsExporterInterceptor();
     realThrift = createMock(AuroraAdmin.Iface.class);
     Injector injector = Guice.createInjector(new AbstractModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         MockDecoratedThrift.bindForwardedMock(binder(), realThrift);
         AopModule.bindThriftDecorator(
             binder(),


Mime
View raw message