Я сделал чат-сервер, который использует многопоточность для работы с несколькими клиентами. У меня есть цикл while, который работает бесконечно и ждет новых клиентов. Я хочу выйти из него после нажатия ctrl+c. Итак, я пытаюсь поймать сигнал SIGINT, как было упомянуто здесь. Но я не могу выйти из программы. Я работаю в терминале на Linux.
server.c
//for running type ./a.out anyportnumber
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <pthread.h>
#include <signal.h>
int s2;
int arr[100];
int tc = 0;
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
volatile sig_atomic_t flag = 1;
void handler(int signal)
{
flag = 0;
}
void sendtoall(char *msg,int s1)
{
int i;
pthread_mutex_lock(&mutex);
for(i = 0; i < tc; i++) {
if(arr[i] != s1)
write(arr[i],msg,strlen(msg));
}
pthread_mutex_unlock(&mutex);
}
void *function(void *s)
{
int s1;
int n;
char rmsg[500];
s1 = *(int *)s;
while((n = read(s1,rmsg,500)) > 0) {
rmsg[n] = '\0';
sendtoall(rmsg,s1);
bzero(rmsg,500);
}
pthread_exit(NULL);
}
int main(int arrc,char *argv[])
{
struct sockaddr_in server,client;
int s1,len;
int n;
int port;
pthread_t t1;
char message[500];
port = atoi(argv[1]);
bzero((char *)&server,sizeof(server));
server.sin_port = htons(port);
server.sin_addr.s_addr = INADDR_ANY;
server.sin_family = AF_INET;
s1 = socket(AF_INET,SOCK_STREAM,0);
if(s1 == -1) {
perror("socket not created\n");
exit(1);
}
if(bind(s1,(struct sockaddr *)&server,sizeof(struct sockaddr)) == -1) {
perror("socket not binded\n");
exit(1);
}
if(listen(s1,5) == -1) {
perror("unable to listen");
exit(1);
}
len = sizeof(struct sockaddr_in);
signal(SIGINT, handler);
while(flag) {
s2 = accept(s1,(struct sockaddr *)&client,&len);
pthread_create(&t1,NULL,function,(void *)&s2);
arr[tc] = s2;
tc++;
}
close(s1);
close(s2);
return 0;
}
close()
в обработчике сигнала, подобного этому, вводит гонку: самое следующее распределение файлового дескриптора будет использовать только что закрытый номер файлового дескриптора. Вашaccept()
может вызываться для чужого сокета, канала, файла, дескриптора очереди сообщений и т. д. 02.01.2016accept()
, который может причинить какой-либо вред: для любого другого типа файлового дескриптораaccept()
ничего не делает и возвращает ошибку (EINVAL, ENOSOCK или EOPNOTSUPP) . 02.01.2016close
иaccept
вместоclose(s1)
обработчик сигнала может использоватьdup2(oldfd, s1)
, гдеoldfd
- любой уже открытый файловый дескриптор, но не подходящий дляaccept()
сокет. Таким образом,s1
будет атомарно повторно связан с тем же объектом, что иoldfd
, аaccept(s1)
вернет соответствующую ошибку без возможности причинения вреда. 02.01.2016