ChronosXYZ/JGUN
1
0
Fork 0
mirror of https://github.com/ChronosX88/JGUN.git synced 2024-11-21 22:12:18 +00:00
Code Issues Projects Releases Wiki Activity

Added some information (and comments) in HAM CRDT class

Browse Source
This commit is contained in:
ChronosX88 2019-05-07 21:04:43 +04:00
parent b563c94cca
commit 2ab66392b2
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/main/java/io/github/chronosx88/JGUN/HAM.java
View File

@ -7,35 +7,36 @@ import org.json.JSONObject;
import java.util.Map; import java.util.Map;
public class HAM { public class HAM {
private static long defer = Long.MAX_VALUE;
static class HAMResult { static class HAMResult {
public boolean defer = false; public boolean defer = false; // Defer means that the current state is greater than our computer time, and should only be processed when our computer time reaches this state
public boolean historical = false; public boolean historical = false; // Historical means the old state. This is usually ignored.
public boolean converge = false; public boolean converge = false; // Everything is fine, you can do merge
public boolean incoming = false; public boolean incoming = false; // Leave incoming value
public boolean current = false; public boolean current = false; // Leave current value
public boolean state = false; public boolean state = false;
public String err = null;
} }
public static HAMResult ham(long machineState, long incomingState, long currentState, Object incomingValue, Object currentValue) { public static HAMResult ham(long machineState, long incomingState, long currentState, Object incomingValue, Object currentValue) {
HAMResult result = new HAMResult(); HAMResult result = new HAMResult();
if(machineState < incomingState) { if(machineState < incomingState) {
// the incoming value is outside the boundary of the machine's state, it must be reprocessed in another state.
result.defer = true; result.defer = true;
return result; return result;
} }
if(incomingState < currentState) { if(incomingState < currentState) {
// the incoming value is within the boundary of the machine's state, but not within the range.
result.historical = true; result.historical = true;
return result; return result;
} }
if(currentState < incomingState) { if(currentState < incomingState) {
// the incoming value is within both the boundary and the range of the machine's state.
result.converge = true; result.converge = true;
result.incoming = true; result.incoming = true;
return result; return result;
} }
if(incomingState == currentState) { if(incomingState == currentState) {
// if incoming state and current state is the same
if(incomingValue.equals(currentValue)) { if(incomingValue.equals(currentValue)) {
result.state = true; result.state = true;
return result; return result;
@ -51,8 +52,7 @@ public class HAM {
return result; return result;
} }
} }
result.err = "Invalid CRDT Data: "+ incomingValue +" to "+ currentValue +" at "+ incomingState +" to "+ currentState +"!"; throw new IllegalArgumentException("Invalid CRDT Data: "+ incomingValue +" to "+ currentValue +" at "+ incomingState +" to "+ currentState +"!");
return result;
} }
public static InMemoryGraph mix(InMemoryGraph change, StorageBackend data) { public static InMemoryGraph mix(InMemoryGraph change, StorageBackend data) {