puntatore booleana statica globale provoca errore di segmentazione utilizzando pthread
https://stackoverflow.com/questions/2982757
-
24-10-2019 - |
italiano
english
français
española
中国
日本の
العربية
Deutsch
한국어
Português
RussianDomanda
Nuovo per la programmazione pthread, e bloccato su questo errore quando si lavora su un C ++ & C codice misto.
Quello che ho fatto è quello di chiamare il codice C nel thread creato dal codice C ++. C'è una statica booleana puntatore is_center utilizzato nel thread e dovrebbe ottenuto libero quando le finiture filo.
Comunque ho notato che ogni volta che quando il programma trasformato in funzione c, il valore del puntatore booleano sarebbe cambiato e l'errore di segmentazione poi è accaduto a causa del free (). E il problema si verifica solo quando si utilizza il codice c. Rimuovere il codice c e multi-thread c ++ parte funziona bene.
Codice dettaglio è il seguente:
static bool *is_center;
// omit other codes in between ...
void streamCluster( PStream* stream)
{
// some code here ...
while(1){
// some code here ...
is_center = (bool*)calloc(points.num,sizeof(bool));
// start the parallel thread here.
// the c code is invoked in this function.
localSearch(&points,kmin, kmax,&kfinal); // parallel
free(is_center);
}
E la funzione utilizzando in parallelo è la seguente (il mio codice c viene richiamato in ogni thread):
void localSearch( Points* points, long kmin, long kmax, long* kfinal ) {
pthread_barrier_t barrier;
pthread_t* threads = new pthread_t[nproc];
pkmedian_arg_t* arg = new pkmedian_arg_t[nproc];
pthread_barrier_init(&barrier,NULL,nproc);
for( int i = 0; i < nproc; i++ ) {
arg[i].points = points;
arg[i].kmin = kmin;
arg[i].kmax = kmax;
arg[i].pid = i;
arg[i].kfinal = kfinal;
arg[i].barrier = &barrier;
pthread_create(threads+i,NULL,localSearchSub,(void*)&arg[i]);
}
for ( int i = 0; i < nproc; i++) {
pthread_join(threads[i],NULL);
}
delete[] threads;
delete[] arg;
pthread_barrier_destroy(&barrier);
}
Infine, la funzione di chiamata il mio codice C:
void* localSearchSub(void* arg_) {
int eventSet = PAPI_NULL;
begin_papi_thread(&eventSet);
pkmedian_arg_t* arg= (pkmedian_arg_t*)arg_;
pkmedian(arg->points,arg->kmin,arg->kmax,arg->kfinal,arg->pid,arg->barrier);
end_papi_thread(&eventSet);
return NULL;
}
E da gdb, quello che ho ottenuto per il is_center è:
Breakpoint 2, localSearchSub (arg_=0x600000000000bc40) at streamcluster.cpp:1711
1711 end_papi_thread(&eventSet);
(gdb) s
Hardware watchpoint 1: is_center
Old value = (bool *) 0x600000000000bba0
New value = (bool *) 0xa93f3
0x400000000000d8d1 in localSearchSub (arg_=0x600000000000bc40) at streamcluster.cpp:1711
1711 end_papi_thread(&eventSet);
Qualche suggerimento? Grazie in anticipo!
Alcuni nuove informazioni relative al codice: per il codice C, sto usando il pacchetto PAPI. Scrivo il mio involucro papi per inizializzare e leggere i contatori di sistema. Il codice è il seguente:
void begin_papi_thread(int* eventSet)
{
int thread_id = pthread_self();
// Events
if (PAPI_create_eventset(eventSet)) {
PAPI_perror(return_value, error_string, PAPI_MAX_STR_LEN);
printf("*** ERROR *** Failed to create event set for thread %d: %s\n.", thread_id, error_string);
}
if((return_value = PAPI_add_events(*eventSet, event_code, event_num)) != PAPI_OK)
{
printf("*** ERROR *** Failed to add event for thread %d: %d.\n", thread_id, return_value);
}
// Start counting
if ((return_value = PAPI_start(*eventSet)) != PAPI_OK) {
PAPI_perror(return_value, error_string, PAPI_MAX_STR_LEN);
printf("*** ERROR *** PAPI failed to start the event for thread %d: %s.\n", thread_id, error_string);
}
}
void end_papi_thread(int* eventSet)
{
int thread_id = pthread_self();
int i;
long long * count_values = (long long*)malloc(sizeof(long long) * event_num);
if (PAPI_read(*eventSet, count_values) != PAPI_OK)
printf("*** ERROR *** Failed to load count values.\n");
if (PAPI_stop(*eventSet, &dummy_values) != PAPI_OK) {
PAPI_perror(return_value, error_string, PAPI_MAX_STR_LEN);
printf("*** ERROR *** PAPI failed to stop the event for thread %d: %s.\n", thread_id, error_string);
return;
}
if(PAPI_cleanup_eventset(*eventSet) != PAPI_OK)
printf("*** ERROR *** Clean up failed for the thread %d.\n", thread_id);
}
Soluzione
Non credo che hai postato abbastanza il codice per capire veramente il problema, ma sembra sospetto che hai dichiarato is_center globale. Presumo che si sta utilizzando in più di un luogo, forse da più thread (localSearchSub ne parla, che è la funzione thread di lavoro).
Se is_center viene letto o scritto da più thread, probabilmente avrete bisogno di proteggerlo con una pthread mutex . Si dice che è "liberata quando le finiture filo", ma si deve essere consapevoli che ci sono discussioni nprocs, e sembra come se fossero tutti di lavoro su una serie di Caccio is_center[points]. Se points != nproc, questo potrebbe B e una brutta cosa [1]. Ogni filo deve probabilmente lavoro sulla propria matrice e localSearch dovrebbe aggregare i risultati.
Le funzioni xxx_papi_thread non si ottiene alcun risultato su Google, quindi posso solo immaginare che sia proprio ... improbabile che saremo in grado di aiutarti, se il problema è lì:)
[1]: Anche se points == nproc, non è necessariamente OK per scrivere a diversi elementi di una matrice da più thread (è compilatore e processore dipendente). Essere sicuri, utilizzare un mutex.
Inoltre, questo è C++ tag. Si può sostituire le matrici calloc e dinamici (utilizzando new) con vectors? Si potrebbe finire più facile per eseguire il debug, e finisce certamente all'altezza più facile da mantenere. Perché odi e vuole punire i lettori del tuo codice? ;)
