Replacement of ThreadHints.onSpinWait by Thread.

The ThreadHints class in Agrona has been deprecated and all call to ThreadHints.onSpinWait have been replaced by Thread.onSpinWait.
real-logic · Jan 14, 2025 · e4d59ba · e4d59ba
1 parent cd224ec
commit e4d59ba
Show file tree

Hide file tree

Showing 8 changed files with 12 additions and 14 deletions.
diff --git a/aeron-driver/src/main/java/io/aeron/driver/DriverConductor.java b/aeron-driver/src/main/java/io/aeron/driver/DriverConductor.java
@@ -1916,6 +1916,11 @@ private void initLogMetadata(
     {
         final UnsafeBuffer logMetaData = rawLog.metaData();
 
+        System.out.println("SessionId: " + sessionId +
+            " streamId:" + streamId +
+            " initialTermId:" + initialTermId +
+            " mtuLength:" + mtuLength);
+
         defaultDataHeader
             .sessionId(sessionId)
             .streamId(streamId)

diff --git a/aeron-samples/src/main/java/io/aeron/samples/raw/BurstSendReceiveUdpPing.java b/aeron-samples/src/main/java/io/aeron/samples/raw/BurstSendReceiveUdpPing.java
@@ -21,7 +21,6 @@
 import org.agrona.SystemUtil;
 import org.agrona.concurrent.HighResolutionTimer;
 import org.agrona.concurrent.SigInt;
-import org.agrona.hints.ThreadHints;
 
 import java.io.IOException;
 import java.net.InetSocketAddress;
@@ -139,7 +138,7 @@ private static void measureRoundTrip(
                     {
                         break;
                     }
-                    ThreadHints.onSpinWait();
+                    Thread.onSpinWait();
                 }
 
                 final long receivedSequenceNumber = buffer.getLong(0);

diff --git a/aeron-samples/src/main/java/io/aeron/samples/raw/ReceiveSendUdpPong.java b/aeron-samples/src/main/java/io/aeron/samples/raw/ReceiveSendUdpPong.java
@@ -19,7 +19,6 @@
 import org.agrona.SystemUtil;
 import org.agrona.concurrent.HighResolutionTimer;
 import org.agrona.concurrent.SigInt;
-import org.agrona.hints.ThreadHints;
 
 import java.io.IOException;
 import java.net.InetSocketAddress;
@@ -88,7 +87,7 @@ public static void main(final String[] args) throws IOException
             boolean available = false;
             while (!available)
             {
-                ThreadHints.onSpinWait();
+                Thread.onSpinWait();
                 if (!running.get())
                 {
                     return;

diff --git a/aeron-samples/src/main/java/io/aeron/samples/raw/ReceiveWriteUdpPong.java b/aeron-samples/src/main/java/io/aeron/samples/raw/ReceiveWriteUdpPong.java
@@ -18,7 +18,6 @@
 import org.agrona.SystemUtil;
 import org.agrona.concurrent.HighResolutionTimer;
 import org.agrona.concurrent.SigInt;
-import org.agrona.hints.ThreadHints;
 
 import java.io.IOException;
 import java.net.InetSocketAddress;
@@ -79,7 +78,7 @@ public static void main(final String[] args) throws IOException
             boolean available = false;
             while (!available)
             {
-                ThreadHints.onSpinWait();
+                Thread.onSpinWait();
                 if (!running.get())
                 {
                     return;

diff --git a/aeron-samples/src/main/java/io/aeron/samples/raw/SelectReceiveSendUdpPong.java b/aeron-samples/src/main/java/io/aeron/samples/raw/SelectReceiveSendUdpPong.java
@@ -19,7 +19,6 @@
 import org.agrona.SystemUtil;
 import org.agrona.concurrent.HighResolutionTimer;
 import org.agrona.concurrent.SigInt;
-import org.agrona.hints.ThreadHints;
 
 import java.io.IOException;
 import java.net.InetSocketAddress;
@@ -107,7 +106,7 @@ public static void main(final String[] args) throws IOException
                     return;
                 }
 
-                ThreadHints.onSpinWait();
+                Thread.onSpinWait();
             }
 
             final Set<SelectionKey> selectedKeys = selector.selectedKeys();

diff --git a/aeron-samples/src/main/java/io/aeron/samples/raw/SendReceiveUdpPing.java b/aeron-samples/src/main/java/io/aeron/samples/raw/SendReceiveUdpPing.java
@@ -21,7 +21,6 @@
 import org.agrona.SystemUtil;
 import org.agrona.concurrent.HighResolutionTimer;
 import org.agrona.concurrent.SigInt;
-import org.agrona.hints.ThreadHints;
 
 import java.io.IOException;
 import java.net.InetSocketAddress;
@@ -119,7 +118,7 @@ private static void measureRoundTrip(
             boolean available = false;
             while (!available)
             {
-                ThreadHints.onSpinWait();
+                Thread.onSpinWait();
                 if (!running.get())
                 {
                     return;

diff --git a/aeron-samples/src/main/java/io/aeron/samples/raw/SendSelectReceiveUdpPing.java b/aeron-samples/src/main/java/io/aeron/samples/raw/SendSelectReceiveUdpPing.java
@@ -21,7 +21,6 @@
 import org.agrona.collections.MutableLong;
 import org.agrona.concurrent.HighResolutionTimer;
 import org.agrona.concurrent.SigInt;
-import org.agrona.hints.ThreadHints;
 
 import java.io.IOException;
 import java.net.InetSocketAddress;
@@ -145,7 +144,7 @@ private static void measureRoundTrip(
                     return;
                 }
 
-                ThreadHints.onSpinWait();
+                Thread.onSpinWait();
             }
 
             final Set<SelectionKey> selectedKeys = selector.selectedKeys();

diff --git a/aeron-samples/src/main/java/io/aeron/samples/raw/WriteReceiveUdpPing.java b/aeron-samples/src/main/java/io/aeron/samples/raw/WriteReceiveUdpPing.java
@@ -18,7 +18,6 @@
 import org.agrona.SystemUtil;
 import org.agrona.concurrent.HighResolutionTimer;
 import org.agrona.concurrent.SigInt;
-import org.agrona.hints.ThreadHints;
 
 import java.io.IOException;
 import java.net.InetSocketAddress;
@@ -111,7 +110,7 @@ private static void measureRoundTrip(
             boolean available = false;
             while (!available)
             {
-                ThreadHints.onSpinWait();
+                Thread.onSpinWait();
                 if (!running.get())
                 {
                     return;