server.c

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#include <arpa/inet.h>
#include <sys/wait.h>
#include <signal.h>

#define PORT "3490"
#define BACKLOG 10

/* обработчик сигнала завершения дочернего процесса */
void sigchld_handler(int s)
{
	/* скрываем unused предупреждение */
	(void)s; 

	/* сохраняем errno, чтобы основной код остался не тронутым, после чистки */
	int saved_errno = errno;

	/* безопасная, неблокирующая, чистка зомби-процессов */
	while( waitpid( -1, NULL, WNOHANG ) > 0 );
	
	/* восстанавливаем errno */
	errno = saved_errno;
}

/* получаем sockaddr, IPv4 или IPv6 */
void* get_in_addr(struct sockaddr* sa) 
{
	if(sa->sa_family == AF_INET) {
		return &( ( ( struct sockaddr_in* ) sa )->sin_addr );
	}

	return &( ( ( struct sockaddr_in6* ) sa )->sin6_addr );
}

int main(void)
{
	struct addrinfo hints;
	memset(&hints, 0, sizeof(hints));
	hints.ai_family = AF_INET;
	hints.ai_socktype = SOCK_STREAM;
	hints.ai_flags = AI_PASSIVE; /* использовать свой IP */
	
	struct addrinfo* servinfo;
	int gai_res = getaddrinfo(NULL, PORT, &hints, &servinfo);
	
	if(gai_res != 0) {
		fprintf(stderr, "getaddrinfo: %s\n", gai_strerror(gai_res));
		exit(1);
	}

	struct addrinfo* p;
	int sockfd;

	/* цикл через все результаты и привязка первому возможному */
	for(p = servinfo; p != NULL; p = p->ai_next) {
		sockfd = socket(p->ai_family, p->ai_socktype, p->ai_protocol);
		if( sockfd == -1 ) {
			perror("server: socket");
			continue;
		}

		int yes = 1;
		int setopt_res = setsockopt( sockfd, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int) ); 
		if( setopt_res == -1 ) {
			perror("setsockopt");
			exit(1);
		}

		int bind_res = bind( sockfd, p->ai_addr, p->ai_addrlen );
		if( bind_res == -1 ) {
			close(sockfd);
			perror("server: bind");
			continue;
		}

		break;
	}

	freeaddrinfo( servinfo );

	if( p == NULL ) {
		fprintf( stderr, "server: failed to bind\n");
		exit(1);
	}

	int listen_res = listen( sockfd, BACKLOG );
	if( listen_res == -1 ) {
		perror("listen");
		exit(1);
	}

	struct sigaction sa;
	/* очищение всех мертвых процессов */
	sa.sa_handler = sigchld_handler; 

	sigemptyset(&sa.sa_mask);
	sa.sa_flags = SA_RESTART;

	int sigaction_res = sigaction( SIGCHLD, &sa, NULL );
	if( sigaction_res == -1 ) {
		perror("sigaction");
		exit(1);
	}

	printf("server: waiting for connections...\n");
	
	char s[INET6_ADDRSTRLEN];
	struct sockaddr_storage their_addr;

	/* главный цикл accept()'ов */
	while(1) {
		socklen_t sin_size = sizeof(their_addr);
		int newfd = accept( sockfd, (struct sockaddr*)&their_addr, &sin_size );
		if(newfd == -1) {
			perror("accept");
			continue;
		}

		inet_ntop( their_addr.ss_family, get_in_addr((struct sockaddr*)&their_addr), s, sizeof(s) );
		printf("server: got connection from %s\n", s);

		if( !fork() ) {
			/* начало дочернего процесса */
			/* дочерний процесс не прослушивает сокет, поэтому закрываем*/
			close(sockfd);
			int send_res = send(newfd, "Hello World!", 13, 0);
			if(send_res == -1) {
				perror("send");
			}
			close(newfd);
			exit(0);
		}

		close(newfd);

	}

	exit( 0 );

}