@@ -116,15 +116,10 @@ public void testSocketChannelWrite() throws Exception {
116
116
117
117
// write should block
118
118
ByteBuffer bb = ByteBuffer .allocate (100 *1024 );
119
- long total = 0 ;
120
119
for (int i =0 ; i <1000 ; i ++) {
121
120
int n = sc1 .write (bb );
122
121
assertTrue (n > 0 );
123
- total += n ;
124
122
bb .clear ();
125
- if ((i % 50 ) == 0 ) {
126
- System .out .println ("wrote: " + total );
127
- }
128
123
}
129
124
}
130
125
});
@@ -133,7 +128,6 @@ public void testSocketChannelWrite() throws Exception {
133
128
/**
134
129
* SocketChannel close while virtual thread blocked in read.
135
130
*/
136
- @ Test (enabled =false )
137
131
public void testSocketChannelReadAsyncClose () throws Exception {
138
132
TestHelper .runInVirtualThread (() -> {
139
133
try (var connection = new Connection ()) {
@@ -150,7 +144,6 @@ public void testSocketChannelReadAsyncClose() throws Exception {
150
144
/**
151
145
* Virtual thread interrupted while blocked in SocketChannel read.
152
146
*/
153
- @ Test (enabled =false )
154
147
public void testSocketChannelReadInterrupt () throws Exception {
155
148
TestHelper .runInVirtualThread (() -> {
156
149
try (var connection = new Connection ()) {
@@ -169,7 +162,6 @@ public void testSocketChannelReadInterrupt() throws Exception {
169
162
/**
170
163
* SocketChannel close while virtual thread blocked in write.
171
164
*/
172
- @ Test (enabled =false )
173
165
public void testSocketChannelWriteAsyncClose () throws Exception {
174
166
TestHelper .runInVirtualThread (() -> {
175
167
try (var connection = new Connection ()) {
@@ -190,7 +182,6 @@ public void testSocketChannelWriteAsyncClose() throws Exception {
190
182
/**
191
183
* Virtual thread interrupted while blocked in SocketChannel write.
192
184
*/
193
- @ Test (enabled =false )
194
185
public void testSocketChannelWriteInterrupt () throws Exception {
195
186
TestHelper .runInVirtualThread (() -> {
196
187
try (var connection = new Connection ()) {
@@ -282,7 +273,6 @@ public void testServerSocketChannelAccept2() throws Exception {
282
273
/**
283
274
* SeverSocketChannel close while virtual thread blocked in accept.
284
275
*/
285
- @ Test (enabled =false )
286
276
public void testServerSocketChannelAcceptAsyncClose () throws Exception {
287
277
TestHelper .runInVirtualThread (() -> {
288
278
try (var ssc = ServerSocketChannel .open ()) {
@@ -301,7 +291,6 @@ public void testServerSocketChannelAcceptAsyncClose() throws Exception {
301
291
/**
302
292
* Virtual thread interrupted while blocked in ServerSocketChannel accept.
303
293
*/
304
- @ Test (enabled =false )
305
294
public void testServerSocketChannelAcceptInterrupt () throws Exception {
306
295
TestHelper .runInVirtualThread (() -> {
307
296
try (var ssc = ServerSocketChannel .open ()) {
0 commit comments