stream: avoid unnecessary drain for sync stream

PR-URL: #50014

Author: ronag

lib/internal/streams/writable.js

@@ -108,6 +108,7 @@ const kWriteCb = 1 << 26;
 constkExpectWriteCb=1<<27;
 constkAfterWriteTickInfo=1<<28;
 constkAfterWritePending=1<<29;
+constkIsDuplex=1<<30;
 
 // TODO(benjamingr) it is likely slower to do it this way than with free functions
 functionmakeBitMapDescriptor(bit){
@@ -286,6 +287,7 @@ function WritableState(options, stream, isDuplex){
 
 if(options&&options.objectMode)this.state|=kObjectMode;
 if(isDuplex&&options&&options.writableObjectMode)this.state|=kObjectMode;
+if(isDuplex)this.state|=kIsDuplex;
 
 // The point at which write() starts returning false
 // Note: 0 is a valid value, means that we always return false if
@@ -513,14 +515,6 @@ function writeOrBuffer(stream, state, chunk, encoding, callback){
 
 state.length+=len;
 
-// stream._write resets state.length
-constret=state.length<state.highWaterMark;
-
-// We must ensure that previous needDrain will not be reset to false.
-if(!ret){
-state.state|=kNeedDrain;
-}
-
 if((state.state&(kWriting|kErrored|kCorked|kConstructed))!==kConstructed){
 state.buffered.push({ chunk, encoding, callback });
 if((state.state&kAllBuffers)!==0&&encoding!=='buffer'){
@@ -539,6 +533,16 @@ function writeOrBuffer(stream, state, chunk, encoding, callback){
 state.state&=~kSync;
 }
 
+constret=(
+((state.state&kIsDuplex)===0||stream._readableState.ended!==true) ?
+state.length<state.highWaterMark :
+state.length+len<state.highWaterMark
+);
+
+if(!ret){
+state.state|=kNeedDrain;
+}
+
 // Return false if errored or destroyed in order to break
 // any synchronous while(stream.write(data)) loops.
 returnret&&(state.state&(kDestroyed|kErrored))===0;