File tree Expand file tree Collapse file tree
xds/src/main/java/io/grpc/xds Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -301,6 +301,8 @@ private static class DataPlaneClientCall
301301
302302 // Path 1: Pending/buffered request body messages from downstream
303303 private final Queue <ByteString > pendingRequestBodyMessages = new ConcurrentLinkedQueue <>();
304+ // Deferred half-close flag for upstream direction
305+ private final AtomicBoolean pendingUpstreamHalfClose = new AtomicBoolean (false );
304306
305307 // Path 2: Buffered request body messages from ext_proc server to forward upstream
306308 private final Queue <ByteString > pendingUpstreamBodyMessages =
@@ -310,8 +312,6 @@ private static class DataPlaneClientCall
310312 // Buffered mutated response bodies from ext_proc server
311313 private final Queue <ByteString > pendingMutatedResponseBodies =
312314 new java .util .concurrent .ConcurrentLinkedQueue <>();
313- // Deferred half-close flag for upstream direction
314- private final AtomicBoolean pendingUpstreamHalfClose = new AtomicBoolean (false );
315315
316316 // Accumulated client window updates to send to ext_proc
317317 private long accumulatedWindowUpdateSidestreamToUpstream = 0 ;
You can’t perform that action at this time.
0 commit comments