stepus53/dhfs
1
0
Fork 0
mirror of https://github.com/usatiuk/dhfs.git synced 2025-10-29 04:57:48 +01:00
Code Issues Packages Projects Releases Wiki Activity

less file touching

Browse Source
This commit is contained in:
Stepan Usatiuk
2024-06-30 13:50:46 +02:00
parent dcb3b0ba57
commit cc856d788f
1 changed files with 5 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
server/src/main/java/com/usatiuk/dhfs/storage/objects/repository/persistence/FileObjectPersistentStore.java
View File

@@ -68,11 +68,10 @@ public class FileObjectPersistentStore implements ObjectPersistentStore {
public ByteString readObject(String name) {
var file = Path.of(root, name);
if (!file.toFile().exists())
throw new StatusRuntimeException(Status.NOT_FOUND);
try {
return UnsafeByteOperations.unsafeWrap(Files.readAllBytes(file));
} catch (NoSuchFileException fx) {
throw new StatusRuntimeException(Status.NOT_FOUND);
} catch (IOException e) {
Log.error("Error reading file " + file, e);
throw new StatusRuntimeException(Status.INTERNAL);
@@ -83,14 +82,10 @@ public class FileObjectPersistentStore implements ObjectPersistentStore {
public void writeObject(String name, ByteString data) {
var file = Path.of(root, name);
if (!Paths.get(root).toFile().isDirectory()
&& !Paths.get(root).toFile().mkdirs())
throw new StatusRuntimeException(Status.INTERNAL);
try {
file.toFile().createNewFile();
try (var fc = new FileOutputStream(file.toFile())) {
if (fc.getChannel().write(data.asReadOnlyByteBuffer()) != data.size())
try (var fc = new FileOutputStream(file.toFile(), false);
var ch = fc.getChannel().truncate(0)) {
if (ch.write(data.asReadOnlyByteBuffer()) != data.size())
throw new StatusRuntimeException(Status.INTERNAL.withDescription("Could not write all bytes to file"));
}
} catch (IOException e) {