[Eνσωματωμένα] Εργασίες 2019

[Thmmy.gr portal]

  Thmmy.gr portal
   Forum
   Downloads
   Ενεργ. Λογαριασμού
   Επικοινωνία
  
  Χρήσιμα links
   Σελίδα τμήματος
   Αλεξάνδρεια
   eTHMMY
   Βιβλιοθήκη Τμήματος
   Φοιτητικά fora
   Πρόγραμμα Λέσχης
   Πρακτική Άσκηση
   Ηλεκτρονική Εξυπηρέτηση Φοιτητών
   Επιτροπή Σεμιναρίων ΤΗΜΜΥ ΑΠΘ
   Διανομή Συγγραμμάτων
   Ψηφιακό Καταθετήριο Διπλωματικών
   RSS Feeds για το eTHMMY
   mTHMMY
  
  Φοιτητικές Ομάδες
   IEEE φοιτητικό παράρτημα ΑΠΘ
   Ομάδα Ρομποτικής
   BEST Thessaloniki
   IAESTE Thessaloniki
   Aristurtle
   Ariadne
  

THMMY.gr Web

Helios_MultiScribbles2SMF Default ThemeSMFone_Blue

Συμβουλές καλής χρήσης του φόρουμ: #0 Youtube embed code and links
Για τις ενσωματώσεις των βίντεο άλλα και τους συνδέσμους προς αυτά, γράφουμε και τον τίτλο του.

Δείτε περισσότερα εδώ...

[cvkagias]

Εγώ ακόμα δεν έχω καταφέρει να συνδεθώ με το raspberry ούτε με τον ένα ούτε με τον άλλο τρόπο. Από ότι έχω δει σε forum, όλοι λένε ότι για να σετάρω την static IP, δεν πειράζω το interfaces αλλά το dhcpcd.conf αρχείο. Κάποιο tip;

[mano_lee]

Εγώ ακόμα δεν έχω καταφέρει να συνδεθώ με το raspberry ούτε με τον ένα ούτε με τον άλλο τρόπο. Από ότι έχω δει σε forum, όλοι λένε ότι για να σετάρω την static IP, δεν πειράζω το interfaces αλλά το dhcpcd.conf αρχείο. Κάποιο tip;

Σύνδεση μέσω καλωδίου

1) Το αρχείο /etc/network/interfaces (του PC σου), θα πρέπει να μοιάζει κάπως έτσι:

Code:

# interfaces(5) file used by ifup(8) and ifdown(8)
auto lo
iface lo inet loopback

iface usb_port_network inet static
  address 192.168.0.5
  netmask 255.255.255.0
  gateway 192.168.0.1

Όπου address θα βάλεις την IP που θες να έχει το PC σου και όπου gateway είναι η IP του pi σου (την IP του pi θα την αλλάξεις μέσα απ το /etc/network/interfaces του pi αργότερα, οποτε θα την αλλαξεις και απο εδώ μετά ώστε να είναι η ίδια, γιατί η 192.168.0.1 είναι αυτή που έχει by default).

Όπου usb_port_network θα βάλεις την καινούρια σύνδεση που φαίνεται απο την εντολη iwconfig όταν συνδέεις το καλώδιο σε ένα usb port.

2) Τσεκάρεις τα δίκτυα στα οποία είναι συνδεδεμένα το pc σου. Αν είναι δείχνει να είναι συνδεδεμένο σε ένα "Wired Connection 1" κάνεις disconnect.

3) Κάνεις sudo /etc/init.d/networking restart

Τότε πρέπει να δείξει ότι συνδέθηκε στο usb_port_network που έβαλες στο /etc/network/interfaces του PC σου.

4) Κάνεις ssh [email protected]

Γενικά, δεν είναι δύσκολο, απλα τρώει κάτι κολλήματα συνέχεια και πρέπει να τα λύνεις με restart του network manager. Οποτε αν ολα αυτα δεν πετυχαινουν κανε και ένα sudo service network-manager restart και μετά κάνε και τα άλλα.

Επίσης, αν συνδέσεις το usb Και σου βγάζει στα δίκτυα "Device not managed" κατά πάσα πιθανότητα δε θα δουλέψει. Οποτε απλά βάλτο σε άλλο port και λογικά εκεί δε θα το βγάζει.

Σύνδεση μέσω wifi

