marcel-baur / rust-project Goto Github PK

• nach duplikaten beim Namen suchen (wenn #11 fertig ist). Eigenes Ticket: #21
• response
• redundancy: mp3 file in einer zweiten datenbank speichern
• bestätigung der redundancy

Sie machen bis auf eine Zeile im Code dasselbe

Wenn jemand das Netzwerk verlassen, will müssen ein paar Dinge passieren:

• funktion zum verlassen des netzwerks (beispielsweise exit)
• alle streams müssen beendet werden
• was passiert wenn derjenige gerade streamt? ==> Wird der Stream abgebrochen/streams übergeben?
• andere Peers benachrichtigen
• network tables aktualisieren
• Musik in Database auf andere Peers verteilen

Analoges Vorgehen wie beim Herunterladen von einem File

• Key-Value DB als Map erstellen
• Netzwerktabelle erstellen (dafür muss auch die eigene IP-Adresse des Peers herausgefunden werden)
• Anfragen zum einklinken ins Netzwerk entgegen nehmen (Ports öffnen)

Jeder Peer weiß wo die Kopie von jedem File liegt das er selber speichert. Falls dann ein Peer rausfliegt kann mit diesem Log die Redundanz einfach wiederhergestellt werden.

Aktuell benötigen wir zwei Argumente: own-name (required) und ip-address (optional).

• Port richtig formatiert
• Port im Netzwerk noch nicht vergeben

Jeder Client ist selber ein Peer im Netzwerk.

Aufbau

Jeder Peer benötigt eine Tabelle mit den anderen Peers als Inhalt (Netzwerktabelle).
Map<own-name, network-ip>

Zwei Optionen:

• Neues Netzwerk erstellen create(own-name)
• An ein existierendes Netzwerk anschließen join(own-name, network-ip)

Neues Netzwerk

Erstellt ein neues Netzerk. Muss dann auch fähig sein neue Peers zu akzeptieren. Erstellt damit die initiale Tabelle von Peers, wo er nur selber drin steht.

Sich einem Netzwerk anschließen

Schließt sich einem Netzwerk an, entsprechend der übergebenen network-id.
Wenn das passiert muss der neue Peer von einem bereits bestehenden Peer die Netzwerktabelle erhalten. Diese muss auch mit den Informationen des neuen Peers aktualisiert werden. Dabei muss sichergestellt werden dass der Name des neuen Netzwerks own-name noch nicht existiert. Andere Peers müssen vom neuen Peer mitbekommen und ihre Netzwerktabellen auch aktualisieren

Letztendlich ja doch nicht, nachdem wir nur noch den lokalen Stand der Datenbank anzeigen wollen?

https://doc.rust-lang.org/nightly/edition-guide/rust-2018/module-system/path-clarity.html#no-more-modrs

• Schnittstelle klar definieren und vom Rest abkapseln

• unwrap() entfernen

Das mit den Schnittstellen machen wir am einfachsten wenn wir schon mit dem Projekt fertig sind und wissen welche Funktionen wir brauchen. Nur die sind dann nach außen hin zugänglich.

Die Shell muss ein eigenes Programm sein welches die Library implementiert (#31)

Hab einen generischen Typ für Responses erstellt, ist aber noch auf meinem Branch

RemoteNotification für Nachrichten an andere Peers, SelfNotification für Shell -> Listener

Wenn man das Programm mit der Aufforderung cargo run xD 6969 123.56.89.87:1337 schaut es so aus als ob man einem Netzwerk beigetreten ist. Alle Programmeingaben bleiben unbeantwortet.

Key Value:

• Key: Name (manuell eingeben): Songname - Künstler
• Value: mp3 file (speichern als Binärdatei)

Rückgabe als (Websocket?) Stream.

Wie verteilen wir die DB? Peer2Peer, Redundancy beachten: Jedes File sollte auf mindestens 2 Peers sein.

Basis-Funktionen:
get(Filename) -> Gibt das mp3 file zurück
stream(filename) -> Streamt das mp3
push(filename, file)

• port ist schon belegt
• port nummer ist nicht in range (1024-65535)

Problem:

Unser Programm läuft mit mehreren Threads. Von einer der Threads (Interaction) werden Einträge in unsere Datenbank (die ja eine HashMap ist) geschrieben. Das Problem ist dass Referenzen nicht ohne weiteres in Threads übergeben werden dürfen. Hat auch gute Gründe, unter anderem dass ja mehrere Threads "gleichzeitig" etwas an der HashMap ändern könnten, was zu unvorhersehbaren Fehlern führen kann (zweimal der gleiche key z.B.).

Ich hab mich etwas auf StackExchange umgesehen um zu schauen wie man das lösen kann. Mit etwas hacken kann man das evtl. umgehen, kann aber sehr gut sein dass das in der Bewertung schlecht ankommt.

Lösungsansatz (eine Lösung hab ich noch nicht):

Do not communicate by sharing memory; instead, share memory by communicating. Wir ändern nicht direkt die HashMap, sondern senden einen Request nach außen um die Datenbank aktuell zu halten. Dieser kann auch zurückgewiesen werden falls etwas nicht passt, doppelte keys zum Beispiel. Letztendlich müssen wir das sowieso mit den Tabellen der anderen Peers abgleichen.

Beim konvertieren vom value -> String

Eventuell ein Notification System für Kommunikation innerhalb der Threads? Wenn das natürlich so easy ist 😅
Müsste auf jeden Fall im ConThread bzw Mainthread gestartet werden.

Ein Bild für die Darstellung der Architektur

• Regelmäßige Anfragen an alle Peers um zu sehen ob die Verbindung noch existiert. Falls nicht muss der Peer entfernt werden.
• Bei regulären Anfragen im Fall einer toten Verbindung den Peer entfernen

Bugs:
Heartbeat/DroppedPeer nicht an sich selber senden

Im moment löuft die Musik weiter, wenn sie aus der Datenbank gelöscht wurde. Die Musik sollte am besten gestoppt werden wenn man die löscht.

Momentan ist es nur für macOS implementiert. Muss auf jeden fall auch für Linux gehen, bestenfalls auch für Windows. Siehe u.A. create_network() Funktion

Welche Files gibt es etc

Sich einem Netzwerk anschließen
Schließt sich einem Netzwerk an, entsprechend der übergebenen network-id.
Wenn das passiert muss der neue Peer von einem bereits bestehenden Peer die Netzwerktabelle erhalten. Diese muss auch mit den Informationen des neuen Peers aktualisiert werden. Dabei muss sichergestellt werden dass der Name des neuen Netzwerks own-name noch nicht existiert. Andere Peers müssen vom neuen Peer mitbekommen und ihre Netzwerktabellen auch aktualisieren

• network table vom bestehenden netzwerk anfordern
• eventuell nach neuem namen fragen / oder anderen namen erstellen
• eigenen Peer erstellen (wir haben dann schon alle namen)
• peer an andere peers im netzwerk schicken

• Musik abspielen
• Musik streamen