在C中調試遞歸線程調用

Question

我一直在試圖調試我的代碼，只要我有一天半的空閒時間，我不知道我的代碼有什麼問題。當我將close()函數添加到遞歸調用時，該程序會給我一個無效的指針。但是，當我刪除close()函數調用的程序運行正常，但它不會做什麼是應該做的，這就是：

• 在用戶 輸入目錄
• 開放加起來所有的文件大小子目錄，如果有的話，並添加 子目錄

而是裏面 的所有文件，它增加了所有的文件大小輸入目錄能夠打開最後一個子目錄，將該目錄內的文件添加到總文件大小計數中。

我想用線程做到這一點。 main()函數從用戶輸入目錄創建一個主線程，並在球杆上運行opendirectory()。

/* 
* Iterates through given directory 
*/ 
void *opendirectory(void *t) 
{ 
pthread_mutex_lock(&dirlock); 
DIR *dpntr; 
struct dirent *dentry; 
char new_directory[512], dir = t; 

printf("OPENING DIRECTORY ... %s\n", t); 

/* Checks if given directory can be opened */ 
if((dpntr = opendir(t)) == NULL) { 
    printf("DIRECTORY FAILED ...%s\n",t); 
    perror("ERROR -- COULD NOT OPEN DIR"); 
    pthread_exit(NULL); 
} 

printf("DIRECTORY OPENED: %s\n", t); 

/* Read each file in current directory */ 
while ((dentry = readdir(dpntr)) != NULL) { 
    /* Ignore special directories */ 
    if(strcmp(dentry -> d_name, ".") == 0 || strcmp(dentry -> d_name, "..") == 0) { 
    continue; 
    } else { 
    compilelist(t, dentry->d_name); 
    } 
} 

pthread_mutex_unlock(&dirlock); 
/* Checks if directory can be closed */ 
if(closedir(dpntr) < 0) 
    printf("ERROR CLOSING %s.\n", t); 

} 

這是確定是否應該創建新線程並且應該遞歸運行的函數。

/* 
* Determines if current file is a directory 
* Creates a new thread if true 
*/ 
void compilelist (const char* dirname, const char *filename) 
{ 
    pthread_mutex_lock(&filelock); 
    struct stat statdata; 
    char *filepathname, *dpntr; 

    /* Allocate memory for filepathname */ 
    if((filepathname = (char *) malloc(sizeof(char) * strlen(dirname))) == NULL) 
    { 
     printf("CANNOT ALLOCATE MEMORY FOR FILE PATH NAME."); 
     pthread_exit(NULL); 
    } 

    /* Concats directory name with file name */ 
    if(dirname[strlen(dirname) -1] == '/') 
    { 
     pthread_mutex_lock(&pathlock); 
     sprintf(filepathname, "%s%s", dirname, filename); 
     pthread_mutex_unlock(&pathlock); 
    }else 
    { 
     pthread_mutex_lock(&pathlock); 
     sprintf(filepathname, "%s/%s", dirname, filename); 
     pthread_mutex_unlock(&pathlock); 
    } 

    lstat(filepathname, &statdata); 

    /* Calls print_statdata() if current item is a file */ 
    if(!(S_ISDIR(statdata.st_mode))) 
    { 
     printf("FILE: %s\n", filepathname); 
     if(!stat(filepathname, &statdata)) 
     { 
      print_statdata(filename, &statdata); 
     } 
     else { 
      fprintf (stderr, "GETTING STAT FOR %s", filepathname); 
      perror("ERROR IN STATDATA WHILE GETTING STAT"); 
     } 
    } 
    /* Recursive call to opendirectory() */ 
    else { 
     pthread_mutex_lock(&dircountlock); 
     dirCount++; 
     pthread_mutex_unlock(&dircountlock); 
     dpntr = filepathname; 
     free(filepathname); 
     printf("SUB-DIRECTORY THREAD: %s\nTHREAD ID NUMBER: %d\n", dpntr, dirCount); 
     pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE); 
     pthread_create(&threads[dirCount-1], &attr, opendirectory, (void *)dpntr); 
    } 

    pthread_mutex_unlock(&filelock); 

} 

這裏是main()

/* 
* Main function prompts user for a directory 
*/ 
int main(int argc, char *argv[]) 
{ 
    int i; 
    char *dPtr; 
    // pthread_attr_t attr; 

    printf("ENTER A DIRECTORY:\n\t"); 
    scanf("%s", directory); 
    dPtr = directory; 

    /* Initialize mutex and condition variable objects */ 
    pthread_mutex_init(&mutex, NULL); 
    pthread_mutex_init(&filelock, NULL); 
    pthread_mutex_init(&dirlock, NULL); 
    pthread_mutex_init(&dircountlock, NULL); 
    pthread_cond_init (&count_threshold_cv, NULL); 

    /* For portability, explicitly create threads in a joinable state */ 
    pthread_attr_init(&attr); 
    pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE); 
    pthread_create(&threads[0], &attr, opendirectory, (void *)dPtr); 

    /* Wait for all threads to complete */ 
    for (i = 0; i < dirCount; i++) { 
     pthread_join(threads[i], NULL); 
    } 

    printf("TOTAL DIRECTORY SIZE: %d\n", dirSize); 

    /* Clean up and exit */ 
    pthread_attr_destroy(&attr); 
    pthread_mutex_destroy(&mutex); 
    pthread_mutex_destroy(&filelock); 
    pthread_mutex_destroy(&dirlock); 
    pthread_mutex_destroy(&dircountlock); 
    pthread_cond_destroy(&count_threshold_cv); 
    pthread_exit (NULL); 

} 

而且全局變量...

pthread_mutex_t mutex; 
pthread_mutex_t dirlock; 
pthread_mutex_t filelock; 
pthread_mutex_t dircountlock; 
pthread_mutex_t threadlock; 
pthread_cond_t count_threshold_cv; 
pthread_attr_t attr; 
pthread_t threads[128]; // handles up to 128 threads (i.e. 128 directories, change accordingly) 
char directory[512]; 
int dirSize = 0; 
int dirCount = 1; // user's input directory 

我覺得所謂的compilelist()功能的底部pthread_create()工作不正常。線程[]指的是默認大小爲20的全局線程數組，假設總共不會超過20個目錄。由於用戶的輸入目錄，dirCount從1開始，並在遇到新目錄時增加。

Answer 1

在這裏，我找到了你的代碼的2個問題：

1. 由於wrang-wrang文件檔案化管理，closedir（T）導致段錯誤。 「

2. 」char filepathname [512];「 compilelist（）是一個本地內存緩衝區，但是你將它傳遞給你的線程（opendirectory）並持續使用它。您應該使用複製或動態分配。

Effo UPD @ 2009nov17： 以上2點固定之後，它在我的FC9 x86_64的正常工作爲止。順便說一句：20號線程是不夠的。

Answer 2

第一個問題：

，每當我有空閒時間，在過去的一天半

不要這樣，你的大腦是不是專爲它。分配一段時間，告訴你的同事/妻子和孩子們，如果他們在這段時間打擾你，會有槍聲和警察參與:-)

其他問題：不知道（因此社區wiki）。

Answer 3

您的代碼：

dpntr = opendir(t) 

...

if(closedir(t) < 0) 

應該是：

if(closedir(dpntr) < 0)