1) Κανεις add new connection (απ το edit connections). Βάζεις σαν τύπο το Ad-hoc. Πας στην καρτέλα για IPv4 και βάζεις με τη σειρά "10.0.0.5", "255.255.255.0", "10.0.0.1". Πάλι εδώ, το πρώτο θα είναι η IP που θα επιλέξεις για το PC σου, και το τελευταίο το default του pi σου (το οποίο θα το αλλάξεις αργότερα στη μορφή που θέλει ο πιτσιανης, με το ΑΕΜ).

2) Συνδέεσαι στο δίκτυο που δημιούργησες.

3) Αφού συνδεθεί, κάνεις ssh [email protected]

[_init]

Παιδιά επειδή δεν το έπιασα και πολύ, μπορεί κάποιος που το κατάφερε να εξηγήσει πως υποτίθεται ότι πρέπει να γίνει η επικοινωνία μεταξύ των συσκευών;

Η κάθε συσκευή δημιουργεί ένα adhoc δίκτυο. Τα δίκτυα αυτά θα έχουν όλα το ίδιο όνομα και τον ίδιο κωδικό (τα προεπιλεγμένα), οπότε θα είναι σα να συνδέονται όλες οι συσκεύες στο ίδιο δίκτο.
Με λίγα λόγια, δε χρειάζετα να κάνεις κάτι, απλά να φέρεις τις συσκεύες σε απόσταση τέτοια ώστε τα δυο δίκτυα να είναι στην ίδια εμβέλεια και θα συνδεθούν αυτόματα.

Μετά, απλά θα πρέπει να τα βάλεις να επικοινωνούν στην ίδια port στο server αρχείο σου (port 2288).

