Move packages from com.twitter.common to org.apache.aurora.common Change the namespace of the forked Twitter Commons from com.twitter.common to org.apache.aurora.common. IntellJ's refactoring capability was used to do the rename.
Testing Done: ./gradlew build -Pq Bugs closed: AURORA-1442 Reviewed at https://reviews.apache.org/r/37807/ Project: http://git-wip-us.apache.org/repos/asf/aurora/repo Commit: http://git-wip-us.apache.org/repos/asf/aurora/commit/06ddaadb Tree: http://git-wip-us.apache.org/repos/asf/aurora/tree/06ddaadb Diff: http://git-wip-us.apache.org/repos/asf/aurora/diff/06ddaadb Branch: refs/heads/master Commit: 06ddaadbcba4c66b8019815de6ca27d50a9df77d Parents: 1a3ed7f Author: Zameer Manji <[email protected]> Authored: Wed Aug 26 13:59:22 2015 -0700 Committer: Zameer Manji <[email protected]> Committed: Wed Aug 26 13:59:22 2015 -0700 ---------------------------------------------------------------------- .../main/java/com/twitter/common/args/Arg.java | 126 -- .../java/com/twitter/common/args/ArgParser.java | 28 - .../java/com/twitter/common/args/CmdLine.java | 54 - .../java/com/twitter/common/args/NoParser.java | 23 - .../java/com/twitter/common/args/Parser.java | 35 - .../com/twitter/common/args/ParserOracle.java | 31 - .../com/twitter/common/args/Positional.java | 40 - .../java/com/twitter/common/args/Verifier.java | 37 - .../com/twitter/common/args/VerifierFor.java | 34 - .../common/args/apt/CmdLineProcessor.java | 677 ------- .../twitter/common/args/apt/Configuration.java | 527 ----- .../java/org/apache/aurora/common/args/Arg.java | 126 ++ .../apache/aurora/common/args/ArgParser.java | 28 + .../org/apache/aurora/common/args/CmdLine.java | 54 + .../org/apache/aurora/common/args/NoParser.java | 23 + .../org/apache/aurora/common/args/Parser.java | 35 + .../apache/aurora/common/args/ParserOracle.java | 31 + .../apache/aurora/common/args/Positional.java | 40 + .../org/apache/aurora/common/args/Verifier.java | 37 + .../apache/aurora/common/args/VerifierFor.java | 34 + .../common/args/apt/CmdLineProcessor.java | 677 +++++++ .../aurora/common/args/apt/Configuration.java | 527 +++++ .../javax.annotation.processing.Processor | 2 +- .../common/application/AbstractApplication.java | 29 - .../twitter/common/application/AppLauncher.java | 202 -- .../twitter/common/application/Application.java | 29 - .../twitter/common/application/Lifecycle.java | 94 - .../common/application/ShutdownRegistry.java | 99 - .../common/application/ShutdownStage.java | 31 - .../common/application/StartupRegistry.java | 52 - .../common/application/StartupStage.java | 31 - .../application/http/DefaultQuitHandler.java | 43 - .../common/application/http/GraphViewer.java | 50 - .../application/http/HttpAssetConfig.java | 51 - .../application/http/HttpFilterConfig.java | 39 - .../application/http/HttpServletConfig.java | 65 - .../common/application/http/Registration.java | 155 -- .../application/modules/AppLauncherModule.java | 50 - .../application/modules/LifecycleModule.java | 195 -- .../modules/LocalServiceRegistry.java | 258 --- .../common/application/modules/LogModule.java | 117 -- .../application/modules/StatsExportModule.java | 85 - .../common/application/modules/StatsModule.java | 146 -- .../application/modules/ThriftModule.java | 41 - .../com/twitter/common/args/ArgFilters.java | 125 -- .../com/twitter/common/args/ArgScanner.java | 560 ----- .../main/java/com/twitter/common/args/Args.java | 224 -- .../com/twitter/common/args/ArgumentInfo.java | 247 --- .../com/twitter/common/args/OptionInfo.java | 201 -- .../java/com/twitter/common/args/Parsers.java | 114 -- .../com/twitter/common/args/PositionalInfo.java | 116 -- .../java/com/twitter/common/args/TypeUtil.java | 120 -- .../java/com/twitter/common/args/Verifiers.java | 92 - .../common/args/constraints/CanExecute.java | 30 - .../constraints/CanExecuteFileVerifier.java | 40 - .../common/args/constraints/CanRead.java | 30 - .../args/constraints/CanReadFileVerifier.java | 40 - .../common/args/constraints/CanWrite.java | 30 - .../args/constraints/CanWriteFileVerifier.java | 40 - .../twitter/common/args/constraints/Exists.java | 30 - .../args/constraints/ExistsFileVerifier.java | 40 - .../common/args/constraints/IsDirectory.java | 30 - .../constraints/IsDirectoryFileVerifier.java | 40 - .../common/args/constraints/NotEmpty.java | 30 - .../constraints/NotEmptyIterableVerifier.java | 41 - .../constraints/NotEmptyStringVerifier.java | 39 - .../common/args/constraints/NotNegative.java | 30 - .../constraints/NotNegativeNumberVerifier.java | 39 - .../common/args/constraints/NotNull.java | 30 - .../args/constraints/NotNullVerifier.java | 39 - .../common/args/constraints/Positive.java | 30 - .../constraints/PositiveNumberVerifier.java | 39 - .../twitter/common/args/constraints/Range.java | 40 - .../args/constraints/RangeNumberVerifier.java | 74 - .../common/args/parsers/AmountParser.java | 86 - .../common/args/parsers/BooleanParser.java | 30 - .../twitter/common/args/parsers/ByteParser.java | 29 - .../common/args/parsers/CharacterParser.java | 33 - .../common/args/parsers/ClassParser.java | 48 - .../twitter/common/args/parsers/DateParser.java | 41 - .../common/args/parsers/DoubleParser.java | 29 - .../common/args/parsers/DurationParser.java | 80 - .../twitter/common/args/parsers/EnumParser.java | 36 - .../twitter/common/args/parsers/FileParser.java | 31 - .../common/args/parsers/FloatParser.java | 29 - .../args/parsers/InetSocketAddressParser.java | 32 - .../common/args/parsers/IntegerParser.java | 29 - .../twitter/common/args/parsers/ListParser.java | 52 - .../twitter/common/args/parsers/LongParser.java | 29 - .../twitter/common/args/parsers/MapParser.java | 68 - .../parsers/NonParameterizedTypeParser.java | 41 - .../common/args/parsers/NumberParser.java | 41 - .../twitter/common/args/parsers/PairParser.java | 57 - .../common/args/parsers/PatternParser.java | 35 - .../common/args/parsers/RangeParser.java | 46 - .../twitter/common/args/parsers/SetParser.java | 54 - .../common/args/parsers/ShortParser.java | 29 - .../common/args/parsers/StringParser.java | 29 - .../args/parsers/TypeParameterizedParser.java | 65 - .../twitter/common/args/parsers/URIParser.java | 36 - .../twitter/common/args/parsers/URLParser.java | 36 - .../twitter/common/args/parsers/UnitParser.java | 54 - .../twitter/common/base/CachingSupplier.java | 68 - .../base/CallableExceptionalSupplier.java | 32 - .../java/com/twitter/common/base/Closure.java | 25 - .../java/com/twitter/common/base/Closures.java | 133 -- .../java/com/twitter/common/base/Command.java | 23 - .../java/com/twitter/common/base/Commands.java | 77 - .../java/com/twitter/common/base/Either.java | 358 ---- .../common/base/ExceptionTransporter.java | 84 - .../twitter/common/base/ExceptionalClosure.java | 35 - .../twitter/common/base/ExceptionalCommand.java | 31 - .../common/base/ExceptionalFunction.java | 37 - .../common/base/ExceptionalFunctions.java | 153 -- .../common/base/ExceptionalSupplier.java | 33 - .../java/com/twitter/common/base/Function.java | 29 - .../twitter/common/base/MorePreconditions.java | 144 -- .../com/twitter/common/base/MoreSuppliers.java | 103 - .../java/com/twitter/common/base/Supplier.java | 28 - .../java/com/twitter/common/base/SupplierE.java | 25 - .../com/twitter/common/collections/Bits.java | 116 -- .../common/collections/BoundedQueue.java | 76 - .../twitter/common/collections/Iterables2.java | 148 -- .../twitter/common/collections/Multimaps.java | 134 -- .../com/twitter/common/collections/Pair.java | 127 -- .../com/twitter/common/inject/Bindings.java | 316 --- .../twitter/common/inject/DefaultProvider.java | 166 -- .../common/inject/ProviderMethodModule.java | 32 - .../twitter/common/inject/TimedInterceptor.java | 106 - .../com/twitter/common/io/Base64ZlibCodec.java | 169 -- .../main/java/com/twitter/common/io/Codec.java | 53 - .../twitter/common/io/CompatibilityCodec.java | 95 - .../java/com/twitter/common/io/FileUtils.java | 193 -- .../java/com/twitter/common/io/JsonCodec.java | 124 -- .../java/com/twitter/common/io/Streamer.java | 54 - .../java/com/twitter/common/io/ThriftCodec.java | 104 - .../com/twitter/common/logging/BufferedLog.java | 278 --- .../java/com/twitter/common/logging/Glog.java | 208 -- .../java/com/twitter/common/logging/Log.java | 45 - .../twitter/common/logging/LogFormatter.java | 80 - .../com/twitter/common/logging/LogUtil.java | 90 - .../twitter/common/logging/RootLogConfig.java | 339 ---- .../logging/julbridge/JULBridgeHandler.java | 196 -- .../julbridge/JULBridgeLevelConverter.java | 99 - .../logging/julbridge/JULBridgeLogManager.java | 87 - .../common/logging/log4j/GlogLayout.java | 100 - .../com/twitter/common/net/Environment.java | 47 - .../common/net/InetSocketAddressHelper.java | 136 -- .../com/twitter/common/net/ProxyAuthorizer.java | 41 - .../com/twitter/common/net/ProxyConfig.java | 30 - .../java/com/twitter/common/net/UrlHelper.java | 156 -- .../com/twitter/common/net/UrlResolver.java | 446 ---- .../com/twitter/common/net/UrlResolverUtil.java | 148 -- .../twitter/common/net/UrlTokenizerUtil.java | 1905 ------------------ .../common/net/http/GuiceServletConfig.java | 41 - .../common/net/http/HttpServerDispatch.java | 123 -- .../net/http/JettyHttpServerDispatch.java | 283 --- .../twitter/common/net/http/RequestLogger.java | 130 -- .../net/http/filters/AbstractHttpFilter.java | 63 - .../net/http/filters/HttpStatsFilter.java | 158 -- .../common/net/http/handlers/AbortHandler.java | 71 - .../common/net/http/handlers/AssetHandler.java | 189 -- .../net/http/handlers/ContentionPrinter.java | 88 - .../common/net/http/handlers/HealthHandler.java | 82 - .../http/handlers/HttpServletRequestParams.java | 87 - .../common/net/http/handlers/LogConfig.java | 132 -- .../common/net/http/handlers/LogPrinter.java | 427 ---- .../common/net/http/handlers/QuitHandler.java | 71 - .../http/handlers/StringTemplateServlet.java | 96 - .../net/http/handlers/TextResponseHandler.java | 58 - .../net/http/handlers/ThreadStackPrinter.java | 41 - .../common/net/http/handlers/ThriftServlet.java | 70 - .../net/http/handlers/TimeSeriesDataSource.java | 134 -- .../common/net/http/handlers/VarsHandler.java | 61 - .../net/http/handlers/VarsJsonHandler.java | 90 - .../loadbalancing/LeastConnectedStrategy.java | 170 -- .../common/net/loadbalancing/LoadBalancer.java | 76 - .../net/loadbalancing/LoadBalancerImpl.java | 122 -- .../loadbalancing/LoadBalancingStrategy.java | 80 - .../net/loadbalancing/MarkDeadStrategy.java | 221 -- .../MarkDeadStrategyWithHostCheck.java | 98 - .../net/loadbalancing/RandomStrategy.java | 57 - .../net/loadbalancing/RequestTracker.java | 37 - .../net/loadbalancing/RoundRobinStrategy.java | 49 - .../StaticLoadBalancingStrategy.java | 61 - .../net/loadbalancing/SubsetStrategy.java | 89 - .../loadbalancing/TrafficMonitorAdapter.java | 68 - .../net/monitoring/ConnectionMonitor.java | 36 - .../common/net/monitoring/TrafficMonitor.java | 259 --- .../com/twitter/common/net/pool/Connection.java | 48 - .../common/net/pool/ConnectionFactory.java | 56 - .../twitter/common/net/pool/ConnectionPool.java | 334 --- .../twitter/common/net/pool/DynamicHostSet.java | 76 - .../common/net/pool/DynamicHostSetUtil.java | 49 - .../twitter/common/net/pool/DynamicPool.java | 169 -- .../com/twitter/common/net/pool/MetaPool.java | 340 ---- .../com/twitter/common/net/pool/ObjectPool.java | 82 - .../net/pool/ResourceExhaustedException.java | 27 - .../common/objectsize/ObjectSizeCalculator.java | 427 ---- .../com/twitter/common/quantity/Amount.java | 208 -- .../java/com/twitter/common/quantity/Data.java | 51 - .../java/com/twitter/common/quantity/Time.java | 62 - .../java/com/twitter/common/quantity/Unit.java | 33 - .../common/stats/ApproximateHistogram.java | 563 ------ .../com/twitter/common/stats/CounterMap.java | 138 -- .../common/stats/CounterMapWithTopKey.java | 89 - .../java/com/twitter/common/stats/Elapsed.java | 83 - .../java/com/twitter/common/stats/Entropy.java | 51 - .../com/twitter/common/stats/Histogram.java | 43 - .../com/twitter/common/stats/Histograms.java | 39 - .../java/com/twitter/common/stats/JvmStats.java | 240 --- .../com/twitter/common/stats/MovingAverage.java | 68 - .../twitter/common/stats/MovingWindowDelta.java | 97 - .../common/stats/NumericStatExporter.java | 125 -- .../com/twitter/common/stats/Percentile.java | 198 -- .../com/twitter/common/stats/PipelineStats.java | 134 -- .../com/twitter/common/stats/Precision.java | 50 - .../common/stats/PrintableHistogram.java | 90 - .../java/com/twitter/common/stats/Rate.java | 146 -- .../java/com/twitter/common/stats/Ratio.java | 98 - .../com/twitter/common/stats/RecordingStat.java | 33 - .../twitter/common/stats/RecordingStatImpl.java | 46 - .../com/twitter/common/stats/RequestStats.java | 142 -- .../twitter/common/stats/ReservoirSampler.java | 97 - .../com/twitter/common/stats/SampledStat.java | 43 - .../com/twitter/common/stats/Significance.java | 59 - .../com/twitter/common/stats/SlidingStats.java | 93 - .../java/com/twitter/common/stats/Stat.java | 37 - .../java/com/twitter/common/stats/StatImpl.java | 35 - .../com/twitter/common/stats/StatRegistry.java | 29 - .../com/twitter/common/stats/Statistics.java | 93 - .../common/stats/StatisticsInterface.java | 70 - .../java/com/twitter/common/stats/Stats.java | 408 ---- .../com/twitter/common/stats/StatsProvider.java | 88 - .../com/twitter/common/stats/TimeSeries.java | 38 - .../common/stats/TimeSeriesRepository.java | 57 - .../common/stats/TimeSeriesRepositoryImpl.java | 197 -- .../java/com/twitter/common/stats/Windowed.java | 136 -- .../common/stats/WindowedApproxHistogram.java | 153 -- .../twitter/common/stats/WindowedHistogram.java | 110 - .../common/stats/WindowedStatistics.java | 173 -- .../common/stats/testing/RealHistogram.java | 42 - .../common/testing/TearDownRegistry.java | 51 - .../common/testing/easymock/EasyMockTest.java | 121 -- .../common/testing/easymock/IterableEquals.java | 90 - .../common/testing/junit/rules/Retry.java | 158 -- .../common/testing/mockito/MockitoTest.java | 31 - .../java/com/twitter/common/thrift/Config.java | 302 --- .../thrift/TResourceExhaustedException.java | 39 - .../common/thrift/TTimeoutException.java | 38 - .../common/thrift/TTransportConnection.java | 70 - .../java/com/twitter/common/thrift/Thrift.java | 390 ---- .../common/thrift/ThriftConnectionFactory.java | 366 ---- .../twitter/common/thrift/ThriftException.java | 26 - .../twitter/common/thrift/ThriftFactory.java | 654 ------ .../java/com/twitter/common/thrift/Util.java | 234 --- .../twitter/common/thrift/callers/Caller.java | 99 - .../common/thrift/callers/CallerDecorator.java | 78 - .../common/thrift/callers/DeadlineCaller.java | 93 - .../common/thrift/callers/DebugCaller.java | 73 - .../common/thrift/callers/RetryingCaller.java | 224 -- .../thrift/callers/StatTrackingCaller.java | 103 - .../common/thrift/callers/ThriftCaller.java | 157 -- .../TMonitoredNonblockingServerSocket.java | 80 - .../thrift/monitoring/TMonitoredProcessor.java | 62 - .../monitoring/TMonitoredServerSocket.java | 111 - .../common/thrift/testing/MockTSocket.java | 45 - .../common/thrift/testing/TestThriftTypes.java | 171 -- .../com/twitter/common/util/BackoffDecider.java | 663 ------ .../com/twitter/common/util/BackoffHelper.java | 152 -- .../twitter/common/util/BackoffStrategy.java | 37 - .../java/com/twitter/common/util/BuildInfo.java | 108 - .../java/com/twitter/common/util/Clock.java | 70 - .../twitter/common/util/CommandExecutor.java | 42 - .../java/com/twitter/common/util/DateUtils.java | 57 - .../java/com/twitter/common/util/FileUtils.java | 51 - .../com/twitter/common/util/LowResClock.java | 108 - .../com/twitter/common/util/ParsingUtil.java | 53 - .../com/twitter/common/util/QueueDrainer.java | 53 - .../java/com/twitter/common/util/Random.java | 78 - .../twitter/common/util/RangeNormalizer.java | 88 - .../common/util/RateLimitedCommandExecutor.java | 90 - .../twitter/common/util/RetryingRunnable.java | 131 -- .../java/com/twitter/common/util/Sampler.java | 54 - .../com/twitter/common/util/StartWatch.java | 48 - .../main/java/com/twitter/common/util/Stat.java | 351 ---- .../com/twitter/common/util/StateMachine.java | 583 ------ .../java/com/twitter/common/util/Timer.java | 71 - .../common/util/TruncatedBinaryBackoff.java | 74 - .../com/twitter/common/util/caching/Cache.java | 46 - .../common/util/caching/CachingMethodProxy.java | 262 --- .../twitter/common/util/caching/LRUCache.java | 170 -- .../util/concurrent/BackingOffFutureTask.java | 56 - .../ExceptionHandlingExecutorService.java | 94 - ...ceptionHandlingScheduledExecutorService.java | 121 -- .../concurrent/ExecutorServiceShutdown.java | 71 - .../concurrent/ForwardingExecutorService.java | 101 - .../common/util/concurrent/MoreExecutors.java | 122 -- .../util/concurrent/RetryingFutureTask.java | 81 - .../common/util/concurrent/TaskConverter.java | 93 - .../logging/ResourceLoggingConfigurator.java | 49 - .../util/logging/UnresettableLogManager.java | 48 - .../util/templating/StringTemplateHelper.java | 96 - .../twitter/common/util/testing/FakeClock.java | 78 - .../twitter/common/util/testing/FakeTicker.java | 69 - .../webassets/bootstrap/BootstrapModule.java | 90 - .../common/webassets/jquery/JQueryModule.java | 36 - .../com/twitter/common/zookeeper/Candidate.java | 79 - .../twitter/common/zookeeper/CandidateImpl.java | 181 -- .../common/zookeeper/CompoundServerSet.java | 224 -- .../common/zookeeper/DistributedLock.java | 39 - .../common/zookeeper/DistributedLockImpl.java | 286 --- .../com/twitter/common/zookeeper/Group.java | 708 ------- .../twitter/common/zookeeper/Partitioner.java | 172 -- .../com/twitter/common/zookeeper/ServerSet.java | 114 -- .../twitter/common/zookeeper/ServerSetImpl.java | 606 ------ .../twitter/common/zookeeper/ServerSets.java | 148 -- .../common/zookeeper/SingletonService.java | 315 --- .../common/zookeeper/StaticServerSet.java | 145 -- .../common/zookeeper/ZooKeeperClient.java | 493 ----- .../twitter/common/zookeeper/ZooKeeperMap.java | 411 ---- .../twitter/common/zookeeper/ZooKeeperNode.java | 349 ---- .../common/zookeeper/ZooKeeperUtils.java | 167 -- .../common/zookeeper/guice/ServerSetModule.java | 270 --- .../guice/client/ZooKeeperClientModule.java | 235 --- .../client/flagged/FlaggedClientConfig.java | 82 - .../zookeeper/testing/BaseZooKeeperTest.java | 154 -- .../zookeeper/testing/ZooKeeperTestServer.java | 222 -- .../common/application/AbstractApplication.java | 29 + .../aurora/common/application/AppLauncher.java | 202 ++ .../aurora/common/application/Application.java | 29 + .../aurora/common/application/Lifecycle.java | 94 + .../common/application/ShutdownRegistry.java | 99 + .../common/application/ShutdownStage.java | 31 + .../common/application/StartupRegistry.java | 52 + .../aurora/common/application/StartupStage.java | 31 + .../application/http/DefaultQuitHandler.java | 43 + .../common/application/http/GraphViewer.java | 50 + .../application/http/HttpAssetConfig.java | 51 + .../application/http/HttpFilterConfig.java | 39 + .../application/http/HttpServletConfig.java | 65 + .../common/application/http/Registration.java | 155 ++ .../application/modules/AppLauncherModule.java | 52 + .../application/modules/LifecycleModule.java | 194 ++ .../modules/LocalServiceRegistry.java | 258 +++ .../common/application/modules/LogModule.java | 117 ++ .../application/modules/StatsExportModule.java | 85 + .../common/application/modules/StatsModule.java | 146 ++ .../application/modules/ThriftModule.java | 41 + .../apache/aurora/common/args/ArgFilters.java | 125 ++ .../apache/aurora/common/args/ArgScanner.java | 560 +++++ .../org/apache/aurora/common/args/Args.java | 224 ++ .../apache/aurora/common/args/ArgumentInfo.java | 247 +++ .../apache/aurora/common/args/OptionInfo.java | 201 ++ .../org/apache/aurora/common/args/Parsers.java | 114 ++ .../aurora/common/args/PositionalInfo.java | 116 ++ .../org/apache/aurora/common/args/TypeUtil.java | 120 ++ .../apache/aurora/common/args/Verifiers.java | 89 + .../common/args/constraints/CanExecute.java | 30 + .../constraints/CanExecuteFileVerifier.java | 40 + .../aurora/common/args/constraints/CanRead.java | 30 + .../args/constraints/CanReadFileVerifier.java | 40 + .../common/args/constraints/CanWrite.java | 30 + .../args/constraints/CanWriteFileVerifier.java | 40 + .../aurora/common/args/constraints/Exists.java | 30 + .../args/constraints/ExistsFileVerifier.java | 40 + .../common/args/constraints/IsDirectory.java | 30 + .../constraints/IsDirectoryFileVerifier.java | 40 + .../common/args/constraints/NotEmpty.java | 30 + .../constraints/NotEmptyIterableVerifier.java | 41 + .../constraints/NotEmptyStringVerifier.java | 39 + .../common/args/constraints/NotNegative.java | 30 + .../constraints/NotNegativeNumberVerifier.java | 39 + .../aurora/common/args/constraints/NotNull.java | 30 + .../args/constraints/NotNullVerifier.java | 39 + .../common/args/constraints/Positive.java | 30 + .../constraints/PositiveNumberVerifier.java | 39 + .../aurora/common/args/constraints/Range.java | 40 + .../args/constraints/RangeNumberVerifier.java | 74 + .../common/args/parsers/AmountParser.java | 86 + .../common/args/parsers/BooleanParser.java | 30 + .../aurora/common/args/parsers/ByteParser.java | 29 + .../common/args/parsers/CharacterParser.java | 33 + .../aurora/common/args/parsers/ClassParser.java | 48 + .../aurora/common/args/parsers/DateParser.java | 41 + .../common/args/parsers/DoubleParser.java | 29 + .../common/args/parsers/DurationParser.java | 80 + .../aurora/common/args/parsers/EnumParser.java | 36 + .../aurora/common/args/parsers/FileParser.java | 31 + .../aurora/common/args/parsers/FloatParser.java | 29 + .../args/parsers/InetSocketAddressParser.java | 32 + .../common/args/parsers/IntegerParser.java | 29 + .../aurora/common/args/parsers/ListParser.java | 52 + .../aurora/common/args/parsers/LongParser.java | 29 + .../aurora/common/args/parsers/MapParser.java | 68 + .../parsers/NonParameterizedTypeParser.java | 41 + .../common/args/parsers/NumberParser.java | 41 + .../aurora/common/args/parsers/PairParser.java | 57 + .../common/args/parsers/PatternParser.java | 35 + .../aurora/common/args/parsers/RangeParser.java | 46 + .../aurora/common/args/parsers/SetParser.java | 54 + .../aurora/common/args/parsers/ShortParser.java | 29 + .../common/args/parsers/StringParser.java | 29 + .../args/parsers/TypeParameterizedParser.java | 65 + .../aurora/common/args/parsers/URIParser.java | 36 + .../aurora/common/args/parsers/URLParser.java | 36 + .../aurora/common/args/parsers/UnitParser.java | 54 + .../aurora/common/base/CachingSupplier.java | 68 + .../base/CallableExceptionalSupplier.java | 32 + .../org/apache/aurora/common/base/Closure.java | 25 + .../org/apache/aurora/common/base/Closures.java | 133 ++ .../org/apache/aurora/common/base/Command.java | 23 + .../org/apache/aurora/common/base/Commands.java | 77 + .../org/apache/aurora/common/base/Either.java | 358 ++++ .../common/base/ExceptionTransporter.java | 84 + .../aurora/common/base/ExceptionalClosure.java | 35 + .../aurora/common/base/ExceptionalCommand.java | 31 + .../aurora/common/base/ExceptionalFunction.java | 37 + .../common/base/ExceptionalFunctions.java | 153 ++ .../aurora/common/base/ExceptionalSupplier.java | 33 + .../org/apache/aurora/common/base/Function.java | 29 + .../aurora/common/base/MorePreconditions.java | 144 ++ .../aurora/common/base/MoreSuppliers.java | 103 + .../org/apache/aurora/common/base/Supplier.java | 28 + .../apache/aurora/common/base/SupplierE.java | 25 + .../apache/aurora/common/collections/Bits.java | 116 ++ .../aurora/common/collections/BoundedQueue.java | 76 + .../aurora/common/collections/Iterables2.java | 148 ++ .../aurora/common/collections/Multimaps.java | 134 ++ .../apache/aurora/common/collections/Pair.java | 127 ++ .../webassets/bootstrap/BootstrapModule.java | 90 + .../common/webassets/jquery/JQueryModule.java | 36 + .../apache/aurora/common/inject/Bindings.java | 316 +++ .../aurora/common/inject/DefaultProvider.java | 166 ++ .../common/inject/ProviderMethodModule.java | 32 + .../aurora/common/inject/TimedInterceptor.java | 106 + .../aurora/common/io/Base64ZlibCodec.java | 169 ++ .../java/org/apache/aurora/common/io/Codec.java | 53 + .../aurora/common/io/CompatibilityCodec.java | 95 + .../org/apache/aurora/common/io/FileUtils.java | 193 ++ .../org/apache/aurora/common/io/JsonCodec.java | 124 ++ .../org/apache/aurora/common/io/Streamer.java | 54 + .../apache/aurora/common/io/ThriftCodec.java | 104 + .../aurora/common/logging/BufferedLog.java | 278 +++ .../org/apache/aurora/common/logging/Glog.java | 208 ++ .../org/apache/aurora/common/logging/Log.java | 45 + .../aurora/common/logging/LogFormatter.java | 80 + .../apache/aurora/common/logging/LogUtil.java | 90 + .../aurora/common/logging/RootLogConfig.java | 339 ++++ .../logging/julbridge/JULBridgeHandler.java | 196 ++ .../julbridge/JULBridgeLevelConverter.java | 99 + .../logging/julbridge/JULBridgeLogManager.java | 87 + .../aurora/common/logging/log4j/GlogLayout.java | 98 + .../apache/aurora/common/net/Environment.java | 47 + .../common/net/InetSocketAddressHelper.java | 136 ++ .../aurora/common/net/ProxyAuthorizer.java | 41 + .../apache/aurora/common/net/ProxyConfig.java | 30 + .../org/apache/aurora/common/net/UrlHelper.java | 156 ++ .../apache/aurora/common/net/UrlResolver.java | 446 ++++ .../aurora/common/net/UrlResolverUtil.java | 148 ++ .../aurora/common/net/UrlTokenizerUtil.java | 1905 ++++++++++++++++++ .../common/net/http/GuiceServletConfig.java | 41 + .../common/net/http/HttpServerDispatch.java | 123 ++ .../net/http/JettyHttpServerDispatch.java | 283 +++ .../aurora/common/net/http/RequestLogger.java | 130 ++ .../net/http/filters/AbstractHttpFilter.java | 63 + .../net/http/filters/HttpStatsFilter.java | 158 ++ .../common/net/http/handlers/AbortHandler.java | 71 + .../common/net/http/handlers/AssetHandler.java | 189 ++ .../net/http/handlers/ContentionPrinter.java | 88 + .../common/net/http/handlers/HealthHandler.java | 82 + .../http/handlers/HttpServletRequestParams.java | 87 + .../common/net/http/handlers/LogConfig.java | 132 ++ .../common/net/http/handlers/LogPrinter.java | 427 ++++ .../common/net/http/handlers/QuitHandler.java | 71 + .../http/handlers/StringTemplateServlet.java | 96 + .../net/http/handlers/TextResponseHandler.java | 58 + .../net/http/handlers/ThreadStackPrinter.java | 41 + .../common/net/http/handlers/ThriftServlet.java | 70 + .../net/http/handlers/TimeSeriesDataSource.java | 134 ++ .../common/net/http/handlers/VarsHandler.java | 61 + .../net/http/handlers/VarsJsonHandler.java | 90 + .../loadbalancing/LeastConnectedStrategy.java | 170 ++ .../common/net/loadbalancing/LoadBalancer.java | 76 + .../net/loadbalancing/LoadBalancerImpl.java | 122 ++ .../loadbalancing/LoadBalancingStrategy.java | 79 + .../net/loadbalancing/MarkDeadStrategy.java | 220 ++ .../MarkDeadStrategyWithHostCheck.java | 98 + .../net/loadbalancing/RandomStrategy.java | 57 + .../net/loadbalancing/RequestTracker.java | 37 + .../net/loadbalancing/RoundRobinStrategy.java | 49 + .../StaticLoadBalancingStrategy.java | 61 + .../net/loadbalancing/SubsetStrategy.java | 89 + .../loadbalancing/TrafficMonitorAdapter.java | 68 + .../net/monitoring/ConnectionMonitor.java | 36 + .../common/net/monitoring/TrafficMonitor.java | 259 +++ .../aurora/common/net/pool/Connection.java | 48 + .../common/net/pool/ConnectionFactory.java | 56 + .../aurora/common/net/pool/ConnectionPool.java | 334 +++ .../aurora/common/net/pool/DynamicHostSet.java | 76 + .../common/net/pool/DynamicHostSetUtil.java | 46 + .../aurora/common/net/pool/DynamicPool.java | 170 ++ .../apache/aurora/common/net/pool/MetaPool.java | 339 ++++ .../aurora/common/net/pool/ObjectPool.java | 82 + .../net/pool/ResourceExhaustedException.java | 27 + .../common/objectsize/ObjectSizeCalculator.java | 427 ++++ .../apache/aurora/common/quantity/Amount.java | 208 ++ .../org/apache/aurora/common/quantity/Data.java | 51 + .../org/apache/aurora/common/quantity/Time.java | 62 + .../org/apache/aurora/common/quantity/Unit.java | 33 + .../common/stats/ApproximateHistogram.java | 563 ++++++ .../apache/aurora/common/stats/CounterMap.java | 138 ++ .../common/stats/CounterMapWithTopKey.java | 89 + .../org/apache/aurora/common/stats/Elapsed.java | 81 + .../org/apache/aurora/common/stats/Entropy.java | 51 + .../apache/aurora/common/stats/Histogram.java | 43 + .../apache/aurora/common/stats/Histograms.java | 39 + .../apache/aurora/common/stats/JvmStats.java | 240 +++ .../aurora/common/stats/MovingAverage.java | 68 + .../aurora/common/stats/MovingWindowDelta.java | 96 + .../common/stats/NumericStatExporter.java | 125 ++ .../apache/aurora/common/stats/Percentile.java | 198 ++ .../aurora/common/stats/PipelineStats.java | 134 ++ .../apache/aurora/common/stats/Precision.java | 50 + .../aurora/common/stats/PrintableHistogram.java | 90 + .../org/apache/aurora/common/stats/Rate.java | 145 ++ .../org/apache/aurora/common/stats/Ratio.java | 98 + .../aurora/common/stats/RecordingStat.java | 33 + .../aurora/common/stats/RecordingStatImpl.java | 46 + .../aurora/common/stats/RequestStats.java | 140 ++ .../aurora/common/stats/ReservoirSampler.java | 97 + .../apache/aurora/common/stats/SampledStat.java | 43 + .../aurora/common/stats/Significance.java | 59 + .../aurora/common/stats/SlidingStats.java | 93 + .../org/apache/aurora/common/stats/Stat.java | 37 + .../apache/aurora/common/stats/StatImpl.java | 35 + .../aurora/common/stats/StatRegistry.java | 29 + .../apache/aurora/common/stats/Statistics.java | 93 + .../common/stats/StatisticsInterface.java | 70 + .../org/apache/aurora/common/stats/Stats.java | 408 ++++ .../aurora/common/stats/StatsProvider.java | 88 + .../apache/aurora/common/stats/TimeSeries.java | 38 + .../common/stats/TimeSeriesRepository.java | 57 + .../common/stats/TimeSeriesRepositoryImpl.java | 197 ++ .../apache/aurora/common/stats/Windowed.java | 136 ++ .../common/stats/WindowedApproxHistogram.java | 153 ++ .../aurora/common/stats/WindowedHistogram.java | 110 + .../aurora/common/stats/WindowedStatistics.java | 173 ++ .../common/stats/testing/RealHistogram.java | 42 + .../aurora/common/testing/TearDownRegistry.java | 51 + .../common/testing/easymock/EasyMockTest.java | 121 ++ .../common/testing/easymock/IterableEquals.java | 90 + .../common/testing/junit/rules/Retry.java | 158 ++ .../common/testing/mockito/MockitoTest.java | 31 + .../org/apache/aurora/common/thrift/Config.java | 302 +++ .../thrift/TResourceExhaustedException.java | 39 + .../aurora/common/thrift/TTimeoutException.java | 38 + .../common/thrift/TTransportConnection.java | 70 + .../org/apache/aurora/common/thrift/Thrift.java | 390 ++++ .../common/thrift/ThriftConnectionFactory.java | 366 ++++ .../aurora/common/thrift/ThriftException.java | 26 + .../aurora/common/thrift/ThriftFactory.java | 653 ++++++ .../org/apache/aurora/common/thrift/Util.java | 231 +++ .../aurora/common/thrift/callers/Caller.java | 99 + .../common/thrift/callers/CallerDecorator.java | 78 + .../common/thrift/callers/DeadlineCaller.java | 93 + .../common/thrift/callers/DebugCaller.java | 73 + .../common/thrift/callers/RetryingCaller.java | 224 ++ .../thrift/callers/StatTrackingCaller.java | 103 + .../common/thrift/callers/ThriftCaller.java | 157 ++ .../TMonitoredNonblockingServerSocket.java | 80 + .../thrift/monitoring/TMonitoredProcessor.java | 62 + .../monitoring/TMonitoredServerSocket.java | 111 + .../common/thrift/testing/MockTSocket.java | 45 + .../common/thrift/testing/TestThriftTypes.java | 171 ++ .../aurora/common/util/BackoffDecider.java | 663 ++++++ .../aurora/common/util/BackoffHelper.java | 152 ++ .../aurora/common/util/BackoffStrategy.java | 37 + .../apache/aurora/common/util/BuildInfo.java | 108 + .../org/apache/aurora/common/util/Clock.java | 70 + .../aurora/common/util/CommandExecutor.java | 42 + .../apache/aurora/common/util/DateUtils.java | 57 + .../apache/aurora/common/util/FileUtils.java | 51 + .../apache/aurora/common/util/LowResClock.java | 108 + .../apache/aurora/common/util/ParsingUtil.java | 53 + .../apache/aurora/common/util/QueueDrainer.java | 53 + .../org/apache/aurora/common/util/Random.java | 78 + .../aurora/common/util/RangeNormalizer.java | 88 + .../common/util/RateLimitedCommandExecutor.java | 88 + .../aurora/common/util/RetryingRunnable.java | 131 ++ .../org/apache/aurora/common/util/Sampler.java | 54 + .../apache/aurora/common/util/StartWatch.java | 48 + .../org/apache/aurora/common/util/Stat.java | 351 ++++ .../apache/aurora/common/util/StateMachine.java | 583 ++++++ .../org/apache/aurora/common/util/Timer.java | 71 + .../common/util/TruncatedBinaryBackoff.java | 74 + .../aurora/common/util/caching/Cache.java | 46 + .../common/util/caching/CachingMethodProxy.java | 262 +++ .../aurora/common/util/caching/LRUCache.java | 170 ++ .../util/concurrent/BackingOffFutureTask.java | 56 + .../ExceptionHandlingExecutorService.java | 91 + ...ceptionHandlingScheduledExecutorService.java | 118 ++ .../concurrent/ExecutorServiceShutdown.java | 71 + .../concurrent/ForwardingExecutorService.java | 101 + .../common/util/concurrent/MoreExecutors.java | 122 ++ .../util/concurrent/RetryingFutureTask.java | 81 + .../common/util/concurrent/TaskConverter.java | 93 + .../logging/ResourceLoggingConfigurator.java | 49 + .../util/logging/UnresettableLogManager.java | 48 + .../util/templating/StringTemplateHelper.java | 96 + .../aurora/common/util/testing/FakeClock.java | 78 + .../aurora/common/util/testing/FakeTicker.java | 65 + .../aurora/common/zookeeper/Candidate.java | 79 + .../aurora/common/zookeeper/CandidateImpl.java | 181 ++ .../common/zookeeper/CompoundServerSet.java | 224 ++ .../common/zookeeper/DistributedLock.java | 39 + .../common/zookeeper/DistributedLockImpl.java | 286 +++ .../apache/aurora/common/zookeeper/Group.java | 708 +++++++ .../aurora/common/zookeeper/Partitioner.java | 172 ++ .../aurora/common/zookeeper/ServerSet.java | 114 ++ .../aurora/common/zookeeper/ServerSetImpl.java | 602 ++++++ .../aurora/common/zookeeper/ServerSets.java | 148 ++ .../common/zookeeper/SingletonService.java | 314 +++ .../common/zookeeper/StaticServerSet.java | 145 ++ .../common/zookeeper/ZooKeeperClient.java | 491 +++++ .../aurora/common/zookeeper/ZooKeeperMap.java | 411 ++++ .../aurora/common/zookeeper/ZooKeeperNode.java | 349 ++++ .../aurora/common/zookeeper/ZooKeeperUtils.java | 167 ++ .../common/zookeeper/guice/ServerSetModule.java | 267 +++ .../guice/client/ZooKeeperClientModule.java | 235 +++ .../client/flagged/FlaggedClientConfig.java | 82 + .../zookeeper/testing/BaseZooKeeperTest.java | 152 ++ .../zookeeper/testing/ZooKeeperTestServer.java | 221 ++ .../http/graphview/dygraph-combined.js | 14 - .../application/http/graphview/dygraph-extra.js | 367 ---- .../application/http/graphview/grapher.js | 365 ---- .../application/http/graphview/graphview.html | 84 - .../common/application/http/graphview/parser.js | 337 ---- .../common/net/http/handlers/logconfig.st | 44 - .../common/net/http/handlers/logprinter.st | 180 -- .../twitter/common/net/http/handlers/thrift.st | 64 - .../2.1.1/css/bootstrap-responsive.min.css | 14 - .../bootstrap/2.1.1/css/bootstrap.min.css | 14 - .../2.1.1/img/glyphicons-halflings-white.png | Bin 8777 -> 0 bytes .../2.1.1/img/glyphicons-halflings.png | Bin 12799 -> 0 bytes .../bootstrap/2.1.1/js/bootstrap.min.js | 19 - .../2.3.2/css/bootstrap-responsive.min.css | 14 - .../bootstrap/2.3.2/css/bootstrap.min.css | 14 - .../2.3.2/img/glyphicons-halflings-white.png | Bin 8777 -> 0 bytes .../2.3.2/img/glyphicons-halflings.png | Bin 12799 -> 0 bytes .../bootstrap/2.3.2/js/bootstrap.min.js | 19 - .../webassets/jquery/js/jquery-1.8.2.min.js | 15 - .../http/graphview/dygraph-combined.js | 14 + .../application/http/graphview/dygraph-extra.js | 367 ++++ .../application/http/graphview/grapher.js | 365 ++++ .../application/http/graphview/graphview.html | 84 + .../common/application/http/graphview/parser.js | 337 ++++ .../2.1.1/css/bootstrap-responsive.min.css | 14 + .../bootstrap/2.1.1/css/bootstrap.min.css | 14 + .../2.1.1/img/glyphicons-halflings-white.png | Bin 0 -> 8777 bytes .../2.1.1/img/glyphicons-halflings.png | Bin 0 -> 12799 bytes .../bootstrap/2.1.1/js/bootstrap.min.js | 19 + .../2.3.2/css/bootstrap-responsive.min.css | 14 + .../bootstrap/2.3.2/css/bootstrap.min.css | 14 + .../2.3.2/img/glyphicons-halflings-white.png | Bin 0 -> 8777 bytes .../2.3.2/img/glyphicons-halflings.png | Bin 0 -> 12799 bytes .../bootstrap/2.3.2/js/bootstrap.min.js | 19 + .../webassets/jquery/js/jquery-1.8.2.min.js | 15 + .../common/net/http/handlers/logconfig.st | 44 + .../common/net/http/handlers/logprinter.st | 180 ++ .../aurora/common/net/http/handlers/thrift.st | 64 + .../thrift/com/twitter/thrift/endpoint.thrift | 99 - .../apache/aurora/common/thrift/endpoint.thrift | 90 + .../common/application/AppLauncherTest.java | 74 - .../modules/LifecycleModuleTest.java | 137 -- .../modules/LocalServiceRegistryTest.java | 170 -- .../modules/StartStatPollerTest.java | 63 - .../com/twitter/common/args/ArgFiltersTest.java | 105 - .../com/twitter/common/args/ArgScannerTest.java | 848 -------- .../java/com/twitter/common/args/ArgTest.java | 34 - .../java/com/twitter/common/args/ArgsTest.java | 73 - .../com/twitter/common/args/OptionInfoTest.java | 108 - .../com/twitter/common/args/ParsersTest.java | 81 - .../common/args/argfilterstest/ArgsRoot.java | 29 - .../args/argfilterstest/subpackageA/ArgsA.java | 29 - .../subpackageA/subsubpackage1/ArgsA1.java | 29 - .../args/argfilterstest/subpackageB/ArgsB.java | 29 - .../subpackageBwithSuffix/ArgsBWithSuffix.java | 29 - .../common/base/CachingSupplierTest.java | 64 - .../com/twitter/common/base/ClosuresTest.java | 173 -- .../com/twitter/common/base/CommandsTest.java | 84 - .../com/twitter/common/base/EitherTest.java | 266 --- .../common/base/ExceptionTransporterTest.java | 57 - .../common/base/ExceptionalFunctionsTest.java | 166 -- .../common/base/MorePreconditionsTest.java | 100 - .../twitter/common/base/MoreSuppliersTest.java | 107 - .../twitter/common/collections/BitsTest.java | 299 --- .../common/collections/BoundedQueueTest.java | 57 - .../common/collections/Iterables2Test.java | 107 - .../twitter/common/collections/PairTest.java | 50 - .../com/twitter/common/inject/BindingsTest.java | 141 -- .../common/inject/DefaultProviderTest.java | 65 - .../twitter/common/io/Base64ZlibCodecTest.java | 94 - .../twitter/common/io/CodecTestUtilities.java | 34 - .../common/io/CompatibilityCodecTest.java | 101 - .../com/twitter/common/io/FileUtilsTest.java | 122 -- .../com/twitter/common/io/JsonCodecTest.java | 105 - .../com/twitter/common/io/ThriftCodecTest.java | 54 - .../twitter/common/logging/BufferedLogTest.java | 141 -- .../common/logging/LogFormatterTest.java | 72 - .../com/twitter/common/logging/LogUtilTest.java | 61 - .../common/logging/RootLogConfigTest.java | 333 --- .../logging/julbridge/JULBridgeHandlerTest.java | 97 - .../julbridge/JULBridgeLevelConverterTest.java | 96 - .../julbridge/JULBridgeLogManagerTest.java | 75 - .../common/net/InetSocketAddressHelperTest.java | 111 - .../com/twitter/common/net/UrlHelperTest.java | 120 -- .../com/twitter/common/net/UrlResolverTest.java | 171 -- .../twitter/common/net/UrlResolverUtilTest.java | 162 -- .../common/net/UrlTokenizerUtilTest.java | 94 - .../common/net/http/RequestLoggerTest.java | 103 - .../filters/HttpStatsFilterIntegrationTest.java | 166 -- .../net/http/filters/HttpStatsFilterTest.java | 227 --- .../net/http/handlers/AssetHandlerTest.java | 380 ---- .../handlers/HttpServletRequestParamsTest.java | 82 - .../net/http/handlers/LogPrinterTest.java | 87 - .../net/http/handlers/StatSupplierTestBase.java | 52 - .../http/handlers/TimeSeriesDataSourceTest.java | 156 -- .../net/http/handlers/VarsHandlerTest.java | 78 - .../net/http/handlers/VarsJsonHandlerTest.java | 73 - .../LeastConnectedStrategyTest.java | 286 --- .../net/loadbalancing/LoadBalancerImplTest.java | 141 -- .../net/loadbalancing/MarkDeadStrategyTest.java | 332 --- .../MarkDeadStrategyWithHostCheckTest.java | 146 -- .../net/loadbalancing/RandomStrategyTest.java | 96 - .../loadbalancing/RoundRobinStrategyTest.java | 104 - .../net/loadbalancing/SubsetStrategyTest.java | 98 - .../net/monitoring/TrafficMonitorTest.java | 122 -- .../common/net/pool/ConnectionPoolTest.java | 255 --- .../common/net/pool/DynamicHostSetUtilTest.java | 58 - .../common/net/pool/DynamicPoolTest.java | 168 -- .../objectsize/ObjectSizeCalculatorTest.java | 213 -- .../com/twitter/common/quantity/AmountTest.java | 117 -- .../common/stats/ApproximateHistogramTest.java | 322 --- .../com/twitter/common/stats/ElapsedTest.java | 83 - .../com/twitter/common/stats/EntropyTest.java | 58 - .../common/stats/MergedHistogramTest.java | 94 - .../twitter/common/stats/MovingAverageTest.java | 83 - .../common/stats/MovingWindowDeltaTest.java | 100 - .../common/stats/NumericStatExporterTest.java | 144 -- .../twitter/common/stats/PercentileTest.java | 204 -- .../twitter/common/stats/PipelineStatsTest.java | 147 -- .../common/stats/PrintableHistogramTest.java | 27 - .../java/com/twitter/common/stats/RateTest.java | 239 --- .../common/stats/ReservoirSamplerTest.java | 76 - .../twitter/common/stats/StatisticsTest.java | 116 -- .../com/twitter/common/stats/StatsTest.java | 110 - .../stats/TimeSeriesRepositoryImplTest.java | 129 -- .../common/stats/WindowedHistogramTest.java | 234 --- .../twitter/common/stats/WindowedStatsTest.java | 202 -- .../com/twitter/common/stats/WindowedTest.java | 110 - .../common/testing/TearDownRegistryTest.java | 46 - .../testing/easymock/EasyMockTestTest.java | 60 - .../testing/easymock/IterableEqualsTest.java | 66 - .../common/testing/junit/rules/RetryTest.java | 230 --- .../thrift/ThriftConnectionFactoryTest.java | 140 -- .../common/thrift/ThriftFactoryTest.java | 242 --- .../com/twitter/common/thrift/ThriftTest.java | 931 --------- .../thrift/callers/AbstractCallerTest.java | 56 - .../thrift/callers/DeadlineCallerTest.java | 119 -- .../thrift/callers/RetryingCallerTest.java | 150 -- .../twitter/common/util/BackoffDeciderTest.java | 324 --- .../twitter/common/util/BackoffHelperTest.java | 173 -- .../twitter/common/util/LowResClockTest.java | 169 -- .../twitter/common/util/QueueDrainerTest.java | 59 - .../util/RateLimitedCommandExecutorTest.java | 115 -- .../com/twitter/common/util/SamplerTest.java | 67 - .../twitter/common/util/StateMachineTest.java | 417 ---- .../common/util/TruncatedBinaryBackoffTest.java | 90 - .../util/caching/CachingMethodProxyTest.java | 257 --- .../common/util/caching/LRUCacheTest.java | 81 - .../ExceptionHandlingExecutorServiceTest.java | 124 -- ...ionHandlingScheduledExecutorServiceTest.java | 137 -- .../templating/StringTemplateHelperTest.java | 93 - .../common/util/testing/FakeClockTest.java | 70 - .../common/zookeeper/CandidateImplTest.java | 228 --- .../common/zookeeper/CompoundServerSetTest.java | 233 --- .../common/zookeeper/DistributedLockTest.java | 174 -- .../com/twitter/common/zookeeper/GroupTest.java | 331 --- .../common/zookeeper/PartitionerTest.java | 161 -- .../common/zookeeper/ServerSetImplTest.java | 438 ---- .../common/zookeeper/ServerSetsTest.java | 48 - .../common/zookeeper/SingletonServiceTest.java | 349 ---- .../common/zookeeper/StaticServerSetTest.java | 85 - .../common/zookeeper/ZooKeeperClientTest.java | 251 --- .../common/zookeeper/ZooKeeperMapTest.java | 418 ---- .../common/zookeeper/ZooKeeperNodeTest.java | 297 --- .../common/zookeeper/ZooKeeperUtilsTest.java | 138 -- .../zookeeper/guice/ServerSetModuleTest.java | 76 - .../common/application/AppLauncherTest.java | 74 + .../modules/LifecycleModuleTest.java | 137 ++ .../modules/LocalServiceRegistryTest.java | 170 ++ .../modules/StartStatPollerTest.java | 63 + .../aurora/common/args/ArgFiltersTest.java | 102 + .../aurora/common/args/ArgScannerTest.java | 852 ++++++++ .../org/apache/aurora/common/args/ArgTest.java | 34 + .../org/apache/aurora/common/args/ArgsTest.java | 73 + .../aurora/common/args/OptionInfoTest.java | 107 + .../apache/aurora/common/args/ParsersTest.java | 81 + .../common/args/argfilterstest/ArgsRoot.java | 29 + .../args/argfilterstest/subpackageA/ArgsA.java | 29 + .../subpackageA/subsubpackage1/ArgsA1.java | 29 + .../args/argfilterstest/subpackageB/ArgsB.java | 29 + .../subpackageBwithSuffix/ArgsBWithSuffix.java | 29 + .../aurora/common/base/CachingSupplierTest.java | 64 + .../apache/aurora/common/base/ClosuresTest.java | 173 ++ .../apache/aurora/common/base/CommandsTest.java | 84 + .../apache/aurora/common/base/EitherTest.java | 263 +++ .../common/base/ExceptionTransporterTest.java | 57 + .../common/base/ExceptionalFunctionsTest.java | 166 ++ .../common/base/MorePreconditionsTest.java | 100 + .../aurora/common/base/MoreSuppliersTest.java | 107 + .../aurora/common/collections/BitsTest.java | 299 +++ .../common/collections/BoundedQueueTest.java | 57 + .../common/collections/Iterables2Test.java | 107 + .../aurora/common/collections/PairTest.java | 50 + .../aurora/common/inject/BindingsTest.java | 140 ++ .../common/inject/DefaultProviderTest.java | 65 + .../aurora/common/io/Base64ZlibCodecTest.java | 91 + .../aurora/common/io/CodecTestUtilities.java | 34 + .../common/io/CompatibilityCodecTest.java | 101 + .../apache/aurora/common/io/FileUtilsTest.java | 121 ++ .../apache/aurora/common/io/JsonCodecTest.java | 104 + .../aurora/common/io/ThriftCodecTest.java | 54 + .../aurora/common/logging/BufferedLogTest.java | 141 ++ .../aurora/common/logging/LogFormatterTest.java | 72 + .../aurora/common/logging/LogUtilTest.java | 61 + .../common/logging/RootLogConfigTest.java | 333 +++ .../logging/julbridge/JULBridgeHandlerTest.java | 94 + .../julbridge/JULBridgeLevelConverterTest.java | 94 + .../julbridge/JULBridgeLogManagerTest.java | 75 + .../common/net/InetSocketAddressHelperTest.java | 111 + .../apache/aurora/common/net/UrlHelperTest.java | 120 ++ .../aurora/common/net/UrlResolverTest.java | 171 ++ .../aurora/common/net/UrlResolverUtilTest.java | 162 ++ .../aurora/common/net/UrlTokenizerUtilTest.java | 94 + .../common/net/http/RequestLoggerTest.java | 102 + .../filters/HttpStatsFilterIntegrationTest.java | 165 ++ .../net/http/filters/HttpStatsFilterTest.java | 227 +++ .../net/http/handlers/AssetHandlerTest.java | 378 ++++ .../handlers/HttpServletRequestParamsTest.java | 82 + .../net/http/handlers/LogPrinterTest.java | 87 + .../net/http/handlers/StatSupplierTestBase.java | 52 + .../http/handlers/TimeSeriesDataSourceTest.java | 156 ++ .../net/http/handlers/VarsHandlerTest.java | 78 + .../net/http/handlers/VarsJsonHandlerTest.java | 73 + .../LeastConnectedStrategyTest.java | 286 +++ .../net/loadbalancing/LoadBalancerImplTest.java | 141 ++ .../net/loadbalancing/MarkDeadStrategyTest.java | 332 +++ .../MarkDeadStrategyWithHostCheckTest.java | 146 ++ .../net/loadbalancing/RandomStrategyTest.java | 97 + .../loadbalancing/RoundRobinStrategyTest.java | 104 + .../net/loadbalancing/SubsetStrategyTest.java | 98 + .../net/monitoring/TrafficMonitorTest.java | 122 ++ .../common/net/pool/ConnectionPoolTest.java | 255 +++ .../common/net/pool/DynamicHostSetUtilTest.java | 57 + .../aurora/common/net/pool/DynamicPoolTest.java | 168 ++ .../objectsize/ObjectSizeCalculatorTest.java | 211 ++ .../aurora/common/quantity/AmountTest.java | 117 ++ .../common/stats/ApproximateHistogramTest.java | 321 +++ .../apache/aurora/common/stats/ElapsedTest.java | 83 + .../apache/aurora/common/stats/EntropyTest.java | 58 + .../common/stats/MergedHistogramTest.java | 94 + .../aurora/common/stats/MovingAverageTest.java | 83 + .../common/stats/MovingWindowDeltaTest.java | 91 + .../common/stats/NumericStatExporterTest.java | 144 ++ .../aurora/common/stats/PercentileTest.java | 204 ++ .../aurora/common/stats/PipelineStatsTest.java | 147 ++ .../common/stats/PrintableHistogramTest.java | 27 + .../apache/aurora/common/stats/RateTest.java | 237 +++ .../common/stats/ReservoirSamplerTest.java | 75 + .../aurora/common/stats/StatisticsTest.java | 116 ++ .../apache/aurora/common/stats/StatsTest.java | 110 + .../stats/TimeSeriesRepositoryImplTest.java | 129 ++ .../common/stats/WindowedHistogramTest.java | 234 +++ .../aurora/common/stats/WindowedStatsTest.java | 202 ++ .../aurora/common/stats/WindowedTest.java | 110 + .../common/testing/TearDownRegistryTest.java | 46 + .../testing/easymock/EasyMockTestTest.java | 60 + .../testing/easymock/IterableEqualsTest.java | 62 + .../common/testing/junit/rules/RetryTest.java | 230 +++ .../thrift/ThriftConnectionFactoryTest.java | 140 ++ .../aurora/common/thrift/ThriftFactoryTest.java | 242 +++ .../apache/aurora/common/thrift/ThriftTest.java | 931 +++++++++ .../thrift/callers/AbstractCallerTest.java | 56 + .../thrift/callers/DeadlineCallerTest.java | 119 ++ .../thrift/callers/RetryingCallerTest.java | 150 ++ .../aurora/common/util/BackoffDeciderTest.java | 324 +++ .../aurora/common/util/BackoffHelperTest.java | 172 ++ .../aurora/common/util/LowResClockTest.java | 169 ++ .../aurora/common/util/QueueDrainerTest.java | 59 + .../util/RateLimitedCommandExecutorTest.java | 115 ++ .../apache/aurora/common/util/SamplerTest.java | 67 + .../aurora/common/util/StateMachineTest.java | 417 ++++ .../common/util/TruncatedBinaryBackoffTest.java | 90 + .../util/caching/CachingMethodProxyTest.java | 257 +++ .../common/util/caching/LRUCacheTest.java | 81 + .../ExceptionHandlingExecutorServiceTest.java | 124 ++ ...ionHandlingScheduledExecutorServiceTest.java | 135 ++ .../templating/StringTemplateHelperTest.java | 92 + .../common/util/testing/FakeClockTest.java | 70 + .../common/zookeeper/CandidateImplTest.java | 226 +++ .../common/zookeeper/CompoundServerSetTest.java | 233 +++ .../common/zookeeper/DistributedLockTest.java | 174 ++ .../aurora/common/zookeeper/GroupTest.java | 331 +++ .../common/zookeeper/PartitionerTest.java | 159 ++ .../common/zookeeper/ServerSetImplTest.java | 434 ++++ .../aurora/common/zookeeper/ServerSetsTest.java | 48 + .../common/zookeeper/SingletonServiceTest.java | 348 ++++ .../common/zookeeper/StaticServerSetTest.java | 85 + .../common/zookeeper/ZooKeeperClientTest.java | 251 +++ .../common/zookeeper/ZooKeeperMapTest.java | 418 ++++ .../common/zookeeper/ZooKeeperNodeTest.java | 297 +++ .../common/zookeeper/ZooKeeperUtilsTest.java | 138 ++ .../zookeeper/guice/ServerSetModuleTest.java | 76 + .../twitter/common/util/templating/template.st | 7 - .../aurora/common/util/templating/template.st | 7 + .../org/apache/aurora/benchmark/Offers.java | 4 +- .../aurora/benchmark/SchedulingBenchmarks.java | 10 +- .../aurora/benchmark/SnapshotBenchmarks.java | 6 +- .../aurora/benchmark/StatusUpdateBenchmark.java | 14 +- .../java/org/apache/aurora/benchmark/Tasks.java | 4 +- .../aurora/benchmark/ThriftApiBenchmarks.java | 6 +- .../benchmark/fakes/FakeStatsProvider.java | 5 +- src/main/java/org/apache/aurora/GuiceUtils.java | 2 +- .../apache/aurora/codec/ThriftBinaryCodec.java | 4 +- .../apache/aurora/scheduler/ResourceSlot.java | 6 +- .../org/apache/aurora/scheduler/Resources.java | 4 +- .../aurora/scheduler/SchedulerLifecycle.java | 30 +- .../aurora/scheduler/SchedulerModule.java | 10 +- .../scheduler/SchedulerServicesModule.java | 8 +- .../aurora/scheduler/TaskIdGenerator.java | 2 +- .../aurora/scheduler/TaskStatusHandlerImpl.java | 2 +- .../org/apache/aurora/scheduler/TaskVars.java | 2 +- .../apache/aurora/scheduler/app/AppModule.java | 34 +- .../aurora/scheduler/app/Log4jConfigurator.java | 6 +- .../aurora/scheduler/app/SchedulerMain.java | 38 +- .../aurora/scheduler/app/VolumeParser.java | 4 +- .../aurora/scheduler/async/AsyncModule.java | 6 +- .../aurora/scheduler/async/DelayExecutor.java | 4 +- .../scheduler/async/GatedDelayExecutor.java | 5 +- .../aurora/scheduler/base/CommandUtil.java | 2 +- .../configuration/ConfigurationManager.java | 6 +- .../scheduler/cron/quartz/AuroraCronJob.java | 6 +- .../scheduler/cron/quartz/CronLifecycle.java | 2 +- .../scheduler/cron/quartz/CronModule.java | 10 +- .../cron/quartz/CronPredictorImpl.java | 2 +- .../cron/quartz/CronSchedulerImpl.java | 2 +- .../scheduler/events/PubsubEventModule.java | 2 +- .../scheduler/filter/AttributeAggregate.java | 2 +- .../scheduler/filter/SchedulingFilterImpl.java | 6 +- .../aurora/scheduler/http/CorsFilter.java | 3 +- .../aurora/scheduler/http/H2ConsoleModule.java | 4 +- .../aurora/scheduler/http/HttpStatsFilter.java | 3 +- .../scheduler/http/JerseyTemplateServlet.java | 7 +- .../scheduler/http/JettyServerModule.java | 30 +- .../aurora/scheduler/http/LeaderRedirect.java | 11 +- .../aurora/scheduler/http/QuitCallback.java | 3 +- .../aurora/scheduler/http/RequestLogger.java | 2 +- .../apache/aurora/scheduler/http/Slaves.java | 4 +- .../aurora/scheduler/http/StructDump.java | 4 +- .../aurora/scheduler/http/Utilization.java | 8 +- .../aurora/scheduler/http/api/ApiModule.java | 4 +- .../http/api/security/HttpSecurityModule.java | 4 +- .../http/api/security/IniShiroRealmModule.java | 4 +- .../api/security/Kerberos5ShiroRealmModule.java | 4 +- .../api/security/KerberosPrincipalParser.java | 4 +- .../http/api/security/ModuleParser.java | 4 +- .../security/ShiroAuthorizingInterceptor.java | 2 +- .../ShiroAuthorizingParamInterceptor.java | 2 +- .../http/api/security/ShiroIniParser.java | 4 +- .../aurora/scheduler/log/mesos/MesosLog.java | 16 +- .../log/mesos/MesosLogStreamModule.java | 12 +- .../mesos/CommandLineDriverSettingsModule.java | 10 +- .../scheduler/mesos/MesosSchedulerImpl.java | 4 +- .../scheduler/mesos/MesosTaskFactory.java | 6 +- .../scheduler/mesos/SchedulerDriverService.java | 2 +- .../aurora/scheduler/mesos/TaskStatusStats.java | 6 +- .../aurora/scheduler/metadata/NearestFit.java | 4 +- .../aurora/scheduler/offers/OfferManager.java | 8 +- .../aurora/scheduler/offers/OffersModule.java | 13 +- .../offers/RandomJitterReturnDelay.java | 7 +- .../aurora/scheduler/preemptor/BiCache.java | 9 +- .../preemptor/PendingTaskProcessor.java | 6 +- .../scheduler/preemptor/PreemptorModule.java | 8 +- .../pruning/JobUpdateHistoryPruner.java | 6 +- .../aurora/scheduler/pruning/PruningModule.java | 8 +- .../scheduler/pruning/TaskHistoryPruner.java | 6 +- .../scheduler/reconciliation/KillRetry.java | 8 +- .../reconciliation/ReconciliationModule.java | 14 +- .../reconciliation/TaskReconciler.java | 9 +- .../scheduler/reconciliation/TaskTimeout.java | 6 +- .../scheduling/RescheduleCalculator.java | 8 +- .../scheduler/scheduling/SchedulingModule.java | 12 +- .../aurora/scheduler/scheduling/TaskGroups.java | 8 +- .../scheduler/scheduling/TaskScheduler.java | 4 +- .../scheduler/scheduling/TaskThrottler.java | 8 +- .../aurora/scheduler/sla/MetricCalculator.java | 6 +- .../aurora/scheduler/sla/SlaAlgorithm.java | 2 +- .../apache/aurora/scheduler/sla/SlaGroup.java | 2 +- .../apache/aurora/scheduler/sla/SlaModule.java | 10 +- .../aurora/scheduler/state/LockManagerImpl.java | 2 +- .../scheduler/state/StateManagerImpl.java | 4 +- .../aurora/scheduler/state/TaskAssigner.java | 4 +- .../scheduler/state/TaskStateMachine.java | 16 +- .../scheduler/stats/AsyncStatsModule.java | 10 +- .../aurora/scheduler/stats/CachedCounters.java | 3 +- .../storage/CallOrderEnforcingStorage.java | 2 +- .../scheduler/storage/StorageBackfill.java | 2 +- .../scheduler/storage/backup/BackupModule.java | 14 +- .../scheduler/storage/backup/Recovery.java | 2 +- .../scheduler/storage/backup/StorageBackup.java | 8 +- .../storage/backup/TemporaryStorage.java | 2 +- .../scheduler/storage/db/DbAttributeStore.java | 5 +- .../scheduler/storage/db/DbJobUpdateStore.java | 4 +- .../scheduler/storage/db/DbLockStore.java | 2 +- .../aurora/scheduler/storage/db/DbModule.java | 10 +- .../scheduler/storage/db/DbQuotaStore.java | 2 +- .../scheduler/storage/db/DbSchedulerStore.java | 2 +- .../aurora/scheduler/storage/db/DbStorage.java | 2 +- .../scheduler/storage/db/DbTaskStore.java | 8 +- .../aurora/scheduler/storage/db/DbUtil.java | 8 +- .../scheduler/storage/db/TaskConfigMapper.java | 2 +- .../aurora/scheduler/storage/db/TaskMapper.java | 2 +- .../storage/db/views/DbAssignedTask.java | 2 +- .../storage/db/views/DbTaskConfig.java | 2 +- .../scheduler/storage/db/views/Pairs.java | 2 +- .../scheduler/storage/log/EntrySerializer.java | 6 +- .../scheduler/storage/log/LogStorage.java | 14 +- .../scheduler/storage/log/LogStorageModule.java | 10 +- .../storage/log/SnapshotDeduplicator.java | 2 +- .../storage/log/SnapshotStoreImpl.java | 6 +- .../scheduler/storage/log/StreamManager.java | 4 +- .../storage/log/StreamManagerImpl.java | 7 +- .../storage/mem/InMemStoresModule.java | 2 +- .../scheduler/storage/mem/MemTaskStore.java | 14 +- .../scheduler/testing/FakeStatsProvider.java | 5 +- .../scheduler/thrift/ReadOnlySchedulerImpl.java | 2 +- .../aurora/scheduler/thrift/Responses.java | 2 +- .../thrift/SchedulerThriftInterface.java | 8 +- .../aurora/scheduler/thrift/aop/AopModule.java | 4 +- .../aop/ThriftStatsExporterInterceptor.java | 4 +- .../scheduler/thrift/auth/ThriftAuthModule.java | 6 +- .../updater/InstanceActionHandler.java | 4 +- .../scheduler/updater/InstanceUpdater.java | 6 +- .../updater/JobUpdateControllerImpl.java | 8 +- .../updater/JobUpdateEventSubscriber.java | 2 +- .../scheduler/updater/OneWayJobUpdater.java | 2 +- .../aurora/scheduler/updater/UpdateFactory.java | 6 +- .../scheduler/storage/db/TaskConfigMapper.xml | 2 +- .../aurora/scheduler/storage/db/TaskMapper.xml | 2 +- .../aurora/auth/UnsecureSessionContextTest.java | 2 +- .../aurora/scheduler/ResourceSlotTest.java | 6 +- .../apache/aurora/scheduler/ResourcesTest.java | 6 +- .../scheduler/SchedulerLifecycleTest.java | 15 +- .../scheduler/TaskStatusHandlerImplTest.java | 2 +- .../apache/aurora/scheduler/TaskVarsTest.java | 6 +- .../aurora/scheduler/app/SchedulerIT.java | 38 +- .../aurora/scheduler/app/local/FakeMaster.java | 6 +- .../scheduler/app/local/LocalSchedulerMain.java | 2 +- .../local/simulator/ClusterSimulatorModule.java | 4 +- .../aurora/scheduler/async/AsyncModuleTest.java | 8 +- .../scheduler/async/GatedDelayExecutorTest.java | 6 +- .../aurora/scheduler/base/AsyncUtilTest.java | 2 +- .../cron/quartz/AuroraCronJobTest.java | 6 +- .../aurora/scheduler/cron/quartz/CronIT.java | 4 +- .../cron/quartz/CronJobManagerImplTest.java | 2 +- .../cron/quartz/CronPredictorImplTest.java | 6 +- .../events/NotifyingSchedulingFilterTest.java | 2 +- .../scheduler/events/PubsubEventModuleTest.java | 10 +- .../filter/AttributeAggregateTest.java | 4 +- .../filter/SchedulingFilterImplTest.java | 4 +- .../aurora/scheduler/http/CorsFilterTest.java | 2 +- .../apache/aurora/scheduler/http/CronTest.java | 2 +- .../scheduler/http/JettyServerModuleTest.java | 26 +- .../scheduler/http/LeaderRedirectTest.java | 12 +- .../apache/aurora/scheduler/http/LocksTest.java | 2 +- .../aurora/scheduler/http/QuitCallbackTest.java | 6 +- .../scheduler/http/RequestLoggerTest.java | 8 +- .../aurora/scheduler/http/ServicesTest.java | 2 +- .../scheduler/http/ServletFilterTest.java | 4 +- .../security/Kerberos5ShiroRealmModuleTest.java | 2 +- ...hiroAuthenticatingThriftInterceptorTest.java | 2 +- .../ShiroAuthorizingInterceptorTest.java | 4 +- .../ShiroAuthorizingParamInterceptorTest.java | 4 +- .../scheduler/log/mesos/MesosLogTest.java | 10 +- .../CommandLineDriverSettingsModuleTest.java | 4 +- .../scheduler/mesos/MesosSchedulerImplTest.java | 6 +- .../mesos/MesosTaskFactoryImplTest.java | 4 +- .../apache/aurora/scheduler/mesos/Offers.java | 2 +- .../mesos/SchedulerDriverServiceTest.java | 2 +- .../aurora/scheduler/mesos/TaskExecutors.java | 4 +- .../scheduler/mesos/TaskStatusStatsTest.java | 12 +- .../scheduler/metadata/NearestFitTest.java | 6 +- .../scheduler/offers/OfferManagerImplTest.java | 6 +- .../offers/RandomJitterReturnDelayTest.java | 4 +- .../aurora/scheduler/preemptor/BiCacheTest.java | 6 +- .../preemptor/PendingTaskProcessorTest.java | 8 +- .../preemptor/PreemptionVictimFilterTest.java | 6 +- .../scheduler/preemptor/PreemptorImplTest.java | 2 +- .../preemptor/PreemptorModuleTest.java | 12 +- .../pruning/JobUpdateHistoryPrunerTest.java | 8 +- .../pruning/TaskHistoryPrunerTest.java | 12 +- .../scheduler/quota/QuotaManagerImplTest.java | 2 +- .../scheduler/reconciliation/KillRetryTest.java | 12 +- .../reconciliation/TaskReconcilerTest.java | 10 +- .../reconciliation/TaskTimeoutTest.java | 10 +- .../RescheduleCalculatorImplTest.java | 8 +- .../scheduler/scheduling/TaskGroupsTest.java | 8 +- .../scheduling/TaskSchedulerImplTest.java | 6 +- .../scheduler/scheduling/TaskThrottlerTest.java | 8 +- .../scheduler/sla/MetricCalculatorTest.java | 10 +- .../aurora/scheduler/sla/SlaModuleTest.java | 18 +- .../scheduler/state/LockManagerImplTest.java | 8 +- .../state/MaintenanceControllerImplTest.java | 4 +- .../scheduler/state/StateManagerImplTest.java | 4 +- .../scheduler/state/TaskAssignerImplTest.java | 2 +- .../scheduler/stats/AsyncStatsModuleTest.java | 2 +- .../scheduler/stats/SlotSizeCounterTest.java | 4 +- .../storage/AbstractTaskStoreTest.java | 6 +- .../scheduler/storage/backup/RecoveryTest.java | 10 +- .../storage/backup/StorageBackupTest.java | 8 +- .../storage/db/DbCronJobStoreTest.java | 6 +- .../scheduler/storage/db/DbStorageTest.java | 2 +- .../scheduler/storage/db/DbTaskStoreTest.java | 6 +- .../storage/db/RowGarbageCollectorTest.java | 6 +- .../scheduler/storage/log/LogManagerTest.java | 8 +- .../scheduler/storage/log/LogStorageTest.java | 8 +- .../storage/log/SnapshotStoreImplTest.java | 4 +- .../storage/log/WriteAheadStorageTest.java | 2 +- .../storage/mem/InMemTaskStoreTest.java | 4 +- .../storage/mem/MemCronJobStoreTest.java | 4 +- .../storage/mem/StorageTransactionTest.java | 6 +- .../storage/testing/StorageTestUtil.java | 2 +- .../testing/FakeScheduledExecutor.java | 8 +- .../thrift/ReadOnlySchedulerImplTest.java | 2 +- .../thrift/SchedulerThriftInterfaceTest.java | 2 +- .../aurora/scheduler/thrift/ThriftIT.java | 4 +- .../scheduler/thrift/aop/AopModuleTest.java | 2 +- .../aop/FeatureToggleInterceptorTest.java | 2 +- .../thrift/aop/LoggingInterceptorTest.java | 3 +- .../thrift/aop/ServerInfoInterceptorTest.java | 2 +- .../aop/ThriftStatsExporterInterceptorTest.java | 4 +- .../aurora/scheduler/updater/AddTaskTest.java | 2 +- .../scheduler/updater/InstanceUpdaterTest.java | 6 +- .../aurora/scheduler/updater/JobDiffTest.java | 2 +- .../updater/JobUpdateEventSubscriberTest.java | 2 +- .../updater/JobUpdateStateMachineTest.java | 2 +- .../aurora/scheduler/updater/JobUpdaterIT.java | 14 +- .../scheduler/updater/OneWayJobUpdaterTest.java | 2 +- .../updater/UpdateFactoryImplTest.java | 2 +- 1161 files changed, 60711 insertions(+), 60805 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons-args/src/main/java/com/twitter/common/args/Arg.java ---------------------------------------------------------------------- diff --git a/commons-args/src/main/java/com/twitter/common/args/Arg.java b/commons-args/src/main/java/com/twitter/common/args/Arg.java deleted file mode 100644 index 6269c7f..0000000 --- a/commons-args/src/main/java/com/twitter/common/args/Arg.java +++ /dev/null @@ -1,126 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.args; - -import javax.annotation.Nullable; - -import com.google.common.annotations.VisibleForTesting; -import com.google.common.base.Preconditions; - -/** - * Wrapper class for the value of an argument. For proper behavior, an {@code Arg} should always - * be annotated with {@link CmdLine}, which will define the command line interface to the argument. - */ -public class Arg<T> { - - @Nullable private final T defaultValue; - @Nullable private T value; - private boolean hasDefault = true; - private boolean valueApplied = false; - private boolean valueObserved = false; - - /** - * Creates an arg that has no default value, meaning that its value can only ever be retrieved - * if it has been externally set. - */ - public Arg() { - this(null); - hasDefault = false; - } - - /** - * Creates an arg that has a default value, and may optionally be set. - * - * @param defaultValue The default value for the arg. - */ - public Arg(@Nullable T defaultValue) { - this.defaultValue = defaultValue; - value = defaultValue; - } - - synchronized void set(@Nullable T appliedValue) { - Preconditions.checkState(!valueApplied, "A value cannot be applied twice to an argument."); - Preconditions.checkState(!valueObserved, "A value cannot be changed after it was read."); - valueApplied = true; - value = appliedValue; - } - - @VisibleForTesting - synchronized void reset() { - valueApplied = false; - valueObserved = false; - value = hasDefault ? defaultValue : null; - } - - public boolean hasDefault() { - return hasDefault; - } - - /** - * Gets the value of the argument. If a value has not yet been applied to the argument, or the - * argument did not provide a default value, {@link IllegalStateException} will be thrown. - * - * @return The argument value. - */ - @Nullable - public synchronized T get() { - // TODO(William Farner): This has a tendency to break bad-arg reporting by ArgScanner. Fix. - Preconditions.checkState(valueApplied || hasDefault, - "A value may only be retrieved from a variable that has a default or has been set."); - valueObserved = true; - return uncheckedGet(); - } - - /** - * Checks whether a value has been applied to the argument (i.e., apart from the default). - * - * @return {@code true} if a value from the command line has been applied to this arg, - * {@code false} otherwise. - */ - public synchronized boolean hasAppliedValue() { - return valueApplied; - } - - /** - * Gets the value of the argument, without checking whether a default was available or if a - * value was applied. - * - * @return The argument value. - */ - @Nullable - synchronized T uncheckedGet() { - return value; - } - - /** - * Convenience factory method to create an arg that has no default value. - * - * @param <T> Type of arg value. - * @return A new arg. - */ - public static <T> Arg<T> create() { - return new Arg<T>(); - } - - /** - * Convenience factory method to create an arg with a default value. - * - * @param value Default argument value. - * @param <T> Type of arg value. - * @return A new arg. - */ - public static <T> Arg<T> create(@Nullable T value) { - return new Arg<T>(value); - } -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons-args/src/main/java/com/twitter/common/args/ArgParser.java ---------------------------------------------------------------------- diff --git a/commons-args/src/main/java/com/twitter/common/args/ArgParser.java b/commons-args/src/main/java/com/twitter/common/args/ArgParser.java deleted file mode 100644 index f1b412f..0000000 --- a/commons-args/src/main/java/com/twitter/common/args/ArgParser.java +++ /dev/null @@ -1,28 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.args; - -import java.lang.annotation.Retention; -import java.lang.annotation.Target; - -import static java.lang.annotation.ElementType.TYPE; -import static java.lang.annotation.RetentionPolicy.SOURCE; - -/** - * Annotation to register a command line argument parser globally. - */ -@Target(TYPE) -@Retention(SOURCE) -public @interface ArgParser { -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons-args/src/main/java/com/twitter/common/args/CmdLine.java ---------------------------------------------------------------------- diff --git a/commons-args/src/main/java/com/twitter/common/args/CmdLine.java b/commons-args/src/main/java/com/twitter/common/args/CmdLine.java deleted file mode 100644 index 68c7e58..0000000 --- a/commons-args/src/main/java/com/twitter/common/args/CmdLine.java +++ /dev/null @@ -1,54 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.args; - -import java.lang.annotation.Retention; -import java.lang.annotation.Target; - -import static java.lang.annotation.ElementType.FIELD; -import static java.lang.annotation.RetentionPolicy.RUNTIME; - -/** - * Annotation for a command line argument. - */ -@Target(FIELD) -@Retention(RUNTIME) -public @interface CmdLine { - /** - * The short name of the argument, as supplied on the command line. The argument can also be - * accessed by the canonical name, which is {@code com.foo.bar.MyArgClass.arg_name}. - * If the global scope contains more than one argument with the same name, all colliding arguments - * must be disambiguated with the canonical form. - * - * The argument name must match the format {@code [\w\-\.]+}. - */ - String name(); - - /** - * The help string to display on the command line in a usage message. - */ - String help(); - - /** - * The parser class to use for parsing this argument. The parser must return the same type as - * the field being annotated. - */ - Class<? extends Parser<?>> parser() default NoParser.class; - - /** - * The flag to indicate whether an argument file is accepted for this argument. - * - */ - boolean argFile() default false; -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons-args/src/main/java/com/twitter/common/args/NoParser.java ---------------------------------------------------------------------- diff --git a/commons-args/src/main/java/com/twitter/common/args/NoParser.java b/commons-args/src/main/java/com/twitter/common/args/NoParser.java deleted file mode 100644 index d0bebc1..0000000 --- a/commons-args/src/main/java/com/twitter/common/args/NoParser.java +++ /dev/null @@ -1,23 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.args; - -/** - * A sentinel parser type for internal use indicating no parser has been selected yet. - */ -abstract class NoParser implements Parser<Object> { - private NoParser() { - throw new UnsupportedOperationException("Not intended for construction."); - } -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons-args/src/main/java/com/twitter/common/args/Parser.java ---------------------------------------------------------------------- diff --git a/commons-args/src/main/java/com/twitter/common/args/Parser.java b/commons-args/src/main/java/com/twitter/common/args/Parser.java deleted file mode 100644 index cd1eebb..0000000 --- a/commons-args/src/main/java/com/twitter/common/args/Parser.java +++ /dev/null @@ -1,35 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.args; - -import java.lang.reflect.Type; - -/** - * An interface to a command line argument parser. - * - * @param <T> The base class this parser can parse all subtypes of. - */ -public interface Parser<T> { - /** - * Parses strings as arguments of a given subtype of {@code T}. - * - * @param parserOracle The registered parserOracle for delegation. - * @param type The target type of the parsed argument. - * @param raw The raw value of the argument. - * @return A value of the given type parsed from the raw value. - * @throws IllegalArgumentException if the raw value could not be parsed into a value of the - * given type. - */ - T parse(ParserOracle parserOracle, Type type, String raw) throws IllegalArgumentException; -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons-args/src/main/java/com/twitter/common/args/ParserOracle.java ---------------------------------------------------------------------- diff --git a/commons-args/src/main/java/com/twitter/common/args/ParserOracle.java b/commons-args/src/main/java/com/twitter/common/args/ParserOracle.java deleted file mode 100644 index 0d8fe46..0000000 --- a/commons-args/src/main/java/com/twitter/common/args/ParserOracle.java +++ /dev/null @@ -1,31 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.args; - -import com.google.common.reflect.TypeToken; - -/** - * A registry of Parsers for different supported argument types. - */ -public interface ParserOracle { - - /** - * Gets the parser associated with a class. - * - * @param type Type to get the parser for. - * @return The parser for {@code cls}. - * @throws IllegalArgumentException If no parser was found for {@code cls}. - */ - <T> Parser<T> get(TypeToken<T> type) throws IllegalArgumentException; -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons-args/src/main/java/com/twitter/common/args/Positional.java ---------------------------------------------------------------------- diff --git a/commons-args/src/main/java/com/twitter/common/args/Positional.java b/commons-args/src/main/java/com/twitter/common/args/Positional.java deleted file mode 100644 index d62b98c..0000000 --- a/commons-args/src/main/java/com/twitter/common/args/Positional.java +++ /dev/null @@ -1,40 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.args; - -import java.lang.annotation.Retention; -import java.lang.annotation.Target; - -import static java.lang.annotation.ElementType.FIELD; -import static java.lang.annotation.RetentionPolicy.RUNTIME; - -/** - * Annotation to mark an {@link Arg} for gathering the positional command line arguments. - */ -@Retention(RUNTIME) -@Target(FIELD) -public @interface Positional { - /** - * The help string to display on the command line in a usage message. - */ - String help(); - - /** - * The parser class to use for parsing the positional arguments. The parser must return the same - * type as the field being annotated. - */ - Class<? extends Parser<?>> parser() default NoParser.class; - - // TODO: https://github.com/twitter/commons/issues/353, Consider to add argFile for positional. -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons-args/src/main/java/com/twitter/common/args/Verifier.java ---------------------------------------------------------------------- diff --git a/commons-args/src/main/java/com/twitter/common/args/Verifier.java b/commons-args/src/main/java/com/twitter/common/args/Verifier.java deleted file mode 100644 index fc7ada1..0000000 --- a/commons-args/src/main/java/com/twitter/common/args/Verifier.java +++ /dev/null @@ -1,37 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.args; - -import java.lang.annotation.Annotation; - -/** - * Typedef for a constraint verifier. - */ -public interface Verifier<T> { - /** - * Verifies the value against the annotation. - * - * @param value Value that is being applied. - * @throws IllegalArgumentException if the value is invalid. - */ - void verify(T value, Annotation annotation) throws IllegalArgumentException; - - /** - * Returns a representation of the constraint this verifier checks. - * - * @param argType The type of the {@link com.twitter.common.args.Arg} this annotation applies to. - * @return A representation of the constraint this verifier checks. - */ - String toString(Class<? extends T> argType, Annotation annotation); -} http://git-wip-us.apache.org/repos/asf/aurora/blob/06ddaadb/commons-args/src/main/java/com/twitter/common/args/VerifierFor.java ---------------------------------------------------------------------- diff --git a/commons-args/src/main/java/com/twitter/common/args/VerifierFor.java b/commons-args/src/main/java/com/twitter/common/args/VerifierFor.java deleted file mode 100644 index 0ac2383..0000000 --- a/commons-args/src/main/java/com/twitter/common/args/VerifierFor.java +++ /dev/null @@ -1,34 +0,0 @@ -/** - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.twitter.common.args; - -import java.lang.annotation.Annotation; -import java.lang.annotation.Retention; -import java.lang.annotation.Target; - -import static java.lang.annotation.ElementType.TYPE; -import static java.lang.annotation.RetentionPolicy.SOURCE; - -/** - * Annotation to register a command line argument verifier. - */ -@Target(TYPE) -@Retention(SOURCE) -public @interface VerifierFor { - /** - * Returns the annotation that marks a field for verification by the annotated - * {@link com.twitter.common.args.Verifier} class. - */ - Class<? extends Annotation> value(); -}
