introduced - LockCheck.updateCpu(al.cpuId());

Rob Austin · Rob Austin · commit e9306e7fcbd4 · 2016-07-29T12:43:28.000+01:00
diff --git a/affinity/src/main/java/net/openhft/affinity/LockInventory.java b/affinity/src/main/java/net/openhft/affinity/LockInventory.java
@@ -88,7 +88,7 @@ public final synchronized AffinityLock acquireLock(boolean bind, int cpuId, Affi
                 AffinityLock al = logicalCoreLocks[i];
                 if (al.canReserve() && (cpuId < 0 || strategy.matches(cpuId, al.cpuId()))) {
                     al.assignCurrentThread(bind, false);
-                    //   LockCheck.updateCpu(al.cpuId());
+                    LockCheck.updateCpu(al.cpuId());
                     return al;
                 }
             }
@@ -109,7 +109,7 @@ public final synchronized AffinityLock acquireCore(boolean bind, int cpuId, Affi
 
                 final AffinityLock al = als[0];
                 al.assignCurrentThread(bind, true);
-                //   LockCheck.updateCpu(al.cpuId());
+                LockCheck.updateCpu(al.cpuId());
                 return al;
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -88,7 +88,7 @@ public final synchronized AffinityLock acquireLock(boolean bind, int cpuId, Affi`
`88`	`88`	`AffinityLock al = logicalCoreLocks[i];`
`89`	`89`	`if (al.canReserve() && (cpuId < 0 \|\| strategy.matches(cpuId, al.cpuId()))) {`
`90`	`90`	`al.assignCurrentThread(bind, false);`
`91`		`- // LockCheck.updateCpu(al.cpuId());`
	`91`	`+ LockCheck.updateCpu(al.cpuId());`
`92`	`92`	`return al;`
`93`	`93`	`}`
`94`	`94`	`}`
`@@ -109,7 +109,7 @@ public final synchronized AffinityLock acquireCore(boolean bind, int cpuId, Affi`
`109`	`109`
`110`	`110`	`final AffinityLock al = als[0];`
`111`	`111`	`al.assignCurrentThread(bind, true);`
`112`		`- // LockCheck.updateCpu(al.cpuId());`
	`112`	`+ LockCheck.updateCpu(al.cpuId());`
`113`	`113`	`return al;`
`114`	`114`	`}`
`115`	`115`	`}`