[Παράλληλα και Διανεμημένα Συστ.] Εργασία 1

[Thmmy.gr portal]

  Thmmy.gr portal
   Forum
   Downloads
   Ενεργ. Λογαριασμού
   Επικοινωνία
  
  Χρήσιμα links
   Σελίδα τμήματος
   Βιβλιοθήκη Τμήματος
   Elearning
   Φοιτητικά fora
   Πρόγραμμα Λέσχης
   Πρακτική Άσκηση
   Ηλεκτρονική Εξυπηρέτηση Φοιτητών
   Διανομή Συγγραμμάτων
   Ψηφιακό Καταθετήριο Διπλωματικών
   Πληροφορίες Καθηγητών
   Instagram @thmmy.gr
   mTHMMY
  
  Φοιτητικές Ομάδες
   ACM
   Aristurtle
   ART
   ASAT
   BEAM
   BEST Thessaloniki
   EESTEC LC Thessaloniki
   EΜΒ Auth
   IAESTE Thessaloniki
   IEEE φοιτητικό παράρτημα ΑΠΘ
   SpaceDot
   VROOM
   Panther
  

THMMY.gr Web

Helios_MultiScribbles2SMF Default ThemeSMFone_Blue

[Ανεβάζετε τα θέματα των εξετάσεων στον τομέα Downloads]

Είσαι πρωτοετής;... Καλώς ήρθες! Μπορείς να βρεις πληροφορίες εδώ. Βοήθεια για τους καινούργιους μέσω χάρτη.

Κατεβάστε εδώ το Android Application για εύκολη πρόσβαση στο forum.

Ανεβάζετε τα θέματα των εξετάσεων στον τομέα Downloads με προσοχή στα ονόματα των αρχείων!

Για οποιοδήποτε πρόβλημα με register/login, στείλτε email στο contact@thmmy.gr.

[georgkonst]

Καλημέρα,

Έχει συναντήσει κανείς στη παραλληλοποίηση της radix_sort.c με pthreads error στην memcpy λόγω overlap? Αν ναι πως το φτιαχνω?  Aυτό έχει σαν αποτέλεσμα στην ίδια γραμμή να έχω "Invalid read of size 1" το οποίο εν τέλει κρασάρει το πρόγραμμα. Το error είναι "access not within mapped region"

Επιπλέον έχω warnings από το valgrind ότι χρησιμοποιώ uninitialized values, πως γίνεται αυτό αν τις περνάω όλες από την test_octree αρχικοποιημένες μέσω δομής αρχικοποιημένες; Το θέμα αυτό υπάρχει με τις pointer μεταβλητές που είναι πίνακες.

Για πείτε  

[unfo]

στη συναρτηση read_data πως περνατε τα ορισματα για να τα δεχτει ?? δεν μπορω να καταλαβω τι κανω λαθος εγω !

[kaspas]

Καλημέρα,

Έχει συναντήσει κανείς στη παραλληλοποίηση της radix_sort.c με pthreads error στην memcpy λόγω overlap? Αν ναι πως το φτιαχνω?  Aυτό έχει σαν αποτέλεσμα στην ίδια γραμμή να έχω "Invalid read of size 1" το οποίο εν τέλει κρασάρει το πρόγραμμα. Το error είναι "access not within mapped region"

Επιπλέον έχω warnings από το valgrind ότι χρησιμοποιώ uninitialized values, πως γίνεται αυτό αν τις περνάω όλες από την test_octree αρχικοποιημένες μέσω δομής αρχικοποιημένες; Το θέμα αυτό υπάρχει με τις pointer μεταβλητές που είναι πίνακες.

Για πείτε 

Σε εμένα όταν συνέβαινε αυτό κάποιος pointer έβλεπε λάθος. Δες αν έχεις καλά τους δείκτες στους πίνακες.

[tpvagenas]

Προσπαθώ να κάνω την υλοποίηση της radix_sort σε openmp και μου βγάζει σφάλμα libgomp: Thread creation failed: Resource temporarily unavailable. Το βγάζει μετά απο κάποιο όριο στο Ν . Ξέρει κανείς γιατί συμβαίνει αυτό?

