| | |
| | | int count = 0; |
| | | while (count<=length-2) |
| | | { |
| | | if ((entryBytes[pos+count] == '\n') && (entryBytes[pos+count+1] == '\n')) |
| | | if (entryBytes[pos+count] == '\n' && entryBytes[pos+count+1] == '\n') |
| | | { |
| | | entryCount++; |
| | | count++; |
| | |
| | | " our=" + ourLastExportedCnt + " slowest=" + slowestCnt); |
| | | } |
| | | |
| | | if ((ourLastExportedCnt - slowestCnt) > ieCtx.initWindow) |
| | | if (ourLastExportedCnt - slowestCnt > ieCtx.initWindow) |
| | | { |
| | | if (logger.isTraceEnabled()) |
| | | { |
| | |
| | | break; |
| | | } |
| | | // Timeout ? |
| | | if ((System.currentTimeMillis() - startTime) >= getAssuredTimeout()) |
| | | if (System.currentTimeMillis() - startTime >= getAssuredTimeout()) |
| | | { |
| | | /* |
| | | Timeout occurred, be sure that ack is not being received and if so, |