一般的なC Tcpサーバのメモリリーク

Question

私のposixのTCPサーバはすべて漏れているようです。私はpsやtopのようなツールでそれらを見守っています。彼らは記憶が絶えず増加していると考えています。 クライアントが出入りするたびに発生します。

例： psが最初に100 VSZを報告したとしましょう。クライアントが入り、238に上昇します。その後、クライアントは終了し、138に落ちます。100なし！クライアントが出入りするたびにメモリが増えます。

私は、例えば、次のようなさまざまなメモリリークツールを試しました。彼らの誰も何も見つけません。 （そして彼らはそれも漏れているとは思わない）

これは混乱しているのですか？それは起こりそうもない。

私は私のコードと潜在的なリークを示して小型汎用のサンプル作りました：

#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; 
} 

今、私はここにあるハンドリング、いくつかのエラーを逃すかもしれないが、このコードでは、いくつかの根本的な欠陥があるのでしょうか？

Answer 1

スレッドが少なくとも漏れています。

デフォルトでは、誰かがpthread_join（）を呼び出すまで、pthreadは終了すると「クリーンアップ」されません。

スレッドを分離スレッドとして作成すると、そのリソースは終了時にクリーンアップされますが、pthread_join（）できなくなります。 これを行う最も簡単な方法は、server_process_threadの最初のものとしてpthread_detach(pthread_self());を呼び出すことです。