Skip to content

Commit 86b30d0

Browse files
committed
Remove race in test
1 parent 5eca107 commit 86b30d0

File tree

1 file changed

+3
-7
lines changed

1 file changed

+3
-7
lines changed

vertx-core/src/test/java/io/vertx/tests/net/NetBandwidthLimitingTest.java

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -265,13 +265,13 @@ public void start(Promise<Void> startPromise) {
265265
@Test
266266
public void testDynamicInboundRateUpdate() {
267267
Assume.assumeFalse(TRANSPORT == Transport.IO_URING);
268-
long startTime = System.nanoTime();
269268

270269
Buffer expected = TestUtils.randomBuffer(64 * 1024 * 4);
271-
Buffer received = Buffer.buffer();
272270
NetServer server = netServer();
273271

274272
server.connectHandler(sock -> {
273+
Buffer received = Buffer.buffer();
274+
long startTime = System.nanoTime();
275275
sock.handler(buff -> {
276276
received.appendBuffer(buff);
277277
if (received.length() == expected.length()) {
@@ -281,8 +281,6 @@ public void testDynamicInboundRateUpdate() {
281281
testComplete();
282282
}
283283
});
284-
// Send some data to the client to trigger the buffer write
285-
sock.write("foo");
286284
});
287285
server.listen(testAddress).await();
288286

@@ -294,9 +292,7 @@ public void testDynamicInboundRateUpdate() {
294292

295293
Future<NetSocket> clientConnect = client.connect(testAddress);
296294
clientConnect.onComplete(onSuccess(sock -> {
297-
sock.handler(buf -> {
298-
sock.write(expected);
299-
});
295+
sock.write(expected);
300296
}));
301297
await();
302298
}

0 commit comments

Comments
 (0)