Changeset c05c58f for benchmark/io/http

Timestamp:

Jan 27, 2021, 1:02:21 PM (3 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:

761a246

Parents:

7cc532b

Message:

Minor improvements to http_ring

File:

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

benchmark/io/http/http_ring.cpp

@@ -53 +53 @@
 };
 
+volatile size_t total = 0;
+volatile size_t count = 0;
+
 //=========================================================
 static struct io_uring_sqe * get_sqe(struct io_uring * ring) {
@@ -64 +67 @@
 
 static void submit(struct io_uring * ) {
+        // io_uring_sqe_set_flags(sqe, IOSQE_ASYNC);
         // io_uring_submit(ring);
 }
@@ -305 +309 @@
         ring_accept(ring, opt.acpt.sockfd, opt.acpt.addr, opt.acpt.addrlen, opt.acpt.flags);
 
+        int reset = 1;
         bool done = false;
         while(!done) {
@@ -345 +350 @@
 
                 io_uring_cqe_seen(ring, cqe);
+                reset--;
+                if(reset == 0) {
+                        size_t ltotal = opt.result.subs;
+                        size_t lcount = opt.result.cnts;
+
+                        std::cout << "Submit average: " << ltotal << "/" << lcount << "(" << (((double)ltotal) / lcount) << ")" << std::endl;
+                        reset = 100000 + (100000 * (ring->ring_fd % 5));
+                }
         }
 
@@ -373 +386 @@
         unsigned backlog = 10;
         bool attach = false;
+        bool sqpoll = false;
 
         //===================
         // Arguments
         int c;
-        while ((c = getopt (argc, argv, "t:p:e:b:a")) != -1) {
+        while ((c = getopt (argc, argv, "t:p:e:b:aS")) != -1) {
                 switch (c)
                 {
@@ -395 +409 @@
                         attach = true;
                         break;
+                case 'S':
+                        sqpoll = true;
+                        break;
                 case '?':
                 default:
-                        std::cerr << "Usage: -t <threads> -p <port> -e <entries> -b <backlog> -a" << std::endl;
+                        std::cerr << "Usage: -t <threads> -p <port> -e <entries> -b <backlog> -aS" << std::endl;
                         return EXIT_FAILURE;
                 }
@@ -478 +495 @@
         pthread_t    thrd_hdls[nthreads];
         options_t    thrd_opts[nthreads];
+        bool fast_poll = true;
+        bool nfix_sqpl = true;
         for(unsigned i = 0; i < nthreads; i++) {
-                if(!attach || i == 0) {
-                        io_uring_queue_init(entries, &thrd_rings[i].storage, 0);
-                }
-                else {
-                        struct io_uring_params p;
-                        memset(&p, 0, sizeof(p));
-                        p.flags = IORING_SETUP_ATTACH_WQ;
+                struct io_uring_params p = { };
+                if(sqpoll) {
+                        p.flags |= IORING_SETUP_SQPOLL;
+                        p.sq_thread_idle = 100;
+                }
+
+                if (attach && i != 0) {
+                        p.flags |= IORING_SETUP_ATTACH_WQ;
                         p.wq_fd = thrd_rings[0].storage.ring_fd;
-                        io_uring_queue_init_params(entries, &thrd_rings[i].storage, &p);
-                }
+                }
+                io_uring_queue_init_params(entries, &thrd_rings[i].storage, &p);
+
+                if(0 == (p.features & IORING_FEAT_FAST_POLL      )) { fast_poll = false; }
+                if(0 == (p.features & IORING_FEAT_SQPOLL_NONFIXED)) { nfix_sqpl = false; }
 
                 thrd_opts[i].acpt.sockfd  = server_fd;
@@ -503 +526 @@
                 }
         }
+
+        if( fast_poll) std::cout << "Fast Poll Present" << std::endl;
+        if(!nfix_sqpl) std::cout << "Non-Fixed SQ Poll not Present" << std::endl;
 
         //===================
@@ -537 +563 @@
         //===================
         (std::cout << "Stopping Threads Done... ").flush();
-        size_t total = 0;
-        size_t count = 0;
         for(unsigned i = 0; i < nthreads; i++) {
                 void * retval;
@@ -546 +570 @@
                         exit(EXIT_FAILURE);
                 }
-                // total += (size_t)retval;
-                total += thrd_opts[i].result.subs;
-                count += thrd_opts[i].result.cnts;
 
                 io_uring_queue_exit(thrd_opts[i].ring);
         }
         std::cout << "done" << std::endl;
-        std::cout << "Submit average: " << total << "/" << count << "(" << (((double)total) / count) << ")" << std::endl;
 
         //===================