sigram commented on a change in pull request #1100: SOLR-13579: Create resource
management API
URL: https://github.com/apache/lucene-solr/pull/1100#discussion_r363828310
##########
File path: solr/core/src/java/org/apache/solr/managed/ResourceManagerPool.java
##########
@@ -0,0 +1,216 @@
+package org.apache.solr.managed;
+
+import java.io.Closeable;
+import java.io.IOException;
+import java.lang.invoke.MethodHandles;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ScheduledFuture;
+import java.util.concurrent.locks.ReentrantLock;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ *
+ */
+public abstract class ResourceManagerPool<T extends ManagedComponent>
implements Closeable {
+ private static final Logger log =
LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
+
+ protected final String name;
+ protected final String type;
+ protected Map<String, Object> poolLimits;
+ protected final Map<String, T> components = new ConcurrentHashMap<>();
+ protected final ResourceManager resourceManager;
+ protected final Class<? extends ManagedComponent> componentClass;
+ private final Map<String, Object> poolParams;
+ protected final ResourcePoolContext poolContext = new ResourcePoolContext();
+ protected final List<ChangeListener> listeners = new ArrayList<>();
+ protected final ReentrantLock updateLock = new ReentrantLock();
+ protected int scheduleDelaySeconds;
+ protected ScheduledFuture<?> scheduledFuture;
+
+ public ResourceManagerPool(String name, String type, ResourceManager
resourceManager,
+ Map<String, Object> poolLimits, Map<String,
Object> poolParams) {
+ this.name = name;
+ this.type = type;
+ this.resourceManager = resourceManager;
+ this.componentClass =
resourceManager.getResourceManagerPoolFactory().getComponentClassByType(type);
+ this.poolLimits = new HashMap<>(poolLimits);
+ this.poolParams = new HashMap<>(poolParams);
+ }
+
+ /** Unique pool name. */
+ public String getName() {
+ return name;
+ }
+
+ /** Pool type. */
+ public String getType() {
+ return type;
+ }
+
+ public ResourceManager getResourceManager() {
+ return resourceManager;
+ }
+
+ /** Add component to this pool. */
+ public void registerComponent(T managedComponent) {
+ if (!componentClass.isAssignableFrom(managedComponent.getClass())) {
+ log.debug("Pool type '" + type + "' is not supported by the component "
+ managedComponent.getManagedComponentId());
+ return;
+ }
+ ManagedComponent existing =
components.putIfAbsent(managedComponent.getManagedComponentId().toString(),
managedComponent);
+ if (existing != null) {
+ throw new IllegalArgumentException("Component '" +
managedComponent.getManagedComponentId() + "' already exists in pool '" + name
+ "' !");
+ }
+ }
+
+ /** Remove named component from this pool. */
+ public boolean unregisterComponent(String componentId) {
+ return components.remove(name) != null;
+ }
+
+ /**
+ * Check whether a named component is registered in this pool.
+ * @param componentId component id
+ * @return true if the component with this name is registered, false
otherwise.
+ */
+ public boolean isRegistered(String componentId) {
+ return components.containsKey(componentId);
+ }
+
+ /** Get components managed by this pool. */
+ public Map<String, T> getComponents() {
+ return Collections.unmodifiableMap(components);
+ }
+
+ public void addChangeListener(ChangeListener listener) {
+ if (!listeners.contains(listener)) {
+ listeners.add(listener);
+ }
+ }
+
+ public void removeChangeListener(ChangeListener listener) {
+ listeners.remove(listener);
+ }
+
+
+ /**
+ * Get the current monitored values from all resources. Result is a map with
resource names as keys,
+ * and param/value maps as values.
+ */
+ public Map<String, Map<String, Object>> getCurrentValues() throws
InterruptedException {
+ updateLock.lockInterruptibly();
Review comment:
Yes, it's a left-over from a previous refactoring.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@lucene.apache.org
For additional commands, e-mail: issues-h...@lucene.apache.org
