Changes in / [a6e0e4c:b3a0df6]


Ignore:
Files:
5 edited

Legend:

Unmodified
Added
Removed

  • Jenkins/FullBuild

    ra6e0e4c rb3a0df6  
    88        def err = null
    99
    10         final scmVars = checkout scm
    11         final commitId = scmVars.GIT_COMMIT
    12 
    1310        try {
    1411                //Wrap build to add timestamp to command line
    … …  
    1613
    1714                        stage('Build') {
     15
     16                                results = [null, null]
    1817
    1918                                parallel (
    … …  
    3231
    3332                        stage('Package') {
    34                                 build job: 'Cforall_Distribute_Ref', parameters: [string(name: 'GitRef', value: commitId), string(name: 'Build', value: currentBuild.number)]
     33                                build job: 'Cforall_Distribute_Ref', parameters: [string(name: 'GitRef', value: gitRefNewValue), string(name: 'Build', value: currentBuild.number)]
    3534                        }
    3635                }
    … …  
    103102}
    104103
     104//Helper routine to collect information about the git history
     105def collect_git_info() {
     106
     107        //create the temporary output directory in case it doesn't already exist
     108        def out_dir = pwd tmp: true
     109        sh "mkdir -p ${out_dir}"
     110
     111        //parse git logs to find what changed
     112        dir("../Cforall_Full_Build@script") {
     113                sh "git reflog > ${out_dir}/GIT_COMMIT"
     114        }
     115        git_reflog = readFile("${out_dir}/GIT_COMMIT")
     116        gitRefOldValue = (git_reflog =~ /moving from (.+) to (.+)/)[0][1]
     117        gitRefNewValue = (git_reflog =~ /moving from (.+) to (.+)/)[0][2]
     118}
     119
    105120//===========================================================================================================
    106121//Routine responsible of sending the email notification once the build is completed

  • benchmark/io/http/main.cfa

    ra6e0e4c rb3a0df6  
    7575        address.sin_port = htons( options.socket.port );
    7676
    77         int waited = 0;
    78         for() {
    79                 ret = bind( server_fd, (struct sockaddr *)&address, sizeof(address) );
    80                 if(ret < 0) {
    81                         if(errno == 98) {
    82                                 if(waited == 0) {
    83                                         printf("Waiting for port\n");
    84                                 } else {
    85                                         printf("\r%d", waited);
    86                                         fflush(stdout);
    87                                 }
    88                                 waited ++;
    89                                 sleep( 1`s );
    90                                 continue;
    91                         }
    92                         abort( "bind error: (%d) %s\n", (int)errno, strerror(errno) );
    93                 }
    94                 break;
     77        ret = bind( server_fd, (struct sockaddr *)&address, sizeof(address) );
     78        if(ret < 0) {
     79                abort( "bind error: (%d) %s\n", (int)errno, strerror(errno) );
    9580        }
    9681

  • libcfa/src/concurrency/coroutine.hfa

    ra6e0e4c rb3a0df6  
    144144
    145145        if( unlikely(dst->context.SP == 0p) ) {
     146                active_thread()->curr_cor = dst;
    146147                __stack_prepare(&dst->stack, 65000);
    147148                __cfactx_start(main, dst, cor, __cfactx_invoke_coroutine);
     149                active_thread()->curr_cor = src;
    148150        }
    149151

  • libcfa/src/concurrency/io/setup.cfa

    ra6e0e4c rb3a0df6  
    1717#define _GNU_SOURCE         /* See feature_test_macros(7) */
    1818
    19 #if defined(__CFA_DEBUG__)
    20         // #define __CFA_DEBUG_PRINT_IO__
    21         // #define __CFA_DEBUG_PRINT_IO_CORE__
    22 #endif
    23 
    2419#include "io/types.hfa"
    2520#include "kernel.hfa"
    … …  
    116111
    117112        void __kernel_io_startup(void) {
    118                 __cfadbg_print_safe(io_core, "Kernel : Creating EPOLL instance\n" );
     113                __cfaabi_dbg_print_safe( "Kernel : Creating EPOLL instance\n" );
    119114
    120115                iopoll.epollfd = epoll_create1(0);
    … …  
    123118                }
    124119
    125                 __cfadbg_print_safe(io_core, "Kernel : Starting io poller thread\n" );
     120                __cfaabi_dbg_print_safe( "Kernel : Starting io poller thread\n" );
    126121
    127122                iopoll.run = true;
    … …  
    146141                // Io polling is now fully stopped
    147142
    148                 __cfadbg_print_safe(io_core, "Kernel : IO poller stopped\n" );
     143                __cfaabi_dbg_print_safe( "Kernel : IO poller stopped\n" );
    149144        }
    150145
    … …  
    154149                id.id = doregister(&id);
    155150                __cfaabi_tls.this_proc_id = &id;
    156                 __cfadbg_print_safe(io_core, "Kernel : IO poller thread starting\n" );
     151                __cfaabi_dbg_print_safe( "Kernel : IO poller thread starting\n" );
    157152
    158153                // Block signals to control when they arrive
    … …  
    189184                }
    190185
    191                 __cfadbg_print_safe(io_core, "Kernel : IO poller thread stopping\n" );
     186                __cfaabi_dbg_print_safe( "Kernel : IO poller thread stopping\n" );
    192187                unregister(&id);
    193188                return 0p;

  • libcfa/src/heap.cfa

    ra6e0e4c rb3a0df6  
    1010// Created On       : Tue Dec 19 21:58:35 2017
    1111// Last Modified By : Peter A. Buhr
    12 // Last Modified On : Fri Dec 11 07:36:34 2020
    13 // Update Count     : 970
     12// Last Modified On : Mon Sep  7 22:17:46 2020
     13// Update Count     : 957
    1414//
    1515
    … …  
    464464} // headers
    465465
    466 #ifdef __CFA_DEBUG__
    467 #if __SIZEOF_POINTER__ == 4
    468 #define MASK 0xdeadbeef
    469 #else
    470 #define MASK 0xdeadbeefdeadbeef
    471 #endif
    472 #define STRIDE size_t
    473 
    474 static void * Memset( void * addr, STRIDE size ) {              // debug only
    475         if ( size % sizeof(STRIDE) != 0 ) abort( "Memset() : internal error, size %zd not multiple of %zd.", size, sizeof(STRIDE) );
    476         if ( (STRIDE)addr % sizeof(STRIDE) != 0 ) abort( "Memset() : internal error, addr %p not multiple of %zd.", addr, sizeof(STRIDE) );
    477 
    478         STRIDE * end = (STRIDE *)addr + size / sizeof(STRIDE);
    479         for ( STRIDE * p = (STRIDE *)addr; p < end; p += 1 ) *p = MASK;
    480         return addr;
    481 } // Memset
    482 #endif // __CFA_DEBUG__
    483 
    484466#define NO_MEMORY_MSG "insufficient heap memory available for allocating %zd new bytes."
    485467
    … …  
    501483                #ifdef __CFA_DEBUG__
    502484                // Set new memory to garbage so subsequent uninitialized usages might fail.
    503                 //memset( (char *)heapEnd + heapRemaining, '\377', increase );
    504                 Memset( (char *)heapEnd + heapRemaining, increase );
     485                memset( (char *)heapEnd + heapRemaining, '\377', increase );
    505486                #endif // __CFA_DEBUG__
    506487                rem = heapRemaining + increase - size;
    … …  
    576557                #ifdef __CFA_DEBUG__
    577558                // Set new memory to garbage so subsequent uninitialized usages might fail.
    578                 //memset( block, '\377', tsize );
    579                 Memset( block, tsize );
     559                memset( block, '\377', tsize );
    580560                #endif // __CFA_DEBUG__
    581561                block->header.kind.real.blockSize = tsize;              // storage size for munmap
    … …  
    626606                #ifdef __CFA_DEBUG__
    627607                // Set free memory to garbage so subsequent usages might fail.
    628                 //memset( ((HeapManager.Storage *)header)->data, '\377', freeElem->blockSize - sizeof( HeapManager.Storage ) );
    629                 Memset( ((HeapManager.Storage *)header)->data, freeElem->blockSize - sizeof( HeapManager.Storage ) );
     608                memset( ((HeapManager.Storage *)header)->data, '\377', freeElem->blockSize - sizeof( HeapManager.Storage ) );
    630609                #endif // __CFA_DEBUG__
    631610
    … …  
    956935                        header->kind.real.size = size;                          // reset allocation size
    957936                        if ( unlikely( ozfill ) && size > osize ) {     // previous request zero fill and larger ?
    958                                 memset( (char *)oaddr + osize, '\0', size - osize ); // initialize added storage
     937                                memset( (char *)oaddr + osize, (int)'\0', size - osize ); // initialize added storage
    959938                        } // if
    960939                        return oaddr;
    … …  
    981960                        header->kind.real.blockSize |= 2;                       // mark new request as zero filled
    982961                        if ( size > osize ) {                                           // previous request larger ?
    983                                 memset( (char *)naddr + osize, '\0', size - osize ); // initialize added storage
     962                                memset( (char *)naddr + osize, (int)'\0', size - osize ); // initialize added storage
    984963                        } // if
    985964                } // if
    … …  
    13481327                header->kind.real.blockSize |= 2;                               // mark new request as zero filled
    13491328                if ( size > osize ) {                                                   // previous request larger ?
    1350                         memset( (char *)naddr + osize, '\0', size - osize ); // initialize added storage
     1329                        memset( (char *)naddr + osize, (int)'\0', size - osize ); // initialize added storage
    13511330                } // if
    13521331        } // if
Note: See TracChangeset for help on using the changeset viewer.