我正在编写一个小服务器，它创建一个新线程来处理每个新连接。我需要使用 pthread_create 的第四个参数将套接字传递给函数。尝试释放用于套接字的内存时，我出现段错误。通信工作正常。我试过通过一个空*和一个空**(投射到空*，有点丑(
这是我在尝试解决这个问题时使用的最新 clud，稍后是否会在响应函数中做实际工作。
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <stdio.h>
#include <pthread.h>
void *respond(void *thread_arg)
{
void *arg = *(void**)thread_arg;
printf("responding...n");
int client_sock;
client_sock = (int)arg;
char *message = "Write smthng to echo!nt";
send(client_sock,message,strlen(message),0);
char *buf = (char*)malloc(100);
int ptr = 0;
char last = ' ';
while (last != 'n') {
recv(client_sock,&last,1,0);
buf[ptr++] = last;
}
buf[ptr++] = 'n';
send(client_sock, buf, ptr, 0);
ptr = 0;
free(buf);
close(client_sock);
//free(arg); // why segfault?
//free(*(void**)thread_arg); // the same
pthread_exit(NULL);
}
int main(int argc, char **argv)
{
int socket_desc, client_sock, addrlen, tmp;
struct sockaddr_in address;
pthread_t *responder_thread;
void *cs;
socket_desc = socket(AF_INET, SOCK_STREAM, 0);
if (socket_desc < 0)
printf("could not create socket");
address.sin_family = AF_INET;
address.sin_addr.s_addr = INADDR_ANY;
address.sin_port = htons(8080);
tmp = bind(socket_desc, (struct sockaddr *)&address, sizeof(address));
if (tmp < 0)
printf("could nod bind to port!");
listen(socket_desc, 5);
addrlen = sizeof(struct sockaddr_in);
while (true) {
client_sock = accept(socket_desc, (struct sockaddr *)&address, (socklen_t*)&addrlen);
if (client_sock < 0) {
printf("could not create client socket");
} else {
printf("Accepted connection!n");
cs = malloc(sizeof(int));
cs = (void*)client_sock;
responder_thread = (pthread_t*)malloc(sizeof(pthread_t*));
tmp = pthread_create(responder_thread, NULL, respond, (void*)&cs);
//cs = NULL;
if (tmp) {
printf("pthread_create returned '%d', exiting", tmp);
exit(-1);
}
}
}
pthread_exit(NULL);
}
最后，澄清一下;当涉及到c.:)时，我非常缺乏经验
您有大量内存泄漏和一般内存错误：
cs = malloc(sizeof(int));
cs = (void*)client_sock;
第一行分配内存并将指针分配给cs，第二行立即用整数值client_sock覆盖该指针来丢弃该指针。稍后您尝试释放该值，这是一个明显的错误，因为它不是有效的指针。
你应该像这样构建你的代码：
int * cs = malloc(sizeof(int));
*cs = client_sock;
pthread_create(..., cs);
和线程功能：
void * respond(void * thread_arg)
{
int * cs = (int*)thread_arg;
/* ... */
free(cs);
}
不需要通过获取cs的地址进行额外的间接寻址。
不要分配指针。将套接字文件描述符直接传递给pthread_create()：
(void*)client_sock
然后，在respond()：
client_sock = (int)thread_arg;
无需malloc()或free()。
尝试更多类似的东西。
int* cs;
...
cs = (int*)malloc(sizeof(int));
*cs = client_sock;
...
tmp = pthread_create(responder_thread, NULL, respond, (void*)cs);
那么你就不需要这个铸造了。
void *arg = *(void**)thread_arg;
你可以释放thread_arg。
free(thread_arg);
cs = malloc(sizeof(int));
cs = (void*)client_sock;
第二个赋值会使代码中出现内存泄漏。