[ReMi0s]

παιδιά για την cilk όταν βάζετε cilk_for στην hashcodes παίρνετε και εσείς χάλια χρόνους;

[georgkonst]

Σε εμένα όταν συνέβαινε αυτό κάποιος pointer έβλεπε λάθος. Δες αν έχεις καλά τους δείκτες στους πίνακες.

 

Code:

     args[i].morton_codes= morton_codes;
      args[i].sorted_morton_codes= sorted_morton_codes;
      args[i].permutation_vector=permutation_vector;
      args[i].index = index;
      args[i].level_record = level_record;
      args[i].size = size;
      args[i].population_threshold = population_threshold;
      args[i].sft = sft - 3;
      args[i].lv= lv+1;
      args[i].offset = offset;
      pthread_create(&threads[i], NULL, truncated_radix_sort,(void *)&args[i]);  
 

Έτσι το κάνω εγώ, δε βλέπω κάτι λάθος με το πως περνάω τις τιμές. Έχω την εντύπωση ότι κάπως πρέπει να αλλάξω τις memcpy πιο πάνω αλλά δεν είμαι σίγουρος πως

Code:

memcpy(permutation_vector, index, (N)*sizeof(unsigned int)); // Copy the pernutation vector
memcpy(sorted_morton_codes, morton_codes, (N)*sizeof(unsigned long int)); // Copy the Morton codes 

[ReMi0s]

Code:

     args[i].morton_codes= morton_codes;
      args[i].sorted_morton_codes= sorted_morton_codes;
      args[i].permutation_vector=permutation_vector;
      args[i].index = index;
      args[i].level_record = level_record;
      args[i].size = size;
      args[i].population_threshold = population_threshold;
      args[i].sft = sft - 3;
      args[i].lv= lv+1;
      args[i].offset = offset;
      pthread_create(&threads[i], NULL, truncated_radix_sort,(void *)&args[i]);  
 

Έτσι το κάνω εγώ, δε βλέπω κάτι λάθος με το πως περνάω τις τιμές. Έχω την εντύπωση ότι κάπως πρέπει να αλλάξω τις memcpy πιο πάνω αλλά δεν είμαι σίγουρος πως

Code:

memcpy(permutation_vector, index, (N)*sizeof(unsigned int)); // Copy the pernutation vector
memcpy(sorted_morton_codes, morton_codes, (N)*sizeof(unsigned long int)); // Copy the Morton codes 

αυτό ειναι λάθος νομίζω.. για να καλέσεις πολλά thread πρεπει να σπάσεις καθε πίνακα σε κομμάτια..
ετσι αφού έχεις ορίζει τα offset και τα size
 args.morton_codes= &morton_codes[offset];
      args.sorted_morton_codes= &sorted_morton_codes[offset];
      args.permutation_vector=&permutation_vector[offset];
      args.index = &index[offset];
      args.level_record = &level_record[offset];
      args.size = size;
      args.population_threshold = population_threshold;
      args.sft = sft - 3;
      args.lv= lv+1;
      pthread_create(&threads, NULL, truncated_radix_sort,(void *)&args);

[ReMi0s]

Παιδιά μπορέι κάποιος να εξηγήσει πώς βάζουμε όσα workers θέλουμε για κάθε cilk_for ?
Βρήκα αυτό αλλα λειτουργεί μόνο για την πρώτη συνάρτηση με cilk_for
char str[3];
    sprintf(str,"%d",NUM_THREADS);
    __cilkrts_set_param("nworkers",str);

στην σελίδα της Intel βρηκα οτι πρέπει μετά απο κάθε εκτέλεση cilk_for  για να ξανα τρέξει με όσα threads θέλουμε να βάλεις
__cilkrts_end_cilk();
ωστόσο αυτή την συνάρτηση δεν την αναγνωρίζει, αν και η βιλιοθήκη της είναι ίδια με της
 __cilkrts_set_param("nworkers",str);

