Remove old mutemap based backpressure implementation

The old mutemap based backpressure implementation is no longer used due to the implementation of the new threshold based backpressure implementation that stores information about actors that triggered muting and actors to unmute on the actors themselves.
ponylang · Jun 22, 2022 · 0574cd8 · 0574cd8
1 parent 9cdcce6
commit 0574cd8
Show file tree

Hide file tree

Showing 7 changed files with 13 additions and 353 deletions.
diff --git a/src/libponyrt/CMakeLists.txt b/src/libponyrt/CMakeLists.txt
@@ -43,7 +43,6 @@ set(_c_src
     platform/threads.c
     sched/cpu.c
     sched/mpmcq.c
-    sched/mutemap.c
     sched/scheduler.c
     sched/start.c
 )

diff --git a/src/libponyrt/actor/actor.c b/src/libponyrt/actor/actor.c
@@ -109,7 +109,7 @@ static void mute_actor(pony_actor_t* actor)
   DTRACE1(ACTOR_MUTED, (uintptr_t)actor);
 }
 
-void ponyint_unmute_actor(pony_actor_t* actor)
+static void unmute_actor(pony_actor_t* actor)
 {
   unset_sync_flag(actor, SYNC_FLAG_MUTED | SYNC_FLAG_MUTED_UNSCHEDULED);
   DTRACE1(ACTOR_UNMUTED, (uintptr_t)actor);
@@ -129,7 +129,7 @@ static void reschedule_actors_to_unmute(pony_ctx_t* ctx, pony_actor_t* actor)
   while(actors_to_unmute != NULL)
   {
     actors_to_unmute = actorlist_pop(actors_to_unmute, &to_unmute);
-    ponyint_unmute_actor(to_unmute);
+    unmute_actor(to_unmute);
     ponyint_sched_add(ctx, to_unmute);
     DTRACE2(ACTOR_SCHEDULED, (uintptr_t)sched, (uintptr_t)to_unmute);
 
@@ -546,7 +546,7 @@ bool ponyint_actor_run(pony_ctx_t* ctx, pony_actor_t* actor, bool polling)
     // we no longer need to be muted but we never got unscheduled
     actor->muted = 0;
     actor->muter = NULL;
-    ponyint_unmute_actor(actor);
+    unmute_actor(actor);
     reschedule_actors_to_unmute(ctx, actor);
   }
 

diff --git a/src/libponyrt/actor/actor.h b/src/libponyrt/actor/actor.h
@@ -118,8 +118,6 @@ PONY_API void pony_apply_backpressure();
 
 PONY_API void pony_release_backpressure();
 
-void ponyint_unmute_actor(pony_actor_t* actor);
-
 PONY_API void ponyint_destroy(pony_ctx_t* ctx, pony_actor_t* actor);
 
 #ifdef USE_MEMTRACK

diff --git a/src/libponyrt/sched/mutemap.c b/src/libponyrt/sched/mutemap.c
diff --git a/src/libponyrt/sched/mutemap.h b/src/libponyrt/sched/mutemap.h