[geode] 02/05: Some cosmetic changes

[udo]

This is an automated email from the ASF dual-hosted git repository.

udo pushed a commit to branch feature/GEODE-3926_3
in repository https://gitbox.apache.org/repos/asf/geode.git

commit 660e937e262d8ef4a05ee19e68a682ae33a09144
Author: Udo Kohlmeyer <ukohlme...@pivotal.io>
AuthorDate: Thu Mar 29 15:22:16 2018 -0700

    Some cosmetic changes
---
 .../internal/ClusterDistributionManager.java        | 21 +++++++++------------
 .../cache/lucene/internal/LuceneServiceImpl.java    |  4 ++--
 2 files changed, 11 insertions(+), 14 deletions(-)

diff --git 
a/geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterDistributionManager.java
 
b/geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterDistributionManager.java
index f190e72..6151c7f 100644
--- 
a/geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterDistributionManager.java
+++ 
b/geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterDistributionManager.java
@@ -892,18 +892,15 @@ public class ClusterDistributionManager implements 
DistributionManager {
           @Override
           public Thread newThread(final Runnable command) {
             ClusterDistributionManager.this.stats.incWaitingThreadStarts();// 
will it be ok?
-            final Runnable r = new Runnable() {
-              @Override
-              public void run() {
-                ClusterDistributionManager.this.stats.incWaitingThreads(1);// 
will it be ok
-                try {
-                  ConnectionTable.threadWantsSharedResources();
-                  Connection.makeReaderThread();
-                  runUntilShutdown(command);
-                } finally {
-                  ConnectionTable.releaseThreadsSockets();
-                  ClusterDistributionManager.this.stats.incWaitingThreads(-1);
-                }
+            final Runnable r = () -> {
+              ClusterDistributionManager.this.stats.incWaitingThreads(1);// 
will it be ok
+              try {
+                ConnectionTable.threadWantsSharedResources();
+                Connection.makeReaderThread();
+                runUntilShutdown(command);
+              } finally {
+                ConnectionTable.releaseThreadsSockets();
+                ClusterDistributionManager.this.stats.incWaitingThreads(-1);
               }
             };
             Thread thread = new Thread(group, r,
diff --git 
a/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/LuceneServiceImpl.java
 
b/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/LuceneServiceImpl.java
index 3e08abd..1aa50e8 100644
--- 
a/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/LuceneServiceImpl.java
+++ 
b/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/LuceneServiceImpl.java
@@ -363,7 +363,7 @@ public class LuceneServiceImpl implements 
InternalLuceneService {
   }
 
   public List<LuceneIndex> getIndexes(String regionPath) {
-    List<LuceneIndex> indexes = new ArrayList();
+    List<LuceneIndex> indexes = new ArrayList<>();
     for (LuceneIndex index : getAllIndexes()) {
       if (index.getRegionPath().equals(regionPath)) {
         indexes.add(index);
@@ -373,7 +373,7 @@ public class LuceneServiceImpl implements 
InternalLuceneService {
   }
 
   public List<LuceneIndexCreationProfile> getDefinedIndexes(String regionPath) 
{
-    List<LuceneIndexCreationProfile> profiles = new ArrayList();
+    List<LuceneIndexCreationProfile> profiles = new ArrayList<>();
     for (LuceneIndexCreationProfile profile : getAllDefinedIndexes()) {
       if (profile.getRegionPath().equals(regionPath)) {
         profiles.add(profile);

-- 
To stop receiving notification emails like this one, please contact
u...@apache.org.