You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@aurora.apache.org by ma...@apache.org on 2014/02/05 03:10:29 UTC
[2/4] Moving @Override to a separate line to comply with IntelliJ
editor.
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/log/SnapshotStoreImpl.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/log/SnapshotStoreImpl.java b/src/main/java/org/apache/aurora/scheduler/storage/log/SnapshotStoreImpl.java
index 4342932..cb0ba50 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/log/SnapshotStoreImpl.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/log/SnapshotStoreImpl.java
@@ -59,11 +59,13 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
private static final Logger LOG = Logger.getLogger(SnapshotStoreImpl.class.getName());
private static final SnapshotField ATTRIBUTE_FIELD = new SnapshotField() {
- @Override public void saveToSnapshot(StoreProvider storeProvider, Snapshot snapshot) {
+ @Override
+ public void saveToSnapshot(StoreProvider storeProvider, Snapshot snapshot) {
snapshot.setHostAttributes(storeProvider.getAttributeStore().getHostAttributes());
}
- @Override public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
+ @Override
+ public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
store.getAttributeStore().deleteHostAttributes();
if (snapshot.isSetHostAttributes()) {
@@ -77,12 +79,14 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
private static final Iterable<SnapshotField> SNAPSHOT_FIELDS = Arrays.asList(
ATTRIBUTE_FIELD,
new SnapshotField() {
- @Override public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
+ @Override
+ public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
snapshot.setTasks(
IScheduledTask.toBuildersSet(store.getTaskStore().fetchTasks(Query.unscoped())));
}
- @Override public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
+ @Override
+ public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
store.getUnsafeTaskStore().deleteAllTasks();
if (snapshot.isSetTasks()) {
@@ -92,7 +96,8 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
}
},
new SnapshotField() {
- @Override public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
+ @Override
+ public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
ImmutableSet.Builder<StoredJob> jobs = ImmutableSet.builder();
for (String managerId : store.getJobStore().fetchManagerIds()) {
for (IJobConfiguration config : store.getJobStore().fetchJobs(managerId)) {
@@ -102,7 +107,8 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
snapshot.setJobs(jobs.build());
}
- @Override public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
+ @Override
+ public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
store.getJobStore().deleteJobs();
if (snapshot.isSetJobs()) {
@@ -115,7 +121,8 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
}
},
new SnapshotField() {
- @Override public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
+ @Override
+ public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
Properties props = new BuildInfo().getProperties();
snapshot.setSchedulerMetadata(
@@ -129,7 +136,8 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
.setVersion(CURRENT_API_VERSION));
}
- @Override public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
+ @Override
+ public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
if (snapshot.isSetSchedulerMetadata()) {
// No delete necessary here since this is a single value.
@@ -139,7 +147,8 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
}
},
new SnapshotField() {
- @Override public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
+ @Override
+ public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
ImmutableSet.Builder<QuotaConfiguration> quotas = ImmutableSet.builder();
for (Map.Entry<String, IQuota> entry : store.getQuotaStore().fetchQuotas().entrySet()) {
quotas.add(new QuotaConfiguration(entry.getKey(), entry.getValue().newBuilder()));
@@ -148,7 +157,8 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
snapshot.setQuotaConfigurations(quotas.build());
}
- @Override public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
+ @Override
+ public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
store.getQuotaStore().deleteQuotas();
if (snapshot.isSetQuotaConfigurations()) {
@@ -159,11 +169,13 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
}
},
new SnapshotField() {
- @Override public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
+ @Override
+ public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
snapshot.setLocks(ILock.toBuildersSet(store.getLockStore().fetchLocks()));
}
- @Override public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
+ @Override
+ public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
store.getLockStore().deleteLocks();
if (snapshot.isSetLocks()) {
@@ -185,9 +197,11 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
}
@Timed("snapshot_create")
- @Override public Snapshot createSnapshot() {
+ @Override
+ public Snapshot createSnapshot() {
return storage.consistentRead(new Work.Quiet<Snapshot>() {
- @Override public Snapshot apply(StoreProvider storeProvider) {
+ @Override
+ public Snapshot apply(StoreProvider storeProvider) {
Snapshot snapshot = new Snapshot();
// Capture timestamp to signify the beginning of a snapshot operation, apply after in case
@@ -203,11 +217,13 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
}
@Timed("snapshot_apply")
- @Override public void applySnapshot(final Snapshot snapshot) {
+ @Override
+ public void applySnapshot(final Snapshot snapshot) {
checkNotNull(snapshot);
storage.write(new MutateWork.NoResult.Quiet() {
- @Override protected void execute(MutableStoreProvider storeProvider) {
+ @Override
+ protected void execute(MutableStoreProvider storeProvider) {
LOG.info("Restoring snapshot.");
for (SnapshotField field : SNAPSHOT_FIELDS) {
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemJobStore.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemJobStore.java b/src/main/java/org/apache/aurora/scheduler/storage/mem/MemJobStore.java
index 0419b45..c3a93d1 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemJobStore.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/mem/MemJobStore.java
@@ -41,7 +41,8 @@ class MemJobStore implements JobStore.Mutable {
private final LoadingCache<String, Manager> managers = CacheBuilder.newBuilder()
.build(new CacheLoader<String, Manager>() {
- @Override public Manager load(String key) {
+ @Override
+ public Manager load(String key) {
return new Manager();
}
});
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemStorage.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemStorage.java b/src/main/java/org/apache/aurora/scheduler/storage/mem/MemStorage.java
index 0769b68..30d77cc 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemStorage.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/mem/MemStorage.java
@@ -62,37 +62,45 @@ public class MemStorage implements Storage {
final AttributeStore.Mutable attributeStore) {
storeProvider = new MutableStoreProvider() {
- @Override public SchedulerStore.Mutable getSchedulerStore() {
+ @Override
+ public SchedulerStore.Mutable getSchedulerStore() {
return schedulerStore;
}
- @Override public JobStore.Mutable getJobStore() {
+ @Override
+ public JobStore.Mutable getJobStore() {
return jobStore;
}
- @Override public TaskStore getTaskStore() {
+ @Override
+ public TaskStore getTaskStore() {
return taskStore;
}
- @Override public TaskStore.Mutable getUnsafeTaskStore() {
+ @Override
+ public TaskStore.Mutable getUnsafeTaskStore() {
return taskStore;
}
- @Override public LockStore.Mutable getLockStore() {
+ @Override
+ public LockStore.Mutable getLockStore() {
return lockStore;
}
- @Override public QuotaStore.Mutable getQuotaStore() {
+ @Override
+ public QuotaStore.Mutable getQuotaStore() {
return quotaStore;
}
- @Override public AttributeStore.Mutable getAttributeStore() {
+ @Override
+ public AttributeStore.Mutable getAttributeStore() {
return attributeStore;
}
};
Stats.export(new StatImpl<Integer>("storage_lock_threads_waiting") {
- @Override public Integer read() {
+ @Override
+ public Integer read() {
return lockManager.getQueueLength();
}
});
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemTaskStore.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemTaskStore.java b/src/main/java/org/apache/aurora/scheduler/storage/mem/MemTaskStore.java
index 796fd75..d1ab503 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemTaskStore.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/mem/MemTaskStore.java
@@ -74,13 +74,15 @@ class MemTaskStore implements TaskStore.Mutable {
private static final Function<Query.Builder, Optional<IJobKey>> QUERY_TO_JOB_KEY =
new Function<Query.Builder, Optional<IJobKey>>() {
- @Override public Optional<IJobKey> apply(Query.Builder query) {
+ @Override
+ public Optional<IJobKey> apply(Query.Builder query) {
return JobKeys.from(query);
}
};
private static final Function<Query.Builder, Optional<String>> QUERY_TO_SLAVE_HOST =
new Function<Query.Builder, Optional<String>>() {
- @Override public Optional<String> apply(Query.Builder query) {
+ @Override
+ public Optional<String> apply(Query.Builder query) {
return Optional.fromNullable(query.get().getSlaveHost());
}
};
@@ -132,7 +134,8 @@ class MemTaskStore implements TaskStore.Mutable {
private final Function<IScheduledTask, Task> toTask =
new Function<IScheduledTask, Task>() {
- @Override public Task apply(IScheduledTask task) {
+ @Override
+ public Task apply(IScheduledTask task) {
return new Task(task, configInterner);
}
};
@@ -224,7 +227,8 @@ class MemTaskStore implements TaskStore.Mutable {
private static Predicate<Task> queryFilter(final TaskQuery query) {
return new Predicate<Task>() {
- @Override public boolean apply(Task canonicalTask) {
+ @Override
+ public boolean apply(Task canonicalTask) {
IScheduledTask task = canonicalTask.task;
ITaskConfig config = task.getAssignedTask().getTask();
if (query.getOwner() != null) {
@@ -314,7 +318,8 @@ class MemTaskStore implements TaskStore.Mutable {
private static final Function<Task, IScheduledTask> TO_SCHEDULED =
new Function<Task, IScheduledTask>() {
- @Override public IScheduledTask apply(Task task) {
+ @Override
+ public IScheduledTask apply(Task task) {
return task.task;
}
};
@@ -412,7 +417,8 @@ class MemTaskStore implements TaskStore.Mutable {
}
private final Function<K, Iterable<String>> lookup = new Function<K, Iterable<String>>() {
- @Override public Iterable<String> apply(K key) {
+ @Override
+ public Iterable<String> apply(K key) {
hitCount.incrementAndGet();
return index.get(key);
}
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/mem/Util.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/mem/Util.java b/src/main/java/org/apache/aurora/scheduler/storage/mem/Util.java
index 2d9941c..9cfb878 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/mem/Util.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/mem/Util.java
@@ -39,7 +39,8 @@ final class Util {
*/
static <T extends TBase<T, ?>> Function<T, T> deepCopier() {
return new Function<T, T>() {
- @Override public T apply(@Nullable T input) {
+ @Override
+ public T apply(@Nullable T input) {
if (input == null) {
return null;
}
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/testing/StorageTestUtil.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/testing/StorageTestUtil.java b/src/main/java/org/apache/aurora/scheduler/storage/testing/StorageTestUtil.java
index 6f71fe2..005bad2 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/testing/StorageTestUtil.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/testing/StorageTestUtil.java
@@ -77,7 +77,8 @@ public class StorageTestUtil {
private <T> IExpectationSetters<T> expectConsistentRead() {
final Capture<Work<T, RuntimeException>> work = EasyMockTest.createCapture();
return expect(storage.consistentRead(capture(work))).andAnswer(new IAnswer<T>() {
- @Override public T answer() {
+ @Override
+ public T answer() {
return work.getValue().apply(storeProvider);
}
});
@@ -86,7 +87,8 @@ public class StorageTestUtil {
private <T> IExpectationSetters<T> expectWeaklyConsistentRead() {
final Capture<Work<T, RuntimeException>> work = EasyMockTest.createCapture();
return expect(storage.weaklyConsistentRead(capture(work))).andAnswer(new IAnswer<T>() {
- @Override public T answer() {
+ @Override
+ public T answer() {
return work.getValue().apply(storeProvider);
}
});
@@ -95,7 +97,8 @@ public class StorageTestUtil {
private <T> IExpectationSetters<T> expectWriteOperation() {
final Capture<MutateWork<T, RuntimeException>> work = EasyMockTest.createCapture();
return expect(storage.write(capture(work))).andAnswer(new IAnswer<T>() {
- @Override public T answer() {
+ @Override
+ public T answer() {
return work.getValue().apply(mutableStoreProvider);
}
});
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/thrift/SchedulerThriftInterface.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/thrift/SchedulerThriftInterface.java b/src/main/java/org/apache/aurora/scheduler/thrift/SchedulerThriftInterface.java
index 479c2d9..a03627d 100644
--- a/src/main/java/org/apache/aurora/scheduler/thrift/SchedulerThriftInterface.java
+++ b/src/main/java/org/apache/aurora/scheduler/thrift/SchedulerThriftInterface.java
@@ -157,7 +157,8 @@ class SchedulerThriftInterface implements AuroraAdmin.Iface {
private static final Function<IScheduledTask, String> GET_ROLE = Functions.compose(
new Function<ITaskConfig, String>() {
- @Override public String apply(ITaskConfig task) {
+ @Override
+ public String apply(ITaskConfig task) {
return task.getOwner().getRole();
}
},
@@ -542,7 +543,8 @@ class SchedulerThriftInterface implements AuroraAdmin.Iface {
final Query.Builder activeQuery = Query.arbitrary(query.setStatuses(Tasks.ACTIVE_STATES));
try {
backoff.doUntilSuccess(new Supplier<Boolean>() {
- @Override public Boolean get() {
+ @Override
+ public Boolean get() {
Set<IScheduledTask> tasks = Storage.Util.consistentFetchTasks(storage, activeQuery);
if (tasks.isEmpty()) {
LOG.info("Tasks all killed, done waiting.");
@@ -792,7 +794,8 @@ class SchedulerThriftInterface implements AuroraAdmin.Iface {
}
return storage.write(new MutateWork.Quiet<Response>() {
- @Override public Response apply(MutableStoreProvider storeProvider) {
+ @Override
+ public Response apply(MutableStoreProvider storeProvider) {
List<String> errors = Lists.newArrayList();
for (ConfigRewrite command : request.getRewriteCommands()) {
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServer.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServer.java b/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServer.java
index 3cc872f..5b55e94 100644
--- a/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServer.java
+++ b/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServer.java
@@ -60,7 +60,8 @@ class ThriftServer {
Thread listeningThread = new ThreadFactoryBuilder().setDaemon(false).build()
.newThread(new Runnable() {
- @Override public void run() {
+ @Override
+ public void run() {
try {
starting.serve();
} catch (Throwable t) {
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServerLauncher.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServerLauncher.java b/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServerLauncher.java
index 504ac69..bb93be3 100644
--- a/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServerLauncher.java
+++ b/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServerLauncher.java
@@ -73,7 +73,8 @@ class ThriftServerLauncher implements ServiceRunner {
new AuroraAdmin.Processor<>(schedulerThriftInterface));
Command shutdown = new Command() {
- @Override public void execute() {
+ @Override
+ public void execute() {
LOG.info("Stopping thrift server.");
schedulerThriftServer.shutdown();
}
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/thrift/aop/AopModule.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/thrift/aop/AopModule.java b/src/main/java/org/apache/aurora/scheduler/thrift/aop/AopModule.java
index 7c29094..c68977a 100644
--- a/src/main/java/org/apache/aurora/scheduler/thrift/aop/AopModule.java
+++ b/src/main/java/org/apache/aurora/scheduler/thrift/aop/AopModule.java
@@ -77,7 +77,8 @@ public class AopModule extends AbstractModule {
}
private static final Function<Method, String> GET_NAME = new Function<Method, String>() {
- @Override public String apply(Method method) {
+ @Override
+ public String apply(Method method) {
return method.getName();
}
};
@@ -104,7 +105,8 @@ public class AopModule extends AbstractModule {
authInterceptor);
install(new PrivateModule() {
- @Override protected void configure() {
+ @Override
+ protected void configure() {
// Ensure that the provided methods exist on the decorated interface.
List<Method> methods =
ImmutableList.copyOf(AuroraSchedulerManager.Iface.class.getMethods());
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/thrift/aop/LoggingInterceptor.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/thrift/aop/LoggingInterceptor.java b/src/main/java/org/apache/aurora/scheduler/thrift/aop/LoggingInterceptor.java
index e66a885..5f8143c 100644
--- a/src/main/java/org/apache/aurora/scheduler/thrift/aop/LoggingInterceptor.java
+++ b/src/main/java/org/apache/aurora/scheduler/thrift/aop/LoggingInterceptor.java
@@ -52,7 +52,8 @@ class LoggingInterceptor implements MethodInterceptor {
ImmutableMap.<Class<?>, Function<Object, String>>of(
JobConfiguration.class,
new Function<Object, String>() {
- @Override public String apply(Object input) {
+ @Override
+ public String apply(Object input) {
JobConfiguration configuration = ((JobConfiguration) input).deepCopy();
if (configuration.isSetTaskConfig()) {
configuration.getTaskConfig().setExecutorConfig(
@@ -63,7 +64,8 @@ class LoggingInterceptor implements MethodInterceptor {
},
SessionKey.class,
new Function<Object, String>() {
- @Override public String apply(Object input) {
+ @Override
+ public String apply(Object input) {
SessionKey key = (SessionKey) input;
return validator.toString(key);
}
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/thrift/aop/ThriftStatsExporterInterceptor.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/thrift/aop/ThriftStatsExporterInterceptor.java b/src/main/java/org/apache/aurora/scheduler/thrift/aop/ThriftStatsExporterInterceptor.java
index 9f7e8bb..c2a613f 100644
--- a/src/main/java/org/apache/aurora/scheduler/thrift/aop/ThriftStatsExporterInterceptor.java
+++ b/src/main/java/org/apache/aurora/scheduler/thrift/aop/ThriftStatsExporterInterceptor.java
@@ -33,7 +33,8 @@ class ThriftStatsExporterInterceptor implements MethodInterceptor {
private final LoadingCache<Method, SlidingStats> stats =
CacheBuilder.newBuilder().build(new CacheLoader<Method, SlidingStats>() {
- @Override public SlidingStats load(Method method) {
+ @Override
+ public SlidingStats load(Method method) {
return new SlidingStats(
Stats.normalizeName(String.format("scheduler_thrift_%s", method.getName())),
"nanos");
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/thrift/aop/UserCapabilityInterceptor.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/thrift/aop/UserCapabilityInterceptor.java b/src/main/java/org/apache/aurora/scheduler/thrift/aop/UserCapabilityInterceptor.java
index 8e6e52d..801e7ae 100644
--- a/src/main/java/org/apache/aurora/scheduler/thrift/aop/UserCapabilityInterceptor.java
+++ b/src/main/java/org/apache/aurora/scheduler/thrift/aop/UserCapabilityInterceptor.java
@@ -52,7 +52,8 @@ class UserCapabilityInterceptor implements MethodInterceptor {
@Inject private CapabilityValidator capabilityValidator;
private static final Function<Object, SessionKey> CAST = new Function<Object, SessionKey>() {
- @Override public SessionKey apply(Object o) {
+ @Override
+ public SessionKey apply(Object o) {
return (SessionKey) o;
}
};
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/GuiceUtilsTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/GuiceUtilsTest.java b/src/test/java/org/apache/aurora/GuiceUtilsTest.java
index 45d527c..5186008 100644
--- a/src/test/java/org/apache/aurora/GuiceUtilsTest.java
+++ b/src/test/java/org/apache/aurora/GuiceUtilsTest.java
@@ -65,7 +65,8 @@ public class GuiceUtilsTest {
throw new RuntimeException("Call failed");
}
- @Override public void get() {
+ @Override
+ public void get() {
throw new RuntimeException("Call failed");
}
}
@@ -73,7 +74,8 @@ public class GuiceUtilsTest {
@Test
public void testExceptionTrapping() {
Injector injector = Guice.createInjector(new AbstractModule() {
- @Override protected void configure() {
+ @Override
+ protected void configure() {
GuiceUtils.bindExceptionTrap(binder(), Flaky.class);
bind(Flaky.class).to(NotSoFlakyImpl.class);
bind(AlsoFlaky.class).to(NotSoFlakyImpl.class);
@@ -114,7 +116,8 @@ public class GuiceUtilsTest {
@Test(expected = CreationException.class)
public void testNoTrappingNonVoidMethods() {
Guice.createInjector(new AbstractModule() {
- @Override protected void configure() {
+ @Override
+ protected void configure() {
GuiceUtils.bindExceptionTrap(binder(), NonVoid.class);
fail("Bind should have failed.");
}
@@ -129,7 +132,8 @@ public class GuiceUtilsTest {
@Test
public void testWhitelistNonVoidMethods() {
Guice.createInjector(new AbstractModule() {
- @Override protected void configure() {
+ @Override
+ protected void configure() {
GuiceUtils.bindExceptionTrap(binder(), NonVoidWhitelisted.class);
}
});
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/MesosSchedulerImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/MesosSchedulerImplTest.java b/src/test/java/org/apache/aurora/scheduler/MesosSchedulerImplTest.java
index fd4d5d5..92c77d5 100644
--- a/src/test/java/org/apache/aurora/scheduler/MesosSchedulerImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/MesosSchedulerImplTest.java
@@ -120,7 +120,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
eventSink = createMock(EventSink.class);
Injector injector = Guice.createInjector(new AbstractModule() {
- @Override protected void configure() {
+ @Override
+ protected void configure() {
bind(Storage.class).toInstance(storageUtil.storage);
bind(SchedulerCore.class).toInstance(createMock(SchedulerCore.class));
bind(Lifecycle.class).toInstance(lifecycle);
@@ -144,7 +145,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
@Test
public void testNoOffers() throws Exception {
new RegisteredFixture() {
- @Override void test() {
+ @Override
+ void test() {
scheduler.resourceOffers(driver, ImmutableList.<Offer>of());
}
}.run();
@@ -153,7 +155,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
@Test
public void testNoAccepts() throws Exception {
new OfferFixture() {
- @Override void respondToOffer() throws Exception {
+ @Override
+ void respondToOffer() throws Exception {
expectOfferAttributesSaved(OFFER);
expect(systemLauncher.createTask(OFFER)).andReturn(Optional.<TaskInfo>absent());
expect(userLauncher.createTask(OFFER)).andReturn(Optional.<TaskInfo>absent());
@@ -164,7 +167,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
@Test
public void testOfferFirstAccepts() throws Exception {
new OfferFixture() {
- @Override void respondToOffer() throws Exception {
+ @Override
+ void respondToOffer() throws Exception {
expectOfferAttributesSaved(OFFER);
expect(systemLauncher.createTask(OFFER)).andReturn(Optional.of(TASK));
expectLaunch(TASK);
@@ -175,7 +179,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
@Test
public void testOfferSchedulerAccepts() throws Exception {
new OfferFixture() {
- @Override void respondToOffer() throws Exception {
+ @Override
+ void respondToOffer() throws Exception {
expectOfferAttributesSaved(OFFER);
expect(systemLauncher.createTask(OFFER)).andReturn(Optional.<TaskInfo>absent());
expect(userLauncher.createTask(OFFER)).andReturn(Optional.of(TASK));
@@ -187,7 +192,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
@Test
public void testAcceptedExceedsOffer() throws Exception {
new OfferFixture() {
- @Override void respondToOffer() throws Exception {
+ @Override
+ void respondToOffer() throws Exception {
expectOfferAttributesSaved(OFFER);
expect(systemLauncher.createTask(OFFER)).andReturn(Optional.of(BIGGER_TASK));
expect(userLauncher.createTask(OFFER)).andReturn(Optional.<TaskInfo>absent());
@@ -198,7 +204,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
@Test
public void testStatusUpdateNoAccepts() throws Exception {
new StatusFixture() {
- @Override void expectations() throws Exception {
+ @Override
+ void expectations() throws Exception {
expect(systemLauncher.statusUpdate(STATUS)).andReturn(false);
expect(userLauncher.statusUpdate(STATUS)).andReturn(false);
}
@@ -208,7 +215,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
@Test
public void testStatusUpdateFirstAccepts() throws Exception {
new StatusFixture() {
- @Override void expectations() throws Exception {
+ @Override
+ void expectations() throws Exception {
expect(systemLauncher.statusUpdate(STATUS)).andReturn(true);
}
}.run();
@@ -217,7 +225,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
@Test
public void testStatusUpdateSecondAccepts() throws Exception {
new StatusFixture() {
- @Override void expectations() throws Exception {
+ @Override
+ void expectations() throws Exception {
expect(systemLauncher.statusUpdate(STATUS)).andReturn(false);
expect(userLauncher.statusUpdate(STATUS)).andReturn(true);
}
@@ -227,7 +236,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
@Test(expected = SchedulerException.class)
public void testStatusUpdateFails() throws Exception {
new StatusFixture() {
- @Override void expectations() throws Exception {
+ @Override
+ void expectations() throws Exception {
expect(systemLauncher.statusUpdate(STATUS)).andReturn(false);
expect(userLauncher.statusUpdate(STATUS)).andThrow(new StorageException("Injected."));
}
@@ -237,7 +247,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
@Test
public void testMultipleOffers() throws Exception {
new RegisteredFixture() {
- @Override void expectations() throws Exception {
+ @Override
+ void expectations() throws Exception {
expectOfferAttributesSaved(OFFER);
expectOfferAttributesSaved(OFFER_2);
expect(systemLauncher.createTask(OFFER)).andReturn(Optional.<TaskInfo>absent());
@@ -247,7 +258,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
expect(userLauncher.createTask(OFFER_2)).andReturn(Optional.<TaskInfo>absent());
}
- @Override void test() {
+ @Override
+ void test() {
scheduler.resourceOffers(driver, ImmutableList.of(OFFER, OFFER_2));
}
}.run();
@@ -256,11 +268,13 @@ public class MesosSchedulerImplTest extends EasyMockTest {
@Test
public void testDisconnected() throws Exception {
new RegisteredFixture() {
- @Override void expectations() throws Exception {
+ @Override
+ void expectations() throws Exception {
eventSink.post(new DriverDisconnected());
}
- @Override void test() {
+ @Override
+ void test() {
scheduler.disconnected(driver);
}
}.run();
@@ -276,7 +290,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
RegisteredFixture() throws Exception {
// Prevent otherwise silent noop tests that forget to call run().
addTearDown(new TearDown() {
- @Override public void tearDown() {
+ @Override
+ public void tearDown() {
assertTrue(runCalled.get());
}
});
@@ -313,11 +328,13 @@ public class MesosSchedulerImplTest extends EasyMockTest {
abstract void respondToOffer() throws Exception;
- @Override void expectations() throws Exception {
+ @Override
+ void expectations() throws Exception {
respondToOffer();
}
- @Override void test() {
+ @Override
+ void test() {
scheduler.resourceOffers(driver, ImmutableList.of(OFFER));
}
}
@@ -327,7 +344,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
super();
}
- @Override void test() {
+ @Override
+ void test() {
scheduler.statusUpdate(driver, STATUS);
}
}
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/SchedulerLifecycleTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/SchedulerLifecycleTest.java b/src/test/java/org/apache/aurora/scheduler/SchedulerLifecycleTest.java
index 282cb02..1b1e948 100644
--- a/src/test/java/org/apache/aurora/scheduler/SchedulerLifecycleTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/SchedulerLifecycleTest.java
@@ -73,7 +73,8 @@ public class SchedulerLifecycleTest extends EasyMockTest {
driverFactory,
storageUtil.storage,
new Lifecycle(shutdownRegistry, new UncaughtExceptionHandler() {
- @Override public void uncaughtException(Thread t, Throwable e) {
+ @Override
+ public void uncaughtException(Thread t, Throwable e) {
fail(e.getMessage());
}
}),
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/TaskVarsTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/TaskVarsTest.java b/src/test/java/org/apache/aurora/scheduler/TaskVarsTest.java
index d6fc72e..728d3a5 100644
--- a/src/test/java/org/apache/aurora/scheduler/TaskVarsTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/TaskVarsTest.java
@@ -80,7 +80,8 @@ public class TaskVarsTest extends EasyMockTest {
expect(trackedStats.makeGauge(EasyMock.eq(name), EasyMock.<Supplier<Long>>anyObject()))
.andAnswer(new IAnswer<Stat<Long>>() {
@SuppressWarnings("unchecked")
- @Override public Stat<Long> answer() {
+ @Override
+ public Stat<Long> answer() {
assertFalse(globalCounters.containsKey(name));
globalCounters.put(name, (Supplier<Long>) EasyMock.getCurrentArguments()[1]);
return null;
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/UserTaskLauncherTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/UserTaskLauncherTest.java b/src/test/java/org/apache/aurora/scheduler/UserTaskLauncherTest.java
index ffc37db..ecf4f90 100644
--- a/src/test/java/org/apache/aurora/scheduler/UserTaskLauncherTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/UserTaskLauncherTest.java
@@ -185,7 +185,8 @@ public class UserTaskLauncherTest extends EasyMockTest {
Ranges portRanges = Ranges.newBuilder()
.addAllRange(Iterables.transform(ports, new Function<Pair<Integer, Integer>, Range>() {
- @Override public Range apply(Pair<Integer, Integer> range) {
+ @Override
+ public Range apply(Pair<Integer, Integer> range) {
return Range.newBuilder().setBegin(range.getFirst()).setEnd(range.getSecond()).build();
}
}))
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/app/SchedulerIT.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/app/SchedulerIT.java b/src/test/java/org/apache/aurora/scheduler/app/SchedulerIT.java
index 9c0e32d..6cfaf39 100644
--- a/src/test/java/org/apache/aurora/scheduler/app/SchedulerIT.java
+++ b/src/test/java/org/apache/aurora/scheduler/app/SchedulerIT.java
@@ -141,7 +141,8 @@ public class SchedulerIT extends BaseZooKeeperTest {
public void mySetUp() throws Exception {
control = createControl();
addTearDown(new TearDown() {
- @Override public void tearDown() {
+ @Override
+ public void tearDown() {
if (mainException.get().isPresent()) {
RuntimeException e = mainException.get().get();
LOG.log(Level.SEVERE, "Scheduler main exited with an exception", e);
@@ -152,7 +153,8 @@ public class SchedulerIT extends BaseZooKeeperTest {
});
backupDir = FileUtils.createTempDir();
addTearDown(new TearDown() {
- @Override public void tearDown() throws Exception {
+ @Override
+ public void tearDown() throws Exception {
org.apache.commons.io.FileUtils.deleteDirectory(backupDir);
}
});
@@ -170,20 +172,21 @@ public class SchedulerIT extends BaseZooKeeperTest {
zkClient = createZkClient();
Module testModule = new AbstractModule() {
- @Override protected void configure() {
+ @Override
+ protected void configure() {
bind(DriverFactory.class).toInstance(driverFactory);
bind(Log.class).toInstance(log);
bind(ThriftConfiguration.class).toInstance(
new ThriftConfiguration() {
- @Override public Optional<? extends InputStream> getSslKeyStream()
- throws IOException {
-
+ @Override
+ public Optional<? extends InputStream> getSslKeyStream() throws IOException {
return Optional.of(
com.google.common.io.Resources.getResource(getClass(), "AuroraTestKeyStore")
.openStream());
}
- @Override public int getServingPort() {
+ @Override
+ public int getServingPort() {
return 0;
}
}
@@ -214,7 +217,8 @@ public class SchedulerIT extends BaseZooKeeperTest {
// Mimic AppLauncher running main.
final SchedulerMain main = injector.getInstance(SchedulerMain.class);
executor.submit(new Runnable() {
- @Override public void run() {
+ @Override
+ public void run() {
try {
main.run();
} catch (RuntimeException e) {
@@ -224,7 +228,8 @@ public class SchedulerIT extends BaseZooKeeperTest {
}
});
addTearDown(new TearDown() {
- @Override public void tearDown() throws Exception {
+ @Override
+ public void tearDown() throws Exception {
lifecycle.shutdown();
new ExecutorServiceShutdown(executor, Amount.of(10L, Time.SECONDS)).execute();
}
@@ -233,12 +238,14 @@ public class SchedulerIT extends BaseZooKeeperTest {
private HostAndPort awaitSchedulerReady() throws Exception {
return executor.submit(new Callable<HostAndPort>() {
- @Override public HostAndPort call() throws Exception {
+ @Override
+ public HostAndPort call() throws Exception {
final AtomicReference<HostAndPort> thriftEndpoint = Atomics.newReference();
ServerSet schedulerService = new ServerSetImpl(zkClient, SERVERSET_PATH);
final CountDownLatch schedulerReady = new CountDownLatch(1);
schedulerService.watch(new HostChangeMonitor<ServiceInstance>() {
- @Override public void onChange(ImmutableSet<ServiceInstance> hostSet) {
+ @Override
+ public void onChange(ImmutableSet<ServiceInstance> hostSet) {
if (!hostSet.isEmpty()) {
Endpoint endpoint = Iterables.getOnlyElement(hostSet).getServiceEndpoint();
thriftEndpoint.set(HostAndPort.fromParts(endpoint.getHost(), endpoint.getPort()));
@@ -262,7 +269,8 @@ public class SchedulerIT extends BaseZooKeeperTest {
this.pos = pos;
}
- @Override public int compareTo(Position position) {
+ @Override
+ public int compareTo(Position position) {
return pos - ((IntPosition) position).pos;
}
}
@@ -273,9 +281,11 @@ public class SchedulerIT extends BaseZooKeeperTest {
private Iterable<Entry> toEntries(LogEntry... entries) {
return Iterables.transform(Arrays.asList(entries),
new Function<LogEntry, Entry>() {
- @Override public Entry apply(final LogEntry entry) {
+ @Override
+ public Entry apply(final LogEntry entry) {
return new Entry() {
- @Override public byte[] contents() {
+ @Override
+ public byte[] contents() {
try {
return entrySerializer.serialize(entry)[0];
} catch (CodingException e) {
@@ -329,7 +339,8 @@ public class SchedulerIT extends BaseZooKeeperTest {
final CountDownLatch driverStarted = new CountDownLatch(1);
expect(driver.start()).andAnswer(new IAnswer<Status>() {
- @Override public Status answer() {
+ @Override
+ public Status answer() {
driverStarted.countDown();
return Status.DRIVER_RUNNING;
}
@@ -338,13 +349,15 @@ public class SchedulerIT extends BaseZooKeeperTest {
// Try to be a good test suite citizen by releasing the blocked thread when the test case exits.
final CountDownLatch testCompleted = new CountDownLatch(1);
expect(driver.join()).andAnswer(new IAnswer<Status>() {
- @Override public Status answer() throws Throwable {
+ @Override
+ public Status answer() throws Throwable {
testCompleted.await();
return Status.DRIVER_STOPPED;
}
});
addTearDown(new TearDown() {
- @Override public void tearDown() {
+ @Override
+ public void tearDown() {
testCompleted.countDown();
}
});
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/async/HistoryPrunerTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/async/HistoryPrunerTest.java b/src/test/java/org/apache/aurora/scheduler/async/HistoryPrunerTest.java
index afb7ce9..811f68c 100644
--- a/src/test/java/org/apache/aurora/scheduler/async/HistoryPrunerTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/async/HistoryPrunerTest.java
@@ -254,7 +254,8 @@ public class HistoryPrunerTest extends EasyMockTest {
pruner = prunerWithRealExecutor();
Command onDeleted = new Command() {
- @Override public void execute() {
+ @Override
+ public void execute() {
// The goal is to verify that the call does not deadlock. We do not care about the outcome.
changeState("b", ASSIGNED, STARTING);
}
@@ -277,7 +278,8 @@ public class HistoryPrunerTest extends EasyMockTest {
pruner = prunerWithRealExecutor();
Command onDeleted = new Command() {
- @Override public void execute() {
+ @Override
+ public void execute() {
// The goal is to verify that the call does not deadlock. We do not care about the outcome.
pruner.tasksDeleted(
new TasksDeleted(ImmutableSet.of(makeTask("a", ScheduleStatus.KILLED))));
@@ -311,7 +313,8 @@ public class HistoryPrunerTest extends EasyMockTest {
final CountDownLatch eventDelivered = new CountDownLatch(1);
Thread eventDispatch = new Thread() {
- @Override public void run() {
+ @Override
+ public void run() {
try {
deleteCalled.await();
} catch (InterruptedException e) {
@@ -329,7 +332,8 @@ public class HistoryPrunerTest extends EasyMockTest {
stateManager.deleteTasks(ImmutableSet.of(taskId));
expectLastCall().andAnswer(new IAnswer<Void>() {
- @Override public Void answer() {
+ @Override
+ public Void answer() {
deleteCalled.countDown();
try {
eventDelivered.await();
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/async/OfferQueueImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/async/OfferQueueImplTest.java b/src/test/java/org/apache/aurora/scheduler/async/OfferQueueImplTest.java
index 441fbef..17ba406 100644
--- a/src/test/java/org/apache/aurora/scheduler/async/OfferQueueImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/async/OfferQueueImplTest.java
@@ -71,7 +71,8 @@ public class OfferQueueImplTest extends EasyMockTest {
executor = Executors.newSingleThreadScheduledExecutor(threadFactory);
testExecutor = Executors.newCachedThreadPool(threadFactory);
addTearDown(new TearDown() {
- @Override public void tearDown() throws Exception {
+ @Override
+ public void tearDown() throws Exception {
new ExecutorServiceShutdown(executor, Amount.of(1L, Time.SECONDS)).execute();
new ExecutorServiceShutdown(testExecutor, Amount.of(1L, Time.SECONDS)).execute();
}
@@ -79,7 +80,8 @@ public class OfferQueueImplTest extends EasyMockTest {
maintenanceController = createMock(MaintenanceController.class);
offerAcceptor = createMock(new Clazz<Function<Offer, Optional<TaskInfo>>>() { });
OfferReturnDelay returnDelay = new OfferReturnDelay() {
- @Override public Amount<Integer, Time> get() {
+ @Override
+ public Amount<Integer, Time> get() {
return RETURN_DELAY;
}
};
@@ -92,7 +94,8 @@ public class OfferQueueImplTest extends EasyMockTest {
// the intrinsic lock and the storage lock.
final CountDownLatch launchAttempted = new CountDownLatch(1);
expect(maintenanceController.getMode(HOST_A)).andAnswer(new IAnswer<MaintenanceMode>() {
- @Override public MaintenanceMode answer() throws InterruptedException {
+ @Override
+ public MaintenanceMode answer() throws InterruptedException {
launchAttempted.await();
return MaintenanceMode.NONE;
}
@@ -102,13 +105,15 @@ public class OfferQueueImplTest extends EasyMockTest {
final CountDownLatch offerAdded = new CountDownLatch(1);
testExecutor.submit(new Runnable() {
- @Override public void run() {
+ @Override
+ public void run() {
offerQueue.addOffer(OFFER_A);
offerAdded.countDown();
}
});
testExecutor.submit(new Runnable() {
- @Override public void run() {
+ @Override
+ public void run() {
try {
offerQueue.launchFirst(offerAcceptor);
launchAttempted.countDown();
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/async/PreemptorImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/async/PreemptorImplTest.java b/src/test/java/org/apache/aurora/scheduler/async/PreemptorImplTest.java
index 3384a3a..bf097d7 100644
--- a/src/test/java/org/apache/aurora/scheduler/async/PreemptorImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/async/PreemptorImplTest.java
@@ -505,7 +505,8 @@ public class PreemptorImplTest extends EasyMockTest {
EasyMock.<String>anyObject(),
EasyMock.eq(EMPTY_JOB))).andAnswer(
new IAnswer<Set<Veto>>() {
- @Override public Set<Veto> answer() {
+ @Override
+ public Set<Veto> answer() {
return ImmutableSet.of();
}
}
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/async/RescheduleCalculatorImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/async/RescheduleCalculatorImplTest.java b/src/test/java/org/apache/aurora/scheduler/async/RescheduleCalculatorImplTest.java
index c450276..70eb52a 100644
--- a/src/test/java/org/apache/aurora/scheduler/async/RescheduleCalculatorImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/async/RescheduleCalculatorImplTest.java
@@ -177,7 +177,8 @@ public class RescheduleCalculatorImplTest extends EasyMockTest {
private static final Function<Map.Entry<ScheduleStatus, Long>, TaskEvent> TO_EVENT =
new Function<Entry<ScheduleStatus, Long>, TaskEvent>() {
- @Override public TaskEvent apply(Entry<ScheduleStatus, Long> input) {
+ @Override
+ public TaskEvent apply(Entry<ScheduleStatus, Long> input) {
return new TaskEvent().setStatus(input.getKey()).setTimestamp(input.getValue());
}
};
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerImplTest.java b/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerImplTest.java
index 4572895..4c86d8a 100644
--- a/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerImplTest.java
@@ -90,7 +90,8 @@ public class TaskSchedulerImplTest extends EasyMockTest {
preemptor = createMock(Preemptor.class);
Injector injector = Guice.createInjector(new AbstractModule() {
- @Override protected void configure() {
+ @Override
+ protected void configure() {
PubsubTestUtil.installPubsub(binder());
bind(AsyncModule.PREEMPTOR_KEY).toInstance(preemptor);
AsyncModule.bindTaskScheduler(binder(), AsyncModule.PREEMPTOR_KEY, reservationDuration);
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerTest.java b/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerTest.java
index 34e0186..4112d61 100644
--- a/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerTest.java
@@ -175,7 +175,8 @@ public class TaskSchedulerTest extends EasyMockTest {
final IScheduledTask copy = IScheduledTask.build(task.newBuilder().setStatus(newState));
// Insert the task if it doesn't already exist.
storage.write(new MutateWork.NoResult.Quiet() {
- @Override protected void execute(MutableStoreProvider storeProvider) {
+ @Override
+ protected void execute(MutableStoreProvider storeProvider) {
TaskStore.Mutable taskStore = storeProvider.getUnsafeTaskStore();
if (taskStore.fetchTasks(Query.taskScoped(Tasks.id(copy))).isEmpty()) {
taskStore.saveTasks(ImmutableSet.of(copy));
@@ -254,7 +255,8 @@ public class TaskSchedulerTest extends EasyMockTest {
final IScheduledTask b = makeTask("b", PENDING);
final IScheduledTask c = makeTask("c", RUNNING);
storage.write(new MutateWork.NoResult.Quiet() {
- @Override protected void execute(MutableStoreProvider store) {
+ @Override
+ protected void execute(MutableStoreProvider store) {
store.getUnsafeTaskStore().saveTasks(ImmutableSet.of(a, b, c));
}
});
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/configuration/ResourcesTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/configuration/ResourcesTest.java b/src/test/java/org/apache/aurora/scheduler/configuration/ResourcesTest.java
index f9f147c..b237677 100644
--- a/src/test/java/org/apache/aurora/scheduler/configuration/ResourcesTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/configuration/ResourcesTest.java
@@ -170,7 +170,8 @@ public class ResourcesTest {
Set<Pair<Long, Long>> actual = ImmutableSet.copyOf(Iterables.transform(
resource.getRanges().getRangeList(),
new Function<Range, Pair<Long, Long>>() {
- @Override public Pair<Long, Long> apply(Range range) {
+ @Override
+ public Pair<Long, Long> apply(Range range) {
return Pair.of(range.getBegin(), range.getEnd());
}
}));
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/cron/noop/NoopCronIT.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/cron/noop/NoopCronIT.java b/src/test/java/org/apache/aurora/scheduler/cron/noop/NoopCronIT.java
index 566fb47..94441b8 100644
--- a/src/test/java/org/apache/aurora/scheduler/cron/noop/NoopCronIT.java
+++ b/src/test/java/org/apache/aurora/scheduler/cron/noop/NoopCronIT.java
@@ -48,7 +48,8 @@ public class NoopCronIT {
@Test
public void testSchedule() throws Exception {
cronScheduler.schedule(SCHEDULE, new Runnable() {
- @Override public void run() {
+ @Override
+ public void run() {
// No-op.
}
});
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/filter/SchedulingFilterImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/filter/SchedulingFilterImplTest.java b/src/test/java/org/apache/aurora/scheduler/filter/SchedulingFilterImplTest.java
index 2ace24a..56de3aa 100644
--- a/src/test/java/org/apache/aurora/scheduler/filter/SchedulingFilterImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/filter/SchedulingFilterImplTest.java
@@ -129,7 +129,8 @@ public class SchedulingFilterImplTest extends EasyMockTest {
private void expectReads() throws Exception {
expect(storage.weaklyConsistentRead(EasyMock.<Quiet<?>>anyObject()))
.andAnswer(new IAnswer<Object>() {
- @Override public Object answer() throws Exception {
+ @Override
+ public Object answer() throws Exception {
Quiet<?> arg = (Quiet<?>) EasyMock.getCurrentArguments()[0];
return arg.apply(storeProvider);
}
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/http/LeaderRedirectTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/http/LeaderRedirectTest.java b/src/test/java/org/apache/aurora/scheduler/http/LeaderRedirectTest.java
index 089db12..aa2313f 100644
--- a/src/test/java/org/apache/aurora/scheduler/http/LeaderRedirectTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/http/LeaderRedirectTest.java
@@ -53,7 +53,8 @@ public class LeaderRedirectTest extends EasyMockTest {
private static final Function<HostAndPort, ServiceInstance> CREATE_INSTANCE =
new Function<HostAndPort, ServiceInstance>() {
- @Override public ServiceInstance apply(HostAndPort endpoint) {
+ @Override
+ public ServiceInstance apply(HostAndPort endpoint) {
return new ServiceInstance()
.setAdditionalEndpoints(ImmutableMap.of(HTTP_PORT_NAME,
new Endpoint(endpoint.getHostText(), endpoint.getPort())));
@@ -70,7 +71,8 @@ public class LeaderRedirectTest extends EasyMockTest {
createMock(new Clazz<DynamicHostSet<ServiceInstance>>() { });
ServiceRunner fakeRunner = new ServiceRunner() {
- @Override public LocalService launch() {
+ @Override
+ public LocalService launch() {
return LocalService.auxiliaryService(HTTP_PORT_NAME, HTTP_PORT, Commands.NOOP);
}
};
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/state/BaseSchedulerCoreImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/state/BaseSchedulerCoreImplTest.java b/src/test/java/org/apache/aurora/scheduler/state/BaseSchedulerCoreImplTest.java
index 79f09cd..8ad5e7a 100644
--- a/src/test/java/org/apache/aurora/scheduler/state/BaseSchedulerCoreImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/state/BaseSchedulerCoreImplTest.java
@@ -151,7 +151,8 @@ public abstract class BaseSchedulerCoreImplTest extends EasyMockTest {
// TODO(William Farner): Set up explicit expectations for calls to generate task IDs.
private final AtomicLong idCounter = new AtomicLong();
private TaskIdGenerator taskIdGenerator = new TaskIdGenerator() {
- @Override public String generate(ITaskConfig input, int instanceId) {
+ @Override
+ public String generate(ITaskConfig input, int instanceId) {
return "task-" + idCounter.incrementAndGet();
}
};
@@ -193,7 +194,8 @@ public abstract class BaseSchedulerCoreImplTest extends EasyMockTest {
private void buildScheduler(Storage newStorage) throws Exception {
this.storage = newStorage;
storage.write(new MutateWork.NoResult.Quiet() {
- @Override protected void execute(MutableStoreProvider storeProvider) {
+ @Override
+ protected void execute(MutableStoreProvider storeProvider) {
StorageBackfill.backfill(storeProvider, clock);
}
});
@@ -306,7 +308,8 @@ public abstract class BaseSchedulerCoreImplTest extends EasyMockTest {
.setTaskLinks(ImmutableMap.<String, String>of());
storage.write(new MutateWork.NoResult.Quiet() {
- @Override protected void execute(MutableStoreProvider storeProvider) {
+ @Override
+ protected void execute(MutableStoreProvider storeProvider) {
storeProvider.getUnsafeTaskStore().saveTasks(ImmutableSet.of(
IScheduledTask.build(
new ScheduledTask()
@@ -355,7 +358,8 @@ public abstract class BaseSchedulerCoreImplTest extends EasyMockTest {
final Set<IScheduledTask> badTasks = ImmutableSet.copyOf(Iterables
.transform(job.getTaskConfigs().values(),
new Function<ITaskConfig, IScheduledTask>() {
- @Override public IScheduledTask apply(ITaskConfig task) {
+ @Override
+ public IScheduledTask apply(ITaskConfig task) {
return IScheduledTask.build(new ScheduledTask()
.setStatus(RUNNING)
.setAssignedTask(
@@ -367,7 +371,8 @@ public abstract class BaseSchedulerCoreImplTest extends EasyMockTest {
}));
storage.write(new MutateWork.NoResult.Quiet() {
- @Override protected void execute(MutableStoreProvider storeProvider) {
+ @Override
+ protected void execute(MutableStoreProvider storeProvider) {
storeProvider.getUnsafeTaskStore().saveTasks(badTasks);
}
});
@@ -1153,7 +1158,8 @@ public abstract class BaseSchedulerCoreImplTest extends EasyMockTest {
@Test
public void testTaskIdLimit() throws Exception {
taskIdGenerator = new TaskIdGenerator() {
- @Override public String generate(ITaskConfig input, int instanceCount) {
+ @Override
+ public String generate(ITaskConfig input, int instanceCount) {
return Strings.repeat("a", SchedulerCoreImpl.MAX_TASK_ID_LENGTH);
}
};
@@ -1167,7 +1173,8 @@ public abstract class BaseSchedulerCoreImplTest extends EasyMockTest {
@Test(expected = ScheduleException.class)
public void testRejectLongTaskId() throws Exception {
taskIdGenerator = new TaskIdGenerator() {
- @Override public String generate(ITaskConfig input, int instanceCount) {
+ @Override
+ public String generate(ITaskConfig input, int instanceCount) {
return Strings.repeat("a", SchedulerCoreImpl.MAX_TASK_ID_LENGTH + 1);
}
};
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/state/CronJobManagerTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/state/CronJobManagerTest.java b/src/test/java/org/apache/aurora/scheduler/state/CronJobManagerTest.java
index 684e239..462e64f 100644
--- a/src/test/java/org/apache/aurora/scheduler/state/CronJobManagerTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/state/CronJobManagerTest.java
@@ -148,7 +148,8 @@ public class CronJobManagerTest extends EasyMockTest {
control.replay();
Injector injector = Guice.createInjector(new AbstractModule() {
- @Override protected void configure() {
+ @Override
+ protected void configure() {
bind(StateManager.class).toInstance(stateManager);
bind(Storage.class).toInstance(storageUtil.storage);
bind(CronScheduler.class).toInstance(cronScheduler);
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/state/MaintenanceControllerImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/state/MaintenanceControllerImplTest.java b/src/test/java/org/apache/aurora/scheduler/state/MaintenanceControllerImplTest.java
index f7f7632..56b691e 100644
--- a/src/test/java/org/apache/aurora/scheduler/state/MaintenanceControllerImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/state/MaintenanceControllerImplTest.java
@@ -71,7 +71,8 @@ public class MaintenanceControllerImplTest extends EasyMockTest {
Injector injector = Guice.createInjector(
new AbstractModule() {
- @Override protected void configure() {
+ @Override
+ protected void configure() {
PubsubTestUtil.installPubsub(binder());
StateModule.bindMaintenanceController(binder());
bind(Storage.class).toInstance(storageUtil.storage);
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/state/StateManagerImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/state/StateManagerImplTest.java b/src/test/java/org/apache/aurora/scheduler/state/StateManagerImplTest.java
index a0525e5..24949c0 100644
--- a/src/test/java/org/apache/aurora/scheduler/state/StateManagerImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/state/StateManagerImplTest.java
@@ -232,7 +232,8 @@ public class StateManagerImplTest extends EasyMockTest {
// Trigger an event that produces a side-effect and a PubSub event .
eventSink.post(matchStateChange(id, INIT, PENDING));
expectLastCall().andAnswer(new IAnswer<Void>() {
- @Override public Void answer() throws Throwable {
+ @Override
+ public Void answer() throws Throwable {
changeState(id, ASSIGNED);
return null;
}
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/state/TaskStateMachineTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/state/TaskStateMachineTest.java b/src/test/java/org/apache/aurora/scheduler/state/TaskStateMachineTest.java
index cc7d59d..a2aaeeb 100644
--- a/src/test/java/org/apache/aurora/scheduler/state/TaskStateMachineTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/state/TaskStateMachineTest.java
@@ -229,7 +229,8 @@ public class TaskStateMachineTest {
private static final Function<Action, SideEffect> TO_SIDE_EFFECT =
new Function<Action, SideEffect>() {
- @Override public SideEffect apply(Action action) {
+ @Override
+ public SideEffect apply(Action action) {
return new SideEffect(action, Optional.<ScheduleStatus>absent());
}
};
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/storage/ReadWriteLockManagerTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/storage/ReadWriteLockManagerTest.java b/src/test/java/org/apache/aurora/scheduler/storage/ReadWriteLockManagerTest.java
index 2a13f8b..5dc7df1 100644
--- a/src/test/java/org/apache/aurora/scheduler/storage/ReadWriteLockManagerTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/storage/ReadWriteLockManagerTest.java
@@ -71,7 +71,8 @@ public class ReadWriteLockManagerTest extends TearDownTestCase {
final CountDownLatch fastReadFinished = new CountDownLatch(1);
Future<String> slowReadResult = executor.submit(new Callable<String>() {
- @Override public String call() throws Exception {
+ @Override
+ public String call() throws Exception {
lockManager.readLock();
slowReadStarted.countDown();
fastReadFinished.await();
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/storage/StorageBackfillTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/storage/StorageBackfillTest.java b/src/test/java/org/apache/aurora/scheduler/storage/StorageBackfillTest.java
index f6ece9c..c0cc0a4 100644
--- a/src/test/java/org/apache/aurora/scheduler/storage/StorageBackfillTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/storage/StorageBackfillTest.java
@@ -54,7 +54,8 @@ public class StorageBackfillTest {
IScheduledTask.build(makeTask(taskId).newBuilder().setStatus(ScheduleStatus.DRAINING));
storage.write(new Storage.MutateWork.NoResult.Quiet() {
- @Override protected void execute(Storage.MutableStoreProvider storeProvider) {
+ @Override
+ protected void execute(Storage.MutableStoreProvider storeProvider) {
storeProvider.getUnsafeTaskStore().saveTasks(ImmutableSet.of(savedTask));
StorageBackfill.backfill(storeProvider, clock);
}
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/storage/backup/RecoveryTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/storage/backup/RecoveryTest.java b/src/test/java/org/apache/aurora/scheduler/storage/backup/RecoveryTest.java
index ad59e9c..b85e270 100644
--- a/src/test/java/org/apache/aurora/scheduler/storage/backup/RecoveryTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/storage/backup/RecoveryTest.java
@@ -78,7 +78,8 @@ public class RecoveryTest extends EasyMockTest {
public void setUp() {
final File backupDir = FileUtils.createTempDir();
addTearDown(new TearDown() {
- @Override public void tearDown() throws Exception {
+ @Override
+ public void tearDown() throws Exception {
org.apache.commons.io.FileUtils.deleteDirectory(backupDir);
}
});
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/storage/backup/StorageBackupTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/storage/backup/StorageBackupTest.java b/src/test/java/org/apache/aurora/scheduler/storage/backup/StorageBackupTest.java
index 7dd96fe..a07f3c9 100644
--- a/src/test/java/org/apache/aurora/scheduler/storage/backup/StorageBackupTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/storage/backup/StorageBackupTest.java
@@ -65,7 +65,8 @@ public class StorageBackupTest extends EasyMockTest {
clock = new FakeClock();
final File backupDir = FileUtils.createTempDir();
addTearDown(new TearDown() {
- @Override public void tearDown() throws Exception {
+ @Override
+ public void tearDown() throws Exception {
org.apache.commons.io.FileUtils.deleteDirectory(backupDir);
}
});
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/storage/log/LogManagerTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/storage/log/LogManagerTest.java b/src/test/java/org/apache/aurora/scheduler/storage/log/LogManagerTest.java
index 1a88dd1..040125e 100644
--- a/src/test/java/org/apache/aurora/scheduler/storage/log/LogManagerTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/storage/log/LogManagerTest.java
@@ -85,7 +85,8 @@ public class LogManagerTest extends EasyMockTest {
Amount.of(Integer.MAX_VALUE, Data.GB);
private static final Function<LogEntry, byte[]> ENCODE = new Function<LogEntry, byte[]>() {
- @Override public byte[] apply(LogEntry entry) {
+ @Override
+ public byte[] apply(LogEntry entry) {
try {
return encode(entry);
} catch (CodingException e) {
@@ -288,7 +289,8 @@ public class LogManagerTest extends EasyMockTest {
this.header = LogEntry.frame(header);
this.chunks = ImmutableList.copyOf(Iterables.transform(chunks,
new Function<Frame, LogEntry>() {
- @Override public LogEntry apply(Frame frame) {
+ @Override
+ public LogEntry apply(Frame frame) {
return LogEntry.frame(frame);
}
}));
@@ -396,7 +398,8 @@ public class LogManagerTest extends EasyMockTest {
tr1.add(op1);
Thread snapshotThread = new Thread() {
- @Override public void run() {
+ @Override
+ public void run() {
StreamTransaction tr2 = streamManager.startTransaction();
tr2.add(op2);
try {
@@ -512,7 +515,8 @@ public class LogManagerTest extends EasyMockTest {
private SaveTasks createSaveTasks(String... taskIds) {
return new SaveTasks(ImmutableSet.copyOf(Iterables.transform(ImmutableList.copyOf(taskIds),
new Function<String, ScheduledTask>() {
- @Override public ScheduledTask apply(String taskId) {
+ @Override
+ public ScheduledTask apply(String taskId) {
return new ScheduledTask().setAssignedTask(new AssignedTask().setTaskId(taskId));
}
})));