Changeset bebfc2e

Timestamp:

Jun 3, 2023, 9:49:49 AM (11 months ago)

Author:

caparsons <caparson@…>

Branches:

ast-experimental, master

Children:

46e6e47

Parents:

ded6c2a6

Message:

renamed some types to make style consistent. fixed race condition in terminated actor detection

File:

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

libcfa/src/concurrency/actor.hfa

@@ -458 +458 @@
 
 static inline void deliver_request( request & this ) {
+    verifyf( this.receiver->ticket != (unsigned long int)MAX, "Attempted to send message to deleted/dead actor\n" );
     this.receiver->allocation_ = this.fn( *this.receiver, *this.msg );
     check_message( *this.msg );
@@ -680 +681 @@
 // assigned at creation to __base_msg_finished to avoid unused message warning
 message __base_msg_finished @= { .allocation_ : Finished };
-struct __DeleteMsg { inline message; } DeleteMsg = __base_msg_finished;
-struct __DestroyMsg { inline message; } DestroyMsg = __base_msg_finished;
-struct __FinishedMsg { inline message; } FinishedMsg = __base_msg_finished;
-
-Allocation receive( actor & this, __DeleteMsg & msg ) { return Delete; }
-Allocation receive( actor & this, __DestroyMsg & msg ) { return Destroy; }
-Allocation receive( actor & this, __FinishedMsg & msg ) { return Finished; }
-
+struct __delete_msg_t { inline message; } delete_msg = __base_msg_finished;
+struct __destroy_msg_t { inline message; } destroy_msg = __base_msg_finished;
+struct __finished_msg_t { inline message; } finished_msg = __base_msg_finished;
+
+Allocation receive( actor & this, __delete_msg_t & msg ) { return Delete; }
+Allocation receive( actor & this, __destroy_msg_t & msg ) { return Destroy; }
+Allocation receive( actor & this, __finished_msg_t & msg ) { return Finished; }
+