1
1
/*
2
- * Copyright (c) 2023, 2024 , Oracle and/or its affiliates. All rights reserved.
2
+ * Copyright (c) 2023, 2025 , Oracle and/or its affiliates. All rights reserved.
3
3
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4
4
*
5
5
* This code is free software; you can redistribute it and/or modify it
@@ -65,15 +65,15 @@ public int socketWriteJFREnabledEventDisabled(SkeletonFixture fixture) {
65
65
@ Fork (value = 1 , jvmArgs = {
66
66
"--add-exports" ,
67
67
"java.base/jdk.internal.event=ALL-UNNAMED" ,
68
- "-XX:StartFlightRecording:jdk.SocketWrite#enabled=true,jdk.SocketWrite#threshold=1s" })
68
+ "-XX:StartFlightRecording:jdk.SocketWrite#enabled=true,jdk.SocketWrite#threshold=1s,jdk.SocketWrite#throttle=off " })
69
69
@ Benchmark
70
70
public int socketWriteJFREnabledEventNotEmitted (SkeletonFixture fixture ) {
71
71
return fixture .write ();
72
72
}
73
73
74
74
@ Fork (value = 1 , jvmArgs = {
75
75
"--add-exports" ,"java.base/jdk.internal.event=ALL-UNNAMED" ,
76
- "-XX:StartFlightRecording:jdk.SocketWrite#enabled=true,jdk.SocketWrite#threshold=0ms,disk=false,jdk.SocketWrite#stackTrace=false" })
76
+ "-XX:StartFlightRecording:jdk.SocketWrite#enabled=true,jdk.SocketWrite#threshold=0ms,disk=false,jdk.SocketWrite#stackTrace=false,jdk.SocketWrite#throttle=off " })
77
77
@ Benchmark
78
78
public int socketWriteJFREnabledEventEmitted (SkeletonFixture fixture ) {
79
79
return fixture .write ();
@@ -99,15 +99,15 @@ public int socketReadJFREnabledEventDisabled(SkeletonFixture fixture) {
99
99
@ Fork (value = 1 , jvmArgs = {
100
100
"--add-exports" ,
101
101
"java.base/jdk.internal.event=ALL-UNNAMED" ,
102
- "-XX:StartFlightRecording:jdk.SocketRead#enabled=true,jdk.SocketRead#threshold=1s" })
102
+ "-XX:StartFlightRecording:jdk.SocketRead#enabled=true,jdk.SocketRead#threshold=1s,jdk.SocketRead#throttle=off " })
103
103
@ Benchmark
104
104
public int socketReadJFREnabledEventNotEmitted (SkeletonFixture fixture ) {
105
105
return fixture .read ();
106
106
}
107
107
108
108
@ Fork (value = 1 , jvmArgs = {
109
109
"--add-exports" ,"java.base/jdk.internal.event=ALL-UNNAMED" ,
110
- "-XX:StartFlightRecording:jdk.SocketRead#enabled=true,jdk.SocketRead#threshold=0ms,disk=false,jdk.SocketRead#stackTrace=false" })
110
+ "-XX:StartFlightRecording:jdk.SocketRead#enabled=true,jdk.SocketRead#threshold=0ms,disk=false,jdk.SocketRead#stackTrace=false,jdk.SocketRead#throttle=off " })
111
111
@ Benchmark
112
112
public int socketReadJFREnabledEventEmitted (SkeletonFixture fixture ) {
113
113
return fixture .read ();
@@ -137,10 +137,7 @@ public int write() {
137
137
try {
138
138
nbytes = write0 ();
139
139
} finally {
140
- long duration = start - SocketWriteEvent .timestamp ();
141
- if (SocketWriteEvent .shouldCommit (duration )) {
142
- SocketWriteEvent .emit (start , duration , nbytes , getRemoteAddress ());
143
- }
140
+ SocketWriteEvent .offer (start , nbytes , getRemoteAddress ());
144
141
}
145
142
return nbytes ;
146
143
}
@@ -158,10 +155,7 @@ public int read() {
158
155
try {
159
156
nbytes = read0 ();
160
157
} finally {
161
- long duration = start - SocketReadEvent .timestamp ();
162
- if (SocketReadEvent .shouldCommit (duration )) {
163
- SocketReadEvent .emit (start , duration , nbytes , getRemoteAddress (), 0 );
164
- }
158
+ SocketReadEvent .offer (start , nbytes , getRemoteAddress (), 0 );
165
159
}
166
160
return nbytes ;
167
161
}
0 commit comments