MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

boundary conditions in blocking and non-blocking IO implementations

Browse Source
This commit is contained in:
Eugene Zhuravlev
2016-03-15 19:31:27 +01:00
parent 065ae0ec6b
commit 7009b79ea7
1 changed files with 14 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/util/src/com/intellij/util/io/BaseOutputReader.java
+14 -9
View File
@@ -69,9 +69,11 @@ public abstract class BaseOutputReader extends BaseDataReader {
boolean read = false;
int n;
while (myReader.ready() && (n = myReader.read(myInputBuffer)) > 0) {
read = true;
processLine(myInputBuffer, myLineBuffer, n);
while (myReader.ready() && (n = myReader.read(myInputBuffer)) >= 0) {
if (n > 0) {
read = true;
processLine(myInputBuffer, myLineBuffer, n);
}
}
if (myLineBuffer.length() > 0) {
@@ -94,14 +96,17 @@ public abstract class BaseOutputReader extends BaseDataReader {
boolean read = false;
int n;
while ((n = myReader.read(myInputBuffer)) > 0) {
read = true;
processLine(myInputBuffer, myLineBuffer, n);
while ((n = myReader.read(myInputBuffer)) >= 0) {
if (n > 0) {
read = true;
processLine(myInputBuffer, myLineBuffer, n);
}
if (!myReader.ready()) {
TimeoutUtil.sleep(mySleepingPolicy.getTimeToSleep(true));
TimeoutUtil.sleep(mySleepingPolicy.getTimeToSleep(n > 0));
if (!myReader.ready()) {
if (myLineBuffer.length() > 0) sendLine(myLineBuffer);
if (myLineBuffer.length() > 0) {
sendLine(myLineBuffer);
}
onBufferExhaustion();
}
}