Changes in / [4f748c5:fde89cf6]


Ignore:
Files:
11 added
35 deleted
33 edited

Legend:

Unmodified
Added
Removed

  • .gitignore

    r4f748c5 rfde89cf6  
    5252tools/prettyprinter/pretty
    5353tools/pretty
    54 tools/catchsig
    55 tools/repeat
    5654
    5755# generated by xfig for user manual

  • configure

    r4f748c5 rfde89cf6  
    62816281
    62826282
    6283 ac_config_files="$ac_config_files Makefile src/driver/Makefile src/Makefile src/benchmark/Makefile src/examples/Makefile src/tests/Makefile src/tests/preempt_longrun/Makefile src/prelude/Makefile src/libcfa/Makefile tools/Makefile tools/prettyprinter/Makefile"
     6283ac_config_files="$ac_config_files Makefile src/driver/Makefile src/Makefile src/benchmark/Makefile src/examples/Makefile src/tests/Makefile src/tests/preempt_longrun/Makefile src/prelude/Makefile src/libcfa/Makefile tools/prettyprinter/Makefile"
    62846284
    62856285
    … …  
    70487048    "src/prelude/Makefile") CONFIG_FILES="$CONFIG_FILES src/prelude/Makefile" ;;
    70497049    "src/libcfa/Makefile") CONFIG_FILES="$CONFIG_FILES src/libcfa/Makefile" ;;
    7050     "tools/Makefile") CONFIG_FILES="$CONFIG_FILES tools/Makefile" ;;
    70517050    "tools/prettyprinter/Makefile") CONFIG_FILES="$CONFIG_FILES tools/prettyprinter/Makefile" ;;
    70527051

  • configure.ac

    r4f748c5 rfde89cf6  
    238238        src/prelude/Makefile
    239239        src/libcfa/Makefile
    240         tools/Makefile
    241240        tools/prettyprinter/Makefile
    242241        ])

  • src/Parser/lex.ll

    r4f748c5 rfde89cf6  
    1010 * Created On       : Sat Sep 22 08:58:10 2001
    1111 * Last Modified By : Peter A. Buhr
    12  * Last Modified On : Wed Oct 25 13:53:56 2017
    13  * Update Count     : 634
     12 * Last Modified On : Sat Sep 23 17:29:28 2017
     13 * Update Count     : 632
    1414 */
    1515
    … …  
    233233__extension__   { KEYWORD_RETURN(EXTENSION); }                  // GCC
    234234extern                  { KEYWORD_RETURN(EXTERN); }
     235fallthrough             { KEYWORD_RETURN(FALLTHRU); }                   // CFA
    235236fallthru                { KEYWORD_RETURN(FALLTHRU); }                   // CFA
    236 fallthrough             { KEYWORD_RETURN(FALLTHROUGH); }                // CFA
    237237finally                 { KEYWORD_RETURN(FINALLY); }                    // CFA
    238238float                   { KEYWORD_RETURN(FLOAT); }

  • src/Parser/parser.yy

    r4f748c5 rfde89cf6  
    1010// Created On       : Sat Sep  1 20:22:55 2001
    1111// Last Modified By : Peter A. Buhr
    12 // Last Modified On : Wed Oct 25 12:28:54 2017
    13 // Update Count     : 2893
     12// Last Modified On : Mon Oct 16 11:07:29 2017
     13// Update Count     : 2892
    1414//
    1515
    … …  
    180180%token ATTRIBUTE EXTENSION                                                              // GCC
    181181%token IF ELSE SWITCH CASE DEFAULT DO WHILE FOR BREAK CONTINUE GOTO RETURN
    182 %token CHOOSE DISABLE ENABLE FALLTHRU FALLTHROUGH TRY CATCH CATCHRESUME FINALLY THROW THROWRESUME AT WITH WHEN WAITFOR // CFA
     182%token CHOOSE DISABLE ENABLE FALLTHRU TRY CATCH CATCHRESUME FINALLY THROW THROWRESUME AT WITH WHEN WAITFOR // CFA
    183183%token ASM                                                                                              // C99, extension ISO/IEC 9899:1999 Section J.5.10(1)
    184184%token ALIGNAS ALIGNOF GENERIC STATICASSERT                             // C11
    … …  
    362362%precedence ELSE        // token precedence for start of else clause in IF/WAITFOR statement
    363363
    364 %locations                      // support location tracking for error messages
     364%locations
    365365
    366366%start translation_unit                                                                 // parse-tree root
    … …  
    974974        ;
    975975
    976 fall_through_name:                                                                              // CFA
     976fall_through:                                                                                   // CFA
    977977        FALLTHRU
    978         | FALLTHROUGH
    979         ;
    980 
    981 fall_through:                                                                                   // CFA
    982         fall_through_name
    983978                { $$ = nullptr; }
    984         | fall_through_name ';'
     979        | FALLTHRU ';'
    985980                { $$ = nullptr; }
    986981        ;
    … …  
    24912486        | TYPEDEFname
    24922487        | TYPEGENname
    2493         | FALLTHROUGH
    2494                 { $$ = Token{ new string( "fallthrough" ), { nullptr, -1 } }; }
    24952488        | CONST
    24962489                { $$ = Token{ new string( "__const__" ), { nullptr, -1 } }; }
    … …  
    27582751//
    27592752//              typedef int foo;
    2760 //              forall( otype T ) struct foo;
     2753//              forall( otype T ) foo( T );
    27612754//              int f( int foo ); // redefine typedef name in new scope
    27622755//

  • src/benchmark/Makefile.am

    r4f748c5 rfde89cf6  
    1919AM_CFLAGS = -g -Wall -Wno-unused-function -O2
    2020CC = @CFA_BINDIR@/@CFA_NAME@
    21 TOOLSDIR = ${abs_top_srcdir}/tools/
    22 REPEAT   = ${TOOLSDIR}repeat
    23 STATS    = ${TOOLSDIR}stat.py
    24 repeats  = 30
    2521
    26 .NOTPARALLEL:
    27 
    28 noinst_PROGRAMS =
     22noinst_PROGRAMS = bench$(EXEEXT) ctxswitch-coroutine$(EXEEXT) ctxswitch-thread$(EXEEXT) sched-int$(EXEEXT) monitor$(EXEEXT) csv-data$(EXEEXT)
    2923
    3024bench$(EXEEXT) :
    … …  
    3630        rm -f ./a.out ;
    3731
     32ctxswitch-coroutine$(EXEEXT):
     33        ${CC} ${AM_CFLAGS} ${CFLAGS} ${ccflags} @CFA_FLAGS@ -nodebug -lrt -DN=50000000 CorCtxSwitch.c
     34        @rm -f .result.log
     35        @for number in 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20; do \
     36                ./a.out | tee -a .result.log ; \
     37        done
     38        @./stat.py .result.log
     39        @rm -f a.out .result.log
     40
     41ctxswitch-thread$(EXEEXT):
     42        ${CC} ${AM_CFLAGS} ${CFLAGS} ${ccflags} @CFA_FLAGS@ -nodebug -lrt -DN=50000000 ThrdCtxSwitch.c
     43        @rm -f .result.log
     44        @for number in 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20; do \
     45                ./a.out | tee -a .result.log ; \
     46        done
     47        @./stat.py .result.log
     48        @rm -f a.out .result.log
     49
     50ctxswitch-pthread$(EXEEXT):
     51        @BACKEND_CC@ ${AM_CFLAGS} ${CFLAGS} ${ccflags} -lrt -pthread -DN=50000000 PthrdCtxSwitch.c
     52        @rm -f .result.log
     53        @for number in 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20; do \
     54                ./a.out | tee -a .result.log ; \
     55        done
     56        @./stat.py .result.log
     57        @rm -f a.out .result.log
     58
     59sched-int$(EXEEXT):
     60        ${CC} ${AM_CFLAGS} ${CFLAGS} ${ccflags} @CFA_FLAGS@ -nodebug -lrt -DN=50000000 SchedInt.c
     61        @rm -f .result.log
     62        @for number in 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20; do \
     63                ./a.out | tee -a .result.log ; \
     64        done
     65        @./stat.py .result.log
     66        @rm -f a.out .result.log
     67
     68monitor$(EXEEXT):
     69        ${CC} ${AM_CFLAGS} ${CFLAGS} ${ccflags} @CFA_FLAGS@ -nodebug -lrt -DN=50000000 Monitor.c
     70        @rm -f .result.log
     71        @for number in 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20; do \
     72                ./a.out | tee -a .result.log ; \
     73        done
     74        @./stat.py .result.log
     75        @rm -f a.out .result.log
     76
    3877csv-data$(EXEEXT):
    3978        @${CC} ${AM_CFLAGS} ${CFLAGS} ${ccflags} @CFA_FLAGS@ -nodebug -lrt -quiet -DN=50000000 csv-data.c
    4079        @./a.out
    4180        @rm -f ./a.out
    42 
    43 ## =========================================================================================================
    44 ctxswitch$(EXEEXT): \
    45         ctxswitch-pthread.run           \
    46         ctxswitch-cfa_coroutine.run     \
    47         ctxswitch-cfa_thread.run        \
    48         ctxswitch-upp_coroutine.run     \
    49         ctxswitch-upp_thread.run
    50 
    51 ctxswitch-cfa_coroutine$(EXEEXT):
    52         ${CC}        ctxswitch/cfa_cor.c   -DBENCH_N=50000000  -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    53 
    54 ctxswitch-cfa_thread$(EXEEXT):
    55         ${CC}        ctxswitch/cfa_thrd.c  -DBENCH_N=50000000  -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    56 
    57 ctxswitch-upp_coroutine$(EXEEXT):
    58         u++          ctxswitch/upp_cor.cc  -DBENCH_N=50000000  -I. -nodebug -lrt -quiet             ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    59 
    60 ctxswitch-upp_thread$(EXEEXT):
    61         u++          ctxswitch/upp_thrd.cc -DBENCH_N=50000000  -I. -nodebug -lrt -quiet             ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    62 
    63 ctxswitch-pthread$(EXEEXT):
    64         @BACKEND_CC@ ctxswitch/pthreads.c  -DBENCH_N=50000000  -I. -lrt -pthread                    ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    65 
    66 ## =========================================================================================================
    67 creation$(EXEEXT) :\
    68         creation-pthread.run            \
    69         creation-cfa_coroutine.run      \
    70         creation-cfa_thread.run         \
    71         creation-upp_coroutine.run      \
    72         creation-upp_thread.run
    73 
    74 creation-cfa_coroutine$(EXEEXT):
    75         ${CC}        creation/cfa_cor.c   -DBENCH_N=10000000   -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    76 
    77 creation-cfa_thread$(EXEEXT):
    78         ${CC}        creation/cfa_thrd.c  -DBENCH_N=10000000   -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    79 
    80 creation-upp_coroutine$(EXEEXT):
    81         u++          creation/upp_cor.cc  -DBENCH_N=50000000   -I. -nodebug -lrt -quiet             ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    82 
    83 creation-upp_thread$(EXEEXT):
    84         u++          creation/upp_thrd.cc -DBENCH_N=50000000   -I. -nodebug -lrt -quiet             ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    85 
    86 creation-pthread$(EXEEXT):
    87         @BACKEND_CC@ creation/pthreads.c  -DBENCH_N=250000     -I. -lrt -pthread                    ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    88 
    89 ## =========================================================================================================
    90 mutex$(EXEEXT) :\
    91         mutex-function.run      \
    92         mutex-pthread_lock.run  \
    93         mutex-upp.run           \
    94         mutex-cfa1.run          \
    95         mutex-cfa2.run          \
    96         mutex-cfa4.run
    97 
    98 mutex-function$(EXEEXT):
    99         @BACKEND_CC@ mutex/function.c    -DBENCH_N=500000000   -I. -lrt -pthread                    ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    100 
    101 mutex-pthread_lock$(EXEEXT):
    102         @BACKEND_CC@ mutex/pthreads.c    -DBENCH_N=50000000    -I. -lrt -pthread                    ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    103 
    104 mutex-upp$(EXEEXT):
    105         u++          mutex/upp.cc        -DBENCH_N=50000000    -I. -nodebug -lrt -quiet             ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    106 
    107 mutex-cfa1$(EXEEXT):
    108         ${CC}        mutex/cfa1.c        -DBENCH_N=5000000     -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    109 
    110 mutex-cfa2$(EXEEXT):
    111         ${CC}        mutex/cfa2.c        -DBENCH_N=5000000     -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    112 
    113 mutex-cfa4$(EXEEXT):
    114         ${CC}        mutex/cfa4.c        -DBENCH_N=5000000     -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    115 
    116 ## =========================================================================================================
    117 signal$(EXEEXT) :\
    118         signal-upp.run          \
    119         signal-cfa1.run         \
    120         signal-cfa2.run         \
    121         signal-cfa4.run
    122 
    123 signal-upp$(EXEEXT):
    124         u++          schedint/upp.cc     -DBENCH_N=5000000     -I. -nodebug -lrt -quiet             ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    125 
    126 signal-cfa1$(EXEEXT):
    127         ${CC}        schedint/cfa1.c     -DBENCH_N=500000      -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    128 
    129 signal-cfa2$(EXEEXT):
    130         ${CC}        schedint/cfa2.c     -DBENCH_N=500000      -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    131 
    132 signal-cfa4$(EXEEXT):
    133         ${CC}        schedint/cfa4.c     -DBENCH_N=500000      -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    134 
    135 ## =========================================================================================================
    136 waitfor$(EXEEXT) :\
    137         waitfor-upp.run         \
    138         waitfor-cfa1.run                \
    139         waitfor-cfa2.run                \
    140         waitfor-cfa4.run
    141 
    142 waitfor-upp$(EXEEXT):
    143         u++          schedext/upp.cc     -DBENCH_N=5000000     -I. -nodebug -lrt -quiet             ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    144 
    145 waitfor-cfa1$(EXEEXT):
    146         ${CC}        schedext/cfa1.c     -DBENCH_N=500000      -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    147 
    148 waitfor-cfa2$(EXEEXT):
    149         ${CC}        schedext/cfa2.c     -DBENCH_N=500000      -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    150 
    151 waitfor-cfa4$(EXEEXT):
    152         ${CC}        schedext/cfa4.c     -DBENCH_N=500000      -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    153 
    154 ## =========================================================================================================
    155 
    156 %.run : %$(EXEEXT) ${REPEAT}
    157         @rm -f .result.log
    158         @echo "------------------------------------------------------"
    159         @echo $<
    160         @${REPEAT} ${repeats} ./a.out | tee -a .result.log
    161         @${STATS} .result.log
    162         @echo "------------------------------------------------------"
    163         @rm -f a.out .result.log
    164 
    165 ${REPEAT} :
    166         @+make -C ${TOOLSDIR} repeat

  • src/benchmark/Makefile.in

    r4f748c5 rfde89cf6  
    9292build_triplet = @build@
    9393host_triplet = @host@
    94 noinst_PROGRAMS =
    9594subdir = src/benchmark
    9695ACLOCAL_M4 = $(top_srcdir)/aclocal.m4
    … …  
    104103CONFIG_CLEAN_VPATH_FILES =
    105104PROGRAMS = $(noinst_PROGRAMS)
     105bench_SOURCES = bench.c
     106bench_OBJECTS = bench.$(OBJEXT)
     107bench_LDADD = $(LDADD)
     108csv_data_SOURCES = csv-data.c
     109csv_data_OBJECTS = csv-data.$(OBJEXT)
     110csv_data_LDADD = $(LDADD)
     111ctxswitch_coroutine_SOURCES = ctxswitch-coroutine.c
     112ctxswitch_coroutine_OBJECTS = ctxswitch-coroutine.$(OBJEXT)
     113ctxswitch_coroutine_LDADD = $(LDADD)
     114ctxswitch_thread_SOURCES = ctxswitch-thread.c
     115ctxswitch_thread_OBJECTS = ctxswitch-thread.$(OBJEXT)
     116ctxswitch_thread_LDADD = $(LDADD)
     117monitor_SOURCES = monitor.c
     118monitor_OBJECTS = monitor.$(OBJEXT)
     119monitor_LDADD = $(LDADD)
     120sched_int_SOURCES = sched-int.c
     121sched_int_OBJECTS = sched-int.$(OBJEXT)
     122sched_int_LDADD = $(LDADD)
    106123AM_V_P = $(am__v_P_@AM_V@)
    107124am__v_P_ = $(am__v_P_@AM_DEFAULT_V@)
    … …  
    116133am__v_at_0 = @
    117134am__v_at_1 =
    118 SOURCES =
    119 DIST_SOURCES =
     135DEFAULT_INCLUDES = -I.@am__isrc@ -I$(top_builddir)
     136depcomp = $(SHELL) $(top_srcdir)/automake/depcomp
     137am__depfiles_maybe = depfiles
     138am__mv = mv -f
     139COMPILE = $(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) \
     140        $(CPPFLAGS) $(AM_CFLAGS) $(CFLAGS)
     141AM_V_CC = $(am__v_CC_@AM_V@)
     142am__v_CC_ = $(am__v_CC_@AM_DEFAULT_V@)
     143am__v_CC_0 = @echo "  CC      " $@;
     144am__v_CC_1 =
     145CCLD = $(CC)
     146LINK = $(CCLD) $(AM_CFLAGS) $(CFLAGS) $(AM_LDFLAGS) $(LDFLAGS) -o $@
     147AM_V_CCLD = $(am__v_CCLD_@AM_V@)
     148am__v_CCLD_ = $(am__v_CCLD_@AM_DEFAULT_V@)
     149am__v_CCLD_0 = @echo "  CCLD    " $@;
     150am__v_CCLD_1 =
     151SOURCES = bench.c csv-data.c ctxswitch-coroutine.c ctxswitch-thread.c \
     152        monitor.c sched-int.c
     153DIST_SOURCES = bench.c csv-data.c ctxswitch-coroutine.c \
     154        ctxswitch-thread.c monitor.c sched-int.c
    120155am__can_run_installinfo = \
    121156  case $$AM_UPDATE_INFO_DIR in \
    … …  
    124159  esac
    125160am__tagged_files = $(HEADERS) $(SOURCES) $(TAGS_FILES) $(LISP)
    126 am__DIST_COMMON = $(srcdir)/Makefile.in
     161# Read a list of newline-separated strings from the standard input,
     162# and print each of them once, without duplicates.  Input order is
     163# *not* preserved.
     164am__uniquify_input = $(AWK) '\
     165  BEGIN { nonempty = 0; } \
     166  { items[$$0] = 1; nonempty = 1; } \
     167  END { if (nonempty) { for (i in items) print i; }; } \
     168'
     169# Make sure the list of sources is unique.  This is necessary because,
     170# e.g., the same source file might be shared among _SOURCES variables
     171# for different programs/libraries.
     172am__define_uniq_tagged_files = \
     173  list='$(am__tagged_files)'; \
     174  unique=`for i in $$list; do \
     175    if test -f "$$i"; then echo $$i; else echo $(srcdir)/$$i; fi; \
     176  done | $(am__uniquify_input)`
     177ETAGS = etags
     178CTAGS = ctags
     179am__DIST_COMMON = $(srcdir)/Makefile.in $(top_srcdir)/automake/depcomp
    127180DISTFILES = $(DIST_COMMON) $(DIST_SOURCES) $(TEXINFOS) $(EXTRA_DIST)
    128181ACLOCAL = @ACLOCAL@
    … …  
    249302top_srcdir = @top_srcdir@
    250303AM_CFLAGS = -g -Wall -Wno-unused-function -O2
    251 TOOLSDIR = ${abs_top_srcdir}/tools/
    252 REPEAT = ${TOOLSDIR}repeat
    253 STATS = ${TOOLSDIR}stat.py
    254 repeats = 30
     304noinst_PROGRAMS = bench$(EXEEXT) ctxswitch-coroutine$(EXEEXT) ctxswitch-thread$(EXEEXT) sched-int$(EXEEXT) monitor$(EXEEXT) csv-data$(EXEEXT)
    255305all: all-am
    256306
    257307.SUFFIXES:
     308.SUFFIXES: .c .o .obj
    258309$(srcdir)/Makefile.in: @MAINTAINER_MODE_TRUE@ $(srcdir)/Makefile.am  $(am__configure_deps)
    259310        @for dep in $?; do \
    … …  
    288339clean-noinstPROGRAMS:
    289340        -test -z "$(noinst_PROGRAMS)" || rm -f $(noinst_PROGRAMS)
    290 tags TAGS:
    291 
    292 ctags CTAGS:
    293 
    294 cscope cscopelist:
    295 
     341
     342mostlyclean-compile:
     343        -rm -f *.$(OBJEXT)
     344
     345distclean-compile:
     346        -rm -f *.tab.c
     347
     348@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/bench.Po@am__quote@
     349@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/csv-data.Po@am__quote@
     350@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/ctxswitch-coroutine.Po@am__quote@
     351@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/ctxswitch-thread.Po@am__quote@
     352@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/monitor.Po@am__quote@
     353@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/sched-int.Po@am__quote@
     354
     355.c.o:
     356@am__fastdepCC_TRUE@    $(AM_V_CC)depbase=`echo $@ | sed 's|[^/]*$$|$(DEPDIR)/&|;s|\.o$$||'`;\
     357@am__fastdepCC_TRUE@    $(COMPILE) -MT $@ -MD -MP -MF $$depbase.Tpo -c -o $@ $< &&\
     358@am__fastdepCC_TRUE@    $(am__mv) $$depbase.Tpo $$depbase.Po
     359@AMDEP_TRUE@@am__fastdepCC_FALSE@       $(AM_V_CC)source='$<' object='$@' libtool=no @AMDEPBACKSLASH@
     360@AMDEP_TRUE@@am__fastdepCC_FALSE@       DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@
     361@am__fastdepCC_FALSE@   $(AM_V_CC@am__nodep@)$(COMPILE) -c -o $@ $<
     362
     363.c.obj:
     364@am__fastdepCC_TRUE@    $(AM_V_CC)depbase=`echo $@ | sed 's|[^/]*$$|$(DEPDIR)/&|;s|\.obj$$||'`;\
     365@am__fastdepCC_TRUE@    $(COMPILE) -MT $@ -MD -MP -MF $$depbase.Tpo -c -o $@ `$(CYGPATH_W) '$<'` &&\
     366@am__fastdepCC_TRUE@    $(am__mv) $$depbase.Tpo $$depbase.Po
     367@AMDEP_TRUE@@am__fastdepCC_FALSE@       $(AM_V_CC)source='$<' object='$@' libtool=no @AMDEPBACKSLASH@
     368@AMDEP_TRUE@@am__fastdepCC_FALSE@       DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@
     369@am__fastdepCC_FALSE@   $(AM_V_CC@am__nodep@)$(COMPILE) -c -o $@ `$(CYGPATH_W) '$<'`
     370
     371ID: $(am__tagged_files)
     372        $(am__define_uniq_tagged_files); mkid -fID $$unique
     373tags: tags-am
     374TAGS: tags
     375
     376tags-am: $(TAGS_DEPENDENCIES) $(am__tagged_files)
     377        set x; \
     378        here=`pwd`; \
     379        $(am__define_uniq_tagged_files); \
     380        shift; \
     381        if test -z "$(ETAGS_ARGS)$$*$$unique"; then :; else \
     382          test -n "$$unique" || unique=$$empty_fix; \
     383          if test $$# -gt 0; then \
     384            $(ETAGS) $(ETAGSFLAGS) $(AM_ETAGSFLAGS) $(ETAGS_ARGS) \
     385              "$$@" $$unique; \
     386          else \
     387            $(ETAGS) $(ETAGSFLAGS) $(AM_ETAGSFLAGS) $(ETAGS_ARGS) \
     388              $$unique; \
     389          fi; \
     390        fi
     391ctags: ctags-am
     392
     393CTAGS: ctags
     394ctags-am: $(TAGS_DEPENDENCIES) $(am__tagged_files)
     395        $(am__define_uniq_tagged_files); \
     396        test -z "$(CTAGS_ARGS)$$unique" \
     397          || $(CTAGS) $(CTAGSFLAGS) $(AM_CTAGSFLAGS) $(CTAGS_ARGS) \
     398             $$unique
     399
     400GTAGS:
     401        here=`$(am__cd) $(top_builddir) && pwd` \
     402          && $(am__cd) $(top_srcdir) \
     403          && gtags -i $(GTAGS_ARGS) "$$here"
     404cscopelist: cscopelist-am
     405
     406cscopelist-am: $(am__tagged_files)
     407        list='$(am__tagged_files)'; \
     408        case "$(srcdir)" in \
     409          [\\/]* | ?:[\\/]*) sdir="$(srcdir)" ;; \
     410          *) sdir=$(subdir)/$(srcdir) ;; \
     411        esac; \
     412        for i in $$list; do \
     413          if test -f "$$i"; then \
     414            echo "$(subdir)/$$i"; \
     415          else \
     416            echo "$$sdir/$$i"; \
     417          fi; \
     418        done >> $(top_builddir)/cscope.files
     419
     420distclean-tags:
     421        -rm -f TAGS ID GTAGS GRTAGS GSYMS GPATH tags
    296422
    297423distdir: $(DISTFILES)
    … …  
    364490
    365491distclean: distclean-am
     492        -rm -rf ./$(DEPDIR)
    366493        -rm -f Makefile
    367 distclean-am: clean-am distclean-generic
     494distclean-am: clean-am distclean-compile distclean-generic \
     495        distclean-tags
    368496
    369497dvi: dvi-am
    … …  
    408536
    409537maintainer-clean: maintainer-clean-am
     538        -rm -rf ./$(DEPDIR)
    410539        -rm -f Makefile
    411540maintainer-clean-am: distclean-am maintainer-clean-generic
    … …  
    413542mostlyclean: mostlyclean-am
    414543
    415 mostlyclean-am: mostlyclean-generic
     544mostlyclean-am: mostlyclean-compile mostlyclean-generic
    416545
    417546pdf: pdf-am
    … …  
    427556.MAKE: install-am install-strip
    428557
    429 .PHONY: all all-am check check-am clean clean-generic \
    430         clean-noinstPROGRAMS cscopelist-am ctags-am distclean \
    431         distclean-generic distdir dvi dvi-am html html-am info info-am \
    432         install install-am install-data install-data-am install-dvi \
    433         install-dvi-am install-exec install-exec-am install-html \
    434         install-html-am install-info install-info-am install-man \
    435         install-pdf install-pdf-am install-ps install-ps-am \
    436         install-strip installcheck installcheck-am installdirs \
    437         maintainer-clean maintainer-clean-generic mostlyclean \
    438         mostlyclean-generic pdf pdf-am ps ps-am tags-am uninstall \
     558.PHONY: CTAGS GTAGS TAGS all all-am check check-am clean clean-generic \
     559        clean-noinstPROGRAMS cscopelist-am ctags ctags-am distclean \
     560        distclean-compile distclean-generic distclean-tags distdir dvi \
     561        dvi-am html html-am info info-am install install-am \
     562        install-data install-data-am install-dvi install-dvi-am \
     563        install-exec install-exec-am install-html install-html-am \
     564        install-info install-info-am install-man install-pdf \
     565        install-pdf-am install-ps install-ps-am install-strip \
     566        installcheck installcheck-am installdirs maintainer-clean \
     567        maintainer-clean-generic mostlyclean mostlyclean-compile \
     568        mostlyclean-generic pdf pdf-am ps ps-am tags tags-am uninstall \
    439569        uninstall-am
    440570
    441571.PRECIOUS: Makefile
    442572
    443 
    444 .NOTPARALLEL:
    445573
    446574bench$(EXEEXT) :
    … …  
    452580        rm -f ./a.out ;
    453581
     582ctxswitch-coroutine$(EXEEXT):
     583        ${CC} ${AM_CFLAGS} ${CFLAGS} ${ccflags} @CFA_FLAGS@ -nodebug -lrt -DN=50000000 CorCtxSwitch.c
     584        @rm -f .result.log
     585        @for number in 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20; do \
     586                ./a.out | tee -a .result.log ; \
     587        done
     588        @./stat.py .result.log
     589        @rm -f a.out .result.log
     590
     591ctxswitch-thread$(EXEEXT):
     592        ${CC} ${AM_CFLAGS} ${CFLAGS} ${ccflags} @CFA_FLAGS@ -nodebug -lrt -DN=50000000 ThrdCtxSwitch.c
     593        @rm -f .result.log
     594        @for number in 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20; do \
     595                ./a.out | tee -a .result.log ; \
     596        done
     597        @./stat.py .result.log
     598        @rm -f a.out .result.log
     599
     600ctxswitch-pthread$(EXEEXT):
     601        @BACKEND_CC@ ${AM_CFLAGS} ${CFLAGS} ${ccflags} -lrt -pthread -DN=50000000 PthrdCtxSwitch.c
     602        @rm -f .result.log
     603        @for number in 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20; do \
     604                ./a.out | tee -a .result.log ; \
     605        done
     606        @./stat.py .result.log
     607        @rm -f a.out .result.log
     608
     609sched-int$(EXEEXT):
     610        ${CC} ${AM_CFLAGS} ${CFLAGS} ${ccflags} @CFA_FLAGS@ -nodebug -lrt -DN=50000000 SchedInt.c
     611        @rm -f .result.log
     612        @for number in 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20; do \
     613                ./a.out | tee -a .result.log ; \
     614        done
     615        @./stat.py .result.log
     616        @rm -f a.out .result.log
     617
     618monitor$(EXEEXT):
     619        ${CC} ${AM_CFLAGS} ${CFLAGS} ${ccflags} @CFA_FLAGS@ -nodebug -lrt -DN=50000000 Monitor.c
     620        @rm -f .result.log
     621        @for number in 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20; do \
     622                ./a.out | tee -a .result.log ; \
     623        done
     624        @./stat.py .result.log
     625        @rm -f a.out .result.log
     626
    454627csv-data$(EXEEXT):
    455628        @${CC} ${AM_CFLAGS} ${CFLAGS} ${ccflags} @CFA_FLAGS@ -nodebug -lrt -quiet -DN=50000000 csv-data.c
    … …  
    457630        @rm -f ./a.out
    458631
    459 ctxswitch$(EXEEXT): \
    460         ctxswitch-pthread.run           \
    461         ctxswitch-cfa_coroutine.run     \
    462         ctxswitch-cfa_thread.run        \
    463         ctxswitch-upp_coroutine.run     \
    464         ctxswitch-upp_thread.run
    465 
    466 ctxswitch-cfa_coroutine$(EXEEXT):
    467         ${CC}        ctxswitch/cfa_cor.c   -DBENCH_N=50000000  -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    468 
    469 ctxswitch-cfa_thread$(EXEEXT):
    470         ${CC}        ctxswitch/cfa_thrd.c  -DBENCH_N=50000000  -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    471 
    472 ctxswitch-upp_coroutine$(EXEEXT):
    473         u++          ctxswitch/upp_cor.cc  -DBENCH_N=50000000  -I. -nodebug -lrt -quiet             ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    474 
    475 ctxswitch-upp_thread$(EXEEXT):
    476         u++          ctxswitch/upp_thrd.cc -DBENCH_N=50000000  -I. -nodebug -lrt -quiet             ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    477 
    478 ctxswitch-pthread$(EXEEXT):
    479         @BACKEND_CC@ ctxswitch/pthreads.c  -DBENCH_N=50000000  -I. -lrt -pthread                    ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    480 
    481 creation$(EXEEXT) :\
    482         creation-pthread.run            \
    483         creation-cfa_coroutine.run      \
    484         creation-cfa_thread.run         \
    485         creation-upp_coroutine.run      \
    486         creation-upp_thread.run
    487 
    488 creation-cfa_coroutine$(EXEEXT):
    489         ${CC}        creation/cfa_cor.c   -DBENCH_N=10000000   -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    490 
    491 creation-cfa_thread$(EXEEXT):
    492         ${CC}        creation/cfa_thrd.c  -DBENCH_N=10000000   -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    493 
    494 creation-upp_coroutine$(EXEEXT):
    495         u++          creation/upp_cor.cc  -DBENCH_N=50000000   -I. -nodebug -lrt -quiet             ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    496 
    497 creation-upp_thread$(EXEEXT):
    498         u++          creation/upp_thrd.cc -DBENCH_N=50000000   -I. -nodebug -lrt -quiet             ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    499 
    500 creation-pthread$(EXEEXT):
    501         @BACKEND_CC@ creation/pthreads.c  -DBENCH_N=250000     -I. -lrt -pthread                    ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    502 
    503 mutex$(EXEEXT) :\
    504         mutex-function.run      \
    505         mutex-pthread_lock.run  \
    506         mutex-upp.run           \
    507         mutex-cfa1.run          \
    508         mutex-cfa2.run          \
    509         mutex-cfa4.run
    510 
    511 mutex-function$(EXEEXT):
    512         @BACKEND_CC@ mutex/function.c    -DBENCH_N=500000000   -I. -lrt -pthread                    ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    513 
    514 mutex-pthread_lock$(EXEEXT):
    515         @BACKEND_CC@ mutex/pthreads.c    -DBENCH_N=50000000    -I. -lrt -pthread                    ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    516 
    517 mutex-upp$(EXEEXT):
    518         u++          mutex/upp.cc        -DBENCH_N=50000000    -I. -nodebug -lrt -quiet             ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    519 
    520 mutex-cfa1$(EXEEXT):
    521         ${CC}        mutex/cfa1.c        -DBENCH_N=5000000     -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    522 
    523 mutex-cfa2$(EXEEXT):
    524         ${CC}        mutex/cfa2.c        -DBENCH_N=5000000     -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    525 
    526 mutex-cfa4$(EXEEXT):
    527         ${CC}        mutex/cfa4.c        -DBENCH_N=5000000     -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    528 
    529 signal$(EXEEXT) :\
    530         signal-upp.run          \
    531         signal-cfa1.run         \
    532         signal-cfa2.run         \
    533         signal-cfa4.run
    534 
    535 signal-upp$(EXEEXT):
    536         u++          schedint/upp.cc     -DBENCH_N=5000000     -I. -nodebug -lrt -quiet             ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    537 
    538 signal-cfa1$(EXEEXT):
    539         ${CC}        schedint/cfa1.c     -DBENCH_N=500000      -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    540 
    541 signal-cfa2$(EXEEXT):
    542         ${CC}        schedint/cfa2.c     -DBENCH_N=500000      -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    543 
    544 signal-cfa4$(EXEEXT):
    545         ${CC}        schedint/cfa4.c     -DBENCH_N=500000      -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    546 
    547 waitfor$(EXEEXT) :\
    548         waitfor-upp.run         \
    549         waitfor-cfa1.run                \
    550         waitfor-cfa2.run                \
    551         waitfor-cfa4.run
    552 
    553 waitfor-upp$(EXEEXT):
    554         u++          schedext/upp.cc     -DBENCH_N=5000000     -I. -nodebug -lrt -quiet             ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    555 
    556 waitfor-cfa1$(EXEEXT):
    557         ${CC}        schedext/cfa1.c     -DBENCH_N=500000      -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    558 
    559 waitfor-cfa2$(EXEEXT):
    560         ${CC}        schedext/cfa2.c     -DBENCH_N=500000      -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    561 
    562 waitfor-cfa4$(EXEEXT):
    563         ${CC}        schedext/cfa4.c     -DBENCH_N=500000      -I. -nodebug -lrt -quiet @CFA_FLAGS@ ${AM_CFLAGS} ${CFLAGS} ${ccflags}
    564 
    565 %.run : %$(EXEEXT) ${REPEAT}
    566         @rm -f .result.log
    567         @echo "------------------------------------------------------"
    568         @echo $<
    569         @${REPEAT} ${repeats} ./a.out | tee -a .result.log
    570         @${STATS} .result.log
    571         @echo "------------------------------------------------------"
    572         @rm -f a.out .result.log
    573 
    574 ${REPEAT} :
    575         @+make -C ${TOOLSDIR} repeat
    576 
    577632# Tell versions [3.59,3.63) of GNU make to not export all variables.
    578633# Otherwise a system limit (for SysV at least) may be exceeded.

  • src/benchmark/bench.h

    r4f748c5 rfde89cf6  
    11#pragma once
    22
    3 #if defined(__CFORALL__)
     3#ifdef __CFORALL__
    44extern "C" {
    55#endif
    6         #include <stdlib.h>
    76        #include <unistd.h>                                     // sysconf
    87        #include <sys/times.h>                                  // times
    98        #include <time.h>
    10 #if defined(__CFORALL__)
     9#ifdef __CFORALL__
    1110}
    1211#endif
    … …  
    2827} // Time
    2928
    30 #ifndef BENCH_N
    31 #define BENCH_N 500 //10000000
     29#ifndef N
     30#define N 10000000
    3231#endif
    33 
    34 #define BENCH(statement, output)                \
    35         size_t n = BENCH_N;                     \
    36         if( argc > 2 ) return 1;                \
    37         if( argc == 2 ) {                               \
    38                 n = atoi(argv[1]);              \
    39         }                                               \
    40         long long int StartTime, EndTime;       \
    41         StartTime = Time();                     \
    42         statement;                                      \
    43         EndTime = Time();                               \
    44         unsigned long long int output =         \
    45         ( EndTime - StartTime ) / n;
    4632
    4733unsigned int default_preemption() {

  • src/driver/cfa.cc

    r4f748c5 rfde89cf6  
    1010// Created On       : Tue Aug 20 13:44:49 2002
    1111// Last Modified By : Peter A. Buhr
    12 // Last Modified On : Tue Oct 31 11:40:44 2017
    13 // Update Count     : 160
     12// Last Modified On : Tue Sep 26 23:12:38 2017
     13// Update Count     : 159
    1414//
    1515
    … …  
    305305        } // if
    306306
    307         shuffle( args, sargs, nargs, 1 );                                       // make room at front of argument list
    308         nargs += 1;
    309307        if ( CFA_flag ) {
    310                 args[sargs] = "-D__CFA_FLAG__=-N";
    311308                args[nargs] = "-D__CFA_PREPROCESS_";
    312309                nargs += 1;
    313         } else {
    314                 args[sargs] = "-D__CFA_FLAG__=-L";
    315         } // if
    316         sargs += 1;
     310        } // if
    317311
    318312        if ( debug ) {

  • src/libcfa/concurrency/kernel.c

    r4f748c5 rfde89cf6  
    548548
    549549        int len = snprintf( abort_text, abort_text_size, "Error occurred while executing task %.256s (%p)", thrd->self_cor.name, thrd );
    550         __lib_debug_write( abort_text, len );
     550        __lib_debug_write( STDERR_FILENO, abort_text, len );
    551551
    552552        if ( thrd != this_coroutine ) {
    553553                len = snprintf( abort_text, abort_text_size, " in coroutine %.256s (%p).\n", this_coroutine->name, this_coroutine );
    554                 __lib_debug_write( abort_text, len );
     554                __lib_debug_write( STDERR_FILENO, abort_text, len );
    555555        }
    556556        else {
    557                 __lib_debug_write( ".\n", 2 );
     557                __lib_debug_write( STDERR_FILENO, ".\n", 2 );
    558558        }
    559559}

  • src/libcfa/concurrency/monitor.c

    r4f748c5 rfde89cf6  
    2121#include "kernel_private.h"
    2222
    23 #include "bits/algorithms.h"
    24 
    2523//-----------------------------------------------------------------------------
    2624// Forward declarations
    … …  
    9795                else if( this->owner == thrd) {
    9896                        // We already have the monitor, just note how many times we took it
     97                        verify( this->recursion > 0 );
    9998                        this->recursion += 1;
    10099
    … …  
    208207                // it means we don't need to do anything
    209208                if( this->recursion != 0) {
    210                         LIB_DEBUG_PRINT_SAFE("Kernel :  recursion still %d\n", this->recursion);
    211209                        unlock( &this->lock );
    212210                        return;
    … …  
    293291
    294292        // Sort monitors based on address -> TODO use a sort specialized for small numbers
    295         __libcfa_small_sort(this.m, count);
     293        qsort(this.m, count);
    296294
    297295        // Save previous thread context
    … …  
    494492        set_owner( monitors, count, signallee );
    495493
    496         LIB_DEBUG_PRINT_BUFFER_DECL( "Kernel : signal_block condition %p (s: %p)\n", this, signallee );
    497 
    498494        //Everything is ready to go to sleep
    499495        BlockInternal( locks, count, &signallee, 1 );
    … …  
    502498        // WE WOKE UP
    503499
    504 
    505         LIB_DEBUG_PRINT_BUFFER_LOCAL( "Kernel :   signal_block returned\n" );
    506500
    507501        //We are back, restore the masks and recursions
    … …  
    542536        short actual_count = aggregate( mon_storage, mask );
    543537
    544         LIB_DEBUG_PRINT_BUFFER_DECL( "Kernel : waitfor %d (s: %d, m: %d)\n", actual_count, mask.size, (short)max);
     538        LIB_DEBUG_PRINT_SAFE("Kernel : waitfor %d (s: %d, m: %d)\n", actual_count, mask.size, (short)max);
    545539
    546540        if(actual_count == 0) return;
    547541
    548         LIB_DEBUG_PRINT_BUFFER_LOCAL( "Kernel : waitfor internal proceeding\n");
     542        LIB_DEBUG_PRINT_SAFE("Kernel : waitfor internal proceeding\n");
    549543
    550544        // Create storage for monitor context
    … …  
    562556                        *mask.accepted = index;
    563557                        if( mask.clauses[index].is_dtor ) {
    564                                 LIB_DEBUG_PRINT_BUFFER_LOCAL( "Kernel : dtor already there\n");
     558                                LIB_DEBUG_PRINT_SAFE("Kernel : dtor already there\n");
    565559                                verifyf( mask.clauses[index].size == 1        , "ERROR: Accepted dtor has more than 1 mutex parameter." );
    566560
    … …  
    574568                        }
    575569                        else {
    576                                 LIB_DEBUG_PRINT_BUFFER_LOCAL( "Kernel : thread present, baton-passing\n");
     570                                LIB_DEBUG_PRINT_SAFE("Kernel : thread present, baton-passing\n");
    577571
    578572                                // Create the node specific to this wait operation
    … …  
    582576                                monitor_save;
    583577
    584                                 LIB_DEBUG_PRINT_BUFFER_LOCAL( "Kernel :  baton of %d monitors : ", count );
    585                                 #ifdef __CFA_DEBUG_PRINT__
    586                                         for( int i = 0; i < count; i++) {
    587                                                 LIB_DEBUG_PRINT_BUFFER_LOCAL( "%p %p ", monitors[i], monitors[i]->signal_stack.top );
    588                                         }
    589                                 #endif
    590                                 LIB_DEBUG_PRINT_BUFFER_LOCAL( "\n");
    591 
    592578                                // Set the owners to be the next thread
    593579                                set_owner( monitors, count, next );
    … …  
    599585                                monitor_restore;
    600586
    601                                 LIB_DEBUG_PRINT_BUFFER_LOCAL( "Kernel : thread present, returned\n");
     587                                LIB_DEBUG_PRINT_SAFE("Kernel : thread present, returned\n");
    602588                        }
    603589
    604                         LIB_DEBUG_PRINT_BUFFER_LOCAL( "Kernel : accepted %d\n", *mask.accepted);
     590                        LIB_DEBUG_PRINT_SAFE("Kernel : accepted %d\n", *mask.accepted);
    605591
    606592                        return;
    … …  
    610596
    611597        if( duration == 0 ) {
    612                 LIB_DEBUG_PRINT_BUFFER_LOCAL( "Kernel : non-blocking, exiting\n");
     598                LIB_DEBUG_PRINT_SAFE("Kernel : non-blocking, exiting\n");
    613599
    614600                unlock_all( locks, count );
    615601
    616                 LIB_DEBUG_PRINT_BUFFER_LOCAL( "Kernel : accepted %d\n", *mask.accepted);
     602                LIB_DEBUG_PRINT_SAFE("Kernel : accepted %d\n", *mask.accepted);
    617603                return;
    618604        }
    … …  
    621607        verifyf( duration < 0, "Timeout on waitfor statments not supported yet.");
    622608
    623         LIB_DEBUG_PRINT_BUFFER_LOCAL( "Kernel : blocking waitfor\n");
     609        LIB_DEBUG_PRINT_SAFE("Kernel : blocking waitfor\n");
    624610
    625611        // Create the node specific to this wait operation
    … …  
    643629        monitor_restore;
    644630
    645         LIB_DEBUG_PRINT_BUFFER_LOCAL( "Kernel : exiting\n");
    646 
    647         LIB_DEBUG_PRINT_BUFFER_LOCAL( "Kernel : accepted %d\n", *mask.accepted);
     631        LIB_DEBUG_PRINT_SAFE("Kernel : exiting\n");
     632
     633        LIB_DEBUG_PRINT_SAFE("Kernel : accepted %d\n", *mask.accepted);
    648634}
    649635
    … …  
    662648
    663649static inline void set_owner( monitor_desc ** monitors, short count, thread_desc * owner ) {
    664         monitors[0]->owner     = owner;
    665         monitors[0]->recursion = 1;
    666         for( int i = 1; i < count; i++ ) {
    667                 monitors[i]->owner     = owner;
    668                 monitors[i]->recursion = 0;
     650        for( int i = 0; i < count; i++ ) {
     651                set_owner( monitors[i], owner );
    669652        }
    670653}
    … …  
    684667static inline thread_desc * next_thread( monitor_desc * this ) {
    685668        //Check the signaller stack
    686         LIB_DEBUG_PRINT_SAFE("Kernel :  mon %p AS-stack top %p\n", this, this->signal_stack.top);
    687669        __condition_criterion_t * urgent = pop( &this->signal_stack );
    688670        if( urgent ) {
    … …  
    736718        for(int i = 0; i < count; i++) {
    737719                (criteria[i]){ monitors[i], waiter };
    738                 LIB_DEBUG_PRINT_SAFE( "Kernel :  target %p = %p\n", criteria[i].target, &criteria[i] );
    739720                push( &criteria[i].target->signal_stack, &criteria[i] );
    740721        }
    … …  
    807788        }
    808789
    809         LIB_DEBUG_PRINT_SAFE( "Kernel :  Runing %i (%p)\n", ready2run, ready2run ? node->waiting_thread : NULL );
     790        // LIB_DEBUG_PRINT_SAFE( "Runing %i\n", ready2run );
    810791        return ready2run ? node->waiting_thread : NULL;
    811792}
    … …  
    875856        short size = 0;
    876857        for( int i = 0; i < mask.size; i++ ) {
    877                 __libcfa_small_sort( mask.clauses[i].list, mask.clauses[i].size );
    878858                for( int j = 0; j < mask.clauses[i].size; j++) {
    879859                        insert_unique( storage, size, mask.clauses[i].list[j] );
    880860                }
    881861        }
    882         // TODO insertion sort instead of this
    883         __libcfa_small_sort( storage, size );
     862        qsort( storage, size );
    884863        return size;
    885864}

  • src/libcfa/concurrency/preemption.c

    r4f748c5 rfde89cf6  
    380380
    381381        if ( sigaction( sig, &act, NULL ) == -1 ) {
    382                 LIB_DEBUG_PRINT_BUFFER_DECL(
     382                LIB_DEBUG_PRINT_BUFFER_DECL( STDERR_FILENO,
    383383                        " __kernel_sigaction( sig:%d, handler:%p, flags:%d ), problem installing signal handler, error(%d) %s.\n",
    384384                        sig, handler, flags, errno, strerror( errno )
    … …  
    397397
    398398        if ( sigaction( sig, &act, NULL ) == -1 ) {
    399                 LIB_DEBUG_PRINT_BUFFER_DECL(
     399                LIB_DEBUG_PRINT_BUFFER_DECL( STDERR_FILENO,
    400400                        " __kernel_sigdefault( sig:%d ), problem reseting signal handler, error(%d) %s.\n",
    401401                        sig, errno, strerror( errno )

  • src/libcfa/interpose.c

    r4f748c5 rfde89cf6  
    127127                        va_end( args );
    128128
    129                         __lib_debug_write( abort_text, len );
    130                         __lib_debug_write( "\n", 1 );
     129                        __lib_debug_write( STDERR_FILENO, abort_text, len );
     130                        __lib_debug_write( STDERR_FILENO, "\n", 1 );
    131131                }
    132132
    133133                len = snprintf( abort_text, abort_text_size, "Cforall Runtime error (UNIX pid:%ld)\n", (long int)getpid() ); // use UNIX pid (versus getPid)
    134                 __lib_debug_write( abort_text, len );
     134                __lib_debug_write( STDERR_FILENO, abort_text, len );
    135135
    136136

  • src/libcfa/libhdr/libdebug.c

    r4f748c5 rfde89cf6  
    99// Author           : Thierry Delisle
    1010// Created On       : Thu Mar 30 12:30:01 2017
    11 // Last Modified By :
    12 // Last Modified On :
     11// Last Modified By : 
     12// Last Modified On : 
    1313// Update Count     : 0
    1414//
    … …  
    2828extern "C" {
    2929
    30         void __lib_debug_write( const char *in_buffer, int len ) {
     30        void __lib_debug_write( int fd, const char *in_buffer, int len ) {
    3131                // ensure all data is written
    32                 for ( int count = 0, retcode; count < len; count += retcode ) {
     32                for ( int count = 0, retcode; count < len; count += retcode ) { 
    3333                        in_buffer += count;
    3434
    3535                        for ( ;; ) {
    36                                 retcode = write( STDERR_FILENO, in_buffer, len - count );
     36                                retcode = write( fd, in_buffer, len - count );
    3737
    3838                                // not a timer interrupt ?
    39                                 if ( retcode != -1 || errno != EINTR ) break;
     39                                if ( retcode != -1 || errno != EINTR ) break; 
    4040                        }
    4141
    … …  
    5252                va_start( args, fmt );
    5353                __lib_debug_acquire();
    54 
     54               
    5555                int len = vsnprintf( buffer, buffer_size, fmt, args );
    56                 __lib_debug_write( buffer, len );
     56                __lib_debug_write( STDERR_FILENO, buffer, len );
    5757
    5858                __lib_debug_release();
    … …  
    6464
    6565                va_start( args, fmt );
    66 
     66               
    6767                int len = vsnprintf( buffer, buffer_size, fmt, args );
    68                 __lib_debug_write( buffer, len );
     68                __lib_debug_write( STDERR_FILENO, buffer, len );
    6969
    7070                va_end( args );
    … …  
    7373        void __lib_debug_print_vararg( const char fmt[], va_list args ) {
    7474                int len = vsnprintf( buffer, buffer_size, fmt, args );
    75                 __lib_debug_write( buffer, len );
     75                __lib_debug_write( STDERR_FILENO, buffer, len );
    7676        }
    7777
    … …  
    8080
    8181                va_start( args, fmt );
    82 
     82               
    8383                int len = vsnprintf( in_buffer, in_buffer_size, fmt, args );
    84                 __lib_debug_write( in_buffer, len );
     84                __lib_debug_write( STDERR_FILENO, in_buffer, len );
    8585
    8686                va_end( args );

  • src/libcfa/libhdr/libdebug.h

    r4f748c5 rfde89cf6  
    4444extern "C" {
    4545#endif
    46         #include <stdarg.h>
    47         #include <stdio.h>
     46      #include <stdarg.h>
    4847
    49       extern void __lib_debug_write( const char *buffer, int len );
     48      extern void __lib_debug_write( int fd, const char *buffer, int len );
    5049      extern void __lib_debug_acquire();
    5150      extern void __lib_debug_release();
    … …  
    5958
    6059#ifdef __CFA_DEBUG_PRINT__
    61         #define LIB_DEBUG_WRITE( buffer, len )         __lib_debug_write( buffer, len )
     60        #define LIB_DEBUG_WRITE( fd, buffer, len )     __lib_debug_write( fd, buffer, len )
    6261        #define LIB_DEBUG_ACQUIRE()                    __lib_debug_acquire()
    6362        #define LIB_DEBUG_RELEASE()                    __lib_debug_release()
    … …  
    6564        #define LIB_DEBUG_PRINT_NOLOCK(...)            __lib_debug_print_nolock (__VA_ARGS__)
    6665        #define LIB_DEBUG_PRINT_BUFFER(...)            __lib_debug_print_buffer (__VA_ARGS__)
    67         #define LIB_DEBUG_PRINT_BUFFER_DECL(...)       char __dbg_text[256]; int __dbg_len = snprintf( __dbg_text, 256, __VA_ARGS__ ); __lib_debug_write( __dbg_text, __dbg_len );
    68         #define LIB_DEBUG_PRINT_BUFFER_LOCAL(...)      __dbg_len = snprintf( __dbg_text, 256, __VA_ARGS__ ); __lib_debug_write( __dbg_text, __dbg_len );
     66        #define LIB_DEBUG_PRINT_BUFFER_DECL(fd, ...)   char text[256]; int len = snprintf( text, 256, __VA_ARGS__ ); __lib_debug_write( fd, text, len );
     67        #define LIB_DEBUG_PRINT_BUFFER_LOCAL(fd, ...)  len = snprintf( text, 256, __VA_ARGS__ ); __lib_debug_write( fd, text, len );
    6968#else
    7069        #define LIB_DEBUG_WRITE(...)               ((void)0)

  • src/libcfa/stdlib

    r4f748c5 rfde89cf6  
    1010// Created On       : Thu Jan 28 17:12:35 2016
    1111// Last Modified By : Peter A. Buhr
    12 // Last Modified On : Tue Oct 31 13:47:24 2017
    13 // Update Count     : 245
     12// Last Modified On : Wed Aug 23 20:29:47 2017
     13// Update Count     : 224
    1414//
    1515
    … …  
    2727// allocation, non-array types
    2828static inline forall( dtype T | sized(T) ) T * malloc( void ) {
    29         // printf( "* malloc\n" );
     29        //printf( "X1\n" );
    3030        return (T *)(void *)malloc( (size_t)sizeof(T) );        // C malloc
    3131} // malloc
    32 
    33 // static inline forall( dtype T | sized(T) ) T & malloc( void ) {
    34 //      int & p = *(T *)(void *)malloc( (size_t)sizeof(T) ); // C malloc
    35 //      printf( "& malloc %p\n", &p );
    36 //      return p;
    37 // //   return (T &)*(T *)(void *)malloc( (size_t)sizeof(T) ); // C malloc
    38 // } // malloc
    3932
    4033extern "C" { void * calloc( size_t dim, size_t size ); } // default C routine
    … …  
    213206//---------------------------------------
    214207
    215 void random_seed( long int s );
    216 char random( void );
    217 char random( char l, char u );
    218 int random( void );
    219 unsigned int random( void );
    220 unsigned int random( unsigned int u );
    221 unsigned int random( unsigned int l, unsigned int u );
    222 //long int random( void );
    223 unsigned long int random( void );
    224 unsigned long int random( unsigned long int u );
    225 unsigned long int random( unsigned long int l, unsigned long int u );
    226 float random( void );
    227 double random( void );
    228 float _Complex random( void );
    229 double _Complex random( void );
    230 long double _Complex random( void );
     208void rand48seed( long int s );
     209char rand48( void );
     210int rand48( void );
     211unsigned int rand48( void );
     212long int rand48( void );
     213unsigned long int rand48( void );
     214float rand48( void );
     215double rand48( void );
     216float _Complex rand48( void );
     217double _Complex rand48( void );
     218long double _Complex rand48( void );
    231219
    232220//---------------------------------------

  • src/libcfa/stdlib.c

    r4f748c5 rfde89cf6  
    1010// Created On       : Thu Jan 28 17:10:29 2016
    1111// Last Modified By : Peter A. Buhr
    12 // Last Modified On : Mon Oct 30 22:43:02 2017
    13 // Update Count     : 297
     12// Last Modified On : Wed Aug 23 20:30:44 2017
     13// Update Count     : 292
    1414//
    1515
    … …  
    275275//---------------------------------------
    276276
    277 void random_seed( long int s ) { srand48( s ); }
    278 char random( void ) { return mrand48(); }
    279 char random( char l, char u ) { return lrand48() % (u - l) + l; }
    280 int random( void ) { return mrand48(); }
    281 unsigned int random( void ) { return lrand48(); }
    282 unsigned int random( unsigned int u ) { return lrand48() % u; }
    283 unsigned int random( unsigned int l, unsigned int u ) { return lrand48() % (u - l) + l; }
    284 //long int random( void ) { return mrand48(); }
    285 unsigned long int random( void ) { return lrand48(); }
    286 unsigned long int random( unsigned long int u ) { return lrand48() % u; }
    287 unsigned long int random( unsigned long int l, unsigned long int u ) { return lrand48() % (u - l) + l; }
    288 float random( void ) { return (float)drand48(); }               // otherwise float uses lrand48
    289 double random( void ) { return drand48(); }
    290 float _Complex random( void ) { return (float)drand48() + (float _Complex)(drand48() * _Complex_I); }
    291 double _Complex random( void ) { return drand48() + (double _Complex)(drand48() * _Complex_I); }
    292 long double _Complex random( void) { return (long double)drand48() + (long double _Complex)(drand48() * _Complex_I); }
     277void rand48seed( long int s ) { srand48( s ); }
     278char rand48( void ) { return mrand48(); }
     279int rand48( void ) { return mrand48(); }
     280unsigned int rand48( void ) { return lrand48(); }
     281long int rand48( void ) { return mrand48(); }
     282unsigned long int rand48( void ) { return lrand48(); }
     283float rand48( void ) { return (float)drand48(); }               // otherwise float uses lrand48
     284double rand48( void ) { return drand48(); }
     285float _Complex rand48( void ) { return (float)drand48() + (float _Complex)(drand48() * _Complex_I); }
     286double _Complex rand48( void ) { return drand48() + (double _Complex)(drand48() * _Complex_I); }
     287long double _Complex rand48( void) { return (long double)drand48() + (long double _Complex)(drand48() * _Complex_I); }
    293288
    294289//---------------------------------------

  • src/main.cc

    r4f748c5 rfde89cf6  
    1010// Author           : Richard C. Bilson
    1111// Created On       : Fri May 15 23:12:02 2015
    12 // Last Modified By : Peter A. Buhr
    13 // Last Modified On : Tue Oct 31 12:22:40 2017
    14 // Update Count     : 445
     12// Last Modified By : Andrew Beach
     13// Last Modified On : Wed Jul 26 14:38:00 2017
     14// Update Count     : 443
    1515//
    1616
    … …  
    8181        expraltp = false,
    8282        libcfap = false,
    83         preludep = false,
    8483        nopreludep = false,
    8584        noprotop = false,
    … …  
    379378
    380379void parse_cmdline( int argc, char * argv[], const char *& filename ) {
    381         enum { Ast, Bbox, Bresolver, CtorInitFix, DeclStats, Expr, ExprAlt, Grammar, LibCFA, Preamble, Nopreamble, Parse, Prototypes, Resolver, Symbol, Tree, TupleExpansion, Validate, };
     380        enum { Ast, Bbox, Bresolver, CtorInitFix, DeclStats, Expr, ExprAlt, Grammar, LibCFA, Nopreamble, Parse, Prototypes, Resolver, Symbol, Tree, TupleExpansion, Validate, };
    382381
    383382        static struct option long_opts[] = {
    … …  
    391390                { "grammar", no_argument, 0, Grammar },
    392391                { "libcfa", no_argument, 0, LibCFA },
    393                 { "preamble", no_argument, 0, Preamble },
    394392                { "no-preamble", no_argument, 0, Nopreamble },
    395393                { "parse", no_argument, 0, Parse },
    … …  
    407405
    408406        int c;
    409         while ( (c = getopt_long( argc, argv, "abBcCdefglLmnNpqrstTvyzZD:F:", long_opts, &long_index )) != -1 ) {
     407        while ( (c = getopt_long( argc, argv, "abBcCdefglLmnpqrstTvyzZD:F:", long_opts, &long_index )) != -1 ) {
    410408                switch ( c ) {
    411409                  case Ast:
    … …  
    453451                  case 'n':                                                                             // do not read preamble
    454452                        nopreludep = true;
    455                         break;
    456                   case Preamble:
    457                   case 'N':                                                                             // read preamble
    458                         preludep = true;
    459453                        break;
    460454                  case Prototypes:

  • src/prelude/prelude.cf

    r4f748c5 rfde89cf6  
    77// Created On       : Sat Nov 29 07:23:41 2014
    88// Last Modified By : Peter A. Buhr
    9 // Last Modified On : Sat Oct 28 16:33:09 2017
    10 // Update Count     : 102
     9// Last Modified On : Sun Oct  8 12:21:33 2017
     10// Update Count     : 97
    1111//
    1212
    … …  
    4141_Bool                   ?++( _Bool & ),                         ?++( volatile _Bool & );
    4242_Bool                   ?--( _Bool & ),                         ?--( volatile _Bool & );
     43unsigned char           ?++( unsigned char & ),                 ?++( volatile unsigned char & );
    4344signed short            ?++( signed short & ),                  ?++( volatile signed short & );
    4445signed short            ?--( signed short & ),                  ?--( volatile signed short & );
    … …  
    195196long double _Complex    ?+?( long double _Complex, long double _Complex ),      ?-?( long double _Complex, long double _Complex );
    196197
    197 forall( dtype T | sized(T) ) T *                ?+?(                T *,          ptrdiff_t );
    198 forall( dtype T | sized(T) ) T *                ?+?(          ptrdiff_t,                T * );
     198forall( dtype T | sized(T) ) T *                        ?+?(                T *,          ptrdiff_t );
     199forall( dtype T | sized(T) ) T *                        ?+?(          ptrdiff_t,                T * );
    199200forall( dtype T | sized(T) ) const T *          ?+?( const          T *,          ptrdiff_t );
    200201forall( dtype T | sized(T) ) const T *          ?+?(          ptrdiff_t, const          T * );
    201 forall( dtype T | sized(T) ) volatile T *       ?+?(       volatile T *,          ptrdiff_t );
    202 forall( dtype T | sized(T) ) volatile T *       ?+?(          ptrdiff_t,       volatile T * );
     202forall( dtype T | sized(T) ) volatile T *               ?+?(       volatile T *,          ptrdiff_t );
     203forall( dtype T | sized(T) ) volatile T *               ?+?(          ptrdiff_t,       volatile T * );
    203204forall( dtype T | sized(T) ) const volatile T * ?+?( const volatile T *,          ptrdiff_t );
    204205forall( dtype T | sized(T) ) const volatile T * ?+?(          ptrdiff_t, const volatile T * );
    205 forall( dtype T | sized(T) ) T *                ?-?(                T *,          ptrdiff_t );
     206forall( dtype T | sized(T) ) T *                        ?-?(                T *,          ptrdiff_t );
    206207forall( dtype T | sized(T) ) const T *          ?-?( const          T *,          ptrdiff_t );
    207 forall( dtype T | sized(T) ) volatile T *       ?-?(       volatile T *,          ptrdiff_t );
     208forall( dtype T | sized(T) ) volatile T *               ?-?(       volatile T *,          ptrdiff_t );
    208209forall( dtype T | sized(T) ) const volatile T * ?-?( const volatile T *,          ptrdiff_t );
    209210forall( dtype T | sized(T) ) ptrdiff_t          ?-?( const volatile T *, const volatile T * );
    … …  
    231232signed int ?<?( _Bool, _Bool ),                                         ?<=?( _Bool, _Bool ),
    232233           ?>?( _Bool, _Bool ),                                         ?>=?( _Bool, _Bool );
    233 signed int ?<?( char, char ),                                           ?<=?( char, char ),
    234            ?>?( char, char ),                                           ?>=?( char, char );
     234signed int ?<?( char, char ),                           ?<=?( char, char ),
     235           ?>?( char, char ),                           ?>=?( char, char );
    235236signed int ?<?( signed char, signed char ),                             ?<=?( signed char, signed char ),
    236237           ?>?( signed char, signed char ),                             ?>=?( signed char, signed char );
    … …  
    240241           ?>?( signed short, signed short ),                           ?>=?( signed short, signed short );
    241242signed int ?<?( unsigned short, unsigned short ),                       ?<=?( unsigned short, unsigned short ),
    242            ?>?( unsigned short, unsigned short ),                       ?>=?( unsigned short, unsigned short );
     243           ?>?( unsigned short, unsigned short ),                               ?>=?( unsigned short, unsigned short );
    243244signed int ?<?( signed int, signed int ),                               ?<=?( signed int, signed int ),
    244245           ?>?( signed int, signed int ),                               ?>=?( signed int, signed int );
    … …  
    473474forall( ftype FT ) FT *                 ?=?( FT * volatile &, zero_t );
    474475
    475 forall( dtype T | sized(T) ) T *                ?+=?(                T *          &, ptrdiff_t );
    476 forall( dtype T | sized(T) ) T *                ?+=?(                T * volatile &, ptrdiff_t );
     476forall( dtype T | sized(T) ) T *                        ?+=?(                T *          &, ptrdiff_t );
     477forall( dtype T | sized(T) ) T *                        ?+=?(                T * volatile &, ptrdiff_t );
    477478forall( dtype T | sized(T) ) const T *          ?+=?( const          T *          &, ptrdiff_t );
    478479forall( dtype T | sized(T) ) const T *          ?+=?( const          T * volatile &, ptrdiff_t );
    479 forall( dtype T | sized(T) ) volatile T *       ?+=?(       volatile T *          &, ptrdiff_t );
    480 forall( dtype T | sized(T) ) volatile T *       ?+=?(       volatile T * volatile &, ptrdiff_t );
     480forall( dtype T | sized(T) ) volatile T *               ?+=?(       volatile T *          &, ptrdiff_t );
     481forall( dtype T | sized(T) ) volatile T *               ?+=?(       volatile T * volatile &, ptrdiff_t );
    481482forall( dtype T | sized(T) ) const volatile T * ?+=?( const volatile T *          &, ptrdiff_t );
    482483forall( dtype T | sized(T) ) const volatile T * ?+=?( const volatile T * volatile &, ptrdiff_t );
    483 forall( dtype T | sized(T) ) T *                ?-=?(                T *          &, ptrdiff_t );
    484 forall( dtype T | sized(T) ) T *                ?-=?(                T * volatile &, ptrdiff_t );
     484forall( dtype T | sized(T) ) T *                        ?-=?(                T *          &, ptrdiff_t );
     485forall( dtype T | sized(T) ) T *                        ?-=?(                T * volatile &, ptrdiff_t );
    485486forall( dtype T | sized(T) ) const T *          ?-=?( const          T *          &, ptrdiff_t );
    486487forall( dtype T | sized(T) ) const T *          ?-=?( const          T * volatile &, ptrdiff_t );
    487 forall( dtype T | sized(T) ) volatile T *       ?-=?(       volatile T *          &, ptrdiff_t );
    488 forall( dtype T | sized(T) ) volatile T *       ?-=?(       volatile T * volatile &, ptrdiff_t );
     488forall( dtype T | sized(T) ) volatile T *               ?-=?(       volatile T *          &, ptrdiff_t );
     489forall( dtype T | sized(T) ) volatile T *               ?-=?(       volatile T * volatile &, ptrdiff_t );
    489490forall( dtype T | sized(T) ) const volatile T * ?-=?( const volatile T *          &, ptrdiff_t );
    490491forall( dtype T | sized(T) ) const volatile T * ?-=?( const volatile T * volatile &, ptrdiff_t );
    … …  
    502503signed long long int    ?=?( signed long long int &, signed long long int ),    ?=?( volatile signed long long int &, signed long long int );
    503504unsigned long long int  ?=?( unsigned long long int &, unsigned long long int ), ?=?( volatile unsigned long long int &, unsigned long long int );
    504 zero_t                  ?=?( zero_t &, zero_t );
     505zero_t          ?=?( zero_t &, zero_t );
    505506one_t                   ?=?( one_t &, one_t );
    506507
    … …  
    673674                        ?+=?( long double _Complex &, long double _Complex ), ?+=?( volatile long double _Complex &, long double _Complex ),
    674675                        ?-=?( long double _Complex &, long double _Complex ), ?-=?( volatile long double _Complex &, long double _Complex );
     676
     677
     678
    675679
    676680
    … …  
    842846forall( dtype DT ) void ^?{}( const volatile  DT *         &);
    843847
    844 void ^?{}(                  void *          &);
    845 void ^?{}( const            void *          &);
    846 void ^?{}(         volatile void *          &);
    847 void ^?{}( const  volatile void *          &);
     848void    ^?{}(               void *          &);
     849void    ^?{}( const         void *          &);
     850void    ^?{}(      volatile void *          &);
     851void    ^?{}( const volatile void *         &);
    848852
    849853// Local Variables: //

  • src/tests/boundedBuffer.c

    r4f748c5 rfde89cf6  
    1 //
    2 // The contents of this file are covered under the licence agreement in the
    3 // file "LICENCE" distributed with Cforall.
    4 //
    5 // boundedBuffer.c --
    6 //
    7 // Author           : Peter A. Buhr
    8 // Created On       : Mon Oct 30 12:45:13 2017
    9 // Last Modified By : Peter A. Buhr
    10 // Last Modified On : Mon Oct 30 23:02:46 2017
    11 // Update Count     : 9
    12 //
    13 
    141#include <stdlib>
    15 #include <fstream>                                                                              // random
     2#include <fstream>
    163#include <kernel>
    174#include <thread>
    18 #include <unistd.h>                                                                             // getpid
     5#include <unistd.h>                                     // getpid
    196
    207monitor Buffer {
    21         condition full, empty;
    22         int front, back, count;
    23         int elements[20];
     8    condition full, empty;
     9    int front, back, count;
     10    int elements[20];
    2411};
    2512
    2613void ?{}( Buffer & buffer ) {
    27         buffer.front = buffer.back = buffer.count = 0;
     14    buffer.front = buffer.back = buffer.count = 0;
    2815}
    2916
    … …  
    3118
    3219void insert( Buffer & mutex buffer, int elem ) {
    33         if ( buffer.count == 20 ) wait( &buffer.empty );
    34         buffer.elements[buffer.back] = elem;
    35         buffer.back = ( buffer.back + 1 ) % 20;
    36         buffer.count += 1;
    37         signal( &buffer.full );
     20    if ( buffer.count == 20 ) wait( &buffer.empty );
     21    buffer.elements[buffer.back] = elem;
     22    buffer.back = ( buffer.back + 1 ) % 20;
     23    buffer.count += 1;
     24    signal( &buffer.full );
    3825}
    3926int remove( Buffer & mutex buffer ) {
    40         if ( buffer.count == 0 ) wait( &buffer.full );
    41         int elem = buffer.elements[buffer.front];
    42         buffer.front = ( buffer.front + 1 ) % 20;
    43         buffer.count -= 1;
    44         signal( &buffer.empty );
    45         return elem;
     27    if ( buffer.count == 0 ) wait( &buffer.full );
     28    int elem = buffer.elements[buffer.front];
     29    buffer.front = ( buffer.front + 1 ) % 20;
     30    buffer.count -= 1;
     31    signal( &buffer.empty );
     32    return elem;
    4633}
    4734
    4835thread Producer {
    49         Buffer & buffer;
    50         unsigned int N;
     36    Buffer * buffer;
     37    unsigned int N;
    5138};
    5239void main( Producer & prod ) {
    53         for ( int i = 1; i <= prod.N; i += 1 ) {
    54                 yield( random( 5 ) );
    55                 insert( prod.buffer, 1 );
    56         } // for
    57         insert( prod.buffer, -1 );
     40    for ( int i = 1; i <= prod.N; i += 1 ) {
     41        yield( (unsigned int)rand48() % 5 );
     42        insert( *prod.buffer, 1 );
     43    } // for
     44    insert( *prod.buffer, -1 );
    5845}
    5946void ?{}( Producer & prod, Buffer * buffer, unsigned int N ) {
    60         &prod.buffer = buffer;
    61         prod.N = N;
    62                 }
     47    prod.buffer = buffer;
     48    prod.N = N;
     49}
    6350
    6451thread Consumer {
    65         Buffer & buffer;
    66         int & sum;                                              // summation of producer values
     52    Buffer * buffer;
     53    int * sum;                                          // summation of producer values
    6754};
    6855void main( Consumer & cons ) {
    69         cons.sum = 0;
    70         for ( ;; ) {
    71                 yield( random( 5 ) );
    72                 int item = remove( cons.buffer );
    73                 if ( item == -1 ) break;                                // sentinel ?
    74                 cons.sum += item;
    75         } // for
     56    *cons.sum = 0;
     57    for ( ;; ) {
     58        yield( (unsigned int)rand48() % 5 );
     59        int item = remove( *cons.buffer );
     60      if ( item == -1 ) break;                          // sentinel ?
     61        *cons.sum += item;
     62    } // for
    7663}
    7764void ?{}( Consumer & cons, Buffer * buffer, int * sum ) {
    78         &cons.buffer = buffer;
    79         &cons.sum = sum;
     65    cons.buffer = buffer;
     66    cons.sum = sum;
    8067}
    8168
    8269int main() {
    83         Buffer buffer;
    84         enum { Prods = 5, Cons = 5 };
    85         Producer * prods[Prods];
    86         Consumer * cons[Cons];
    87         const int Sentinel = -1;
    88         int sums[Cons];
    89         int i;
    90         processor p;
     70    Buffer buffer;
     71    enum { Prods = 5, Cons = 5 };
     72    Producer * prods[Prods];
     73    Consumer * cons[Cons];
     74    const int Sentinel = -1;
     75    int sums[Cons];
     76    int i;
     77    processor p;
    9178
    92         //random_seed( getpid() );
    93         random_seed( 1003 );
     79    //rand48seed( getpid() );
     80    rand48seed( 1003 );
    9481
    95         for ( i = 0; i < Cons; i += 1 ) {                       // create consumers
    96                 cons[i] = new( &buffer, &sums[i] );
    97         } // for
    98         for ( i = 0; i < Prods; i += 1 ) {                      // create producers
    99                 prods[i] = new( &buffer, 100000u );
    100         } // for
     82    for ( i = 0; i < Cons; i += 1 ) {                   // create consumers
     83        cons[i] = new( &buffer, &sums[i] );
     84    } // for
     85    for ( i = 0; i < Prods; i += 1 ) {                  // create producers
     86        prods[i] = new( &buffer, 100000u );
     87    } // for
    10188
    102         for ( i = 0; i < Prods; i += 1 ) {                      // wait for producers to finish
    103                 delete( prods[i] );
    104         } // for
    105         for ( i = 0; i < Cons; i += 1 ) {                       // generate sentinal values to stop consumers
    106                 insert( buffer, Sentinel );
    107         } // for
    108         int sum = 0;
    109         for ( i = 0; i < Cons; i += 1 ) {                       // wait for consumers to finish
    110                 delete( cons[i] );
    111                 sum += sums[i];
    112         } // for
    113         sout | "total:" | sum | endl;
     89    for ( i = 0; i < Prods; i += 1 ) {                  // wait for producers to finish
     90        delete( prods[i] );
     91    } // for
     92    for ( i = 0; i < Cons; i += 1 ) {                   // generate sentinal values to stop consumers
     93        insert( buffer, Sentinel );
     94    } // for
     95    int sum = 0;
     96    for ( i = 0; i < Cons; i += 1 ) {                   // wait for consumers to finish
     97        delete( cons[i] );
     98        sum += sums[i];
     99    } // for
     100    sout | "total:" | sum | endl;
    114101}
    115 
    116 // Local Variables: //
    117 // tab-width: 4 //
    118 // compile-command: "cfa boundedBuffer.c" //
    119 // End: //

  • src/tests/matrixSum.c

    r4f748c5 rfde89cf6  
    1111// Created On       : Mon Oct  9 08:29:28 2017
    1212// Last Modified By : Peter A. Buhr
    13 // Last Modified On : Sun Oct 29 21:08:48 2017
    14 // Update Count     : 2
     13// Last Modified On : Mon Oct  9 08:30:08 2017
     14// Update Count     : 1
    1515//
    1616
    … …  
    2020
    2121thread Adder {
    22     int * row, cols, * subtotal;                                                // communication
     22    int * row, cols, * subtotal;                        // communication
    2323};
    2424
    … …  
    3232    *adder.subtotal = 0;
    3333    for ( int c = 0; c < adder.cols; c += 1 ) {
    34                 *adder.subtotal += adder.row[c];
     34        *adder.subtotal += adder.row[c];
    3535    } // for
    3636}
    … …  
    3939    const int rows = 10, cols = 1000;
    4040    int matrix[rows][cols], subtotals[rows], total = 0;
    41     processor p;                                                                                // extra kernel thread
     41    processor p;                                        // extra kernel thread
    4242
    4343    for ( int r = 0; r < rows; r += 1 ) {
    44                 for ( int c = 0; c < cols; c += 1 ) {
    45                         matrix[r][c] = 1;
    46                 } // for
     44        for ( int c = 0; c < cols; c += 1 ) {
     45            matrix[r][c] = 1;
     46        } // for
    4747    } // for
    4848    Adder * adders[rows];
    49     for ( int r = 0; r < rows; r += 1 ) {                               // start threads to sum rows
    50                 adders[r] = &(*malloc()){ matrix[r], cols, subtotals[r] };
    51 //              adders[r] = new( matrix[r], cols, &subtotals[r] );
     49    for ( int r = 0; r < rows; r += 1 ) {               // start threads to sum rows
     50        adders[r] = &(*malloc()){ matrix[r], cols, subtotals[r] };
     51//      adders[r] = new( matrix[r], cols, &subtotals[r] );
    5252    } // for
    53     for ( int r = 0; r < rows; r += 1 ) {                               // wait for threads to finish
    54                 delete( adders[r] );
    55                 total += subtotals[r];                                                  // total subtotals
     53    for ( int r = 0; r < rows; r += 1 ) {               // wait for threads to finish
     54        delete( adders[r] );
     55        total += subtotals[r];                          // total subtotals
    5656    } // for
    5757    sout | total | endl;

  • src/tests/prodcons.c

    r4f748c5 rfde89cf6  
    1010// Created On       : Mon Sep 18 12:23:39 2017
    1111// Last Modified By : Peter A. Buhr
    12 // Last Modified On : Mon Oct 30 23:06:05 2017
    13 // Update Count     : 42
     12// Last Modified On : Wed Sep 20 17:03:28 2017
     13// Update Count     : 40
    1414//
    1515
    1616#include <fstream>
    1717#include <coroutine>
    18 #include <stdlib>                                                                               // random
     18#include <stdlib>                                                                               // rand48
    1919#include <unistd.h>                                                                             // getpid
    2020
    … …  
    3030        // 1st resume starts here
    3131        for ( int i = 0; i < prod.N; i += 1 ) {
    32                 int p1 = random( 100 );
    33                 int p2 = random( 100 );
     32                int p1 = (unsigned int)rand48() % 100;                  // non-negative
     33                int p2 = (unsigned int)rand48() % 100;
    3434                sout | p1 | " " | p2 | endl;
    3535                int status = delivery( *prod.c, p1, p2 );
    … …  
    9090        Prod prod;
    9191        Cons cons = { prod };
    92         random_seed( /* getpid() */ 103 );                                      // fixed seed for testing
     92        rand48seed( /* getpid() */ 103 );                                       // fixed seed for testing
    9393        start( prod, 5, cons );
    9494        sout | "main stops" | endl;

  • src/tests/random.c

    r4f748c5 rfde89cf6  
    1010// Created On       : Tue Jul  5 21:29:30 2016
    1111// Last Modified By : Peter A. Buhr
    12 // Last Modified On : Mon Oct 30 23:06:49 2017
    13 // Update Count     : 6
     12// Last Modified On : Wed Jul  6 18:00:29 2016
     13// Update Count     : 3
    1414//
    1515
    … …  
    1919
    2020int main() {
    21         //srandom( getpid() );                                                          // set random seed
    22         random_seed( 1003 );                                                            // fixed seed for repeatable tests
     21        //rand48seed( getpid() );                                                               // set random seed
     22        rand48seed( 1003 );                                                                     // fixed seed for repeatable tests
    2323
    2424        // test polymorphic calls to random and stream
    25         char c = random();
     25        char c = rand48();
    2626        sout | c | endl;
    27         int i = random();
     27        int i = rand48();
    2828    sout | i | endl;
    29         unsigned int ui = random();
     29        unsigned int ui = rand48();
    3030    sout | ui | endl;
    31         long int li = random();
     31        long int li = rand48();
    3232    sout | li | endl;
    33         unsigned long int uli = random();
     33        unsigned long int uli = rand48();
    3434    sout | uli | endl;
    35     float f = random();
     35    float f = rand48();
    3636    sout | f | endl;
    37     double d = random();
     37    double d = rand48();
    3838    sout | d | endl;
    39     float _Complex fc = random();
     39    float _Complex fc = rand48();
    4040    sout | fc | endl;
    41     double _Complex dc = random();
     41    double _Complex dc = rand48();
    4242    sout | dc | endl;
    43     long double _Complex ldc = random();
     43    long double _Complex ldc = rand48();
    4444    sout | ldc | endl;
    4545} // main

  • src/tests/rational.c

    r4f748c5 rfde89cf6  
    1010// Created On       : Mon Mar 28 08:43:12 2016
    1111// Last Modified By : Peter A. Buhr
    12 // Last Modified On : Tue Oct 10 23:25:04 2017
    13 // Update Count     : 67
     12// Last Modified On : Wed Aug 23 21:40:11 2017
     13// Update Count     : 66
    1414//
    1515

  • src/tests/sched-ext-barge.c

    r4f748c5 rfde89cf6  
    4242void main( barger_t & this ) {
    4343        yield();
    44         while( barge( global ) ) { yield(random( 10 )); }
     44        while( barge( global ) ) { yield(((unsigned)rand48()) % 10); }
    4545}
    4646
    4747bool do_call( global_t & mutex this ) {
    48         yield(random( 10 ));
     48        yield(((unsigned)rand48()) % 10);
    4949        if( this.state != WAITFOR && !this.done && this.started ) {
    5050                serr | "Barging before caller detected" | endl;
    … …  
    5757thread caller_t {};
    5858void main( caller_t & this ) {
    59         while( do_call(global) ) { yield(random( 10 )); }
     59        while( do_call(global) ) { yield(((unsigned)rand48()) % 10); }
    6060}
    6161
    … …  
    6363        this.started = true;
    6464        for( int i = 0; i < N; i++) {
    65                 yield(random( 10 ));
     65                yield(((unsigned)rand48()) % 10);
    6666                this.state = WAITFOR;
    6767                waitfor(do_call, this) {

  • src/tests/sched-ext-dtor.c

    r4f748c5 rfde89cf6  
    4545
    4646void main( dummy_t & this ) {
    47         yield(random( 10 ));
     47        yield(((unsigned)rand48()) % 10);
    4848        set_state( this, MAIN );
    4949        waitfor( ^?{}, this ) {
    … …  
    5858        for( int i = 0; i < N; i++ ){
    5959                dummy_t dummy[4];
    60                 yield( random( 100 ) );
     60                yield( ((unsigned)rand48()) % 100 );
    6161        }
    6262        sout | "Stopping" | endl;

  • src/tests/sched-ext-recurse.c

    r4f748c5 rfde89cf6  
    1515static const unsigned long N = 5_000ul;
    1616
    17 static inline void rand_yield() { yield(random( 10 )); }
     17static inline void rand_yield() { yield(((unsigned)rand48()) % 10); }
    1818
    1919enum state_t { FIRST, SECOND, THIRD, LAST, STOP };
    … …  
    2323        for (i = 0; i < 4; i++)
    2424        {
    25                 int j = random( 4 );
     25                int j = ((unsigned)rand48()) % 4;
    2626                enum state_t t = array[j];
    2727                array[j] = array[i];
    … …  
    131131
    132132int main() {
    133         random_seed( time(NULL) );
     133        rand48seed( time(NULL) );
    134134        sout | "Starting" | endl;
    135135        {

  • src/tests/sched-ext-when.c

    r4f748c5 rfde89cf6  
    1515static const unsigned long N = 4_998ul;
    1616
    17 static inline void rand_yield() { yield(random( 10 )); }
     17static inline void rand_yield() { yield(((unsigned)rand48()) % 10); }
    1818
    1919monitor global_t {
    … …  
    7777
    7878int main() {
    79         random_seed( time(NULL) );
     79        rand48seed( time(NULL) );
    8080        sout | "Starting" | endl;
    8181        {

  • src/tests/sched-ext.c

    r4f748c5 rfde89cf6  
    2626volatile bool done;
    2727
     28unsigned rand10() {
     29        return (unsigned)rand48() % 10;
     30}
     31
    2832//----------------------------------------------------------------------------------------------------
    2933// Acceptor
    … …  
    3236void do_wait( global_t * mutex a ) {
    3337        sout | "Waiting to accept" | endl;
    34         yield( random( 10 ) );
     38        yield( rand10() );
    3539
    3640        sout | "Accepting" | endl;
    … …  
    4448
    4549        sout | "Accepted" | endl;
    46         yield( random( 10 ) );
     50        yield( rand10() );
    4751}
    4852
    … …  
    6468void main( Acceptee* this ) {
    6569        while( !done ) {
    66                 yield( random( 10 ) );
     70                yield( rand10() );
    6771                do_notify( &globalA );
    68                 yield( random( 10 ) );
     72                yield( rand10() );
    6973        }
    7074}
    … …  
    7478int main(int argc, char* argv[]) {
    7579        done = false;
    76         random_seed( time( NULL ) );
     80        rand48seed( time( NULL ) );
    7781        printf("%p\n", &globalA);
    7882        sout | "Starting" | endl;

  • src/tests/sched-int-barge.c

    r4f748c5 rfde89cf6  
    6464
    6565        if( action == 0 ) {
    66                 c.do_signal = max( random( 10 ), 1);
    67                 c.do_wait1 = random( c.do_signal );
    68                 c.do_wait2 = random( c.do_signal );
     66                c.do_signal = max( ((unsigned)rand48()) % 10, 1);
     67                c.do_wait1 = ((unsigned)rand48()) % (c.do_signal);
     68                c.do_wait2 = ((unsigned)rand48()) % (c.do_signal);
    6969
    7070                if(c.do_wait1 == c.do_wait2) sout | "Same" | endl;
    … …  
    109109
    110110int main(int argc, char* argv[]) {
    111         random_seed(0);
     111        rand48seed(0);
    112112        processor p;
    113113        {

  • src/tests/sched-int-block.c

    r4f748c5 rfde89cf6  
    4949        wait( &cond, (uintptr_t)this_thread );
    5050
    51         yield( random( 10 ) );
     51        yield( ((unsigned)rand48()) % 10 );
    5252
    5353        if(a.last_thread != a.last_signaller || b.last_thread != b.last_signaller ) {
    … …  
    5858        a.last_thread = b.last_thread = this_thread;
    5959
    60         yield( random( 10 ) );
     60        yield( ((unsigned)rand48()) % 10 );
    6161}
    6262
    … …  
    7070//------------------------------------------------------------------------------
    7171void signal_op( global_data_t & mutex a, global_data_t & mutex b ) {
    72         yield( random( 10 ) );
     72        yield( ((unsigned)rand48()) % 10 );
    7373
    7474        [a.last_thread, b.last_thread, a.last_signaller, b.last_signaller] = this_thread;
    … …  
    8383                }
    8484
    85                 yield( random( 10 ) );
     85                yield( ((unsigned)rand48()) % 10 );
    8686
    8787                if(a.last_thread != next || b.last_thread != next) {
    … …  
    118118
    119119int main(int argc, char* argv[]) {
    120         random_seed( time( NULL ) );
     120        rand48seed( time( NULL ) );
    121121        done = false;
    122122        processor p;

  • src/tests/sched-int-disjoint.c

    r4f748c5 rfde89cf6  
    8888        signal( &cond, a, data );
    8989
    90         yield( random( 10 ) );
     90        yield( (unsigned)rand48() % 10 );
    9191
    9292        //This is technically a mutual exclusion violation but the mutex monitor protects us
    … …  
    109109// Main loop
    110110int main(int argc, char* argv[]) {
    111         random_seed( time( NULL ) );
     111        rand48seed( time( NULL ) );
    112112        all_done = false;
    113113        processor p;

  • src/tests/sched-int-wait.c

    r4f748c5 rfde89cf6  
    6262
    6363        while( waiter_left != 0 ) {
    64                 unsigned action = random( 4 );
     64                unsigned action = (unsigned)rand48() % 4;
    6565                switch( action ) {
    6666                        case 0:
    … …  
    127127// Main
    128128int main(int argc, char* argv[]) {
    129         random_seed( time( NULL ) );
     129        rand48seed( time( NULL ) );
    130130        waiter_left = 4;
    131131        processor p[2];
Note: See TracChangeset for help on using the changeset viewer.