/* depend: */
/* cflags: */
-/* linker: color.o debug.o */
+/* linker: color.o debug.o http.o server.o signal.o */
#include <assert.h>
#include <stdio.h>
#include <stdlib.h>
-#ifdef _WIN32 /* Windows */
-#include <winsock2.h>
-#include <ws2tcpip.h>
-#else /* Posix */
#include <unistd.h>
-#include <fcntl.h>
-#include <sys/types.h>
-#include <sys/socket.h>
-#endif
+#include <signal.h>
#include "debug.h"
+#include "http.h"
+#include "server.h"
+#include "signal.h"
/* types */
-#ifdef _WIN32 /* Windows */
-typedef SOCKET socket_t;
-#else /* Posix */
-typedef int socket_t;
-#endif
-
/* constants */
#define BUFFER_SIZE 4096
char *progname = NULL;
int port = 8080;
+socket_t sock = INVALID_SOCKET;
+socket_t conn = INVALID_SOCKET;
/* help function */
return ret;
}
-/* open listening socket */
-
-socket_t open_listening_socket (int port)
+void stop_server (__attribute__((unused)) int sig)
{
-#ifdef _WIN32 /* Windows */
- WSADATA WSAData;
- WSAStartup (MAKEWORD(2,0), &WSAData);
- assert (INVALID_SOCKET == (socket_t)-1);
-#endif
-
- VERBOSE (DEBUG, fprintf (stdout, "Opening socket\n"));
-#ifdef _WIN32 /* Windows */
- socket_t sock = socket (AF_INET, SOCK_STREAM, IPPROTO_TCP);
- if (sock == INVALID_SOCKET)
- return -1;
-#else /* Posix */
- socket_t sock = socket (PF_INET, SOCK_STREAM, IPPROTO_TCP);
- if (socket < 0)
- return -1;
-#endif
-
- struct sockaddr_in addr = {0};
-#ifdef _WIN32 /* Windows */
- addr.sin_family = AF_INET;
-#else /* Posix */
- addr.sin_family = PF_INET;
-#endif
- addr.sin_port = htons (port);
- addr.sin_addr.s_addr = htonl (INADDR_ANY);
-
- VERBOSE (DEBUG, fprintf (stdout, "Binding socket\n"));
- int rc = bind (sock, (struct sockaddr *)&addr, sizeof (addr));
-#ifdef _WIN32 /* Windows */
- if (rc == SOCKET_ERROR) {
- VERBOSE (ERROR, fprintf (stderr, "error: %d\n", WSAGetLastError ()));
- if (closesocket (sock) == SOCKET_ERROR) {
- VERBOSE (ERROR, fprintf (stderr, "error: %d\n", WSAGetLastError ()));
- }
-#else /* Posix */
- if (socket < 0) {
- VERBOSE (ERROR, fprintf (stderr, "error: %d\n", errno));
- close (sock);
-#endif
- return -1;
+ if (conn != INVALID_SOCKET) {
+ close_socket (conn);
}
-
- VERBOSE (DEBUG, fprintf (stdout, "Configuring socket\n"));
-#ifdef _WIN32 /* Windows */
-#else /* Posix */
- fcntl (sock, F_SETFL, O_NONBLOCK);
-#endif
- int val = 1;
- rc = setsockopt (sock, IPPROTO_TCP, TCP_NODELAY, (char *)&val, sizeof (val));
- if (rc < 0) {
- VERBOSE (ERROR, fprintf (stderr, "%s\n", "setsockopt/TCP_NODELAY"));
-#ifdef _WIN32 /* Windows */
- closesocket (sock);
-#else /* Posix */
- close (sock);
-#endif
- return -1;
+ if (sock != INVALID_SOCKET) {
+ close_socket (sock);
}
-
- return sock;
-}
-
-/* close listening socket */
-void close_listening_socket (socket_t sock)
-{
-#ifdef _WIN32 /* Windows */
- closesocket (sock);
- WSACleanup ();
-#else /* Posix */
- close (sock);
-#endif
+ terminate_network_context ();
+ exit (0);
}
/* main function */
int main (int argc, char *argv[])
{
int i = 0;
- int ret = 0;
/* program name */
while (argc-- > 1) {
char *arg = *(++argv);
if (arg[0] != '-') {
- VERBOSE (ERROR, fprintf (stderr, "%s: invalid option -- '%s'\n", progname, arg); usage (1));
+ VERBOSE (ERROR, PERROR ("%s: invalid option -- '%s'\n", progname, arg); usage (1));
return 1;
}
char c = arg[1];
case 'p':
arg = (arg[2]) ? arg + 2 : (--argc > 0) ? *(++argv) : NULL;
if (arg == NULL) {
- VERBOSE (ERROR, fprintf (stderr, "%s: missing port number\n", progname); usage (1));
+ VERBOSE (ERROR, PERROR ("%s: missing port number\n", progname); usage (1));
return 1;
}
port = atoi (arg);
if (port <= 0) {
- VERBOSE (ERROR, fprintf (stderr, "%s: incorrect port number (%s)\n", progname, arg); usage (1));
+ VERBOSE (ERROR, PERROR ("%s: incorrect port number (%s)\n", progname, arg); usage (1));
return 1;
}
break;
case 'v':
arg = (arg[2]) ? arg + 2 : (--argc > 0) ? *(++argv) : NULL;
if (arg == NULL) {
- VERBOSE (ERROR, fprintf (stderr, "%s: missing verbose level\n", progname); usage (1));
+ VERBOSE (ERROR, PERROR ("%s: missing verbose level\n", progname); usage (1));
return 1;
}
verbose = atoi (arg);
}
}
- VERBOSE (DEBUG, fprintf (stdout, "Initializing socket\n"));
- socket_t sock = open_listening_socket (port);
- if (sock == (socket_t)-1) {
- VERBOSE (ERROR, fprintf (stderr, "Can't open listening socket\n"));
+ VERBOSE (DEBUG, PRINT ("Initializing socket\n"));
+ init_network_context ();
+ sock = open_listening_socket (port);
+ if (sock == INVALID_SOCKET) {
+ VERBOSE (ERROR, PERROR ("Can't open listening socket\n"));
return 1;
}
+ VERBOSE (INFO, PRINT ("Listening socket on port %d\n", port));
- VERBOSE (INFO, fprintf (stdout, "Listening socket on port %d\n", port));
- sleep (2);
+ signal (SIGTERM, &stop_server);
- VERBOSE (DEBUG, fprintf (stdout, "Closing socket\n"));
- close_listening_socket (sock);
+ /* main loop */
+ while (1) {
+ conn = accept_incoming_connection (sock);
+ if (conn == INVALID_SOCKET) {
+ usleep (1e5);
+ continue;
+ }
- return ret;
+ VERBOSE (DEBUG, PRINT ("Server connected, waiting for data\n"));
+
+ unsigned char *data = {0};
+
+ int len = receive_data (conn, &data);
+ if (len == 0) {
+ VERBOSE (WARNING, PRINT ("Connection closed by peer (rx)\n"));
+ } else if (len < 0) {
+ VERBOSE (WARNING, PRINT ("Connection in error (rx)\n"));
+ } else {
+ VERBOSE (DEBUG, PRINT ("Received %d bytes\n", len));
+
+ // processing
+ VERBOSE (DEBUG, PRINT ("Processing %s\n", data));
+ len = processing (data, len, &data);
+
+ int rc = send_data (conn, data, len);
+ if (rc == 0) {
+ VERBOSE (WARNING, PRINT ("Connection closed by peer (tx)\n"));
+ } else if (rc < 0) {
+ VERBOSE (WARNING, PRINT ("Connection in error (tx)\n"));
+ }
+ }
+
+ VERBOSE (DEBUG, PRINT ("Closing connection\n"));
+ if (data) {
+ free (data);
+ }
+ close_socket (conn);
+ conn = INVALID_SOCKET;
+ }
+
+ VERBOSE (DEBUG, PRINT ("Closing socket\n"));
+ close_socket (sock);
+ terminate_network_context ();
+
+ return 2;
}
// test: webserver.exe -h
// test: webserver.exe -v 2>&1 | grep -q 'missing verbose level'
// test: webserver.exe -p 2>&1 | grep -q 'missing port number'
// test: webserver.exe -p -1 2>&1 | grep -q 'incorrect port number'
-// test: webserver.exe | grep -q 'Listening socket on port 8080'
-// test: webserver.exe -p 8000 | grep -q 'Listening socket on port 8000'
+// test: webserver.exe > test.log & pid=$!; sleep 1; kill -9 $pid; grep -q 'Listening socket on port 8080' test.log
+// test: webserver.exe -p 8000 > test.log & pid=$!; sleep 1; kill -9 $pid; grep -q 'Listening socket on port 8000' test.log
+// test: webserver.exe & pid=$!; sleep 1; kill -TERM $pid; ps aux | grep -q [w]ebserver.exe && kill -9 $pid || rc=1; test x$rc = x1
/* vim: set ts=4 sw=4 et: */
Soft'N'Design Software / projects / webserver.git / blobdiff