Changeset db614d0 for libcfa/src

Timestamp:

Sep 23, 2021, 12:41:56 PM (3 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, ast-experimental, enum, forall-pointer-decay, master, pthread-emulation, qualifiedEnum

Children:

4500e52

Parents:

420b498

Message:

Added stats for epoll

Location:

libcfa/src/concurrency

Files:

• stats.cfa (modified) (3 diffs)
• stats.hfa (modified) (1 diff)

libcfa/src/concurrency/stats.cfa

@@ -48 +48 @@
                         stats->io.calls.completed   = 0;
                         stats->io.calls.errors.busy = 0;
+                        stats->io.ops.sockread      = 0;
+                        stats->io.ops.epllread      = 0;
+                        stats->io.ops.sockwrite     = 0;
+                        stats->io.ops.epllwrite     = 0;
                 #endif
 
@@ -104 +108 @@
                         tally_one( &cltr->io.calls.completed  , &proc->io.calls.completed   );
                         tally_one( &cltr->io.calls.errors.busy, &proc->io.calls.errors.busy );
+                        tally_one( &cltr->io.ops.sockread     , &proc->io.ops.sockread      );
+                        tally_one( &cltr->io.ops.epllread     , &proc->io.ops.epllread      );
+                        tally_one( &cltr->io.ops.sockwrite    , &proc->io.ops.sockwrite     );
+                        tally_one( &cltr->io.ops.epllwrite    , &proc->io.ops.epllwrite     );
                 #endif
         }
@@ -179 +187 @@
                                      | " - cmp " | eng3(io.calls.drain) | "/" | eng3(io.calls.completed) | "(" | ws(3, 3, avgcomp) | "/drain)"
                                      | " - " | eng3(io.calls.errors.busy) | " EBUSY";
+                                sstr | "- ops blk: "
+                                     |   " sk rd: " | eng3(io.ops.sockread)  | "epll: " | eng3(io.ops.epllread)
+                                     |   " sk wr: " | eng3(io.ops.sockwrite) | "epll: " | eng3(io.ops.epllwrite);
                                 sstr | nl;
                         }

libcfa/src/concurrency/stats.hfa

@@ -102 +102 @@
                                 volatile uint64_t sleeps;
                         } poller;
+                        struct {
+                                volatile uint64_t sockread;
+                                volatile uint64_t epllread;
+                                volatile uint64_t sockwrite;
+                                volatile uint64_t epllwrite;
+                        } ops;
                 };
         #endif