1 | #include "server.h" |
---|
2 | |
---|
3 | static void handle_request(int, struct sockaddr_in); |
---|
4 | |
---|
5 | int main(int argc, char ** argv) |
---|
6 | { |
---|
7 | // fd -> file descriptor |
---|
8 | int socket_server_fd = (int)NULL, |
---|
9 | socket_server_port = (int)NULL, |
---|
10 | socket_accept_fd = (int)NULL, |
---|
11 | sockaddr_in_size = sizeof(struct sockaddr_in), |
---|
12 | err = (int)NULL, |
---|
13 | pid = (int)NULL; |
---|
14 | |
---|
15 | /* Internet socket address stuct */ |
---|
16 | struct sockaddr_in server_addr, |
---|
17 | accept_addr; |
---|
18 | |
---|
19 | bzero((char *) &server_addr, sockaddr_in_size); |
---|
20 | bzero((char *) &accept_addr, sockaddr_in_size); |
---|
21 | |
---|
22 | // make a socket |
---|
23 | socket_server_fd = socket(AF_INET, SOCK_STREAM, 0); |
---|
24 | if ( socket_server_fd == __SOCKET_ERROR__ ) |
---|
25 | { |
---|
26 | fprintf(stderr, "\nCould not make a socket\n"); |
---|
27 | exit(EXIT_FAILURE); |
---|
28 | } |
---|
29 | |
---|
30 | // fill address struct |
---|
31 | server_addr.sin_addr.s_addr = INADDR_ANY; |
---|
32 | server_addr.sin_port = htons(8888); |
---|
33 | server_addr.sin_family = AF_INET; |
---|
34 | bzero(&(server_addr.sin_zero), 8); |
---|
35 | |
---|
36 | // bind to a port |
---|
37 | if ( bind(socket_server_fd, (struct sockaddr *)&(server_addr), sizeof(server_addr)) == __SOCKET_ERROR__ ) |
---|
38 | { |
---|
39 | fprintf(stderr, "\nCould not connect to host\n"); |
---|
40 | exit(EXIT_FAILURE); |
---|
41 | } |
---|
42 | |
---|
43 | // get port number |
---|
44 | getsockname(socket_server_fd, (struct sockaddr *)&(server_addr), (socklen_t *) &(sockaddr_in_size)); |
---|
45 | //if ( __DEBUG__ || verbose ) |
---|
46 | //{ |
---|
47 | printf("\nopened socket as fd (%d) on port (%d) for stream i/o\n", socket_server_fd, ntohs(server_addr.sin_port)); |
---|
48 | |
---|
49 | printf("Server\n\ |
---|
50 | sin_family = %d\n\ |
---|
51 | sin_addr.s_addr = %d\n\ |
---|
52 | sin_port = %d\n" |
---|
53 | , server_addr.sin_family |
---|
54 | , server_addr.sin_addr.s_addr |
---|
55 | , ntohs(server_addr.sin_port) |
---|
56 | ); |
---|
57 | printf("\nMaking a listen queue of %d elements", __QUEUE_SIZE__); |
---|
58 | //} |
---|
59 | |
---|
60 | // establish listen queue |
---|
61 | if ( listen(socket_server_fd, __QUEUE_SIZE__) == __SOCKET_ERROR__ ) |
---|
62 | { |
---|
63 | fprintf(stderr, "\nCould not listen\n"); |
---|
64 | exit(EXIT_FAILURE); |
---|
65 | } |
---|
66 | |
---|
67 | while ( 1 ) |
---|
68 | { |
---|
69 | //if ( __DEBUG__ || verbose ) |
---|
70 | puts("\nWaiting for a connection\n"); |
---|
71 | |
---|
72 | // get the connected socket |
---|
73 | socket_accept_fd = accept(socket_server_fd, (struct sockaddr *) &(accept_addr), (socklen_t *) &(sockaddr_in_size)); |
---|
74 | |
---|
75 | if ( socket_accept_fd > -1 ) |
---|
76 | { |
---|
77 | pid = fork(); |
---|
78 | if ( pid ) |
---|
79 | { |
---|
80 | close(socket_accept_fd); |
---|
81 | continue; |
---|
82 | } |
---|
83 | else |
---|
84 | { |
---|
85 | close(socket_server_fd); |
---|
86 | handle_request(socket_accept_fd, accept_addr); |
---|
87 | close(socket_accept_fd); |
---|
88 | } |
---|
89 | //close(socket_accept_fd); |
---|
90 | } |
---|
91 | } |
---|
92 | } |
---|
93 | |
---|
94 | static void handle_request(int sock, struct sockaddr_in client_addr) |
---|
95 | { |
---|
96 | char * buffer_client; |
---|
97 | |
---|
98 | buffer_client = (char *) malloc(sizeof(char) * __BUFFER_SIZE__); |
---|
99 | bzero(buffer_client, __BUFFER_SIZE__); |
---|
100 | |
---|
101 | read(sock, buffer_client, __BUFFER_SIZE__); |
---|
102 | printf("%s\n", buffer_client); |
---|
103 | |
---|
104 | free(buffer_client); |
---|
105 | } |
---|