You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by dw...@apache.org on 2021/03/10 09:56:02 UTC
[lucene] 06/42: precommit errs
This is an automated email from the ASF dual-hosted git repository.
dweiss pushed a commit to branch jira/solr14155-1
in repository https://gitbox.apache.org/repos/asf/lucene.git
commit f5398927056efb4308c0408d578ed9de47bc9bec
Author: noble <no...@apache.org>
AuthorDate: Mon Jul 13 11:47:54 2020 +1000
precommit errs
---
.../java/org/apache/solr/core/CoreContainer.java | 22 ++++++++++++----
.../src/java/org/apache/solr/core/SolrCore.java | 29 ++++++++++++++++------
.../apache/solr/pkg/CoreRefreshingClassLoader.java | 6 ++---
3 files changed, 41 insertions(+), 16 deletions(-)
diff --git a/solr/core/src/java/org/apache/solr/core/CoreContainer.java b/solr/core/src/java/org/apache/solr/core/CoreContainer.java
index 19127ce..b0c76c3 100644
--- a/solr/core/src/java/org/apache/solr/core/CoreContainer.java
+++ b/solr/core/src/java/org/apache/solr/core/CoreContainer.java
@@ -24,7 +24,19 @@ import java.nio.file.Path;
import java.nio.file.Paths;
import java.security.spec.InvalidKeySpecException;
import java.text.SimpleDateFormat;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.LinkedHashSet;
+import java.util.List;
+import java.util.Locale;
+import java.util.Map;
+import java.util.Optional;
+import java.util.Properties;
+import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
@@ -1579,7 +1591,7 @@ public class CoreContainer {
/**
* reloads a core
- * refer {@link CoreContainer#reload(String, UUID)} for details
+ * refer {@link CoreContainer#reload(String, Long)} for details
*/
public void reload(String name) {
reload(name, null);
@@ -1590,16 +1602,16 @@ public class CoreContainer {
* and processed by the old core
*
* @param name the name of the SolrCore to reload
- * @param coreId The unique identifier of the core
+ * @param coreStartTime The start time of the core
*/
- public void reload(String name, Long coreId) {
+ public void reload(String name, Long coreStartTime) {
if (isShutDown) {
throw new AlreadyClosedException();
}
SolrCore newCore = null;
SolrCore core = solrCores.getCoreFromAnyList(name, false);
if (core != null) {
- if(coreId != null && core.uniqueId.longValue() != coreId) {
+ if(coreStartTime != null && core.startNanoTime.longValue() != coreStartTime) {
//trying to reload an already unloaded core
return;
}
diff --git a/solr/core/src/java/org/apache/solr/core/SolrCore.java b/solr/core/src/java/org/apache/solr/core/SolrCore.java
index 085da91..cce19dd 100644
--- a/solr/core/src/java/org/apache/solr/core/SolrCore.java
+++ b/solr/core/src/java/org/apache/solr/core/SolrCore.java
@@ -31,7 +31,22 @@ import java.nio.charset.StandardCharsets;
import java.nio.file.NoSuchFileException;
import java.nio.file.Path;
import java.nio.file.Paths;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Iterator;
+import java.util.LinkedHashMap;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Optional;
+import java.util.Properties;
+import java.util.Set;
import java.util.concurrent.Callable;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArrayList;
@@ -125,7 +140,10 @@ import org.apache.solr.schema.FieldType;
import org.apache.solr.schema.IndexSchema;
import org.apache.solr.schema.ManagedIndexSchema;
import org.apache.solr.schema.SimilarityFactory;
-import org.apache.solr.search.*;
+import org.apache.solr.search.QParserPlugin;
+import org.apache.solr.search.SolrFieldCacheBean;
+import org.apache.solr.search.SolrIndexSearcher;
+import org.apache.solr.search.ValueSourceParser;
import org.apache.solr.search.stats.LocalStatsCache;
import org.apache.solr.search.stats.StatsCache;
import org.apache.solr.update.DefaultSolrCoreState;
@@ -176,11 +194,6 @@ public final class SolrCore implements SolrInfoBean, Closeable {
private String name;
private String logid; // used to show what name is set
- /**
- * A unique id to differentiate multiple instances of the same core
- * If we reload a core, the name remains same , but the id will be new
- */
- public final Long uniqueId = System.nanoTime();
private boolean isReloaded = false;
@@ -195,7 +208,7 @@ public final class SolrCore implements SolrInfoBean, Closeable {
private final SolrCoreState solrCoreState;
private final Date startTime = new Date();
- private final long startNanoTime = System.nanoTime();
+ public final Long startNanoTime = System.nanoTime();
private final RequestHandlers reqHandlers;
private final PluginBag<SearchComponent> searchComponents = new PluginBag<>(SearchComponent.class, this);
private final PluginBag<UpdateRequestProcessorFactory> updateProcessors = new PluginBag<>(UpdateRequestProcessorFactory.class, this, true);
diff --git a/solr/core/src/java/org/apache/solr/pkg/CoreRefreshingClassLoader.java b/solr/core/src/java/org/apache/solr/pkg/CoreRefreshingClassLoader.java
index e75d595..5532615 100644
--- a/solr/core/src/java/org/apache/solr/pkg/CoreRefreshingClassLoader.java
+++ b/solr/core/src/java/org/apache/solr/pkg/CoreRefreshingClassLoader.java
@@ -17,12 +17,12 @@
package org.apache.solr.pkg;
+import java.util.function.Function;
+
import org.apache.solr.core.PluginInfo;
import org.apache.solr.core.SolrCore;
import org.apache.solr.core.SolrResourceLoader;
-import java.util.function.Function;
-
/**A utility class that loads classes from packages and reloads core if any of those packages are updated
*
*/
@@ -54,7 +54,7 @@ public class CoreRefreshingClassLoader implements PackageListeners.Listener {
public void changed(PackageLoader.Package pkg, Ctx ctx) {
PackageLoader.Package.Version version = pkg.getLatest(solrCore.getSolrConfig().maxPackageVersion(info.cName.pkg));
if(version != this.version) {
- ctx.runLater(SolrCore.class.getName(), () -> solrCore.getCoreContainer().reload(CoreRefreshingClassLoader.class.getName() , solrCore.uniqueId));
+ ctx.runLater(SolrCore.class.getName(), () -> solrCore.getCoreContainer().reload(CoreRefreshingClassLoader.class.getName() , solrCore.startNanoTime));
}
}