Changeset efdd18c

Timestamp:

Mar 30, 2023, 3:49:10 PM (20 months ago)

Author:

caparson <caparson@…>

Branches:

ADT, ast-experimental, master

Children:

a45e21c

Parents:

9319a23

Message:

updated actor header to use better name for stat toggling

File:

• libcfa/src/concurrency/actor.hfa (modified) (20 diffs)

libcfa/src/concurrency/actor.hfa

@@ -35 +35 @@
 
 // show stats
-// #define STATS
+// #define ACTOR_STATS
 
 // forward decls
@@ -122 +122 @@
     copy_queue * c_queue;           // current queue
     volatile bool being_processed;  // flag to prevent concurrent processing
-    #ifdef STATS
+    #ifdef ACTOR_STATS
     unsigned int id;
     size_t missed;                  // transfers skipped due to being_processed flag being up
@@ -132 +132 @@
     c_queue = owned_queue;
     being_processed = false;
-    #ifdef STATS
+    #ifdef ACTOR_STATS
     id = i;
     missed = 0;
@@ -153 +153 @@
     // check if queue is being processed elsewhere
     if ( unlikely( being_processed ) ) {
-        #ifdef STATS
+        #ifdef ACTOR_STATS
         missed++;
         #endif
@@ -175 +175 @@
 struct worker_info {
     volatile unsigned long long stamp;
-    #ifdef STATS
+    #ifdef ACTOR_STATS
     size_t stolen_from, try_steal, stolen, failed_swaps, msgs_stolen;
     unsigned long long processed;
@@ -182 +182 @@
 };
 static inline void ?{}( worker_info & this ) {
-    #ifdef STATS
+    #ifdef ACTOR_STATS
     this.stolen_from = 0;
     this.try_steal = 0;                             // attempts to steal
@@ -194 +194 @@
 }
 
-// #ifdef STATS
+// #ifdef ACTOR_STATS
 // unsigned int * stolen_arr;
 // unsigned int * replaced_queue;
@@ -206 +206 @@
 };
 
-#ifdef STATS
+#ifdef ACTOR_STATS
 // aggregate counters for statistics
 size_t __total_tries = 0, __total_stolen = 0, __total_workers, __all_gulps = 0,
@@ -235 +235 @@
 }; // executor
 
-// #ifdef STATS
+// #ifdef ACTOR_STATS
 // __spinlock_t out_lock;
 // #endif
 static inline void ^?{}( worker & mutex this ) with(this) { 
-    #ifdef STATS
+    #ifdef ACTOR_STATS
     __atomic_add_fetch(&__all_gulps, executor_->w_infos[id].gulps,__ATOMIC_SEQ_CST);
     __atomic_add_fetch(&__all_processed, executor_->w_infos[id].processed,__ATOMIC_SEQ_CST);
@@ -276 +276 @@
         no_steal = true;
     
-    #ifdef STATS
+    #ifdef ACTOR_STATS
     // stolen_arr = aalloc( nrqueues );
     // replaced_queue = aalloc( nrqueues );
@@ -341 +341 @@
     } // for
 
-    #ifdef STATS
+    #ifdef ACTOR_STATS
     size_t misses = 0;
     for ( i; nrqueues ) {
@@ -358 +358 @@
     if ( seperate_clus ) delete( cluster );
 
-    #ifdef STATS // print formatted stats
+    #ifdef ACTOR_STATS // print formatted stats
     printf("    Actor System Stats:\n");
     printf("\tActors Created:\t\t\t\t%lu\n\tMessages Sent:\t\t\t\t%lu\n", __num_actors_stats, __all_processed);
@@ -404 +404 @@
     ticket = __get_next_ticket( *__actor_executor_ );
     __atomic_fetch_add( &__num_actors_, 1, __ATOMIC_RELAXED );
-    #ifdef STATS
+    #ifdef ACTOR_STATS
     __atomic_fetch_add( &__num_actors_stats, 1, __ATOMIC_SEQ_CST );
     #endif
@@ -513 +513 @@
             continue;
 
-        #ifdef STATS
+        #ifdef ACTOR_STATS
         curr_steal_queue = try_swap_queues( this, i + vic_start, swap_idx );
         if ( curr_steal_queue ) {
@@ -526 +526 @@
         #else
         curr_steal_queue = try_swap_queues( this, i + vic_start, swap_idx );
-        #endif // STATS
+        #endif // ACTOR_STATS
 
         return;
@@ -558 +558 @@
 
 void main( worker & this ) with(this) {
-    // #ifdef STATS
+    // #ifdef ACTOR_STATS
     // for ( i; executor_->nrqueues ) {
     //     replaced_queue[i] = 0;
@@ -587 +587 @@
         }
         transfer( *curr_work_queue, &current_queue );
-        #ifdef STATS
+        #ifdef ACTOR_STATS
         executor_->w_infos[id].gulps++;
-        #endif // STATS
+        #endif // ACTOR_STATS
         #ifdef __STEAL
         if ( isEmpty( *current_queue ) ) {
@@ -599 +599 @@
             __atomic_store_n( &executor_->w_infos[id].stamp, rdtscl(), __ATOMIC_RELAXED );
             
-            #ifdef STATS
+            #ifdef ACTOR_STATS
             executor_->w_infos[id].try_steal++;
-            #endif // STATS
+            #endif // ACTOR_STATS
             
             steal_work( this, start + prng( range ) );
@@ -608 +608 @@
         #endif // __STEAL
         while ( ! isEmpty( *current_queue ) ) {
-            #ifdef STATS
+            #ifdef ACTOR_STATS
             executor_->w_infos[id].processed++;
             #endif
@@ -636 +636 @@
 
 static inline void __reset_stats() {
-    #ifdef STATS
+    #ifdef ACTOR_STATS
     __total_tries = 0;
     __total_stolen = 0;