Skip to content

Commit a3ad702

Browse files
committed
Added support for setting thread affinity using a description, closes #54
1 parent 96ae1d2 commit a3ad702

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

affinity/src/main/java/net/openhft/affinity/AffinityLock.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -312,7 +312,7 @@ public void bind(boolean wholeCore) {
312312
} else if (cpuId >= 0) {
313313
bound = true;
314314
assignedThread = Thread.currentThread();
315-
LOGGER.info("Assigning cpu {} to {}", cpuId, assignedThread);
315+
LOGGER.info("Assigning cpu {} to {} on thread id {}", cpuId, assignedThread, Affinity.getThreadId());
316316
}
317317
if (cpuId >= 0) {
318318
BitSet affinity = new BitSet();

affinity/src/main/java/net/openhft/affinity/lockchecker/FileLockBasedLockChecker.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -137,7 +137,7 @@ public String getMetaInfo(int id) throws IOException {
137137
FileChannel fc = lr.channel;
138138
ByteBuffer buffer = ByteBuffer.allocate(64);
139139
int len = fc.read(buffer, 0);
140-
String content = new String(buffer.array(), 0, len);
140+
String content = len < 1 ? "" : new String(buffer.array(), 0, len);
141141
if (content.isEmpty()) {
142142
LOGGER.warn("Empty lock file {}", file.getAbsolutePath());
143143
return null;

0 commit comments

Comments
 (0)