Changeset 53a8e68 for src/libcfa/concurrency

Timestamp:

Jul 21, 2017, 3:21:44 PM (7 years ago)

Author:

Rob Schluntz <rschlunt@…>

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:

bff227f

Parents:

cb43451

Message:

Update several more library files for references

Location:

src/libcfa/concurrency

Files:

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

src/libcfa/concurrency/coroutine.c

@@ -78 +78 @@
 
 void ^?{}(coStack_t& this) {
-        if ( ! this->userStack ) {
+        if ( ! this.userStack ) {
                 LIB_DEBUG_DO(
                         if ( mprotect( this.storage, pageSize, PROT_READ | PROT_WRITE ) == -1 ) {

src/libcfa/concurrency/kernel.c

@@ -169 +169 @@
                 LIB_DEBUG_PRINT_SAFE("Kernel : core %p signaling termination\n", &this);
                 this.is_terminated = true;
-                P( this.terminated );
+                P( &this.terminated );
                 pthread_join( this.kernel_thread, NULL );
         }
@@ -468 +468 @@
         // (the coroutine that contains the processing control flow)
         systemProcessor = (system_proc_t *)&systemProcessorStorage;
-        systemProcessor{ systemCluster, (processorCtx_t *)&systemProcessorCtxStorage };
+        (*systemProcessor){ systemCluster, (processorCtx_t *)&systemProcessorCtxStorage };
 
         // Add the main thread to the ready queue

src/libcfa/concurrency/monitor.c

@@ -203 +203 @@
         __condition_criterion_t criteria[count];
         for(int i = 0; i < count; i++) {
-                (&criteria[i]){ this->monitors[i], &waiter };
+                (criteria[i]){ this->monitors[i], &waiter };
                 // LIB_DEBUG_PRINT_SAFE( "Criterion %p\n", &criteria[i] );
         }
@@ -315 +315 @@
         __condition_criterion_t criteria[count];
         for(int i = 0; i < count; i++) {
-                (&criteria[i]){ this->monitors[i], &waiter };
+                (criteria[i]){ this->monitors[i], &waiter };
                 // LIB_DEBUG_PRINT_SAFE( "Criterion %p\n", &criteria[i] );
                 push( &criteria[i].target->signal_stack, &criteria[i] );

src/libcfa/concurrency/thread.c

@@ -36 +36 @@
         (this.cor){};
         this.cor.name = "Anonymous Coroutine";
-        this.mon.owner = this;
+        this.mon.owner = &this;
         this.mon.recursion = 1;
         this.next = NULL;