Ошибка сегментации или SizeOf неправильно используется
Поэтому я работаю над программой, в которой использую pthreads для параллельного решения проблемы. Прямо сейчас я получаю ошибку сегмента, когда запускаю следующий код в функции: average_power.
Это уместная часть кода, в которой я почти уверен, что ошибка где-то:
struct args {
signal *sigs;
int filter_orders;
double *filter_coeffss;
signal *outputs;
int threadIDs;
int bandwidths;
int bandNumbers;
};
double *band_power;
pthread_t *tid; // array of thread ids
int numThread;
int numProc;
void *worker(void *arg){
struct args *currentArgs = (struct args*) arg;
int i;
int blocksize = currentArgs->bandNumbers / numThread; // note: floor
int mystart, myend;
int currentID = currentArgs->threadIDs;
int band;
int bandwidth = currentArgs->bandwidths;
mystart = currentID*blocksize;
if (currentID==(numThread-1)) { // last processor
// the last processor will take care of the leftover
// elements of the vector, in case num_threads doesn't
// divide vector_len
myend = currentArgs->bandNumbers;
} else {
myend = (currentID+1) * blocksize;
}
cpu_set_t set;
CPU_ZERO(&set);
CPU_SET(currentID%numProc,&set);
if (sched_setaffinity(0,numProc,&set)<0) { // do it
perror("Can't setaffinity"); // hopefully doesn't fail
exit(-1);
}
//THIS LOOP WILL BE THE NEW WORKER PROCESS TO BE SPLIT UP VIA BANDS
for (band=mystart;band<myend;band++) {
// Make the filter
generate_band_pass(currentArgs->sigs->Fs,
band*bandwidth+0.0001, // keep within limits
(band+1)*bandwidth-0.0001,
currentArgs->filter_orders,
currentArgs->filter_coeffss);
hamming_window(currentArgs->filter_orders,currentArgs->filter_coeffss);
// Convolve
convolve(currentArgs->sigs->num_samples,
currentArgs->sigs->data,
currentArgs->filter_orders,
currentArgs->filter_coeffss,
currentArgs->outputs->data);
// Capture characteristics
band_power[band] = avg_power(currentArgs->outputs->data, currentArgs->outputs->num_samples);
}
pthread_exit(NULL);
}
Так что это рабочая функция вместе со структурными аргументами, переданными ей из этого раздела другой функции, где потоки инициализируются и получают инструкции:
band_power = (double *) malloc(sizeof(double)*numThread);
tid = (pthread_t *) malloc(sizeof(pthread_t)*numThread);
///create all structs and initialize
struct args *curargs;
int p;
int num_started;
for(p=0;p<numThread;p++){
outputNew = (struct signal *) malloc(sizeof(struct signal)); //THIS IS THE LINE THAT
outputNew = allocate_signal(sig->num_samples, sig->Fs, 0);
curargs = (struct args *) malloc(sizeof(struct args));
curargs->sigs = sig;
curargs->filter_orders = filter_order;
curargs->filter_coeffss = filter_coeffs;
curargs->outputs = outputNew;
curargs->threadIDs = p;
curargs->bandwidths = bandwidth;
curargs->bandNumbers = num_bands;
rc=pthread_create( &(tid[p]), // thread id gets put here
NULL, // use default attributes
worker, // thread will begin in this function
curargs // we'll give it i as the argument
);
if (rc==0) {
printf("Started thread %ld, tid %lu\n",p,tid[p]);
num_started++;
} else {
printf("Failed to start thread %ld\n",p);
perror("Failed to start thread");
tid[p]=0xdeadbeef;
}
Таким образом, ошибка, которую я получаю, это либо segfault внутри одного из потоков, когда в конце * worker вызывается Average_power (Average_power верна, я это доказал), либо я получаю сообщение об ошибке, когда я раскомментирую следующую строку в мой цикл, который инициализирует массив.
outputNew = (struct signal *) malloc(sizeof(struct signal));
Я хотел убедиться, что outputNew до того, как он был помещен в структуру arg, имел свое собственное пространство, чтобы он не перезаписывался, но эта строка не дает ему скомпилироваться. Я не делаю это правильно? В противном случае average_power получает доступ к этой переменной (выводам) из структуры args, и когда это происходит, происходит ошибка по умолчанию, что, я думаю, означает, что некоторая память где-то используется неправильно? Извините, если это так долго, и я могу уточнить любые детали, если я недостаточно хорошо их произнесу. Все остальные функции или вызовы вещей относятся к моему проекту, и я знаю, что они верны, мои ошибки происходят из-за моей реализации pthread и передачи данных куда-то.
1 ответ
Я не вижу переменную outputNew
объявлено где угодно Возможно вместо
outputNew = (struct signal *) malloc(sizeof(struct signal));
что вы имели в виду:
struct signal *outputNew = malloc(sizeof(struct signal));