(long addr, ByteBuffer tmp)
| 271 | } |
| 272 | |
| 273 | private void readFully(long addr, ByteBuffer tmp) throws IOException { |
| 274 | do { |
| 275 | int many = fc.read(tmp, addr); |
| 276 | if (many <= 0) { |
| 277 | throw new IOException(); |
| 278 | } |
| 279 | addr = addr + many; |
| 280 | } while (tmp.hasRemaining()); |
| 281 | } |
| 282 | |
| 283 | private synchronized void flushBuffer() throws IOException { |
| 284 | // flush defautl buffer, reset pending count |
no test coverage detected