153154155156157158159160161162163
List<RecordBatch> batches = accum.drain(cluster, nodes, 5 * 1024, 0).get(node1.id()); if (batches != null) { for (RecordBatch batch : batches) { for (LogEntry entry : batch.records) read++; accum.deallocate(batch); } } } for (Thread t : threads)