[feugatos_#]

Η κάθε συσκευή δημιουργεί ένα adhoc δίκτυο. Τα δίκτυα αυτά θα έχουν όλα το ίδιο όνομα και τον ίδιο κωδικό (τα προεπιλεγμένα), οπότε θα είναι σα να συνδέονται όλες οι συσκεύες στο ίδιο δίκτο.
Με λίγα λόγια, δε χρειάζετα να κάνεις κάτι, απλά να φέρεις τις συσκεύες σε απόσταση τέτοια ώστε τα δυο δίκτυα να είναι στην ίδια εμβέλεια και θα συνδεθούν αυτόματα.

Μετά, απλά θα πρέπει να τα βάλεις να επικοινωνούν στην ίδια port στο server αρχείο σου (port 2288).

Ευχαριστώ πολύ για την απάντηση. Έχω προσπαθήσει αυτό που περιγράφεις απλά μάλλον αντιμετωπίζω δυσκολίες γιατί χρησιμοποιώ zsun

[feugatos_#]

Υπάρχει κάποιος συνάδελφος που κατάφερε να στήσει adhoc δίκτυο με zsun και να συνδεθεί μέσω του υπολογιστή ώστε να το συζητήσουμε;

[_init]

Απάντηση Φλώρου
Θα στείλετε πολλαπλά μηνύματα με το format που καθορίσαμε στην εκφώνηση.
Δεν θα στείλετε όλη την λίστα με τα μηνύματα με ένα send, αλλά με πολλαπλά (ένα για κάθε μήνυμα).
Στο τέλος της λίστας θα κλείσετε το socket.

Δηλαδή, όσο είναι εντός εμβέλειας δε θα μείνει ανοιχτό το socket σε περίπτωση που σταλθούν νέα μηνύματα?

[Florence]

Μετα την εγγραφη της εικονας στην καρτα SD, αναφερεται στο manual ότι επιστρεφεται ο αριθμος των block στη μορφη:

xxx+0 records in
yyy+0 records out
yyyyyyyyyy bytes (yyy kB, yyy KiB) copied, 0.00144744 s, 283 MB/s

Εγω μετα την εγγραφη παιρνω
414+1 records in
414+1 records out

Παρολα αυτα οταν ελεγχω αν η εικονα εγγραφηκε σωστα παιρνω ότι οι 2 εικονες ειναι ταυτοσημες. Θα πρεπε να ανησυχω επειδη κατα την εγγραφη επιστρεφεται +1 και οχι +0 ? Ειχε καποιος αλλος αυτες τις επιστρεφομενες τιμες?

[geormich]

Εγώ έκανα δύο συναρτήσεις στον buffer, μία serialize που παίρνει όλο τον buffer και τον κάνει ένα μεγάλο string με συγκεκριμένο format και μία deserialize που παίρνει ένα string (ελπίζοντας ότι θα έχει το σωστό format) και το μεταφράζει σε στοιχεία του buffer. Έτσι ο ένας στέλνει το string της serialize και ο άλλος που το παίρνει κάνει deserialize.

Για να ανακαλύψω τις συσκευές στο δίκτυο και να βρω τις IP, αυτή τη στιγμή, κάνω ένα broadcast ping και μετά χρησιμοποιώ το arp cache. Έπειτα για να δω αν κάθε μία από τις συσκευές που ανακάλυψα είναι online κάνω ξεχωριστά ping τη κάθε μία. Αυτό όμως παίρνει αρκετό χρόνο. Έχετε βρει κάποιο καλύτερο τρόπο; Εσείς τι κάνετε;

Επίσης, παρατήρησα ότι τα timestamps του κάθε node (έχω 2 Rpi και τεστάρω) είναι διαφορετικά ακόμα και για πολύ κοντινές χρονικά καταγραφές, κάνετε κάποιο clock synchronization για να το διορθώσετε; Αν το έχει ψάξει κανείς ας στείλει links/υλικό.

Apostolof καλα ολα αυτα που λες..Αλλα.....Ερωτήσεις:
1.εκανες ενα αρχειο και ειναι ολα τα ενσωματωμενα servers ή υπάρχουν και clients και servers?

Πιο συγκεκριμένα απο αυτο που λεει δεν καταλαβαινεις αν θα ειναι a.polloi clients polloi servers   b.1 server πολλοι clients η c.ολοι servers-clients....Πώς το έκανες εσύ?Σε περίπτωση που είναι όλοι servers-clients όταν βλέπουν κάτι συνδεδεμένο και οι 2 αποστελουν και λαμβανουν μηνυματα αναλογα με το ΑΕΜ και επειτα και οι 2 το αποθηκευουν στη λιστα τους....

2.Αυτο με το serialize deserialize ειναι απαραιτητο??δεν μπορουμε να μετατρεψουμε τους ints σε ενα string και να τα ενσωματωσουμε ολα σε ενα string για να τα στειλουμε ως μηνυματα?

3.Μπορείς να πεις τιποτα παραπανω για το πως ανιχνευεις τις συσκευες? (ια να ανακαλύψω τις συσκευές στο δίκτυο και να βρω τις IP, αυτή τη στιγμή, κάνω ένα broadcast ping και μετά χρησιμοποιώ το arp cache. Έπειτα για να δω αν κάθε μία από τις συσκευές που ανακάλυψα είναι online κάνω ξεχωριστά ping τη κάθε μία.) κανα link

4.Τα μηνυματα τα εχεις αποθηκευσει σε ουρα???

[_init]

Πιο συγκεκριμένα απο αυτο που λεει δεν καταλαβαινεις αν θα ειναι a.polloi clients polloi servers   b.1 server πολλοι clients η c.ολοι servers-clients....Πώς το έκανες εσύ?Σε περίπτωση που είναι όλοι servers-clients όταν βλέπουν κάτι συνδεδεμένο και οι 2 αποστελουν και λαμβανουν μηνυματα αναλογα με το ΑΕΜ και επειτα και οι 2 το αποθηκευουν στη λιστα τους....

είναι p2p σύστημα οπότε όλα τα nodes είναι και client και server μαζί. Σε ένα tcp socket μπορείς και να στέλνεις και να λαμβάνεις ταυτόχρονα όποτε εφόσον κάνεις establish το connection μεταξύ των δύο nodes δεν σε ενδιαφέρει ποιος είναι ο client και ποιος είναι ο server.
επίσης, δεν πρέπει να στέλνεις και να λαμβάνεις μόνο τα μηνύματα που αφορούν στο ΑΕΜ σου αλλά όλα τα μηνύματα που έχει το node στο buffer του.

2.Αυτο με το serialize deserialize ειναι απαραιτητο??δεν μπορουμε να μετατρεψουμε τους ints σε ενα string και να τα ενσωματωσουμε ολα σε ενα string για να τα στειλουμε ως μηνυματα?

Δεν τίθεται θέμα serialize-deserialize. Στέλνεις κάθε μήνυμα ξεχωριστά (σαν string), όχι όλο το buffer μαζί.

3.Μπορείς να πεις τιποτα παραπανω για το πως ανιχνευεις τις συσκευες? (ια να ανακαλύψω τις συσκευές στο δίκτυο και να βρω τις IP, αυτή τη στιγμή, κάνω ένα broadcast ping και μετά χρησιμοποιώ το arp cache. Έπειτα για να δω αν κάθε μία από τις συσκευές που ανακάλυψα είναι online κάνω ξεχωριστά ping τη κάθε μία.) κανα link

Θα δίνετε λίστα με τα ΑΕΜ, οπότε θα μπορείς να φτιάξεις την ip του κάθε node στο δίκτυο και μετά θα προσπαθείς να κάνεις connect() σε κάθε node απο τη λίστα που θα έχεις φτιάξει.

4.Τα μηνυματα τα εχεις αποθηκευσει σε ουρα???

Η εκφώνηση λέει ότι τα μηνύματα αποθηκεύονται σε ring buffer. ενδεικτικά.

[Apostolof]

+1 σε ό,τι είπε ο _init. Είχα κάνει το ποστ πριν δώσει κάποιες επεξηγήσεις και αλλάξει την εκφώνηση οπότε πολλά από όσα έκανα ήταν άχρηστα

[geormich]

είναι p2p σύστημα οπότε όλα τα nodes είναι και client και server μαζί. Σε ένα tcp socket μπορείς και να στέλνεις και να λαμβάνεις ταυτόχρονα όποτε εφόσον κάνεις establish το connection μεταξύ των δύο nodes δεν σε ενδιαφέρει ποιος είναι ο client και ποιος είναι ο server.
επίσης, δεν πρέπει να στέλνεις και να λαμβάνεις μόνο τα μηνύματα που αφορούν στο ΑΕΜ σου αλλά όλα τα μηνύματα που έχει το node στο buffer του.

Δεν τίθεται θέμα serialize-deserialize. Στέλνεις κάθε μήνυμα ξεχωριστά (σαν string), όχι όλο το buffer μαζί.

Θα δίνετε λίστα με τα ΑΕΜ, οπότε θα μπορείς να φτιάξεις την ip του κάθε node στο δίκτυο και μετά θα προσπαθείς να κάνεις connect() σε κάθε node απο τη λίστα που θα έχεις φτιάξει.

Η εκφώνηση λέει ότι τα μηνύματα αποθηκεύονται σε ring buffer.
ενδεικτικά: https://embedjournal.com/implementing-circular-buffer-embedded-c/.

ΟΚ..Απλά έχω κάποιες τελευταίες ερωτήσεις πάνω στις απαντήσεις σου..

ΝΟ1 ερώτηση..Στην πρώτη απάντηση που έδοσες για το P2P εννοείς

α.ότι θα έχω 1 τελικό αρχείο(server-client ας το πούμε) με 2 threads μέσα όπου αυτό περιλαμβάνει ουσιαστικά για κάθε thread 1 connection και 1 socket..Δηλαδή καποιο socket πρεπει να ειναι σε standby  
και καποιο να παροσπαθει να κανει connection..Ή αλλιώς ένα socket για να περιμένει για αίτημα connection για αποστολή ή λήψη μηνύματος(λειτουργία server) και ένα socket για να κάνει αίτημα για αποστολή ή λήψη μηνύματος(λειτουργία client)?

β.2 αρχεία ένα server και ένα client με 1 thread το καθένα μέσα

γ.1 αρχείο με ένα thread μέσα????

Εγώ αν το κάνω με 1 αρχείο ξέρω να το κάνω μόνο με 2 threads..Υπάρχει και άλλος τρόπος??Εσύ ποιον τρόπο εννοείς??

ΝΟ2 ερώτηση.Όταν στέλνεις ένα μήνυμα πχ 500 χαρακτήρες γράφεις ότι πρέπει να το στείλουμε 1-1 τα μηνύματα σωστά?Πώς όμως θα γίνει αυτό?Αφού όταν ανοίγεις ένα socket αυτό κλείνει μόνο του..Πρέπει να το έχω πάντα ανοιχτό?Πώς θα το κάνω??

ΝΟ3 ερώτηση μου έγραψες <<Θα δίνετε λίστα με τα ΑΕΜ, οπότε θα μπορείς να φτιάξεις την ip του κάθε node στο δίκτυο και μετά θα προσπαθείς να κάνεις connect() σε κάθε node απο τη λίστα που θα έχεις φτιάξει.>>
Που θα δίνετε η λίστα?? Την γραφω εγώ εννοείς??  Επίσης εννοείς ότι πρέπει εγώ να ορίσω μια τυχαία IP για κάθε ΑΕΜ??Και επίσης πώς θα την εντοπίζω την IP του γείτονα για να του στείλω μήνυμα??Εγώ αυτό που ξέρω ότι μπορεί να γίνει είναι με μια συνάρτηση πχ findip() που μπορείς να φτιάξεις να βρεις την IP την δικιά σου ενός ενσωματωμένου ας πούμε αλλά όχι να βρεις την IP του γείτονα..του receiver ας πούμε..γι αυτόν φαντάζομαι πρέπει να βάλεις τον χρήστη να πληκτρολογήσει την IP του receiver..Υπάρχει κι άλλος τρόπος??Εννοείς πχ να στέλνω σε όλους τυχαία μηνύματα από όλους και να έχω εκ των προτέρων εγώ ορίσει τα ΑΕΜ και να βάλω πχ μια random που θα επιλέγει τυχαία από την λίστα που έχω ορίσει εγώ με ΑΕΜ ένα ΑΕΜ....??Αυτό πώς γίνεται όμως στην πράξη??Αυτό εννοείς εν τέλει??

ΝΟ4 ερώτηση:  εγώ τα μηνύματα θα τα σβήνω από τον buffer είτε όταν γεμίσει είτε όταν παραδοθεί το μήνυμα στο σωστό παραλήπτη  ?'Η μόνο αν έχει γεμίσει? Το μονο που θα κοιταω δηλαδή ειναι αν το εχω ξαναστειλει σε αυτον που εχω κανει connection? Ή πρέπει να κοιτάω και αν ο παραλήπτης είναι ο τελικός παραλήπτης του μηνύματος που στέλνω??Και τότε να το διαγράφω από τον buffer του παραλήπτη..Βέβαια εδώ υπάρχει το πρόβλημα ότι μπορεί να διαγραφεί μόνο από τον δικό του buffer και όχι από τον buffer των άλλων και οι άλλοι να μην ξέρουν αν διαγράφηκε..Συνεπώς αν ισχύει αυτό οι άλλοι θα συνεχίσουν να στέλνουν το ίδιο μήνυμα σαν να μην στάλθηκε στον τελικό παραλήπτη του..By the way ίσως να υπάρχει κάποιος efficient τρόπος αλλά χρειάζεται ή όχι τελικώς??

ΑΝ μπορείς please πες μου κι αυτές τις ερωτήσεις κι έκλεισα

[_init]

ΟΚ..Απλά έχω κάποιες τελευταίες ερωτήσεις πάνω στις απαντήσεις σου..

ΝΟ1 ερώτηση..Στην πρώτη απάντηση που έδοσες για το P2P εννοείς

α.ότι θα έχω 1 τελικό αρχείο(server-client ας το πούμε) με 2 threads μέσα όπου αυτό περιλαμβάνει ουσιαστικά για κάθε thread 1 connection και 1 socket..Δηλαδή καποιο socket πρεπει να ειναι σε standby  
και καποιο να παροσπαθει να κανει connection..Ή αλλιώς ένα socket για να περιμένει για αίτημα connection για αποστολή ή λήψη μηνύματος(λειτουργία server) και ένα socket για να κάνει αίτημα για αποστολή ή λήψη μηνύματος(λειτουργία client)?

β.2 αρχεία ένα server και ένα client με 1 thread το καθένα μέσα

γ.1 αρχείο με ένα thread μέσα????

Εγώ αν το κάνω με 1 αρχείο ξέρω να το κάνω μόνο με 2 threads..Υπάρχει και άλλος τρόπος??Εσύ ποιον τρόπο εννοείς??

Ένα αρχείο θέλεις, ναι.
Απο εκεί και πέρα έχει πολλούς τρόπου με τους οποίους μπορείς να το υλοποιήσεις.
Ενδεικτικά, μια αρχιτεκτονική είναι:
- Ένα server thread που κάνει listen()
- Ένα client thread που προσπαθεί να κάνει connect() σε άλλα nodes απο τη λίστα
- Ένα thread για κάθε socket που προκύπτει είτε απο τον client είτε απο τον server

Θεωρητικά, θα μπορούσες να κάνεις ένα αρχείο με ένα thread μέσα και να χρησιμοποιήσεις asychronous Ι/Ο multiplexing (linux epoll ή kqueue) για να τα διαχειριστείς όλα αλλά είναι αρκετά πιο σύνθετο και δεν υπάρχει λόγος.

ΝΟ2 ερώτηση.Όταν στέλνεις ένα μήνυμα πχ 500 χαρακτήρες γράφεις ότι πρέπει να το στείλουμε 1-1 τα μηνύματα σωστά?Πώς όμως θα γίνει αυτό?Αφού όταν ανοίγεις ένα socket αυτό κλείνει μόνο του..Πρέπει να το έχω πάντα ανοιχτό?Πώς θα το κάνω??

Ένα socket δεν κλείνει μετά απο επιτυχή αποστολή μηνύματος. Για να κλείσεις το socket πρέπει να χρησιμοποιήσεις close() ή shutdown().
Εκτός αν θέλεις να πείς κάτι άλλο και δεν το καταλαβαίνω εγώ σωστά.

ΝΟ3 ερώτηση μου έγραψες <<Θα δίνετε λίστα με τα ΑΕΜ, οπότε θα μπορείς να φτιάξεις την ip του κάθε node στο δίκτυο και μετά θα προσπαθείς να κάνεις connect() σε κάθε node απο τη λίστα που θα έχεις φτιάξει.>>
Που θα δίνετε η λίστα?? Την γραφω εγώ εννοείς??  Επίσης εννοείς ότι πρέπει εγώ να ορίσω μια τυχαία IP για κάθε ΑΕΜ??Και επίσης πώς θα την εντοπίζω την IP του γείτονα για να του στείλω μήνυμα??Εγώ αυτό που ξέρω ότι μπορεί να γίνει είναι με μια συνάρτηση πχ findip() που μπορείς να φτιάξεις να βρεις την IP την δικιά σου ενός ενσωματωμένου ας πούμε αλλά όχι να βρεις την IP του γείτονα..του receiver ας πούμε..γι αυτόν φαντάζομαι πρέπει να βάλεις τον χρήστη να πληκτρολογήσει την IP του receiver..Υπάρχει κι άλλος τρόπος??Εννοείς πχ να στέλνω σε όλους τυχαία μηνύματα από όλους και να έχω εκ των προτέρων εγώ ορίσει τα ΑΕΜ και να βάλω πχ μια random που θα επιλέγει τυχαία από την λίστα που έχω ορίσει εγώ με ΑΕΜ ένα ΑΕΜ....??Αυτό πώς γίνεται όμως στην πράξη??Αυτό εννοείς εν τέλει??

Υποτίθεται θα μας δώσουν λίστα με τα ΑΕΜ όσων είναι γραμμένοι στο μάθημα.
Η εκφώνηση λέει ότι το κάθε RPi πρέπει να έχει IP στο δίκτυο της μορφής 10.0.ΧΧ.ΥΥ όπου ΧΧΥΥ το ΑΕΜ του κάθε φοιτητή.
Οπότε, αν σου δώσει λίστα με τα ΑΕΜ εσύ έχεις ουσιαστικά και τις IP όλων των πιθανών nodes αφού έχουν την παραπάνω μορφή.
Άρα, στο πρόγραμμα θα φτιάξεις μια τέτοια λίστα με όλες τις IP και θα βάλεις το client thread σου να σκαναρει ένα ένα item τη λίστα και να προσπαθεί να κάνει connect() -κάνοντας skip nodes που πιθανον θα έχουν συνδεθεί απο server thread, οπότε καλό θα ήταν στον πίνακα με τις IP να κράτας και μια bool status στήλη ώστε να μην προσπαθείς να κάνεις connect σε node που είσαι ήδη συνδεδεμένος-

ΝΟ4 ερώτηση:  εγώ τα μηνύματα θα τα σβήνω από τον buffer είτε όταν γεμίσει είτε όταν παραδοθεί το μήνυμα στο σωστό παραλήπτη  ?'Η μόνο αν έχει γεμίσει? Το μονο που θα κοιταω δηλαδή ειναι αν το εχω ξαναστειλει σε αυτον που εχω κανει connection? Ή πρέπει να κοιτάω και αν ο παραλήπτης είναι ο τελικός παραλήπτης του μηνύματος που στέλνω??Και τότε να το διαγράφω από τον buffer του παραλήπτη..Βέβαια εδώ υπάρχει το πρόβλημα ότι μπορεί να διαγραφεί μόνο από τον δικό του buffer και όχι από τον buffer των άλλων και οι άλλοι να μην ξέρουν αν διαγράφηκε..Συνεπώς αν ισχύει αυτό οι άλλοι θα συνεχίσουν να στέλνουν το ίδιο μήνυμα σαν να μην στάλθηκε στον τελικό παραλήπτη του..By the way ίσως να υπάρχει κάποιος efficient τρόπος αλλά χρειάζεται ή όχι τελικώς??

To buffer ουσιαστικά είναι το ιστορικό των τελευταίων 2000 unique μηνυμάτων που έχει λάβει το node σου + τα μηνύματα που κάνεις generate.

Προσθέτεις μήνυμα στο buffer όταν:
- συνδεθείς με ένα αλλο node, κάνεις receive μήνυμα και ελέγξεις ότι δεν είναι ήδη στο buffer
- κάνεις generate random μήνυμα, όπως αναφέρει η εκφώνηση

Απο εκεί και πέρα, κάθε φορά που κάνεις connect με ένα node του στέλνεις όλο το buffer σου (όπως είναι τη δεδομένη στιγμή) ή του στέλνεις απο το σήμειο και κάτω που είχες μείνει (γιατί λέει στην εκφώνηση ότι πρέπει να κρατας ποια μηνύματα έχει στείλει σε ποιον, οπότε αν δεν έχουν μπει στο buffer σου πάνω απο 2000 μηνύματα απο τότε που συνδέθηκες τελευταία φορά με το Χ node, αν ξανασυνδεθείς δεν χρειάζεται να του στείλεις όλο το buffer απο τη αρχή αλλά μόνα τα καινούργια μηνύματα απο την τελευταία φορά).

Επίσης:
- Δεν σε ενδιαφέρει αν και πως θα φτάσει το μήνυμα σου στον τελικό παραλήπτη.
- Όταν κάνεις generate το δικό σου μήνυμα, απλά το προσθέτεις στο buffer σου και το transmission γίνεται με τον παραπάνω τρόπο.
- Δεν ασχολείσαι καθόλου με τα buffer των άλλων.
- Για το σβήσιμο των παλαιότερων μηνυμάτων υπάρχει μια υλοποίηση στο λινκ που έγραψα στο προηγούμενο ποστ.

[geormich]

Ένα αρχείο θέλεις, ναι.
Απο εκεί και πέρα έχει πολλούς τρόπου με τους οποίους μπορείς να το υλοποιήσεις.
Ενδεικτικά, μια αρχιτεκτονική είναι:
- Ένα server thread που κάνει listen()
- Ένα client thread που προσπαθεί να κάνει connect() σε άλλα nodes απο τη λίστα
- Ένα thread για κάθε socket που προκύπτει είτε απο τον client είτε απο τον server

Θεωρητικά, θα μπορούσες να κάνεις ένα αρχείο με ένα thread μέσα και να χρησιμοποιήσεις asychronous Ι/Ο multiplexing (linux epoll ή kqueue) για να τα διαχειριστείς όλα αλλά είναι αρκετά πιο σύνθετο και δεν υπάρχει λόγος.

Ένα socket δεν κλείνει μετά απο επιτυχή αποστολή μηνύματος. Για να κλείσεις το socket πρέπει να χρησιμοποιήσεις close() ή shutdown().
Εκτός αν θέλεις να πείς κάτι άλλο και δεν το καταλαβαίνω εγώ σωστά.

Υποτίθεται θα μας δώσουν λίστα με τα ΑΕΜ όσων είναι γραμμένοι στο μάθημα.
Η εκφώνηση λέει ότι το κάθε RPi πρέπει να έχει IP στο δίκτυο της μορφής 10.0.ΧΧ.ΥΥ όπου ΧΧΥΥ το ΑΕΜ του κάθε φοιτητή.
Οπότε, αν σου δώσει λίστα με τα ΑΕΜ εσύ έχεις ουσιαστικά και τις IP όλων των πιθανών nodes αφού έχουν την παραπάνω μορφή.
Άρα, στο πρόγραμμα θα φτιάξεις μια τέτοια λίστα με όλες τις IP και θα βάλεις το client thread σου να σκαναρει ένα ένα item τη λίστα και να προσπαθεί να κάνει connect() -κάνοντας skip nodes που πιθανον θα έχουν συνδεθεί απο server thread, οπότε καλό θα ήταν στον πίνακα με τις IP να κράτας και μια bool status στήλη ώστε να μην προσπαθείς να κάνεις connect σε node που είσαι ήδη συνδεδεμένος-

To buffer ουσιαστικά είναι το ιστορικό των τελευταίων 2000 unique μηνυμάτων που έχει λάβει το node σου + τα μηνύματα που κάνεις generate.

Προσθέτεις μήνυμα στο buffer όταν:
- συνδεθείς με ένα αλλο node, κάνεις receive μήνυμα και ελέγξεις ότι δεν είναι ήδη στο buffer
- κάνεις generate random μήνυμα, όπως αναφέρει η εκφώνηση

Απο εκεί και πέρα, κάθε φορά που κάνεις connect με ένα node του στέλνεις όλο το buffer σου (όπως είναι τη δεδομένη στιγμή) ή του στέλνεις απο το σήμειο και κάτω που είχες μείνει (γιατί λέει στην εκφώνηση ότι πρέπει να κρατας ποια μηνύματα έχει στείλει σε ποιον, οπότε αν δεν έχουν μπει στο buffer σου πάνω απο 2000 μηνύματα απο τότε που συνδέθηκες τελευταία φορά με το Χ node, αν ξανασυνδεθείς δεν χρειάζεται να του στείλεις όλο το buffer απο τη αρχή αλλά μόνα τα καινούργια μηνύματα απο την τελευταία φορά).

Επίσης:
- Δεν σε ενδιαφέρει αν και πως θα φτάσει το μήνυμα σου στον τελικό παραλήπτη.
- Όταν κάνεις generate το δικό σου μήνυμα, απλά το προσθέτεις στο buffer σου και το transmission γίνεται με τον παραπάνω τρόπο.
- Δεν ασχολείσαι καθόλου με τα buffer των άλλων.
- Για το σβήσιμο των παλαιότερων μηνυμάτων υπάρχει μια υλοποίηση στο λινκ που έγραψα στο προηγούμενο ποστ.

Oκ..Κατάλαβα..Ευχαριστώ πάρα πολύ _init..Η βοήθειά σου ήταν valuable..
Μια final last question
Η υλοποίησή της εργασίας με το μοντέλο P2P ουσιαστικά βασίζεται στο consumer-producer μοντέλο με τον consumer ως τον client και τον producer ως τον server??
Απλά στο P2P model ο κάθε consumer-client είναι και producer-server??
Θα μπορούσα δηλαδή να βασίσω την υλοποίησή μου στο producer-consumer μοντέλο θεωρώντας τον consumer ως τον client και τον producer ως τον server?

[_init]

Oκ..Κατάλαβα..Ευχαριστώ πάρα πολύ _init..Η βοήθειά σου ήταν valuable..
Μια final last question
Η υλοποίησή της εργασίας με το μοντέλο P2P ουσιαστικά βασίζεται στο consumer-producer μοντέλο με τον consumer ως τον client και τον producer ως τον server??
Απλά στο P2P model ο κάθε consumer-client είναι και producer-server??

χαρά μου να βοθήσω όσο μπορώ 

Ναι, θεωρητικά θα μπορούσες να κάνεις ένα τέτοιο abstraction (one producer-multiple consumers) αλλά δεν ξέρω κατά πόσο θα βοηθούσε.
Το κάθε node είναι producer με την έννοια ότι συνδέονται σε αυτό άλλα nodes και τραβάνε απο το buffer του και παράλληλα είναι και ένας απο τους πολλούς consumers του κάθε άλλου node που συνδέεται με τη έννοια ότι τραβάει απο το buffer εκείνου.

[feugatos_#]

Μιας που το topic αναβίωσε... θα ξανακάνω την ίδια ερώτηση:

Υπάρχει κάποιος που έχει καταφέρει να κάνει δύο zsun συσκευές να επικοινωνήσουν μεταξύ τους;