Changeset c235179 for benchmark/io/http/http_ring.cpp

Timestamp:

Feb 1, 2021, 3:48:19 PM (4 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:

5e99a9a

Parents:

f99f5ba

Message:

Added the option to pre-accept in httpring, this seems to have a major impact.

File:

• benchmark/io/http/http_ring.cpp (modified) (6 diffs)

benchmark/io/http/http_ring.cpp

@@ -20 +20 @@
                 socklen_t *addrlen;
                 int flags;
+                unsigned cnt;
         } acpt;
 
@@ -433 +434 @@
         // Accept our first connection
         // May not take effect until io_uring_submit_and_wait
-        connection::accept(ring, opt);
+        for(unsigned i = 0; i < opt.acpt.cnt; i++) {
+                connection::accept(ring, opt);
+        }
 
         int reset = 1;       // Counter to print stats once in a while
@@ -528 +531 @@
         unsigned entries = 256;     // number of entries per ring/kernel thread
         unsigned backlog = 262144;  // backlog argument to listen
+        unsigned preaccept = 1;     // start by accepting X per threads
         bool attach = false;        // Whether or not to attach all the rings
         bool sqpoll = false;        // Whether or not to use SQ Polling
@@ -534 +538 @@
         // Arguments Parsing
         int c;
-        while ((c = getopt (argc, argv, "t:p:e:b:aS")) != -1) {
+        while ((c = getopt (argc, argv, "t:p:e:b:c:aS")) != -1) {
                 switch (c)
                 {
@@ -548 +552 @@
                 case 'b':
                         backlog = atoi(optarg);
+                        break;
+                case 'c':
+                        preaccept = atoi(optarg);
                         break;
                 case 'a':
@@ -681 +688 @@
                 thrd_opts[i].acpt.addrlen = (socklen_t*)&addrlen;
                 thrd_opts[i].acpt.flags   = 0;
+                thrd_opts[i].acpt.cnt     = preaccept;
                 thrd_opts[i].endfd        = efd;
                 thrd_opts[i].ring         = &thrd_rings[i].storage;