Changes in / [ff2d1139:ee2938a]


Ignore:
Location:
src
Files:
8 edited

Legend:

Unmodified
Added
Removed
  • src/SymTab/Mangler.cc

    rff2d1139 ree2938a  
    9999                        Mangler::Mangler( bool mangleOverridable, bool typeMode, bool mangleGenericParams )
    100100                                : nextVarNum( 0 ), isTopLevel( true ), mangleOverridable( mangleOverridable ), typeMode( typeMode ), mangleGenericParams( mangleGenericParams ) {}
     101
     102                        Mangler::Mangler( const Mangler &rhs ) : mangleName() {
     103                                varNums = rhs.varNums;
     104                                nextVarNum = rhs.nextVarNum;
     105                                isTopLevel = rhs.isTopLevel;
     106                                mangleOverridable = rhs.mangleOverridable;
     107                                typeMode = rhs.typeMode;
     108                        }
    101109
    102110                        void Mangler::mangleDecl( DeclarationWithType * declaration ) {
  • src/libcfa/Makefile.in

    rff2d1139 ree2938a  
    263263        containers/result containers/vector concurrency/coroutine \
    264264        concurrency/thread concurrency/kernel concurrency/monitor \
    265         ${shell find stdhdr -type f -printf "%p "} math gmp \
    266         bits/align.h bits/containers.h bits/defs.h bits/debug.h \
    267         bits/locks.h concurrency/invoke.h
     265        ${shell echo stdhdr/*} math gmp bits/align.h bits/containers.h \
     266        bits/defs.h bits/debug.h bits/locks.h concurrency/invoke.h
    268267HEADERS = $(nobase_cfa_include_HEADERS)
    269268am__tagged_files = $(HEADERS) $(SOURCES) $(TAGS_FILES) $(LISP)
     
    429428libcfa_d_a_SOURCES = ${libsrc}
    430429libcfa_d_a_CFLAGS = -debug -O0 #No need for __CFA_DEBUG__ since we pass -debug
    431 stdhdr = ${shell find stdhdr -type f -printf "%p "}
     430stdhdr = ${shell echo stdhdr/*}
    432431cfa_includedir = $(CFA_INCDIR)
    433432nobase_cfa_include_HEADERS = \
  • src/libcfa/concurrency/alarm.c

    rff2d1139 ree2938a  
    4141void ?{}( __cfa_time_t & this, zero_t zero ) { this.val = 0; }
    4242
    43 void ?{}( itimerval & this, __cfa_time_t * alarm ) with( this ) {
    44         it_value.tv_sec = alarm->val / one_second;                      // seconds
    45         it_value.tv_usec = max( (alarm->val % one_second) / one_microsecond, 1000 ); // microseconds
    46         it_interval.tv_sec = 0;
    47         it_interval.tv_usec = 0;
     43void ?{}( itimerval & this, __cfa_time_t * alarm ) {
     44        this.it_value.tv_sec = alarm->val / one_second;                 // seconds
     45        this.it_value.tv_usec = max( (alarm->val % one_second) / one_microsecond, 1000 ); // microseconds
     46        this.it_interval.tv_sec = 0;
     47        this.it_interval.tv_usec = 0;
    4848}
    4949
     
    8484//=============================================================================================
    8585
    86 void ?{}( alarm_node_t & this, thread_desc * thrd, __cfa_time_t alarm = zero_time, __cfa_time_t period = zero_time ) with( this ) {
     86void ?{}( alarm_node_t & this, thread_desc * thrd, __cfa_time_t alarm = zero_time, __cfa_time_t period = zero_time ) {
    8787        this.thrd = thrd;
    8888        this.alarm = alarm;
    8989        this.period = period;
    90         next = 0;
    91         set = false;
    92         kernel_alarm = false;
    93 }
    94 
    95 void ?{}( alarm_node_t & this, processor   * proc, __cfa_time_t alarm = zero_time, __cfa_time_t period = zero_time ) with( this ) {
     90        this.next = 0;
     91        this.set = false;
     92        this.kernel_alarm = false;
     93}
     94
     95void ?{}( alarm_node_t & this, processor   * proc, __cfa_time_t alarm = zero_time, __cfa_time_t period = zero_time ) {
    9696        this.proc = proc;
    9797        this.alarm = alarm;
    9898        this.period = period;
    99         next = 0;
    100         set = false;
    101         kernel_alarm = true;
     99        this.next = 0;
     100        this.set = false;
     101        this.kernel_alarm = true;
    102102}
    103103
  • src/libcfa/concurrency/alarm.h

    rff2d1139 ree2938a  
    114114};
    115115
    116 static inline void ?{}( alarm_list_t & this ) with( this ) {
    117         head = 0;
    118         tail = &head;
     116static inline void ?{}( alarm_list_t & this ) {
     117        this.head = 0;
     118        this.tail = &this.head;
    119119}
    120120
  • src/libcfa/concurrency/coroutine.c

    rff2d1139 ree2938a  
    3939//-----------------------------------------------------------------------------
    4040// Coroutine ctors and dtors
    41 void ?{}(coStack_t& this) with( this ) {
    42         size            = 65000;        // size of stack
    43         storage = NULL; // pointer to stack
    44         limit           = NULL; // stack grows towards stack limit
    45         base            = NULL; // base of stack
    46         context = NULL; // address of cfa_context_t
    47         top             = NULL; // address of top of storage
    48         userStack       = false;
     41void ?{}(coStack_t& this) {
     42        this.size               = 65000;        // size of stack
     43        this.storage    = NULL; // pointer to stack
     44        this.limit              = NULL; // stack grows towards stack limit
     45        this.base               = NULL; // base of stack
     46        this.context    = NULL; // address of cfa_context_t
     47        this.top                = NULL; // address of top of storage
     48        this.userStack  = false;
    4949}
    5050
     
    6060}
    6161
    62 void ?{}(coroutine_desc& this, const char * name) with( this ) {
     62void ?{}(coroutine_desc& this, const char * name) {
    6363        this.name = name;
    64         errno_ = 0;
    65         state = Start;
    66         starter = NULL;
    67         last = NULL;
     64        this.errno_ = 0;
     65        this.state = Start;
     66        this.starter = NULL;
     67        this.last = NULL;
    6868}
    6969
  • src/libcfa/concurrency/kernel.c

    rff2d1139 ree2938a  
    142142}
    143143
    144 void ?{}(processor & this, cluster * cltr) with( this ) {
     144void ?{}(processor & this, cluster * cltr) {
    145145        this.cltr = cltr;
    146         terminated{ 0 };
    147         do_terminate = false;
    148         preemption_alarm = NULL;
    149         pending_preemption = false;
     146        this.terminated{ 0 };
     147        this.do_terminate = false;
     148        this.preemption_alarm = NULL;
     149        this.pending_preemption = false;
    150150
    151151        start( &this );
    152152}
    153153
    154 void ?{}(processor & this, cluster * cltr, processorCtx_t & runner) with( this ) {
     154void ?{}(processor & this, cluster * cltr, processorCtx_t & runner) {
    155155        this.cltr = cltr;
    156         terminated{ 0 };
    157         do_terminate = false;
    158         preemption_alarm = NULL;
    159         pending_preemption = false;
    160         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();
    161161
    162162        this.runner = &runner;
  • src/libcfa/concurrency/monitor

    rff2d1139 ree2938a  
    2727};
    2828
    29 static inline void ?{}(monitor_desc & this) with( this ) {
    30         lock{};
    31         entry_queue{};
    32         signal_stack{};
    33         owner         = NULL;
    34         recursion     = 0;
    35         mask.accepted = NULL;
    36         mask.data     = NULL;
    37         mask.size     = 0;
    38         dtor_node     = NULL;
     29static inline void ?{}(monitor_desc & this) {
     30        (this.lock){};
     31        (this.entry_queue){};
     32        (this.signal_stack){};
     33        this.owner         = NULL;
     34        this.recursion     = 0;
     35        this.mask.accepted = NULL;
     36        this.mask.data     = NULL;
     37        this.mask.size     = 0;
     38        this.dtor_node     = NULL;
    3939}
    4040
  • src/libcfa/concurrency/monitor.c

    rff2d1139 ree2938a  
    151151                        // We already have the monitor... but where about to destroy it so the nesting will fail
    152152                        // Abort!
    153                         abort( "Attempt to destroy monitor %p by thread \"%.256s\" (%p) in nested mutex.", this, thrd->self_cor.name, thrd );
     153                        abort( "Attempt to destroy monitor %p by thread \"%.256s\" (%p) in nested mutex." );
    154154                }
    155155
     
    358358}
    359359
    360 void ?{}(__condition_criterion_t & this ) with( this ) {
    361         ready  = false;
    362         target = NULL;
    363         owner  = NULL;
    364         next   = NULL;
     360void ?{}(__condition_criterion_t & this ) {
     361        this.ready  = false;
     362        this.target = NULL;
     363        this.owner  = NULL;
     364        this.next   = NULL;
    365365}
    366366
     
    427427                thread_desc * this_thrd = this_thread;
    428428                if ( this.monitor_count != this_thrd->monitors.size ) {
    429                         abort( "Signal on condition %p made with different number of monitor(s), expected %li got %li", &this, this.monitor_count, this_thrd->monitors.size );
     429                        abort( "Signal on condition %p made with different number of monitor(s), expected %i got %i", &this, this.monitor_count, this_thrd->monitors.size );
    430430                }
    431431
    432432                for(int i = 0; i < this.monitor_count; i++) {
    433433                        if ( this.monitors[i] != this_thrd->monitors[i] ) {
    434                                 abort( "Signal on condition %p made with different monitor, expected %p got %p", &this, this.monitors[i], this_thrd->monitors[i] );
     434                                abort( "Signal on condition %p made with different monitor, expected %p got %i", &this, this.monitors[i], this_thrd->monitors[i] );
    435435                        }
    436436                }
Note: See TracChangeset for help on using the changeset viewer.