AFFINITY-9 Made the bind operation more tolerant of the case when no CPU/Core could be reserved

JozsefBartokHFT · JozsefBartokHFT · commit 74d122c36c19 · 2014-05-03T08:42:29.000+03:00
diff --git a/affinity/src/main/java/net/openhft/affinity/AffinityLock.java b/affinity/src/main/java/net/openhft/affinity/AffinityLock.java
@@ -212,7 +212,7 @@ public void bind(boolean wholeCore) {
             throw new IllegalStateException("cpu " + cpuId + " already bound to " + assignedThread);
 
         if (wholeCore) {
-            lockInventory.bindWhileCore(cpuId);
+            lockInventory.bindWholeCore(cpuId);
         } else if (cpuId >= 0) {
             bound = true;
             assignedThread = Thread.currentThread();
diff --git a/affinity/src/main/java/net/openhft/affinity/LockInventory.java b/affinity/src/main/java/net/openhft/affinity/LockInventory.java
@@ -92,7 +92,12 @@ public final synchronized AffinityLock acquireCore(boolean bind, int cpuId, Affi
         return acquireLock(bind, cpuId, strategies);
     }
 
-    public final synchronized void bindWhileCore(int logicalCoreID) {
+    public final synchronized void bindWholeCore(int logicalCoreID) {
+        if (logicalCoreID < 0) {
+            LOGGER.warning("Can't bind core since it was not possible to reserve it!");
+            return;
+        }
+
         int core = toPhysicalCore(logicalCoreID);
         for (AffinityLock al : physicalCoreLocks.get(core)) {
             if (al.isBound() && al.assignedThread != null && al.assignedThread.isAlive()) {
