geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject [geode] 02/05: Some cosmetic changes
Date Fri, 30 Mar 2018 23:51:39 GMT
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 <ukohlmeyer@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
udo@apache.org.

Mime
View raw message