You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ud...@apache.org on 2018/03/30 23:51:39 UTC
[geode] 02/05: Some cosmetic changes
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 <uk...@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.