Ignore:
File:
1 edited

Legend:

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

    r381fdee rc40e7c5  
    1010// Created On       : Tue Jan 17 12:27:26 2017
    1111// Last Modified By : Peter A. Buhr
    12 // Last Modified On : Thu Feb  8 23:52:19 2018
    13 // Update Count     : 5
     12// Last Modified On : Tue Feb  6 21:51:26 2018
     13// Update Count     : 4
    1414//
    1515
    1616//C Includes
    1717#include <stddef.h>
     18#define ftype `ftype`
    1819extern "C" {
    1920#include <stdio.h>
     
    2324#include <unistd.h>
    2425}
     26#undef ftype
    2527
    2628//CFA Includes
     
    142144}
    143145
    144 void ?{}(processor & this, cluster * cltr) {
     146void ?{}(processor & this, cluster * cltr) with( this ) {
    145147        this.cltr = cltr;
    146         this.terminated{ 0 };
    147         this.do_terminate = false;
    148         this.preemption_alarm = NULL;
    149         this.pending_preemption = false;
     148        terminated{ 0 };
     149        do_terminate = false;
     150        preemption_alarm = NULL;
     151        pending_preemption = false;
    150152
    151153        start( &this );
    152154}
    153155
    154 void ?{}(processor & this, cluster * cltr, processorCtx_t & runner) {
     156void ?{}(processor & this, cluster * cltr, processorCtx_t & runner) with( this ) {
    155157        this.cltr = cltr;
    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();
     158        terminated{ 0 };
     159        do_terminate = false;
     160        preemption_alarm = NULL;
     161        pending_preemption = false;
     162        kernel_thread = pthread_self();
    161163
    162164        this.runner = &runner;
     
    168170        if( ! do_terminate ) {
    169171                __cfaabi_dbg_print_safe("Kernel : core %p signaling termination\n", &this);
    170                 do_terminate = true;
     172                terminate(&this);
    171173                P( terminated );
    172174                pthread_join( kernel_thread, NULL );
Note: See TracChangeset for help on using the changeset viewer.