|
|
@ -231,9 +231,9 @@ public class SeaweedOutputStream extends OutputStream implements Syncable, Strea |
|
|
|
waitForTaskToComplete(); |
|
|
|
} |
|
|
|
final Future<Void> job = completionService.submit(() -> { |
|
|
|
System.out.println(path + " is going to save [" + (writePosition) + "," + ((writePosition) + bytesLength) + ")"); |
|
|
|
// System.out.println(path + " is going to save [" + (writePosition) + "," + ((writePosition) + bytesLength) + ")"); |
|
|
|
SeaweedWrite.writeData(entry, replication, filerGrpcClient, writePosition, bufferToWrite.array(), bufferToWrite.position(), bufferToWrite.limit()); |
|
|
|
System.out.println(path + " saved [" + (writePosition) + "," + ((writePosition) + bytesLength) + ")"); |
|
|
|
// System.out.println(path + " saved [" + (writePosition) + "," + ((writePosition) + bytesLength) + ")"); |
|
|
|
bufferToWrite.clear(); |
|
|
|
ByteBufferPool.release(bufferToWrite); |
|
|
|
return null; |
|
|
|