2012-01-02 22 views
0

我的posix tcp服務器似乎全部泄漏。我正在用ps和top等工具來關注他們,他們認爲內存在不斷增加。 只要客戶進入和/或離開,就會發生這種情況。通用C Tcp服務器內存泄漏

EG。假設ps首先報告100 VSZ。一個客戶進入並且它上升到238.然後客戶退出並且它下降到138. 不是100!每次客戶進入和退出內存都會增加。

我已經嘗試了一噸不同的內存泄漏工具,例如。 valgrind並沒有發現任何東西。 (而且他們也不認爲它也是漏水的。)

難道是ps和top嗎?這似乎不太可能。

我做了演示我的代碼和潛在的泄漏少量樣品通用:

#include <stdio.h> 
#include <stdlib.h> 
#include <pthread.h> 
#include <sys/socket.h> 
#include <arpa/inet.h> 
#include <signal.h> 
#include <unistd.h> 

#define MAX_BUFFER 100*1024 

void* server_process_thread(void* args) 
{ 
    int client = (int)args; 
    unsigned char* buffer = NULL; 
    int r; 

    /* allocate something huge */ 
    if((buffer = malloc(MAX_BUFFER)) == NULL) 
    { 
     perror("Couldn't allocate"); 
     goto exit; 
    } 

    printf("Client processing ...\n"); 

    //echo all that comes 
    while(1) 
    { 
     r = read(client, buffer, MAX_BUFFER); 
     if(r <= 0) break; 
     write(client, buffer, r); 
    } 

exit: 
    printf("Client exit\n"); 
    free(buffer); 
    close(client); 
    pthread_exit(NULL); 
} 

int main(void) 
{ 
    struct sockaddr_in server_sockaddr = {0}; 
    struct sockaddr_in clientSockAddr = {0}; 
    int flags = 1; 
    int server = 0; 
    int client = 0; 
    pthread_t thread = 0; 
    socklen_t clientSockSize = sizeof(clientSockAddr); 

    //init tcp 
    signal(SIGCHLD, SIG_IGN); 
    signal(SIGPIPE, SIG_IGN); 
    signal(SIGALRM, SIG_IGN); 

    if ((server = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) == -1) 
    { 
     perror("Couldn't open socket"); 
     return -1; 
    } 

    flags = 1; 
    if ((setsockopt(server, SOL_SOCKET, SO_REUSEADDR, (void *) &flags, sizeof(flags))) == -1) 
    { 
     perror("Couldn't set socket reuse"); 
     return -1; 
    } 

    server_sockaddr.sin_family = AF_INET; 
    server_sockaddr.sin_port = htons(666); 
    server_sockaddr.sin_addr.s_addr = htonl(INADDR_ANY); //IP 

    if (bind(server, (struct sockaddr *) &server_sockaddr, sizeof(server_sockaddr)) == -1) 
    { 
     perror("Couldn't bind socket"); 
     return -1; 
    } 

    //LISTEN 
    if (listen(server, SOMAXCONN) == -1) 
    { 
     perror("Couldn't listen on socket"); 
     return -1; 
    } 

    printf("TCP Echo Server started ...\n"); 

    //wait for clients 
    while(1) 
    { 
     client = accept(server, (struct sockaddr*) (&clientSockAddr), &clientSockSize); 

     if(pthread_create(&thread, NULL, server_process_thread, (void*)client) != 0) 
     { 
      perror("Couldn't create thread"); 
      return -1; 
     } 
    } 

    //dispose 
    printf("Server exit\n"); 
    close(server); 
    return EXIT_SUCCESS; 
} 

現在,我可能會錯過一些錯誤處理在這裏和那裏,但有在該代碼中的一些根本缺陷?

回答

3

您至少泄漏了線程。

默認情況下,pthreads在退出之前不會被「清理」,直到有人對其調用pthread_join()。

如果將線程創建爲分離線程,則其資源在退出時將被清除(但不能再pthread_join()它)。 最簡單的方法是撥打pthread_detach(pthread_self());作爲您的server_process_thread中的第一件事。

+0

我以爲我已經嘗試過,但它似乎工作時添加到示例。 – Illishar 2012-01-02 11:14:03