diff --git a/src/test/java/net/openhft/chronicle/map/fromdocs/acid/DirtyReadIntolerant.java b/src/test/java/net/openhft/chronicle/map/fromdocs/acid/DirtyReadTolerance.java similarity index 87% rename from src/test/java/net/openhft/chronicle/map/fromdocs/acid/DirtyReadIntolerant.java rename to src/test/java/net/openhft/chronicle/map/fromdocs/acid/DirtyReadTolerance.java index 421589c5d..12cf3b0bc 100644 --- a/src/test/java/net/openhft/chronicle/map/fromdocs/acid/DirtyReadIntolerant.java +++ b/src/test/java/net/openhft/chronicle/map/fromdocs/acid/DirtyReadTolerance.java @@ -17,18 +17,19 @@ import java.util.Arrays; import static net.openhft.chronicle.values.Values.newNativeReference; -public class DirtyReadIntolerant { +public class DirtyReadTolerance { - public static void main(String... ignored) throws Exception { + public static void main(String args[]) throws Exception { - System.out.println("DirtyReadOffender,chrAig,DirtyReadVictim"); + System.out.println("DirtyReadOffender,chrAig["+args[0]+"],DirtyReadVictim"); + String isoLevel = args[0]; ChronicleMap operand = - DirtyReadIntolerant.acquireChronicleMapOperand( + DirtyReadTolerance.acquireChronicleMapOperand( "C:\\Users\\buddy\\dev\\shm\\OPERAND_CHRONICLE_MAP" ); ChronicleMap operator = - DirtyReadIntolerant.acquireChronicleMapOperator( + DirtyReadTolerance.acquireChronicleMapOperator( "C:\\Users\\buddy\\dev\\shm\\OPERATOR_CHRONICLE_MAP" ); ChronicleAcidIsolationGovernor chrAig = new ChronicleAcidIsolationGovernor(); @@ -40,7 +41,7 @@ public class DirtyReadIntolerant { DirtyReadOffender offender = new DirtyReadOffender(); offender.setCraig(chrAig); - DirtyReadVictim victim = new DirtyReadVictim(); + DirtyReadVictim victim = new DirtyReadVictim(isoLevel); victim.setCraig(chrAig); (new Thread(offender)).start(); diff --git a/src/test/java/net/openhft/chronicle/map/fromdocs/acid/DirtyReadVictim.java b/src/test/java/net/openhft/chronicle/map/fromdocs/acid/DirtyReadVictim.java index 0fd68cc6c..d41b963fa 100644 --- a/src/test/java/net/openhft/chronicle/map/fromdocs/acid/DirtyReadVictim.java +++ b/src/test/java/net/openhft/chronicle/map/fromdocs/acid/DirtyReadVictim.java @@ -4,13 +4,19 @@ package net.openhft.chronicle.map.fromdocs.acid; import net.openhft.chronicle.map.acid.BondVOInterface; import net.openhft.chronicle.map.acid.ChronicleAcidIsolation; import net.openhft.chronicle.map.acid.ChronicleAcidIsolationGovernor; - import java.sql.SQLException; import java.util.Scanner; - import static net.openhft.chronicle.values.Values.newNativeReference; public class DirtyReadVictim implements Runnable { + int isoLevel = ChronicleAcidIsolation.LOWEST_LATENCY; + + DirtyReadVictim(String isoL) { + if (isoL.equals("DIRTY_READ_INTOLERANT")) + this.isoLevel = ChronicleAcidIsolation.DIRTY_READ_INTOLERANT; + else if (isoL.equals("DIRTY_READ_OPTIMISTIC")) + this.isoLevel = ChronicleAcidIsolation.DIRTY_READ_OPTIMISTIC; + } ChronicleAcidIsolationGovernor chrAig; @@ -40,7 +46,9 @@ public class DirtyReadVictim implements Runnable { " DirtyReadVictim calling chrAig.get('369604101')" ); //sc.nextLine(); - chrAig.setTransactionIsolation(ChronicleAcidIsolation.DIRTY_READ_INTOLERANT); + chrAig.setTransactionIsolation(this.isoLevel); + //chrAig.setTransactionIsolation(ChronicleAcidIsolation.DIRTY_READ_INTOLERANT); + //chrAig.setTransactionIsolation(ChronicleAcidIsolation.DIRTY_READ_OPTIMISTIC); bond = chrAig.get("369604101"); Double coupon = bond.getCoupon(); System.out.println(