Skip to content

Commit b9e1e2b

Browse files
committed
Fix race condition in serverStream_triggerEvent_afterClose test.
Wait for the server stream to be fully closed (via awaitClose) before calling triggerEvent, to ensure the transport has processed the cancellation and marked the listener as closed. This fixes flakiness in slower transports like Jetty. TAG=agy CONV=e1bfa5a2-e855-4f79-abdd-ef2b264977be
1 parent feeab1e commit b9e1e2b

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

core/src/testFixtures/java/io/grpc/internal/AbstractTransportTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2139,6 +2139,8 @@ public void serverStream_triggerEvent_afterClose() throws Exception {
21392139
// Close the stream from client side
21402140
clientStream.cancel(Status.CANCELLED);
21412141

2142+
serverStreamListener.awaitClose(TIMEOUT_MS, TimeUnit.MILLISECONDS);
2143+
21422144
Object event = new Object();
21432145
serverStream.triggerEvent(event);
21442146

0 commit comments

Comments
 (0)