221222223224225226227228229230231
transferBuffer.flip(); while (transferBuffer.hasRemaining()) { fc.write(transferBuffer); } transferBuffer.clear(); } LineNumberReader lnr = new LineNumberReader(new FileReader(file)); int countLines = 0;
7576777879808182838485
ByteBuffer transferBuffer = ByteBuffer.allocate(8192); int read = 0; do { transferBuffer.clear(); read = fc.read(transferBuffer); if (read > 0) { transferBuffer.flip(); outChannel.write(transferBuffer);
177178179180181182183184185186187
int size = outChannel.write(copyBuffer); written.addAndGet(size); if (copyBuffer.hasRemaining()) { copyBuffer.compact(); } else { copyBuffer.clear(); } } } outChannel.close();
178179180181182183184185186187188
7475767778798081828384
616617618619620621622623624625626
nGet = Math.min(nGet, remainingBytes); bb.get(buffer, 0, nGet); outStream.write(buffer, 0, nGet); remainingBytes -= nGet; } bb.clear(); } } else { int len; while ((len = inputStream.read(buffer)) > 0) { outStream.write(buffer, 0, len);