Maintenance (#180)

* remove sudo param from travisci config; closes #179

* upgrade gradle wrapper and netflixoss plugin

* change info log statements to debug
add experimental api for evaluating assignable VMs
fix javadoc for disabling VMs; closes 178

Author: corindwyer

.travis.yml

@@ -1,7 +1,6 @@
 language: java
 jdk:
 - oraclejdk8
-sudo: false
 install: ./installViaTravis.sh
 script: ./buildViaTravis.sh
 env:

build.gradle

@@ -24,7 +24,7 @@ buildscript {
         }
     }
     dependencies {
-        classpath 'com.netflix.nebula:gradle-netflixoss-project-plugin:3.5.2'
+        classpath 'com.netflix.nebula:gradle-netflixoss-project-plugin:5.0.0'
     }
 }
 
@@ -58,4 +58,8 @@ subprojects {
    tasks.withType(Javadoc) {
        options.addStringOption('Xdoclint:none', '-quiet')
    }
+
+    test {
+        maxParallelForks = Runtime.runtime.availableProcessors().intdiv(2) ?: 1
+    }
 }

fenzo-core/src/main/java/com/netflix/fenzo/AssignableVMs.java

@@ -346,7 +346,7 @@ void purgeInactiveVMs(Set<String> excludeVms) {
                         vmCollection.remove(avm);
                         if (avm.getCurrVMId() != null)
                             vmIdToHostnameMap.remove(avm.getCurrVMId(), avm.getHostname());
-                        logger.info("Removed inactive host " + avm.getHostname());
+                        logger.debug("Removed inactive host " + avm.getHostname());
                     }
                 }
             }

fenzo-core/src/main/java/com/netflix/fenzo/AssignableVirtualMachine.java

@@ -492,7 +492,7 @@ private void assignResourceSets(TaskRequest request) {
     }
 
     void expireLease(String leaseId) {
-        logger.info("Got request to expire lease on " + hostname);
+        logger.debug("Got request to expire lease on " + hostname);
         leasesToExpire.offer(leaseId);
     }
 

fenzo-core/src/main/java/com/netflix/fenzo/TaskScheduler.java

@@ -136,12 +136,7 @@ private TaskSchedulingService(Builder builder) {
      * new leases.
      */
     public void start() {
-        executorService.scheduleWithFixedDelay(new Runnable() {
-            @Override
-            public void run() {
-                TaskSchedulingService.this.scheduleOnce();
-            }
-        }, 0, loopIntervalMillis, TimeUnit.MILLISECONDS);
+        executorService.scheduleWithFixedDelay(TaskSchedulingService.this::scheduleOnce, 0, loopIntervalMillis, TimeUnit.MILLISECONDS);
     }
 
     /**

fenzo-core/src/main/java/com/netflix/fenzo/TaskSchedulingService.java

@@ -300,7 +300,7 @@ public void setTotalResources(Map<VMResource, Double> totalResourcesMap) {
             for (QueueBucket b : sortedBuckets.getSortedList()) {
                 b.setTotalResources(tierResources);
             }
-            logger.info("Re-sorting buckets in tier " + tierNumber + " after totals changed");
+            logger.debug("Re-sorting buckets in tier " + tierNumber + " after totals changed");
             sortedBuckets.resort();
         }
     }

fenzo-core/src/main/java/com/netflix/fenzo/queues/tiered/Tier.java

@@ -45,12 +45,7 @@ private TaskScheduler getScheduler(VMTaskFitnessCalculator fitnessCalculator) {
         return new TaskScheduler.Builder()
                 .withFitnessCalculator(fitnessCalculator)
                 .withLeaseOfferExpirySecs(1000000)
-                .withLeaseRejectAction(new Action1<VirtualMachineLease>() {
-                    @Override
-                    public void call(VirtualMachineLease virtualMachineLease) {
-                        logger.info("Rejecting lease on " + virtualMachineLease.hostname());
-                    }
-                })
+                .withLeaseRejectAction(virtualMachineLease -> logger.info("Rejecting lease on " + virtualMachineLease.hostname()))
                 .build();
     }