求教多线程socket server是否有内存泄露

sinosinux

大家好，我在aix系统上写了一个pthread多线程的socket server程序，代码如下。长时间运行以后，发现进程的内存缓慢上涨，求分析这个程序是否有内存泄露，谢谢！！

1. # include <iostream>
   
2. # include <string>
   
3. # include <sstream>
   
4. # include <list>
   
5. # include <map>
   
6. # include <vector>
   
7. # include <pthread.h>
   
8. # include <semaphore.h>
   
9. # include <errno.h>
   
10. # include <stdio.h>
    
11. # include <stdlib.h>
    
12. # include <signal.h>
    
13. # include <unistd.h>
    
14. # include <algorithm>
    
15. # include <netdb.h>
    
16. # include <netinet/in.h>
    
17. # include <sys/types.h>
    
18. # include <sys/socket.h>
    
19. # include <sys/socketvar.h>
    
20. # include <arpa/inet.h>
    
21. # include <sys/time.h>
    
22. # include <sys/limits.h>
    
23. # include <time.h>
    
24. 
    
25. 
    
26. using namespace std;
    
27. 
    
28. pthread_mutex_t pinmutex = PTHREAD_MUTEX_INITIALIZER;
    
29. pthread_attr_t tattr;
    
30. 
    
31. 
    
32. class Pin
    
33. {
    
34. public:
    
35.     Pin() {};
    
36.     Pin (int id, string nm)
    
37.     {
    
38.         fd = id;
    
39.         name = nm;
    
40.     }
    
41.     Pin(int id, char* nm)
    
42.     {
    
43.         fd = id;
    
44.         name = nm;
    
45.     }
    
46.     int fd;
    
47.     string name;
    
48. };
    
49. map<int, Pin> pins;
    
50. 
    
51. class PEMutex
    
52. {
    
53.     private:
    
54.     pthread_mutex_t& _mutex;
    
55. 
    
56.     public:
    
57.     PEMutex(pthread_mutex_t& mutex):_mutex(mutex)
    
58.     {
    
59.         pthread_mutex_lock(&mutex);
    
60.     }
    
61.     ~PEMutex()
    
62.     {
    
63.         pthread_mutex_unlock(&_mutex);
    
64.     }
    
65. };
    
66. 
    
67. 
    
68. void* threadfunc(void* apin)
    
69. {
    
70.     pthread_detach(pthread_self());
    
71.     Pin* pin = (Pin*)apin;
    
72.     int fd = pin->fd;
    
73. 
    
74.     char buf[] = "hello client";
    
75.     send(fd, buf, strlen(buf), 0);
    
76.     cout << buf << ":" << pthread_self() << endl;
    
77.     close(fd);
    
78.     {
    
79.         PEMutex mutex(pinmutex);
    
80.         pins.erase(fd);
    
81.     }
    
82.     pthread_exit(0);
    
83.     return NULL;
    
84. }
    
85. 
    
86. 
    
87. int main(int argc, char** argv)
    
88. {
    
89.     int    clientsocket;
    
90.     int    serversocket;
    
91.     int port = 14000;
    
92.     socklen_t client_len;
    
93.     struct sockaddr_in client, LSocket;
    
94.     int ret;
    
95. 
    
96.     pthread_attr_init (&tattr);
    
97.     pthread_attr_setstacksize (&tattr, PTHREAD_STACK_MIN * 1024);
    
98. 
    
99.     memset(&LSocket, 0, sizeof(LSocket));
    
100.     LSocket.sin_family = AF_INET;
     
101.     LSocket.sin_port = htons(port);
     
102.     serversocket = socket (AF_INET, SOCK_STREAM, 0);
     
103.     if (serversocket < 0)
     
104.     {
     
105.         cout << "socket failed:"<< errno << endl;
     
106.         exit(1);
     
107.     }
     
108.     int option = 1;
     
109.     if (setsockopt (serversocket, SOL_SOCKET, SO_REUSEADDR, &option, sizeof(option) ) < 0 )
     
110.     {
     
111.         cout << "setsockopt failed:"<< errno << endl;
     
112.         exit(1);
     
113.     }
     
114.     ret = bind (serversocket, (struct sockaddr *)&LSocket, sizeof(struct sockaddr));
     
115.     if (ret < 0) {
     
116.         cout << "bind failed:"<< errno << endl;
     
117.         exit(1);
     
118.     }
     
119.     listen(serversocket, 5);
     
120.     client_len = sizeof(struct sockaddr_in);
     
121.     cout << "start listen at:" << port << endl;
     
122. 
     
123.     while(1) {
     
124.         clientsocket = accept(serversocket, (struct sockaddr *)&client, &client_len);
     
125.         if (clientsocket > 0)
     
126.         {
     
127.             stringstream portSS;
     
128.             portSS << ntohs (client.sin_port);
     
129.             string cliName = string(inet_ntoa (client.sin_addr)) + ":" + portSS.str();
     
130.             cout << cliName << endl;
     
131.             {
     
132.                 PEMutex mutex(pinmutex);
     
133.                 Pin pin(clientsocket, cliName.c_str());
     
134.                 pins[clientsocket] = pin;
     
135.                 pthread_t hdl;
     
136.                 int ret = pthread_create(&hdl, &tattr, threadfunc, &pins[clientsocket]);
     
137.             }
     
138.         }
     
139.         else
     
140.         {
     
141.             cout << "accept failed:" << errno << endl;
     
142.             sleep (1);
     
143.         }
     
144.     }
     
145. 
     
146.     return 0;
     
147. }
     

复制代码