Ошибка сегментации или 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));
Другие вопросы по тегам