"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "dso-l2/src/main/java/com/tc/l2/state/StateManager.java" between
terracotta-core-5.7.0.tar.gz and terracotta-core-5.7.1.tar.gz

About: Terracotta - Clustering technology for Java ("Network Attached Memory", "Distributed Cache"). Source code of the server (5.x) core components.

StateManager.java  (terracotta-core-5.7.0):StateManager.java  (terracotta-core-5.7.1)
skipping to change at line 24 skipping to change at line 24
* *
* The Initial Developer of the Covered Software is * The Initial Developer of the Covered Software is
* Terracotta, Inc., a Software AG company * Terracotta, Inc., a Software AG company
* *
*/ */
package com.tc.l2.state; package com.tc.l2.state;
import com.tc.l2.context.StateChangedEvent; import com.tc.l2.context.StateChangedEvent;
import com.tc.l2.msg.L2StateMessage; import com.tc.l2.msg.L2StateMessage;
import com.tc.net.NodeID; import com.tc.net.NodeID;
import com.tc.net.ServerID;
import com.tc.net.groups.GroupException; import com.tc.net.groups.GroupException;
import com.tc.util.State; import com.tc.util.State;
import java.util.Set; import java.util.Set;
import com.tc.text.PrettyPrintable; import com.tc.text.PrettyPrintable;
public interface StateManager extends PrettyPrintable { public interface StateManager extends PrettyPrintable {
public final State ACTIVE_COORDINATOR = new State("ACTIVE-COORDINATOR" ); public final State ACTIVE_COORDINATOR = new State("ACTIVE-COORDINATOR" );
public final State RECOVERING_STATE = new State("RECOVERING"); public final State RECOVERING_STATE = new State("RECOVERING");
public final State PASSIVE_UNINITIALIZED = new State("PASSIVE-UNINITIALI ZED"); public final State PASSIVE_UNINITIALIZED = new State("PASSIVE-UNINITIALI ZED");
skipping to change at line 65 skipping to change at line 66
public void moveToStopState(); public void moveToStopState();
public boolean moveToStopStateIf(Set<ServerMode> validStates); public boolean moveToStopStateIf(Set<ServerMode> validStates);
public void publishActiveState(NodeID nodeID) throws GroupException; public void publishActiveState(NodeID nodeID) throws GroupException;
public void handleClusterStateMessage(L2StateMessage clusterMsg); public void handleClusterStateMessage(L2StateMessage clusterMsg);
public NodeID getActiveNodeID(); public NodeID getActiveNodeID();
public Set<NodeID> getPassiveStandbys(); public Set<ServerID> getPassiveStandbys();
public static ServerMode convert(State state) { public static ServerMode convert(State state) {
if (state == null) { if (state == null) {
return ServerMode.START; return ServerMode.START;
} else { } else {
return ServerMode.VALID_STATES.stream().filter(m->m.getState().equals(stat e)).findFirst().get(); return ServerMode.VALID_STATES.stream().filter(m->m.getState().equals(stat e)).findFirst().get();
} }
} }
} }
 End of changes. 2 change blocks. 
1 lines changed or deleted 2 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)