tomaswolf commented on code in PR #217: URL: https://github.com/apache/mina-sshd/pull/217#discussion_r857178648
########## sshd-core/src/main/java/org/apache/sshd/common/channel/ChannelOutputStream.java: ########## @@ -50,12 +64,15 @@ public class ChannelOutputStream extends OutputStream implements java.nio.channe private final Duration maxWaitTimeout; private final byte cmd; private final boolean eofOnClose; - private final byte[] b = new byte[1]; - private final AtomicBoolean closedState = new AtomicBoolean(false); + private final AtomicReference<OpenState> openState = new AtomicReference<>(OpenState.OPEN); + + private final Object bufferLock = new Object(); private Buffer buffer; private int bufferLength; private int lastSize; - private boolean noDelay; + private boolean isFlushing; + + private volatile boolean noDelay; Review Comment: Done. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr...@mina.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@mina.apache.org For additional commands, e-mail: dev-h...@mina.apache.org