Reaction nextReaction;
synchronized (reactions) {
for (Entry<String, Reaction> reactionEntry : reactions.entrySet()) {
- net.pterodactylus.reactor.State state = stateManager.loadState(reactionEntry.getKey());
+ net.pterodactylus.reactor.State state = stateManager.loadLastState(reactionEntry.getKey());
long stateTime = (state != null) ? state.time() : 0;
nextReactions.put(stateTime + reactionEntry.getValue().updateInterval(), Pair.of(reactionEntry.getKey(), reactionEntry.getValue()));
}
logger.debug(String.format("Next Reaction: %s.", nextReaction));
/* wait until the next reaction has to run. */
- net.pterodactylus.reactor.State lastState = stateManager.loadState(reactionName);
+ net.pterodactylus.reactor.State lastState = stateManager.loadLastState(reactionName);
long lastStateTime = (lastState != null) ? lastState.time() : 0;
int lastStateFailCount = (lastState != null) ? lastState.failCount() : 0;
long waitTime = (lastStateTime + nextReaction.updateInterval()) - System.currentTimeMillis();
//
/**
- * Loads the state with the given name.
+ * Loads the last state with the given name.
*
* @param reactionName
* The name of the reaction
* @return The loaded state, or {@code null} if the state could not be
* loaded
*/
- public State loadState(String reactionName) {
+ public State loadLastState(String reactionName) {
File stateFile = stateFile(reactionName);
try {
State state = objectMapper.readValue(stateFile, AbstractState.class);