Fix[BMQ]: Move the read queue low watermark for each new reader (#896)

dorjesinpo · web-flow · commit 394209485882 · 2025-08-27T14:58:55.000-04:00
Signed-off-by: dorjesinpo &lt;129227380+dorjesinpo@users.noreply.github.com&gt;
diff --git a/src/groups/bmq/bmqio/bmqio_ntcchannel.cpp b/src/groups/bmq/bmqio/bmqio_ntcchannel.cpp
@@ -1177,6 +1177,9 @@ void NtcChannel::read(Status*                   status,
 
             return;
         }
+        // Move the read queue low watermark so not to miss already received
+        // data.
+        d_streamSocket_sp->setReadQueueLowWatermark(1);
     }
 
     if (timer) {

Original file line number	Diff line number	Diff line change
`@@ -1177,6 +1177,9 @@ void NtcChannel::read(Status* status,`
`1177`	`1177`
`1178`	`1178`	`return;`
`1179`	`1179`	`}`
	`1180`	`+ // Move the read queue low watermark so not to miss already received`
	`1181`	`+ // data.`
	`1182`	`+ d_streamSocket_sp->setReadQueueLowWatermark(1);`
`1180`	`1183`	`}`
`1181`	`1184`
`1182`	`1185`	`if (timer) {`