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

Added updating this peer at config after setting ip and port.

Browse Source
This commit is contained in:
WickedJack99
2024-04-06 20:26:04 +02:00
parent 01ec9be2d5
commit 226d05f871
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/vslab1/src/Main.java
View File

@@ -11,11 +11,15 @@ import java.util.Scanner;
import vslab1.src.FileReaderWriter.FileReaderWriter;
import vslab1.src.Input.InputThread;
import vslab1.src.Input.NetworkController;
import vslab1.src.Peers.EOnlineState;
import vslab1.src.Peers.Peer;
import vslab1.src.Receiving.ReceiverThread;
import vslab1.src.Receiving.ReceivingQueue;
import vslab1.src.Request.RequestExecuterThread;
import vslab1.src.Sending.SenderThread;
import vslab1.src.Sending.SendingQueue;
import vslab1.src.Timeout.JobList;
import vslab1.src.Timeout.TimeoutThread;
public class Main {
public static void main(String[] args) {
@@ -28,13 +32,17 @@ public class Main {
SendingQueue sendingQueue = new SendingQueue();
ReceivingQueue receivingQueue = new ReceivingQueue();
RequestExecuterThread requestExecuterThread = new RequestExecuterThread(sendingQueue, receivingQueue);
JobList jobList = new JobList();
TimeoutThread timeoutThread = new TimeoutThread(jobList);
timeoutThread.start();
RequestExecuterThread requestExecuterThread = new RequestExecuterThread(sendingQueue, receivingQueue, jobList);
requestExecuterThread.start();
ReceiverThread receiverThread = new ReceiverThread(datagramSocket, receivingQueue);
receiverThread.start();
SenderThread senderThread = new SenderThread(datagramSocket, sendingQueue);
senderThread.start();
InputThread inputThread = new InputThread(inputScanner, senderThread, receiverThread, requestExecuterThread, sendingQueue);
InputThread inputThread = new InputThread(inputScanner, senderThread, receiverThread, requestExecuterThread, timeoutThread, sendingQueue, jobList);
inputThread.start();
try {
@@ -81,6 +89,7 @@ public class Main {
receivedValidAndFreePort = true;
}
}
FileReaderWriter.updatePeer(new Peer(localIpAddress, localPort, null, EOnlineState.Online));
return datagramSocket;
}
}