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

somewhat working FS layer

Browse Source
This commit is contained in:
Stepan Usatiuk
2024-08-03 21:46:00 +02:00
parent e8929350f9
commit 99e60f726f
3 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
dhfs-parent/server/src/main/java/com/usatiuk/dhfs/files/service/DhfsFileServiceImpl.java
View File

@@ -111,7 +111,7 @@ public class DhfsFileServiceImpl implements DhfsFileService {
if (d instanceof File f) {
ret = new GetattrRes(f.getMtime(), f.getCtime(), f.getMode(), f.isSymlink() ? GetattrType.SYMLINK : GetattrType.FILE);
} else if (d instanceof TreeNodeJObjectData) {
ret = new GetattrRes(100, 100, 0777, GetattrType.DIRECTORY);
ret = new GetattrRes(100, 100, 0700, GetattrType.DIRECTORY);
} else {
throw new StatusRuntimeException(Status.DATA_LOSS.withDescription("FsNode is not an FsNode: " + m.getName()));
}

4
dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/jklepmanntree/JKleppmannTreeManager.java
View File

@@ -74,6 +74,8 @@ public class JKleppmannTreeManager {
}
private JKleppmannTree createTree(String name) {
return new JKleppmannTree(_persistentData.computeIfAbsent(name, n -> new JKleppmannTreePersistentData(opQueueHelper, n, new AtomicClock())), storageInterfaceService, jPeerInterface);
var pdata = _persistentData.computeIfAbsent(name, n -> new JKleppmannTreePersistentData(opQueueHelper, n, new AtomicClock()));
pdata.restoreHelper(opQueueHelper);
return new JKleppmannTree(pdata, storageInterfaceService, jPeerInterface);
}
}

8
dhfs-parent/server/src/main/java/com/usatiuk/dhfs/objects/jklepmanntree/JKleppmannTreePersistentData.java
View File

@@ -30,13 +30,17 @@ public class JKleppmannTreePersistentData implements Serializable, OpQueue {
@Getter
private final ReentrantReadWriteLock _logLock = new ReentrantReadWriteLock();
private final OpQueueHelper _helper;
private transient OpQueueHelper _helper;
JKleppmannTreePersistentData(OpQueueHelper opQueueHelper, String name, AtomicClock clock) {
_name = name;
_clock = clock;
_selfUuid = opQueueHelper.getSelfUUid();
restoreHelper(opQueueHelper);
}
public void restoreHelper(OpQueueHelper opQueueHelper) {
_helper = opQueueHelper;
_selfUuid = _helper.getSelfUUid();
_helper.registerOnConnection(this);
}