Changeset 857a1c6

Timestamp:

Apr 16, 2021, 2:28:03 PM (2 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, arm-eh, ast-experimental, enum, forall-pointer-decay, jacob/cs343-translation, master, new-ast-unique-expr, pthread-emulation, qualifiedEnum

Children:

c8a0210

Parents:

e07b589

Message:

Performance fixes to http benchmark

Location:

benchmark/io/http

Files:

• protocol.cfa (modified) (5 diffs)
• worker.cfa (modified) (1 diff)

benchmark/io/http/protocol.cfa

@@ -5 +5 @@
         #include <fcntl.h>
 }
+
+#define xstr(s) str(s)
+#define str(s) #s
 
 #include <fstream.hfa>
@@ -21 +24 @@
 
 #define PLAINTEXT_1WRITE
+#define PLAINTEXT_MEMCPY
 #define PLAINTEXT_NOCOPY
 
@@ -85 +89 @@
 #if defined(PLAINTEXT_NOCOPY)
 int answer_plaintext( int fd ) {
-        return answer(fd, http_msgs[OK200_PlainText]->msg, http_msgs[OK200_PlainText]->len + 1); // +1 cause snprintf doesn't count nullterminator
+        return answer(fd, http_msgs[OK200_PlainText]->msg, http_msgs[OK200_PlainText]->len); // +1 cause snprintf doesn't count nullterminator
+}
+#elif defined(PLAINTEXT_MEMCPY)
+#define TEXTSIZE 15
+int answer_plaintext( int fd ) {
+        char text[] = "Hello, World!\n\n";
+        char ts[] = xstr(TEXTSIZE) " \n\n";
+        _Static_assert(sizeof(text) - 1 == TEXTSIZE);
+        char buffer[512 + TEXTSIZE];
+        char * it = buffer;
+        memcpy(it, http_msgs[OK200]->msg, http_msgs[OK200]->len);
+        it += http_msgs[OK200]->len;
+        int len = http_msgs[OK200]->len;
+        memcpy(it, ts, sizeof(ts) - 1);
+        it += sizeof(ts) - 1;
+        len += sizeof(ts) - 1;
+        memcpy(it, text, TEXTSIZE);
+        return answer(fd, buffer, len + TEXTSIZE);
 }
 #elif defined(PLAINTEXT_1WRITE)
 int answer_plaintext( int fd ) {
-        char text[] = "Hello, World!\n";
+        char text[] = "Hello, World!\n\n";
         char buffer[512 + sizeof(text)];
         char * it = buffer;
@@ -103 +124 @@
 #else
 int answer_plaintext( int fd ) {
-        char text[] = "Hello, World!\n";
+        char text[] = "Hello, World!\n\n";
         int ret = answer_header(fd, sizeof(text));
         if( ret < 0 ) return ret;
@@ -194 +215 @@
 const char * original_http_msgs[] = {
         "HTTP/1.1 200 OK\nServer: HttoForall\nDate: %s \nContent-Type: text/plain\nContent-Length: ",
-        "HTTP/1.1 200 OK\nServer: HttoForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 15\n\nHello, World!\n",
+        "HTTP/1.1 200 OK\nServer: HttoForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 15\n\nHello, World!\n\n",
         "HTTP/1.1 400 Bad Request\nServer: HttoForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 0 \n\n",
         "HTTP/1.1 404 Not Found\nServer: HttoForall\nDate: %s \nContent-Type: text/plain\nContent-Length: 0 \n\n",

benchmark/io/http/worker.cfa

@@ -18 +18 @@
 void ?{}( Worker & this ) {
         size_t cli = rand() % options.clopts.cltr_cnt;
-        ((thread&)this){ "Server Worker Thread", *options.clopts.instance[cli] };
+        ((thread&)this){ "Server Worker Thread", *options.clopts.instance[cli], 512000 };
         options.clopts.thrd_cnt[cli]++;
         this.pipe[0] = -1;