τι κάνω λάθος;

[nikoscha]

Code:

     args[i].morton_codes= morton_codes;
      args[i].sorted_morton_codes= sorted_morton_codes;
      args[i].permutation_vector=permutation_vector;
      args[i].index = index;
      args[i].level_record = level_record;
      args[i].size = size;
      args[i].population_threshold = population_threshold;
      args[i].sft = sft - 3;
      args[i].lv= lv+1;
      args[i].offset = offset;
      pthread_create(&threads[i], NULL, truncated_radix_sort,(void *)&args[i]);  
 

Έτσι το κάνω εγώ, δε βλέπω κάτι λάθος με το πως περνάω τις τιμές. Έχω την εντύπωση ότι κάπως πρέπει να αλλάξω τις memcpy πιο πάνω αλλά δεν είμαι σίγουρος πως

Code:

memcpy(permutation_vector, index, (N)*sizeof(unsigned int)); // Copy the pernutation vector
memcpy(sorted_morton_codes, morton_codes, (N)*sizeof(unsigned long int)); // Copy the Morton codes 

Μεσα στν memcpy δεν πρεπει να βαλεις τις μεταβλητες απλα morton_codes κτλ. Αλλα στην δικια σ περιπτωση πρεπει να δείχνεις στο structure δλδ arg->morton_codes

[nikoscha]

Με pthreads ειναι καλυτερα στην radix_Sort να τρεχει την πρωτη φορα σειριακα και στην συνεχεια να τρέχει παράλληλα ; Δηλαδη καθε φορα που κανει την αναδρομη να δημιουργουνται και τα threads

[georgkonst]

Μεσα στν memcpy δεν πρεπει να βαλεις τις μεταβλητες απλα morton_codes κτλ. Αλλα στην δικια σ περιπτωση πρεπει να δείχνεις στο structure δλδ arg->morton_codes

 

Code:

struct radix_args *one_args = (struct radix_args *) arg;
   unsigned long int *morton_codes = one_args->morton_codes;
   unsigned long int *sorted_morton_codes = one_args->sorted_morton_codes;
   unsigned int *permutation_vector = one_args->permutation_vector;
   unsigned int *level_record = one_args->level_record;
   unsigned int *index = one_args->index;
   int N = one_args->N;
   int population_threshold = one_args->population_threshold;
   int sft =one_args->sft;
   int lv = one_args->lv;

Δημιουργώ πιο πάνω τη δομή και περνάω τις μεταβλητές της σε τοπικές μεταβλητές, οπότε δε κάνει διαφορά (δοκίμασα και να το βάλω όπως λες)

EDIT:
Κλασσικά όλα τα προβλήματα μου λύθηκαν απλά ξαναγράφοντας το από την αρχή, είχα κάποια θέματα με το πως περνούσα τις μεταβλητές της δομής. To περίεργο τώρα είναι ότι η παράλληλη truncated_radix_sort με 8 threads κάνει ~5 δευτερόλεπτα να εκτελεστεί για Ν=2^20 

[Ροζ συννεφάκι]

Έχει μπει κανείς στο e-learning όπου θα υποβάλλουμε την εργασία? Αν δείτε στο ημερολόγιο, μετά το τέλος της προθεσμίας έχει μια εβδομάδα για να αξιολογήσουμε τις εργασίες 4 συμφοιτητών μας και ο τελικός βαθμός θα κριθεί και από αυτό! 
Τι φάση? είχε ακούσει κανείς κάτι σχετικό??

[c0ndemn3d]

Πρώτη φορά γίνεται αυτό στο μάθημα

[Vlassis]

παιδιά για την cilk όταν βάζετε cilk_for στην hashcodes παίρνετε και εσείς χάλια χρόνους;

οχι, υπαρχει βελτιωση!

[Ροζ συννεφάκι]

Γενικά θέλετε παράταση της προθεσμίας? Γιατί θα στείλω μέιλ σήμερα, να ξέρω τι να του πω.. Μην είμαι μόνο εγώ που θέλω!