From 48debdf040d0e0b1af8d11a339ce8332e2454d3f Mon Sep 17 00:00:00 2001
From: tanyaionova <isaqtm@gmail.com>
Date: Wed, 20 Nov 2019 22:03:16 +0300
Subject: Init

---
 cc_const.cc | 106 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 106 insertions(+)
 create mode 100644 cc_const.cc

(limited to 'cc_const.cc')

diff --git a/cc_const.cc b/cc_const.cc
new file mode 100644
index 0000000..85e9ec7
--- /dev/null
+++ b/cc_const.cc
@@ -0,0 +1,106 @@
+#define _GNU_SOURCE
+
+#include <unistd.h>
+#include <errno.h>
+#include <fcntl.h>
+#include <string.h>
+#include <aio.h>
+
+#include <sys/socket.h>
+#include <sys/epoll.h>
+#include <sys/types.h>
+#include <netinet/in.h>
+#include <sys/epoll.h>
+#include <jemalloc/jemalloc.h>
+
+#include <string>
+
+#include "log.h"
+
+#define PORT 8080
+#define LISTEN_N 50
+#define EVENTS_N 50
+
+void die (const char *msg) {
+    (void)msg;
+    log_error ("  %s", msg);
+    log_error ("  %s", strerror (errno));
+    exit (EXIT_FAILURE);
+}
+
+
+#define assertfd(FD) if (FD < 0) die (#FD " is not a valid file descriptor")
+#define assert(EX) if (!(EX)) die (#EX " is false")
+
+std::string resp =
+    "HTTP/1.1 200 OK\r\n"
+    "Content-Length: 25\r\n"
+    "Content-Type: text/html\r\n"
+    "Connection: close\r\n"
+    "\r\n"
+    "Hello from const server\r\n";
+
+void dostuff (int sock);
+
+int main () {
+
+    int sockfd, newsockfd;
+    unsigned clilen;
+    struct sockaddr_in serv_addr, cli_addr;
+    log_set_level (LOG_INFO);
+
+
+    sockfd = socket(AF_INET, SOCK_STREAM, 0);
+    assertfd (sockfd);
+    int enable = 1;
+    assert (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &enable, sizeof(int)) >= 0);
+
+    bzero((char *) &serv_addr, sizeof(serv_addr));
+    serv_addr.sin_family = AF_INET;
+    serv_addr.sin_addr.s_addr = INADDR_ANY;
+    serv_addr.sin_port = htons(PORT);
+
+    assert (bind(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) >= 0);
+
+    struct epoll_event ev, events[EVENTS_N];
+    int epollfd = epoll_create1 (0);
+    ev.data.ptr = NULL;
+    ev.events = EPOLLIN | EPOLLERR;
+    assert (epoll_ctl (epollfd, EPOLL_CTL_ADD, sockfd, &ev) == 0);
+
+    listen(sockfd, LISTEN_N);
+    clilen = sizeof(cli_addr);
+    for (;;) {
+        /*int nfds = epoll_wait (epollfd, events, EVENTS_N, 3000);
+        if (nfds == 0) {
+            exit (EXIT_SUCCESS);
+        }
+        assert (nfds != -1);
+        log_trace ("nfds: %d", nfds);
+        for (int i = 0; i < nfds; ++i) {*/
+        for (;;) {            //if (events[i].data.ptr == NULL) {
+                newsockfd = accept4(sockfd, (struct sockaddr *) &cli_addr, &clilen, SOCK_NONBLOCK);
+                assertfd (newsockfd);
+                log_trace ("new: %d", newsockfd);
+
+                dostuff (newsockfd);
+            //}
+            //else {
+            //    die ("pffff");
+            //}
+        }
+    }
+    return 0;
+}
+
+ssize_t write_sock (int sock);
+
+void dostuff (int sock) {
+    write_sock (sock);
+    close (sock);
+}
+
+inline ssize_t write_sock (int sock) {
+    
+    return write (sock, resp.c_str (), resp.size ());
+}
-- 
cgit v1.2.1-18-gbd029