Changeset c40e7c5 for src/libcfa/concurrency

Timestamp:

Feb 12, 2018, 11:57:50 AM (6 years ago)

Author:

Thierry Delisle <tdelisle@…>

Branches:

ADT, aaron-thesis, arm-eh, ast-experimental, cleanup-dtors, deferred_resn, demangler, enum, forall-pointer-decay, jacob/cs343-translation, jenkins-sandbox, master, new-ast, new-ast-unique-expr, new-env, no_list, persistent-indexer, pthread-emulation, qualifiedEnum, resolv-new, with_gc

Children:

d56ca354

Parents:

eb7f20c

Message:

Finished adding with statements to kernel

Location:

src/libcfa/concurrency

Files:

• alarm.c (modified) (2 diffs)
• alarm.h (modified) (1 diff)
• coroutine.c (modified) (2 diffs)
• kernel.c (modified) (1 diff)
• monitor (modified) (1 diff)
• monitor.c (modified) (1 diff)

src/libcfa/concurrency/alarm.c

@@ -41 +41 @@
 void ?{}( __cfa_time_t & this, zero_t zero ) { this.val = 0; }
 
-void ?{}( itimerval & this, __cfa_time_t * alarm ) {
-        this.it_value.tv_sec = alarm->val / one_second;                 // seconds
-        this.it_value.tv_usec = max( (alarm->val % one_second) / one_microsecond, 1000 ); // microseconds
-        this.it_interval.tv_sec = 0;
-        this.it_interval.tv_usec = 0;
+void ?{}( itimerval & this, __cfa_time_t * alarm ) with( this ) {
+        it_value.tv_sec = alarm->val / one_second;                      // seconds
+        it_value.tv_usec = max( (alarm->val % one_second) / one_microsecond, 1000 ); // microseconds
+        it_interval.tv_sec = 0;
+        it_interval.tv_usec = 0;
 }
 
@@ -84 +84 @@
 //=============================================================================================
 
-void ?{}( alarm_node_t & this, thread_desc * thrd, __cfa_time_t alarm = zero_time, __cfa_time_t period = zero_time ) {
+void ?{}( alarm_node_t & this, thread_desc * thrd, __cfa_time_t alarm = zero_time, __cfa_time_t period = zero_time ) with( this ) {
         this.thrd = thrd;
         this.alarm = alarm;
         this.period = period;
-        this.next = 0;
-        this.set = false;
-        this.kernel_alarm = false;
-}
-
-void ?{}( alarm_node_t & this, processor   * proc, __cfa_time_t alarm = zero_time, __cfa_time_t period = zero_time ) {
+        next = 0;
+        set = false;
+        kernel_alarm = false;
+}
+
+void ?{}( alarm_node_t & this, processor   * proc, __cfa_time_t alarm = zero_time, __cfa_time_t period = zero_time ) with( this ) {
         this.proc = proc;
         this.alarm = alarm;
         this.period = period;
-        this.next = 0;
-        this.set = false;
-        this.kernel_alarm = true;
+        next = 0;
+        set = false;
+        kernel_alarm = true;
 }
 

src/libcfa/concurrency/alarm.h

@@ -114 +114 @@
 };
 
-static inline void ?{}( alarm_list_t & this ) {
-        this.head = 0;
-        this.tail = &this.head;
+static inline void ?{}( alarm_list_t & this ) with( this ) {
+        head = 0;
+        tail = &head;
 }
 

src/libcfa/concurrency/coroutine.c

@@ -39 +39 @@
 //-----------------------------------------------------------------------------
 // Coroutine ctors and dtors
-void ?{}(coStack_t& this) {
-        this.size               = 65000;        // size of stack
-        this.storage    = NULL; // pointer to stack
-        this.limit              = NULL; // stack grows towards stack limit
-        this.base               = NULL; // base of stack
-        this.context    = NULL; // address of cfa_context_t
-        this.top                = NULL; // address of top of storage
-        this.userStack  = false;
+void ?{}(coStack_t& this) with( this ) {
+        size            = 65000;        // size of stack
+        storage = NULL; // pointer to stack
+        limit           = NULL; // stack grows towards stack limit
+        base            = NULL; // base of stack
+        context = NULL; // address of cfa_context_t
+        top             = NULL; // address of top of storage
+        userStack       = false;
 }
 
@@ -60 +60 @@
 }
 
-void ?{}(coroutine_desc& this, const char * name) {
+void ?{}(coroutine_desc& this, const char * name) with( this ) {
         this.name = name;
-        this.errno_ = 0;
-        this.state = Start;
-        this.starter = NULL;
-        this.last = NULL;
+        errno_ = 0;
+        state = Start;
+        starter = NULL;
+        last = NULL;
 }
 

src/libcfa/concurrency/kernel.c

@@ -144 +144 @@
 }
 
-void ?{}(processor & this, cluster * cltr) {
+void ?{}(processor & this, cluster * cltr) with( this ) {
         this.cltr = cltr;
-        this.terminated{ 0 };
-        this.do_terminate = false;
-        this.preemption_alarm = NULL;
-        this.pending_preemption = false;
+        terminated{ 0 };
+        do_terminate = false;
+        preemption_alarm = NULL;
+        pending_preemption = false;
 
         start( &this );
 }
 
-void ?{}(processor & this, cluster * cltr, processorCtx_t & runner) {
+void ?{}(processor & this, cluster * cltr, processorCtx_t & runner) with( this ) {
         this.cltr = cltr;
-        this.terminated{ 0 };
-        this.do_terminate = false;
-        this.preemption_alarm = NULL;
-        this.pending_preemption = false;
-        this.kernel_thread = pthread_self();
+        terminated{ 0 };
+        do_terminate = false;
+        preemption_alarm = NULL;
+        pending_preemption = false;
+        kernel_thread = pthread_self();
 
         this.runner = &runner;

src/libcfa/concurrency/monitor

@@ -27 +27 @@
 };
 
-static inline void ?{}(monitor_desc & this) {
-        (this.lock){};
-        (this.entry_queue){};
-        (this.signal_stack){};
-        this.owner         = NULL;
-        this.recursion     = 0;
-        this.mask.accepted = NULL;
-        this.mask.data     = NULL;
-        this.mask.size     = 0;
-        this.dtor_node     = NULL;
+static inline void ?{}(monitor_desc & this) with( this ) {
+        lock{};
+        entry_queue{};
+        signal_stack{};
+        owner         = NULL;
+        recursion     = 0;
+        mask.accepted = NULL;
+        mask.data     = NULL;
+        mask.size     = 0;
+        dtor_node     = NULL;
 }
 

src/libcfa/concurrency/monitor.c

@@ -358 +358 @@
 }
 
-void ?{}(__condition_criterion_t & this ) {
-        this.ready  = false;
-        this.target = NULL;
-        this.owner  = NULL;
-        this.next   = NULL;
+void ?{}(__condition_criterion_t & this ) with( this ) {
+        ready  = false;
+        target = NULL;
+        owner  = NULL;
+        next   = NULL;
 }