Changes in benchmark/io/http/http_ring.cpp [c235179:eeb4866]

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;
 
@@ -434 +433 @@
         // Accept our first connection
         // May not take effect until io_uring_submit_and_wait
-        for(unsigned i = 0; i < opt.acpt.cnt; i++) {
-                connection::accept(ring, opt);
-        }
+        connection::accept(ring, opt);
 
         int reset = 1;       // Counter to print stats once in a while
@@ -531 +528 @@
         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
@@ -538 +534 @@
         // Arguments Parsing
         int c;
-        while ((c = getopt (argc, argv, "t:p:e:b:c:aS")) != -1) {
+        while ((c = getopt (argc, argv, "t:p:e:b:aS")) != -1) {
                 switch (c)
                 {
@@ -552 +548 @@
                 case 'b':
                         backlog = atoi(optarg);
-                        break;
-                case 'c':
-                        preaccept = atoi(optarg);
                         break;
                 case 'a':
@@ -688 +681 @@
                 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;