Ignore:
File:
1 edited

Legend:

Unmodified
Added
Removed
  • src/libcfa/concurrency/kernel.c

    rc40e7c5 r381fdee  
    1010// Created On       : Tue Jan 17 12:27:26 2017
    1111// Last Modified By : Peter A. Buhr
    12 // Last Modified On : Tue Feb  6 21:51:26 2018
    13 // Update Count     : 4
     12// Last Modified On : Thu Feb  8 23:52:19 2018
     13// Update Count     : 5
    1414//
    1515
    1616//C Includes
    1717#include <stddef.h>
    18 #define ftype `ftype`
    1918extern "C" {
    2019#include <stdio.h>
     
    2423#include <unistd.h>
    2524}
    26 #undef ftype
    2725
    2826//CFA Includes
     
    144142}
    145143
    146 void ?{}(processor & this, cluster * cltr) with( this ) {
     144void ?{}(processor & this, cluster * cltr) {
    147145        this.cltr = cltr;
    148         terminated{ 0 };
    149         do_terminate = false;
    150         preemption_alarm = NULL;
    151         pending_preemption = false;
     146        this.terminated{ 0 };
     147        this.do_terminate = false;
     148        this.preemption_alarm = NULL;
     149        this.pending_preemption = false;
    152150
    153151        start( &this );
    154152}
    155153
    156 void ?{}(processor & this, cluster * cltr, processorCtx_t & runner) with( this ) {
     154void ?{}(processor & this, cluster * cltr, processorCtx_t & runner) {
    157155        this.cltr = cltr;
    158         terminated{ 0 };
    159         do_terminate = false;
    160         preemption_alarm = NULL;
    161         pending_preemption = false;
    162         kernel_thread = pthread_self();
     156        this.terminated{ 0 };
     157        this.do_terminate = false;
     158        this.preemption_alarm = NULL;
     159        this.pending_preemption = false;
     160        this.kernel_thread = pthread_self();
    163161
    164162        this.runner = &runner;
     
    170168        if( ! do_terminate ) {
    171169                __cfaabi_dbg_print_safe("Kernel : core %p signaling termination\n", &this);
    172                 terminate(&this);
     170                do_terminate = true;
    173171                P( terminated );
    174172                pthread_join( kernel_thread, NULL );
Note: See TracChangeset for help on using the changeset viewer.