Changeset 129:38d30c5ceaf3 in rrlib_finroc_core_utils-java
- Timestamp:
- 14.07.2019 23:15:03 (3 years ago)
- Branch:
- default
- Phase:
- public
- Tags:
- tip
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
jc/stream/ChunkedBuffer.java
r128 r129 174 174 // any changes? if not, wait for change... 175 175 long written = writtenBytes; 176 if ( (long)(bc.virtualPosition + buffer.position + len)> written) {177 assert( (long)(bc.virtualPosition + buffer.position)<= written) : "Programming error as it seems";176 if (bc.virtualPosition + buffer.position + len > written) { 177 assert(bc.virtualPosition + buffer.position <= written) : "Programming error as it seems"; 178 178 179 179 if (!blockingReaders) { … … 183 183 while (true) { 184 184 written = writtenBytes; 185 if ( (long)(bc.virtualPosition + buffer.position + len)<= written) {185 if (bc.virtualPosition + buffer.position + len <= written) { 186 186 break; 187 187 } … … 244 244 BufferChunk bc = (BufferChunk)buffer.customData; 245 245 //System.out.println(bc.virtualPosition +" + " + buffer.position +" < "+ writtenBytes); 246 return ( (long)(bc.virtualPosition + buffer.end)< writtenBytes);246 return (bc.virtualPosition + buffer.end < writtenBytes); 247 247 } 248 248 … … 282 282 283 283 // keep buffer, but commit new write position 284 assert(writtenBytes <= (long)(bc.virtualPosition + buffer.position));284 assert(writtenBytes <= bc.virtualPosition + buffer.position); 285 285 bc.curSize.set(0, buffer.position); 286 286 return true; … … 435 435 assert(inputStreamBuffer == user); 436 436 BufferChunk bc = (BufferChunk)buffer.customData; 437 return (long)(bc.virtualPosition + buffer.end)< writtenBytes;437 return bc.virtualPosition + buffer.end < writtenBytes; 438 438 } 439 439
Note: See TracChangeset
for help on using the changeset viewer.