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

Correcting mistake, was adding to send queue at wrong request.

Browse Source
This commit is contained in:
WickedJack99
2024-04-07 11:59:49 +02:00
parent f79527c16b
commit c00982c17c
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/vslab1/src/Request/Data/OnlineStateNotificationRequest.java
View File

@@ -5,6 +5,7 @@ import vslab1.src.Peers.EOnlineState;
import vslab1.src.Peers.Peer;
import vslab1.src.Sending.SendingQueue;
import vslab1.src.Sending.Data.EDataType;
import vslab1.src.Sending.Data.OnlineStateNotification;
import vslab1.src.Timeout.JobList;
public record OnlineStateNotificationRequest(Peer sender, Peer receiver, JobList jobList) implements Requestable {
@@ -26,8 +27,8 @@ public record OnlineStateNotificationRequest(Peer sender, Peer receiver, JobList
@Override
public void execute(SendingQueue sendingQueue) {
FileReaderWriter.updatePeer(new Peer(sender.ipAddress(), sender.port(), null, EOnlineState.Online));
sendingQueue.add(new OnlineStateNotification(receiver, sender));
}
}

3
src/main/java/vslab1/src/Request/Data/OnlineStateRequestRequest.java
View File

@@ -24,8 +24,7 @@ public record OnlineStateRequestRequest(Peer sender, Peer receiver) implements R
@Override
public void execute(SendingQueue sendingQueue) {
// This is receiver and wants to notify the sender about its online state.
sendingQueue.add(new OnlineStateNotification(receiver, sender));
System.out.println("Peer @ " + sender.ipAddress() + ":" + sender.port() + " online");
}
}