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

Server: try downloading from all if we have a dummy object

Browse Source 
just speeds up sync a little
This commit is contained in:
Stepan Usatiuk
2025-03-31 16:06:17 +02:00
parent 0f8002dc2c
commit 29663f575d
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
dhfs-parent/server/src/main/java/com/usatiuk/dhfs/repository/RemoteObjectServiceClient.java
View File

@@ -46,6 +46,8 @@ public class RemoteObjectServiceClient {
ProtoSerializer<OpP, Op> opProtoSerializer; ProtoSerializer<OpP, Op> opProtoSerializer;
@Inject @Inject
ProtoSerializer<GetObjectReply, ReceivedObject> receivedObjectProtoSerializer; ProtoSerializer<GetObjectReply, ReceivedObject> receivedObjectProtoSerializer;
@Inject
PeerManager peerManager;
public Pair<PeerId, ReceivedObject> getSpecificObject(JObjectKey key, PeerId peerId) { public Pair<PeerId, ReceivedObject> getSpecificObject(JObjectKey key, PeerId peerId) {
return rpcClientFactory.withObjSyncClient(peerId, (peer, client) -> { return rpcClientFactory.withObjSyncClient(peerId, (peer, client) -> {
@@ -63,7 +65,9 @@ public class RemoteObjectServiceClient {
} }
var targetVersion = objMeta.versionSum(); var targetVersion = objMeta.versionSum();
var targets = objMeta.knownRemoteVersions().entrySet().stream() var targets = objMeta.knownRemoteVersions().isEmpty()
? peerManager.getAvailableHosts()
: objMeta.knownRemoteVersions().entrySet().stream()
.filter(entry -> entry.getValue().equals(targetVersion)) .filter(entry -> entry.getValue().equals(targetVersion))
.map(Map.Entry::getKey).toList(); .map(Map.Entry::getKey).toList();