Changes in / [68e6031:1ab7d3fe]
- Files:
-
- 6 deleted
- 8 edited
Legend:
- Unmodified
- Added
- Removed
-
src/GenPoly/GenPoly.cc
r68e6031 r1ab7d3fe 28 28 for ( std::list< Expression* >::iterator param = params.begin(); param != params.end(); ++param ) { 29 29 TypeExpr *paramType = dynamic_cast< TypeExpr* >( *param ); 30 assert f(paramType,"Aggregate parameters should be type expressions");30 assert(paramType && "Aggregate parameters should be type expressions"); 31 31 if ( isPolyType( paramType->get_type(), env ) ) return true; 32 32 } -
src/libcfa/Makefile.am
r68e6031 r1ab7d3fe 40 40 CC = ${abs_top_srcdir}/src/driver/cfa 41 41 42 headers = limits stdlib math iostream fstream iterator rational assert containers/vector concurrency/ coroutines concurrency/threads concurrency/kernel42 headers = limits stdlib math iostream fstream iterator rational assert containers/vector concurrency/threads 43 43 runtimehdrs = concurrency 44 44 libobjs = ${headers:=.o} -
src/libcfa/Makefile.in
r68e6031 r1ab7d3fe 98 98 libcfa_d_a-assert.$(OBJEXT) \ 99 99 containers/libcfa_d_a-vector.$(OBJEXT) \ 100 concurrency/libcfa_d_a-coroutines.$(OBJEXT) \ 101 concurrency/libcfa_d_a-threads.$(OBJEXT) \ 102 concurrency/libcfa_d_a-kernel.$(OBJEXT) 100 concurrency/libcfa_d_a-threads.$(OBJEXT) 103 101 am__objects_2 = libcfa_d_a-libcfa-prelude.$(OBJEXT) $(am__objects_1) \ 104 102 concurrency/CtxSwitch-@MACHINE_TYPE@.$(OBJEXT) \ … … 113 111 libcfa_a-rational.$(OBJEXT) libcfa_a-assert.$(OBJEXT) \ 114 112 containers/libcfa_a-vector.$(OBJEXT) \ 115 concurrency/libcfa_a-coroutines.$(OBJEXT) \ 116 concurrency/libcfa_a-threads.$(OBJEXT) \ 117 concurrency/libcfa_a-kernel.$(OBJEXT) 113 concurrency/libcfa_a-threads.$(OBJEXT) 118 114 am__objects_4 = libcfa_a-libcfa-prelude.$(OBJEXT) $(am__objects_3) \ 119 115 concurrency/CtxSwitch-@MACHINE_TYPE@.$(OBJEXT) \ … … 276 272 EXTRA_FLAGS = -g -Wall -Wno-unused-function -I${abs_top_srcdir}/src/libcfa/libhdr -imacros libcfa-prelude.c @CFA_FLAGS@ 277 273 AM_CCASFLAGS = @CFA_FLAGS@ 278 headers = limits stdlib math iostream fstream iterator rational assert containers/vector concurrency/ coroutines concurrency/threads concurrency/kernel274 headers = limits stdlib math iostream fstream iterator rational assert containers/vector concurrency/threads 279 275 runtimehdrs = concurrency 280 276 libobjs = ${headers:=.o} … … 366 362 @$(MKDIR_P) concurrency/$(DEPDIR) 367 363 @: > concurrency/$(DEPDIR)/$(am__dirstamp) 368 concurrency/libcfa_d_a-coroutines.$(OBJEXT): \369 concurrency/$(am__dirstamp) \370 concurrency/$(DEPDIR)/$(am__dirstamp)371 364 concurrency/libcfa_d_a-threads.$(OBJEXT): concurrency/$(am__dirstamp) \ 372 concurrency/$(DEPDIR)/$(am__dirstamp)373 concurrency/libcfa_d_a-kernel.$(OBJEXT): concurrency/$(am__dirstamp) \374 365 concurrency/$(DEPDIR)/$(am__dirstamp) 375 366 concurrency/CtxSwitch-@MACHINE_TYPE@.$(OBJEXT): \ … … 384 375 containers/libcfa_a-vector.$(OBJEXT): containers/$(am__dirstamp) \ 385 376 containers/$(DEPDIR)/$(am__dirstamp) 386 concurrency/libcfa_a-coroutines.$(OBJEXT): \387 concurrency/$(am__dirstamp) \388 concurrency/$(DEPDIR)/$(am__dirstamp)389 377 concurrency/libcfa_a-threads.$(OBJEXT): concurrency/$(am__dirstamp) \ 390 concurrency/$(DEPDIR)/$(am__dirstamp)391 concurrency/libcfa_a-kernel.$(OBJEXT): concurrency/$(am__dirstamp) \392 378 concurrency/$(DEPDIR)/$(am__dirstamp) 393 379 concurrency/libcfa_a-invoke.$(OBJEXT): concurrency/$(am__dirstamp) \ … … 401 387 -rm -f *.$(OBJEXT) 402 388 -rm -f concurrency/CtxSwitch-@MACHINE_TYPE@.$(OBJEXT) 403 -rm -f concurrency/libcfa_a-coroutines.$(OBJEXT)404 389 -rm -f concurrency/libcfa_a-invoke.$(OBJEXT) 405 -rm -f concurrency/libcfa_a-kernel.$(OBJEXT)406 390 -rm -f concurrency/libcfa_a-threads.$(OBJEXT) 407 -rm -f concurrency/libcfa_d_a-coroutines.$(OBJEXT)408 391 -rm -f concurrency/libcfa_d_a-invoke.$(OBJEXT) 409 -rm -f concurrency/libcfa_d_a-kernel.$(OBJEXT)410 392 -rm -f concurrency/libcfa_d_a-threads.$(OBJEXT) 411 393 -rm -f containers/libcfa_a-vector.$(OBJEXT) … … 434 416 @AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/libcfa_d_a-stdlib.Po@am__quote@ 435 417 @AMDEP_TRUE@@am__include@ @am__quote@concurrency/$(DEPDIR)/CtxSwitch-@MACHINE_TYPE@.Po@am__quote@ 436 @AMDEP_TRUE@@am__include@ @am__quote@concurrency/$(DEPDIR)/libcfa_a-coroutines.Po@am__quote@437 418 @AMDEP_TRUE@@am__include@ @am__quote@concurrency/$(DEPDIR)/libcfa_a-invoke.Po@am__quote@ 438 @AMDEP_TRUE@@am__include@ @am__quote@concurrency/$(DEPDIR)/libcfa_a-kernel.Po@am__quote@439 419 @AMDEP_TRUE@@am__include@ @am__quote@concurrency/$(DEPDIR)/libcfa_a-threads.Po@am__quote@ 440 @AMDEP_TRUE@@am__include@ @am__quote@concurrency/$(DEPDIR)/libcfa_d_a-coroutines.Po@am__quote@441 420 @AMDEP_TRUE@@am__include@ @am__quote@concurrency/$(DEPDIR)/libcfa_d_a-invoke.Po@am__quote@ 442 @AMDEP_TRUE@@am__include@ @am__quote@concurrency/$(DEPDIR)/libcfa_d_a-kernel.Po@am__quote@443 421 @AMDEP_TRUE@@am__include@ @am__quote@concurrency/$(DEPDIR)/libcfa_d_a-threads.Po@am__quote@ 444 422 @AMDEP_TRUE@@am__include@ @am__quote@containers/$(DEPDIR)/libcfa_a-vector.Po@am__quote@ … … 610 588 @am__fastdepCC_FALSE@ $(AM_V_CC@am__nodep@)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_d_a_CFLAGS) $(CFLAGS) -c -o containers/libcfa_d_a-vector.obj `if test -f 'containers/vector.c'; then $(CYGPATH_W) 'containers/vector.c'; else $(CYGPATH_W) '$(srcdir)/containers/vector.c'; fi` 611 589 612 concurrency/libcfa_d_a-coroutines.o: concurrency/coroutines.c613 @am__fastdepCC_TRUE@ $(AM_V_CC)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_d_a_CFLAGS) $(CFLAGS) -MT concurrency/libcfa_d_a-coroutines.o -MD -MP -MF concurrency/$(DEPDIR)/libcfa_d_a-coroutines.Tpo -c -o concurrency/libcfa_d_a-coroutines.o `test -f 'concurrency/coroutines.c' || echo '$(srcdir)/'`concurrency/coroutines.c614 @am__fastdepCC_TRUE@ $(AM_V_at)$(am__mv) concurrency/$(DEPDIR)/libcfa_d_a-coroutines.Tpo concurrency/$(DEPDIR)/libcfa_d_a-coroutines.Po615 @AMDEP_TRUE@@am__fastdepCC_FALSE@ $(AM_V_CC)source='concurrency/coroutines.c' object='concurrency/libcfa_d_a-coroutines.o' libtool=no @AMDEPBACKSLASH@616 @AMDEP_TRUE@@am__fastdepCC_FALSE@ DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@617 @am__fastdepCC_FALSE@ $(AM_V_CC@am__nodep@)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_d_a_CFLAGS) $(CFLAGS) -c -o concurrency/libcfa_d_a-coroutines.o `test -f 'concurrency/coroutines.c' || echo '$(srcdir)/'`concurrency/coroutines.c618 619 concurrency/libcfa_d_a-coroutines.obj: concurrency/coroutines.c620 @am__fastdepCC_TRUE@ $(AM_V_CC)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_d_a_CFLAGS) $(CFLAGS) -MT concurrency/libcfa_d_a-coroutines.obj -MD -MP -MF concurrency/$(DEPDIR)/libcfa_d_a-coroutines.Tpo -c -o concurrency/libcfa_d_a-coroutines.obj `if test -f 'concurrency/coroutines.c'; then $(CYGPATH_W) 'concurrency/coroutines.c'; else $(CYGPATH_W) '$(srcdir)/concurrency/coroutines.c'; fi`621 @am__fastdepCC_TRUE@ $(AM_V_at)$(am__mv) concurrency/$(DEPDIR)/libcfa_d_a-coroutines.Tpo concurrency/$(DEPDIR)/libcfa_d_a-coroutines.Po622 @AMDEP_TRUE@@am__fastdepCC_FALSE@ $(AM_V_CC)source='concurrency/coroutines.c' object='concurrency/libcfa_d_a-coroutines.obj' libtool=no @AMDEPBACKSLASH@623 @AMDEP_TRUE@@am__fastdepCC_FALSE@ DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@624 @am__fastdepCC_FALSE@ $(AM_V_CC@am__nodep@)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_d_a_CFLAGS) $(CFLAGS) -c -o concurrency/libcfa_d_a-coroutines.obj `if test -f 'concurrency/coroutines.c'; then $(CYGPATH_W) 'concurrency/coroutines.c'; else $(CYGPATH_W) '$(srcdir)/concurrency/coroutines.c'; fi`625 626 590 concurrency/libcfa_d_a-threads.o: concurrency/threads.c 627 591 @am__fastdepCC_TRUE@ $(AM_V_CC)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_d_a_CFLAGS) $(CFLAGS) -MT concurrency/libcfa_d_a-threads.o -MD -MP -MF concurrency/$(DEPDIR)/libcfa_d_a-threads.Tpo -c -o concurrency/libcfa_d_a-threads.o `test -f 'concurrency/threads.c' || echo '$(srcdir)/'`concurrency/threads.c … … 638 602 @am__fastdepCC_FALSE@ $(AM_V_CC@am__nodep@)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_d_a_CFLAGS) $(CFLAGS) -c -o concurrency/libcfa_d_a-threads.obj `if test -f 'concurrency/threads.c'; then $(CYGPATH_W) 'concurrency/threads.c'; else $(CYGPATH_W) '$(srcdir)/concurrency/threads.c'; fi` 639 603 640 concurrency/libcfa_d_a-kernel.o: concurrency/kernel.c641 @am__fastdepCC_TRUE@ $(AM_V_CC)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_d_a_CFLAGS) $(CFLAGS) -MT concurrency/libcfa_d_a-kernel.o -MD -MP -MF concurrency/$(DEPDIR)/libcfa_d_a-kernel.Tpo -c -o concurrency/libcfa_d_a-kernel.o `test -f 'concurrency/kernel.c' || echo '$(srcdir)/'`concurrency/kernel.c642 @am__fastdepCC_TRUE@ $(AM_V_at)$(am__mv) concurrency/$(DEPDIR)/libcfa_d_a-kernel.Tpo concurrency/$(DEPDIR)/libcfa_d_a-kernel.Po643 @AMDEP_TRUE@@am__fastdepCC_FALSE@ $(AM_V_CC)source='concurrency/kernel.c' object='concurrency/libcfa_d_a-kernel.o' libtool=no @AMDEPBACKSLASH@644 @AMDEP_TRUE@@am__fastdepCC_FALSE@ DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@645 @am__fastdepCC_FALSE@ $(AM_V_CC@am__nodep@)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_d_a_CFLAGS) $(CFLAGS) -c -o concurrency/libcfa_d_a-kernel.o `test -f 'concurrency/kernel.c' || echo '$(srcdir)/'`concurrency/kernel.c646 647 concurrency/libcfa_d_a-kernel.obj: concurrency/kernel.c648 @am__fastdepCC_TRUE@ $(AM_V_CC)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_d_a_CFLAGS) $(CFLAGS) -MT concurrency/libcfa_d_a-kernel.obj -MD -MP -MF concurrency/$(DEPDIR)/libcfa_d_a-kernel.Tpo -c -o concurrency/libcfa_d_a-kernel.obj `if test -f 'concurrency/kernel.c'; then $(CYGPATH_W) 'concurrency/kernel.c'; else $(CYGPATH_W) '$(srcdir)/concurrency/kernel.c'; fi`649 @am__fastdepCC_TRUE@ $(AM_V_at)$(am__mv) concurrency/$(DEPDIR)/libcfa_d_a-kernel.Tpo concurrency/$(DEPDIR)/libcfa_d_a-kernel.Po650 @AMDEP_TRUE@@am__fastdepCC_FALSE@ $(AM_V_CC)source='concurrency/kernel.c' object='concurrency/libcfa_d_a-kernel.obj' libtool=no @AMDEPBACKSLASH@651 @AMDEP_TRUE@@am__fastdepCC_FALSE@ DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@652 @am__fastdepCC_FALSE@ $(AM_V_CC@am__nodep@)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_d_a_CFLAGS) $(CFLAGS) -c -o concurrency/libcfa_d_a-kernel.obj `if test -f 'concurrency/kernel.c'; then $(CYGPATH_W) 'concurrency/kernel.c'; else $(CYGPATH_W) '$(srcdir)/concurrency/kernel.c'; fi`653 654 604 concurrency/libcfa_d_a-invoke.obj: concurrency/invoke.c 655 605 @am__fastdepCC_TRUE@ $(AM_V_CC)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_d_a_CFLAGS) $(CFLAGS) -MT concurrency/libcfa_d_a-invoke.obj -MD -MP -MF concurrency/$(DEPDIR)/libcfa_d_a-invoke.Tpo -c -o concurrency/libcfa_d_a-invoke.obj `if test -f 'concurrency/invoke.c'; then $(CYGPATH_W) 'concurrency/invoke.c'; else $(CYGPATH_W) '$(srcdir)/concurrency/invoke.c'; fi` … … 792 742 @am__fastdepCC_FALSE@ $(AM_V_CC@am__nodep@)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_a_CFLAGS) $(CFLAGS) -c -o containers/libcfa_a-vector.obj `if test -f 'containers/vector.c'; then $(CYGPATH_W) 'containers/vector.c'; else $(CYGPATH_W) '$(srcdir)/containers/vector.c'; fi` 793 743 794 concurrency/libcfa_a-coroutines.o: concurrency/coroutines.c795 @am__fastdepCC_TRUE@ $(AM_V_CC)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_a_CFLAGS) $(CFLAGS) -MT concurrency/libcfa_a-coroutines.o -MD -MP -MF concurrency/$(DEPDIR)/libcfa_a-coroutines.Tpo -c -o concurrency/libcfa_a-coroutines.o `test -f 'concurrency/coroutines.c' || echo '$(srcdir)/'`concurrency/coroutines.c796 @am__fastdepCC_TRUE@ $(AM_V_at)$(am__mv) concurrency/$(DEPDIR)/libcfa_a-coroutines.Tpo concurrency/$(DEPDIR)/libcfa_a-coroutines.Po797 @AMDEP_TRUE@@am__fastdepCC_FALSE@ $(AM_V_CC)source='concurrency/coroutines.c' object='concurrency/libcfa_a-coroutines.o' libtool=no @AMDEPBACKSLASH@798 @AMDEP_TRUE@@am__fastdepCC_FALSE@ DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@799 @am__fastdepCC_FALSE@ $(AM_V_CC@am__nodep@)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_a_CFLAGS) $(CFLAGS) -c -o concurrency/libcfa_a-coroutines.o `test -f 'concurrency/coroutines.c' || echo '$(srcdir)/'`concurrency/coroutines.c800 801 concurrency/libcfa_a-coroutines.obj: concurrency/coroutines.c802 @am__fastdepCC_TRUE@ $(AM_V_CC)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_a_CFLAGS) $(CFLAGS) -MT concurrency/libcfa_a-coroutines.obj -MD -MP -MF concurrency/$(DEPDIR)/libcfa_a-coroutines.Tpo -c -o concurrency/libcfa_a-coroutines.obj `if test -f 'concurrency/coroutines.c'; then $(CYGPATH_W) 'concurrency/coroutines.c'; else $(CYGPATH_W) '$(srcdir)/concurrency/coroutines.c'; fi`803 @am__fastdepCC_TRUE@ $(AM_V_at)$(am__mv) concurrency/$(DEPDIR)/libcfa_a-coroutines.Tpo concurrency/$(DEPDIR)/libcfa_a-coroutines.Po804 @AMDEP_TRUE@@am__fastdepCC_FALSE@ $(AM_V_CC)source='concurrency/coroutines.c' object='concurrency/libcfa_a-coroutines.obj' libtool=no @AMDEPBACKSLASH@805 @AMDEP_TRUE@@am__fastdepCC_FALSE@ DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@806 @am__fastdepCC_FALSE@ $(AM_V_CC@am__nodep@)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_a_CFLAGS) $(CFLAGS) -c -o concurrency/libcfa_a-coroutines.obj `if test -f 'concurrency/coroutines.c'; then $(CYGPATH_W) 'concurrency/coroutines.c'; else $(CYGPATH_W) '$(srcdir)/concurrency/coroutines.c'; fi`807 808 744 concurrency/libcfa_a-threads.o: concurrency/threads.c 809 745 @am__fastdepCC_TRUE@ $(AM_V_CC)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_a_CFLAGS) $(CFLAGS) -MT concurrency/libcfa_a-threads.o -MD -MP -MF concurrency/$(DEPDIR)/libcfa_a-threads.Tpo -c -o concurrency/libcfa_a-threads.o `test -f 'concurrency/threads.c' || echo '$(srcdir)/'`concurrency/threads.c … … 819 755 @AMDEP_TRUE@@am__fastdepCC_FALSE@ DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@ 820 756 @am__fastdepCC_FALSE@ $(AM_V_CC@am__nodep@)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_a_CFLAGS) $(CFLAGS) -c -o concurrency/libcfa_a-threads.obj `if test -f 'concurrency/threads.c'; then $(CYGPATH_W) 'concurrency/threads.c'; else $(CYGPATH_W) '$(srcdir)/concurrency/threads.c'; fi` 821 822 concurrency/libcfa_a-kernel.o: concurrency/kernel.c823 @am__fastdepCC_TRUE@ $(AM_V_CC)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_a_CFLAGS) $(CFLAGS) -MT concurrency/libcfa_a-kernel.o -MD -MP -MF concurrency/$(DEPDIR)/libcfa_a-kernel.Tpo -c -o concurrency/libcfa_a-kernel.o `test -f 'concurrency/kernel.c' || echo '$(srcdir)/'`concurrency/kernel.c824 @am__fastdepCC_TRUE@ $(AM_V_at)$(am__mv) concurrency/$(DEPDIR)/libcfa_a-kernel.Tpo concurrency/$(DEPDIR)/libcfa_a-kernel.Po825 @AMDEP_TRUE@@am__fastdepCC_FALSE@ $(AM_V_CC)source='concurrency/kernel.c' object='concurrency/libcfa_a-kernel.o' libtool=no @AMDEPBACKSLASH@826 @AMDEP_TRUE@@am__fastdepCC_FALSE@ DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@827 @am__fastdepCC_FALSE@ $(AM_V_CC@am__nodep@)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_a_CFLAGS) $(CFLAGS) -c -o concurrency/libcfa_a-kernel.o `test -f 'concurrency/kernel.c' || echo '$(srcdir)/'`concurrency/kernel.c828 829 concurrency/libcfa_a-kernel.obj: concurrency/kernel.c830 @am__fastdepCC_TRUE@ $(AM_V_CC)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_a_CFLAGS) $(CFLAGS) -MT concurrency/libcfa_a-kernel.obj -MD -MP -MF concurrency/$(DEPDIR)/libcfa_a-kernel.Tpo -c -o concurrency/libcfa_a-kernel.obj `if test -f 'concurrency/kernel.c'; then $(CYGPATH_W) 'concurrency/kernel.c'; else $(CYGPATH_W) '$(srcdir)/concurrency/kernel.c'; fi`831 @am__fastdepCC_TRUE@ $(AM_V_at)$(am__mv) concurrency/$(DEPDIR)/libcfa_a-kernel.Tpo concurrency/$(DEPDIR)/libcfa_a-kernel.Po832 @AMDEP_TRUE@@am__fastdepCC_FALSE@ $(AM_V_CC)source='concurrency/kernel.c' object='concurrency/libcfa_a-kernel.obj' libtool=no @AMDEPBACKSLASH@833 @AMDEP_TRUE@@am__fastdepCC_FALSE@ DEPDIR=$(DEPDIR) $(CCDEPMODE) $(depcomp) @AMDEPBACKSLASH@834 @am__fastdepCC_FALSE@ $(AM_V_CC@am__nodep@)$(CC) $(DEFS) $(DEFAULT_INCLUDES) $(INCLUDES) $(AM_CPPFLAGS) $(CPPFLAGS) $(libcfa_a_CFLAGS) $(CFLAGS) -c -o concurrency/libcfa_a-kernel.obj `if test -f 'concurrency/kernel.c'; then $(CYGPATH_W) 'concurrency/kernel.c'; else $(CYGPATH_W) '$(srcdir)/concurrency/kernel.c'; fi`835 757 836 758 concurrency/libcfa_a-invoke.obj: concurrency/invoke.c -
src/libcfa/concurrency/invoke.c
r68e6031 r1ab7d3fe 14 14 15 15 extern void __suspend_no_inline__F___1(void); 16 extern void __scheduler_remove__F_P9sthread_h__1(struct thread_h*);17 16 18 17 void CtxInvokeCoroutine( … … 21 20 void *this 22 21 ) { 23 // LIB_DEBUG_PRINTF("Invoke Coroutine : Received %p (main %p, get_c %p)\n", this, main, get_coroutine);22 LIB_DEBUG_PRINTF("Invoke : Received %p (main %p, get_c %p)\n", this, main, get_coroutine); 24 23 25 24 struct coroutine* cor = get_coroutine( this ); … … 32 31 33 32 main( this ); 34 35 //Final suspend, should never return36 __suspend_no_inline__F___1();37 assertf(false, "Resumed dead coroutine");38 }39 40 void CtxInvokeThread(41 void (*main)(void *),42 struct thread_h *(*get_thread)(void *),43 void *this44 ) {45 // LIB_DEBUG_PRINTF("Invoke Thread : Received %p (main %p, get_t %p)\n", this, main, get_thread);46 47 __suspend_no_inline__F___1();48 49 struct thread_h* thrd = get_thread( this );50 struct coroutine* cor = &thrd->c;51 cor->state = Active;52 53 // LIB_DEBUG_PRINTF("Invoke Thread : invoking main %p (args %p)\n", main, this);54 main( this );55 56 __scheduler_remove__F_P9sthread_h__1(thrd);57 58 //Final suspend, should never return59 __suspend_no_inline__F___1();60 assertf(false, "Resumed dead thread");61 33 } 62 34 … … 68 40 void (*invoke)(void *) 69 41 ) { 70 // LIB_DEBUG_PRINTF("StartCoroutine : Passing in %p (main %p) to invoke (%p) from start (%p)\n", this, main, invoke, CtxStart);42 LIB_DEBUG_PRINTF("StartCoroutine : Passing in %p (main %p, get_c %p) to %p\n", this, main, get_coroutine, invoke); 71 43 72 44 struct coStack_t* stack = &get_coroutine( this )->stack; -
src/libcfa/concurrency/invoke.h
r68e6031 r1ab7d3fe 35 35 }; 36 36 37 struct thread_h {38 struct coroutine c;39 };40 41 37 #endif //_INVOKE_H_ 42 38 #else //! defined(__CFA_INVOKE_PRIVATE__) -
src/libcfa/concurrency/threads
r68e6031 r1ab7d3fe 9 9 // 10 10 // Author : Thierry Delisle 11 // Created On : Tue Jan 1712:27:26 201611 // Created On : Mon Nov 28 12:27:26 2016 12 12 // Last Modified By : Thierry Delisle 13 // Last Modified On : --13 // Last Modified On : Mon Nov 28 12:27:26 2016 14 14 // Update Count : 0 15 15 // … … 18 18 #define THREADS_H 19 19 20 #include "assert" 20 #include "assert" // 21 21 #include "invoke.h" 22 23 #include "coroutines"24 22 25 23 //----------------------------------------------------------------------------- … … 27 25 // Anything that implements this trait can be resumed. 28 26 // Anything that is resumed is a coroutine. 29 trait is_thread(dtype T /*| sized(T)*/) { 30 void main(T* this); 31 thread_h* get_thread(T* this); 32 /*void ?{}(T*); 33 void ^?{}(T*);*/ 27 trait is_coroutine(dtype T) { 28 void co_main(T* this); 29 coroutine* get_coroutine(T* this); 34 30 }; 35 36 forall(otype T | is_thread(T) )37 static inline coroutine* get_coroutine(T* this) {38 return &get_thread(this)->c;39 }40 41 static inline coroutine* get_coroutine(thread_h* this) {42 return &this->c;43 }44 31 45 32 //----------------------------------------------------------------------------- 46 33 // Ctors and dtors 47 void ?{}(thread_h* this); 48 void ^?{}(thread_h* this); 34 void ?{}(coStack_t* this); 35 void ?{}(coroutine* this); 36 void ^?{}(coStack_t* this); 37 void ^?{}(coroutine* this); 49 38 50 39 //----------------------------------------------------------------------------- 51 // thread runner 52 // Structure that actually start and stop threads 53 forall(otype T | is_thread(T) ) 54 struct thread { 55 T handle; 56 }; 40 // Public coroutine API 41 static inline void suspend(); 57 42 58 forall( otype T | is_thread(T))59 void ?{}( thread(T)* this);43 forall(dtype T | is_coroutine(T)) 44 static inline void resume(T* cor); 60 45 61 forall(otype T, ttype P | is_thread(T) | { void ?{}(T*, P); } ) 62 void ?{}( thread(T)* this, P params ); 63 64 forall(otype T | is_thread(T) ) 65 void ^?{}( thread(T)* this ); 46 forall(dtype T | is_coroutine(T)) 47 void prime(T* cor); 66 48 67 49 //----------------------------------------------------------------------------- 68 50 // PRIVATE exposed because of inline 51 52 // Start coroutine routines 53 extern "C" { 54 forall(dtype T | is_coroutine(T)) 55 void CtxInvokeCoroutine(T* this); 56 57 forall(dtype T | is_coroutine(T)) 58 void CtxStart(T* this, void (*invoke)(T*)); 59 } 60 61 // Get current coroutine 62 extern coroutine* current_coroutine; //PRIVATE, never use directly 63 static inline coroutine* this_coroutine(void) { 64 return current_coroutine; 65 } 66 67 // Private wrappers for context switch and stack creation 68 extern void corCxtSw(coroutine* src, coroutine* dst); 69 extern void create_stack( coStack_t* this, unsigned int storageSize ); 70 71 // Suspend implementation inlined for performance 72 static inline void suspend() { 73 coroutine* src = this_coroutine(); // optimization 74 75 assertf( src->last != 0, 76 "Attempt to suspend coroutine %.256s (%p) that has never been resumed.\n" 77 "Possible cause is a suspend executed in a member called by a coroutine user rather than by the coroutine main.", 78 src->name, src ); 79 assertf( src->last->notHalted, 80 "Attempt by coroutine %.256s (%p) to suspend back to terminated coroutine %.256s (%p).\n" 81 "Possible cause is terminated coroutine's main routine has already returned.", 82 src->name, src, src->last->name, src->last ); 83 84 corCxtSw( src, src->last ); 85 } 86 87 // Resume implementation inlined for performance 88 forall(dtype T | is_coroutine(T)) 89 static inline void resume(T* cor) { 90 coroutine* src = this_coroutine(); // optimization 91 coroutine* dst = get_coroutine(cor); 92 93 if( unlikely(!dst->stack.base) ) { 94 create_stack(&dst->stack, dst->stack.size); 95 CtxStart(cor, CtxInvokeCoroutine); 96 } 97 98 // not resuming self ? 99 if ( src != dst ) { 100 assertf( dst->notHalted , 101 "Attempt by coroutine %.256s (%p) to resume terminated coroutine %.256s (%p).\n" 102 "Possible cause is terminated coroutine's main routine has already returned.", 103 src->name, src, dst->name, dst ); 104 105 // set last resumer 106 dst->last = src; 107 } // if 108 109 // always done for performance testing 110 corCxtSw( src, dst ); 111 } 69 112 70 113 #endif //THREADS_H -
src/libcfa/concurrency/threads.c
r68e6031 r1ab7d3fe 1 // -*- Mode: CFA -*-2 1 // 3 2 // Cforall Version 1.0.0 Copyright (C) 2016 University of Waterloo … … 9 8 // 10 9 // Author : Thierry Delisle 11 // Created On : Tue Jan 1712:27:26 201610 // Created On : Mon Nov 28 12:27:26 2016 12 11 // Last Modified By : Thierry Delisle 13 // Last Modified On : --12 // Last Modified On : Mon Nov 28 12:27:26 2016 14 13 // Update Count : 0 15 14 // 16 15 16 extern "C" { 17 #include <stddef.h> 18 #include <malloc.h> 19 #include <errno.h> 20 #include <string.h> 21 #include <unistd.h> 22 #include <sys/mman.h> 23 } 24 17 25 #include "threads" 18 19 #include "kernel"20 26 #include "libhdr.h" 21 27 … … 23 29 #include "invoke.h" 24 30 25 #include <stdlib> 31 //----------------------------------------------------------------------------- 32 // Global state variables 33 34 // minimum feasible stack size in bytes 35 #define MinStackSize 1000 36 static size_t pageSize = 0; // architecture pagesize HACK, should go in proper runtime singleton 37 38 //Extra private desctructor for the main 39 //FIXME the main should not actually allocate a stack 40 //Since the main is never resumed the extra stack does not cause 41 //any problem but it is wasted memory 42 void ?{}(coStack_t* this, size_t size); 43 void ?{}(coroutine* this, size_t size); 44 45 //Main coroutine 46 //FIXME do not construct a stack for the main 47 coroutine main_coroutine = { 1000 }; 48 49 //Current coroutine 50 //Will need to be in TLS when multi-threading is added 51 coroutine* current_coroutine = &main_coroutine; 26 52 27 53 //----------------------------------------------------------------------------- 28 // Forward declarations 29 forall(otype T | is_thread(T) ) 30 void start( thread(T)* this ); 31 32 forall(otype T | is_thread(T) ) 33 void stop( thread(T)* this ); 34 35 //----------------------------------------------------------------------------- 36 // Thread ctors and dtors 37 38 void ?{}(thread_h* this) { 39 (&this->c){}; 54 // Coroutine ctors and dtors 55 void ?{}(coStack_t* this) { 56 this->size = 10240; // size of stack 57 this->storage = NULL; // pointer to stack 58 this->limit = NULL; // stack grows towards stack limit 59 this->base = NULL; // base of stack 60 this->context = NULL; // address of cfa_context_t 61 this->top = NULL; // address of top of storage 62 this->userStack = false; 40 63 } 41 64 42 void ^?{}(thread_h* this) { 43 ^(&this->c){}; 65 void ?{}(coStack_t* this, size_t size) { 66 this{}; 67 this->size = size; 68 69 create_stack(this, this->size); 44 70 } 45 71 46 forall(otype T | is_thread(T) ) 47 void ?{}( thread(T)* this ) { 48 printf("thread() ctor\n"); 49 (&this->handle){}; 50 start(this); 72 void ?{}(coroutine* this) { 73 this->name = "Anonymous Coroutine"; 74 this->errno_ = 0; 75 this->state = Start; 76 this->notHalted = true; 77 this->starter = NULL; 78 this->last = NULL; 51 79 } 52 80 53 forall(otype T, ttype P | is_thread(T) | { void ?{}(T*, P); } ) 54 void ?{}( thread(T)* this, P params ) { 55 (&this->handle){ params }; 56 start(this); 81 void ?{}(coroutine* this, size_t size) { 82 this{}; 83 (&this->stack){size}; 57 84 } 58 85 59 forall(otype T | is_thread(T) ) 60 void ^?{}( thread(T)* this ) { 61 stop(this); 62 ^(&this->handle){}; 86 void ^?{}(coStack_t* this) { 87 if ( ! this->userStack ) { 88 LIB_DEBUG_DO( 89 if ( mprotect( this->storage, pageSize, PROT_READ | PROT_WRITE ) == -1 ) { 90 abortf( "(coStack_t *)%p.^?{}() : internal error, mprotect failure, error(%d) %s.", this, errno, strerror( errno ) ); 91 } 92 ); 93 free( this->storage ); 94 } 63 95 } 64 96 65 //----------------------------------------------------------------------------- 66 // Starting and stopping threads 67 extern "C" { 68 forall(dtype T | is_thread(T)) 69 void CtxInvokeThread(T * this); 97 void ^?{}(coroutine* this) {} 98 99 // Part of the Public API 100 // Not inline since only ever called once per coroutine 101 forall(dtype T | is_coroutine(T)) 102 void prime(T* cor) { 103 coroutine* this = get_coroutine(cor); 104 assert(this->state == Start); 105 106 this->state = Primed; 107 resume(cor); 70 108 } 71 109 72 forall(otype T | is_thread(T)) 73 void start( thread(T)* this ) { 74 T* handle = &this->handle; 75 coroutine* thrd_c = get_coroutine(handle); 76 thread_h* thrd_h = get_thread (handle); 77 thrd_c->last = this_coroutine(); 78 current_coroutine = thrd_c; 79 80 // LIB_DEBUG_PRINTF("Thread start : %p (t %p, c %p)\n", handle, thrd_c, thrd_h); 81 82 create_stack(&thrd_c->stack, thrd_c->stack.size); 83 CtxStart(handle, CtxInvokeThread); 84 CtxSwitch( thrd_c->last->stack.context, thrd_c->stack.context ); 85 86 scheduler_add(thrd_h); 110 // We need to call suspend from invoke.c, so we expose this wrapper that 111 // is not inline (We can't inline Cforall in C) 112 void suspend_no_inline(void) { 113 suspend(); 87 114 } 88 115 89 forall(otype T | is_thread(T) ) 90 void stop( thread(T)* this ) { 116 void corCxtSw(coroutine* src, coroutine* dst) { 117 // THREAD_GETMEM( This )->disableInterrupts(); 91 118 119 // set state of current coroutine to inactive 120 src->state = Inactive; 121 122 // set new coroutine that task is executing 123 current_coroutine = dst; 124 125 // context switch to specified coroutine 126 CtxSwitch( src->stack.context, dst->stack.context ); 127 // when CtxSwitch returns we are back in the src coroutine 128 129 // set state of new coroutine to active 130 src->state = Active; 131 132 // THREAD_GETMEM( This )->enableInterrupts(); 133 } //ctxSwitchDirect 134 135 void create_stack( coStack_t* this, unsigned int storageSize ) { 136 //TEMP HACK do this on proper kernel startup 137 if(pageSize == 0ul) pageSize = sysconf( _SC_PAGESIZE ); 138 139 size_t cxtSize = libCeiling( sizeof(machine_context_t), 8 ); // minimum alignment 140 141 if ( (intptr_t)this->storage == 0 ) { 142 this->userStack = false; 143 this->size = libCeiling( storageSize, 16 ); 144 // use malloc/memalign because "new" raises an exception for out-of-memory 145 146 // assume malloc has 8 byte alignment so add 8 to allow rounding up to 16 byte alignment 147 LIB_DEBUG_DO( this->storage = memalign( pageSize, cxtSize + this->size + pageSize ) ); 148 LIB_NO_DEBUG_DO( this->storage = malloc( cxtSize + this->size + 8 ) ); 149 150 LIB_DEBUG_DO( 151 if ( mprotect( this->storage, pageSize, PROT_NONE ) == -1 ) { 152 abortf( "(uMachContext &)%p.createContext() : internal error, mprotect failure, error(%d) %s.", this, (int)errno, strerror( (int)errno ) ); 153 } // if 154 ); 155 156 if ( (intptr_t)this->storage == 0 ) { 157 abortf( "Attempt to allocate %d bytes of storage for coroutine or task execution-state but insufficient memory available.", this->size ); 158 } // if 159 160 LIB_DEBUG_DO( this->limit = (char *)this->storage + pageSize ); 161 LIB_NO_DEBUG_DO( this->limit = (char *)libCeiling( (unsigned long)this->storage, 16 ) ); // minimum alignment 162 163 } else { 164 assertf( ((size_t)this->storage & (libAlign() - 1)) != 0ul, "Stack storage %p for task/coroutine must be aligned on %d byte boundary.", this->storage, (int)libAlign() ); 165 this->userStack = true; 166 this->size = storageSize - cxtSize; 167 168 if ( this->size % 16 != 0u ) this->size -= 8; 169 170 this->limit = (char *)libCeiling( (unsigned long)this->storage, 16 ); // minimum alignment 171 } // if 172 assertf( this->size >= MinStackSize, "Stack size %d provides less than minimum of %d bytes for a stack.", this->size, MinStackSize ); 173 174 this->base = (char *)this->limit + this->size; 175 this->context = this->base; 176 this->top = (char *)this->context + cxtSize; 92 177 } 93 178 -
src/tests/coroutine.c
r68e6031 r1ab7d3fe 1 1 #include <fstream> 2 #include < coroutines>2 #include <threads> 3 3 4 4 struct Fibonacci { … … 15 15 } 16 16 17 void main(Fibonacci* this) {17 void co_main(Fibonacci* this) { 18 18 #ifdef MORE_DEBUG 19 19 sout | "Starting main of coroutine " | this | endl;
Note: See TracChangeset
for help on using the changeset viewer.