honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[ENHANCEMENT] clear out finished notifications on cluster change 

Original commit: elastic/x-pack-elasticsearch@22e31ff0a3
This commit is contained in:
Areek Zillur 2015-01-23 13:37:26 -05:00
parent d9fa7bec0f
commit 5387741df2
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
plugin/src/main/java/org/elasticsearch/license/plugin/core/LicensesService.java
View File

@ -52,7 +52,7 @@ import static org.elasticsearch.license.core.Licenses.reduceAndMap;
* <p/> * <p/>
* Registration Scheme: * Registration Scheme:
* <p/> * <p/>
* A consumer plugin (feature) is registered with {@link LicensesClientService#register(String, TrialLicenseOptions, java.util.Collection<org.elasticsearch.license.plugin.core.LicensesService.ExpirationCallback>, LicensesClientService.Listener)} * A consumer plugin (feature) is registered with {@link LicensesClientService#register(String, TrialLicenseOptions, java.util.Collection<ExpirationCallback>, LicensesClientService.Listener)}
* This method can be called at any time during the life-cycle of the consumer plugin. * This method can be called at any time during the life-cycle of the consumer plugin.
* If the feature can not be registered immediately, it is queued up and registered on the first clusterChanged event with * If the feature can not be registered immediately, it is queued up and registered on the first clusterChanged event with
* no {@link org.elasticsearch.gateway.GatewayService#STATE_NOT_RECOVERED_BLOCK} block * no {@link org.elasticsearch.gateway.GatewayService#STATE_NOT_RECOVERED_BLOCK} block
@ -905,9 +905,14 @@ public class LicensesService extends AbstractLifecycleComponent<LicensesService>
}; };
} }
/**
* schedules all {@link ExpirationCallback} associated with <code>license</code>
* If callbacks are already scheduled clear up finished notifications from the queue
*/
private void scheduleNotificationIfNeeded(final License license) { private void scheduleNotificationIfNeeded(final License license) {
long expiryDate = ((license != null) ? license.expiryDate() : -1l); long expiryDate = ((license != null) ? license.expiryDate() : -1l);
if (currentExpiryDate.get() == expiryDate) { if (currentExpiryDate.get() == expiryDate) {
clearFinishedNotifications(notificationQueue);
return; return;
} }
currentExpiryDate.set(expiryDate); currentExpiryDate.set(expiryDate);