[C] Pthread e mutex/condition

[Dawidh]

ciao a tutti.. allora, il programma funziona nel seguente modo:
partono 4 thread, 1 fa da client e manda richieste (mettendo tutto in una coda circolare) e sblocca un thread, in caso dovrebbe lasciare la richiesta in coda e un thread appena si libera la preleva.
gli altri 3 threads invece prendono tali richiesta dalla coda e fanno delle cose:

il problema è qui:

void put_richiesta(struct buffer *b)
{
  struct element *x;
  int i=0;
  pthread_mutex_lock(&b->m);
  fprintf(stderr, "T bloccato\n");
  b->blocked_readers++;
  pthread_cond_wait(&b->block_read, &b->m);
  fprintf(stderr, "T sbloccato........\n");
  fprintf(stderr, "prima dell'estrazione "); print_CA();
  if (extract_CA(x) == 1) { 
    //fprintf(stderr, "1");
    for (i=0; i<x->t; i++) {
    fprintf(stderr, "%s\n", x->msg);
    sleep(1);
    }
    //fprintf(stderr, "2");
  pthread_mutex_unlock(&b->m);
  fprintf(stderr, "dopo l'estrazione ");print_CA();
  }
  else {
  fprintf(stderr, "Non ci sono elementi in coda\n");
  pthread_mutex_unlock(&b->m);
  }
  extract_CA(x);
  pthread_mutex_unlock(&b->m);
}

praticamente preleva la richiesta: fa delle stampe ogni secondo del messaggio preso. La prima volta che si fa una insert (e quindi subito dopo viene fatta la signal e poi la extract descitta qui sopra) tutto funziona bene, però quando si inserisce una nuova richiesta,viene inserita (sicuro perchè viene stampato un log delle operazioni) però il programma si blocca alla riga che vi ho segnato in rosso. dando errore di segmentation fault
non sappiamo il perché, tutto il resto va bene, perché stampiamo log ogni momento, dovrebbe estrarre dalla seconda posizione della coda (anche i puntatori sono messi giusti) ma non lo fa. Avete qualche idea del perché?????????
Grazie

[ilsensine]

Puoi postare la tua extract_CA? Credo ci sia un grossolano bug. Da come hai implementato il tutto sembra che in "x" ti aspetti il valore di ritorno, il che non può avvenire se non passi x per riferimento.

Inoltre hai una race condition sulla pthread_cond_wait; l'uso corretto di questa funzione è il seguente:

  pthread_mutex_lock(&mtx);
  while (!the_condition_im_waiting_for())
    pthread_cond_wait(&cond, &mtx);
  process_the_condition();
  pthread_mutex_unlock(&mtx);

A te manca la logica che ho schematizzato con la while. Se un inserimento avviene dopo la tua pthread_mutex_unlock, rimarrai bloccato sulla variabile di condizione!

[Dawidh]

int extract_CA(struct element *x)
{
  if(a.num == 0)
    return 0;
  *x = a.elements[a.tail];
  a.tail = (a.tail + 1) % 5;
  a.num--;
  return 1;  
}

Questa è la extract.
Il problema non è che mi si blocca il programma, anche perchè per ora è in fase di realizzazione, il client mette in coda e fa una signal per il thread che si sblocca, e lo stiamo testando mettendo una richiesta per volta....
il codice che ho messo era commentato in parte e ho sbagliato a postare, le ultime due righe in realtà non ci sono... Queste qui in rosso:

  else {
  fprintf(stderr, "Non ci sono elementi in coda\n");
  pthread_mutex_unlock(&b->m);
  }
  extract_CA(x);
  pthread_mutex_unlock(&b->m);
}

scusa per lo sbaglio.

[ilsensine]

Originariamente inviato da Dawidh

int extract_CA(struct element *x)
{
  if(a.num == 0)
    return 0;
  *x = a.elements[a.tail];
  a.tail = (a.tail + 1) % 5;
  a.num--;
  return 1;  
}

Questa è la extract.

...ed è sbagliato, in quanto x punta a (void *) rand().
Dichiara:
struct element x;
e passa &x a extract_CA.

Il problema non è che mi si blocca il programma

Lo so, ma lì ho visto una race condition che potrebbe causarlo e te la ho segnalata.

[Dawidh]

Vero... grazie adesso abbiamo risolto...........
Grazie mille, per un problema così stupido abbiamo perso quasi una giornata.......