Studium_Angewandte_Informatik_Bachelor/verteilte_systeme_lab01_filesharing_peer
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Removed some Method chaining.

Browse Source
This commit is contained in:
WickedJack99
2024-04-22 21:58:22 +02:00
parent 8f7d0afef4
commit b7c51b4b21
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/vslab1/src/Request/RequestExecuterThread.java
View File

@@ -85,14 +85,17 @@ public class RequestExecuterThread extends Thread implements Terminatable {
}
}
if (receivedData.has("join")) {
return new ReceivedJoinRequest(parseIPPortField(receivedData), FileReaderWriter.getThisPeer(EUpdateFlag.Update));
Peer sender = parseIPPortField(receivedData);
return new ReceivedJoinRequest(sender, FileReaderWriter.getThisPeer(EUpdateFlag.Update));
}
if (receivedData.has("peerJoined")) {
return new ReceivedPeerJoinedNotification(parseIPPortField(receivedData), FileReaderWriter.getThisPeer(EUpdateFlag.Update));
Peer sender = parseIPPortField(receivedData);
return new ReceivedPeerJoinedNotification(sender, FileReaderWriter.getThisPeer(EUpdateFlag.Update));
}
if (receivedData.has("peer")) {
Peer sender = parseIPPortField(receivedData);
JSONArray files = receivedData.getJSONArray("files");
return new ReceivedPeerNotification(parseIPPortField(receivedData), FileReaderWriter.getThisPeer(EUpdateFlag.DoNotUpdate), files);
return new ReceivedPeerNotification(sender, FileReaderWriter.getThisPeer(EUpdateFlag.Update), files);
}
if (receivedData.has("leave")) {
return new ReceivedLeaveNotification(parseIPPortField(receivedData), FileReaderWriter.getThisPeer(EUpdateFlag.DoNotUpdate));