()
| 281 | } |
| 282 | |
| 283 | private synchronized void flushBuffer() throws IOException { |
| 284 | // flush defautl buffer, reset pending count |
| 285 | flushBuffer(writeBuffer); |
| 286 | pendingWrites = 0; |
| 287 | } |
| 288 | |
| 289 | private void flushBuffer(ByteBuffer b) throws IOException { |
| 290 | // flush arbitrary buffer to disk, update next write pos |
no test coverage detected