mirror of
https://github.com/OpenHFT/Chronicle-Map.git
synced 2021-09-13 01:26:12 +00:00
Reduce redundant newlines
This commit is contained in:
@@ -25,7 +25,8 @@ import net.openhft.chronicle.core.OS;
|
||||
* are stateful - so need to keep an instance in thread local that seems to be overall more pain
|
||||
* than gain.
|
||||
*/
|
||||
public enum TierCountersArea {;
|
||||
public enum TierCountersArea {
|
||||
; // none
|
||||
|
||||
public static final long NEXT_TIER_INDEX_OFFSET = 0L;
|
||||
public static final long PREV_TIER_INDEX_OFFSET = NEXT_TIER_INDEX_OFFSET + 8L;
|
||||
|
||||
@@ -16,7 +16,8 @@
|
||||
|
||||
package net.openhft.chronicle.hash.impl.stage.entry;
|
||||
|
||||
public enum ChecksumHashing {;
|
||||
public enum ChecksumHashing {
|
||||
; // none
|
||||
|
||||
/**
|
||||
* A smart procedure copied from CityHash/FarmHash, see the full implementation in
|
||||
|
||||
@@ -3,7 +3,8 @@ package net.openhft.chronicle.map.internal;
|
||||
import net.openhft.chronicle.core.analytics.AnalyticsFacade;
|
||||
import net.openhft.chronicle.core.pom.PomProperties;
|
||||
|
||||
public enum AnalyticsHolder {;
|
||||
public enum AnalyticsHolder {
|
||||
; // none
|
||||
|
||||
// Todo: VERSION is "unknown" for some reason
|
||||
private static final String VERSION = PomProperties.version("net.openhft", "chronicle-map");
|
||||
|
||||
@@ -42,7 +42,8 @@ public class DirtyReadOffender implements Runnable {
|
||||
" @t=" + System.currentTimeMillis() +
|
||||
" DirtyReadOffender ACQUIRING offHeapLock.writeLock();"
|
||||
);
|
||||
while ((stamp = this.offHeapLock.writeLock()) == 0) {;
|
||||
while ((stamp = this.offHeapLock.writeLock()) == 0) {
|
||||
; // none
|
||||
}
|
||||
System.out.println(
|
||||
" @t=" + System.currentTimeMillis() +
|
||||
|
||||
@@ -36,7 +36,8 @@ public class DirtyReadVictim implements Runnable {
|
||||
" ,,@t=" + System.currentTimeMillis() +
|
||||
" DirtyReadVictim CALLING offHeapLock.tryOptimisticRead()"
|
||||
);
|
||||
while ((stamp = this.offHeapLock.tryOptimisticRead()) == 0) {;
|
||||
while ((stamp = this.offHeapLock.tryOptimisticRead()) == 0) {
|
||||
; // none
|
||||
}
|
||||
System.out.println(
|
||||
" ,,@t=" + System.currentTimeMillis() +
|
||||
|
||||
+2
-1
@@ -42,7 +42,8 @@ public class DirtyReadOffender implements Runnable {
|
||||
" @t=" + System.currentTimeMillis() +
|
||||
" DirtyReadOffender ACQUIRING offHeapLock.writeLock();"
|
||||
);
|
||||
while ((stamp = this.offHeapLock.writeLock()) == 0) {;
|
||||
while ((stamp = this.offHeapLock.writeLock()) == 0) {
|
||||
; // none
|
||||
}
|
||||
System.out.println(
|
||||
" @t=" + System.currentTimeMillis() +
|
||||
|
||||
@@ -36,7 +36,8 @@ public class DirtyReadVictim implements Runnable {
|
||||
" ,,@t=" + System.currentTimeMillis() +
|
||||
" DirtyReadVictim CALLING offHeapLock.tryOptimisticRead()"
|
||||
);
|
||||
while ((stamp = this.offHeapLock.tryOptimisticRead()) == 0) {;
|
||||
while ((stamp = this.offHeapLock.tryOptimisticRead()) == 0) {
|
||||
; // none
|
||||
}
|
||||
System.out.println(
|
||||
" ,,@t=" + System.currentTimeMillis() +
|
||||
|
||||
+2
-1
@@ -368,7 +368,8 @@ public class ChronicleStampedLock extends StampedLock {
|
||||
unlockWrite(stamp);
|
||||
} else if (stamp > 0L) {
|
||||
unlockRead(stamp);
|
||||
} else {;// lock available
|
||||
} else {
|
||||
; // none// lock available
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
+2
-1
@@ -39,7 +39,8 @@ public class DirtyReadIntolerant {
|
||||
" DirtyReadIntolerant sleeping " + sleepMock + " seconds"
|
||||
);
|
||||
Thread.sleep(sleepMock * 1_000);
|
||||
while ((stamp = offHeapLock.readLock()) < 0) {;
|
||||
while ((stamp = offHeapLock.readLock()) < 0) {
|
||||
; // none
|
||||
}
|
||||
System.out.println(
|
||||
" ,,@t=" + System.currentTimeMillis() +
|
||||
|
||||
+2
-1
@@ -56,7 +56,8 @@ public class DirtyReadOffender {
|
||||
" @t=" + System.currentTimeMillis() +
|
||||
" DirtyReadOffender ACQUIRING offHeapLock.writeLock();"
|
||||
);
|
||||
while ((stamp = offHeapLock.writeLock()) == 0) {;
|
||||
while ((stamp = offHeapLock.writeLock()) == 0) {
|
||||
; // none
|
||||
}
|
||||
System.out.println(
|
||||
" @t=" + System.currentTimeMillis() +
|
||||
|
||||
+2
-1
@@ -43,7 +43,8 @@ public class DirtyReadVictimTest {
|
||||
OS.getTarget() + "/OPERAND_ChronicleStampedLock"
|
||||
/*"C:\\Users\\buddy\\dev\\shm\\OPERAND_ChronicleStampedLock"*/
|
||||
);
|
||||
while ((stamp = offHeapLock.tryOptimisticRead()) == 0) {;
|
||||
while ((stamp = offHeapLock.tryOptimisticRead()) == 0) {
|
||||
; // none
|
||||
}
|
||||
System.out.println(
|
||||
" ,,@t=" + System.currentTimeMillis() +
|
||||
|
||||
@@ -63,7 +63,8 @@ public class DirtyReadOffenderIPCTest implements Runnable {
|
||||
"..... @t=" + System.currentTimeMillis() +
|
||||
" DirtyReadOffender ACQUIRING offHeapLock.writeLock();"
|
||||
);
|
||||
while ((stamp = offHeapLock.writeLock()) == 0) {;
|
||||
while ((stamp = offHeapLock.writeLock()) == 0) {
|
||||
; // none
|
||||
}
|
||||
System.out.println(
|
||||
"..... @t=" + System.currentTimeMillis() +
|
||||
|
||||
@@ -52,7 +52,8 @@ class DirtyReadOffenderTest implements Runnable {
|
||||
"..... @t=" + System.currentTimeMillis() +
|
||||
" DirtyReadOffender ACQUIRING offHeapLock.writeLock();"
|
||||
);
|
||||
while ((stamp = offHeapLock.writeLock()) == 0) {;
|
||||
while ((stamp = offHeapLock.writeLock()) == 0) {
|
||||
; // none
|
||||
}
|
||||
System.out.println(
|
||||
"..... @t=" + System.currentTimeMillis() +
|
||||
|
||||
@@ -84,7 +84,8 @@ public class DirtyReadVictimIPCTest {
|
||||
OS.getTarget() + "/shm-" +
|
||||
"OPERAND_ChronicleStampedLock"
|
||||
);
|
||||
while ((stamp = offHeapLock.tryOptimisticRead()) == 0) {;
|
||||
while ((stamp = offHeapLock.tryOptimisticRead()) == 0) {
|
||||
; // none
|
||||
}
|
||||
System.out.println(
|
||||
" ,,@t=" + System.currentTimeMillis() +
|
||||
@@ -178,7 +179,8 @@ public class DirtyReadVictimIPCTest {
|
||||
OS.getTarget() + "/shm-"
|
||||
+ "OPERAND_ChronicleStampedLock"
|
||||
);
|
||||
while ((stamp = offHeapLock.tryOptimisticRead()) == 0) {;
|
||||
while ((stamp = offHeapLock.tryOptimisticRead()) == 0) {
|
||||
; // none
|
||||
}
|
||||
System.out.println(
|
||||
" ,,@t=" + System.currentTimeMillis() +
|
||||
|
||||
Reference in New Issue
Block a user